Update data_manager.py

data_manager.py

@@ -601,34 +601,53 @@ class DataManager:
 
     async def get_ohlcv_data_for_symbols(self, symbols: List[str]) -> List[Dict[str, Any]]:
         """
-        جلب بيانات OHLCV كاملة للرموز المحددة مع جميع الإطارات الزمنية
+        جلب بيانات OHLCV كاملة للرموز المحددة مع جميع الإطارات الزمنية بشكل متوازي
         """
-        results = []
-        
-        print(f"📊 جلب بيانات OHLCV كاملة لـ {len(symbols)} عملة...")
+        print(f"📊 جلب بيانات OHLCV كاملة لـ {len(symbols)} عملة بشكل متوازي...")
         print("   📈 الإطارات الزمنية: 5m, 15m, 1h, 4h, 1d, 1w")
         
-        for i, symbol in enumerate(symbols):
-            try:
-                ohlcv_data = await self._fetch_complete_ohlcv(symbol)
-                if ohlcv_data:
-                    results.append(ohlcv_data)
-                    print(f"   ✅ ({i+1}/{len(symbols)}) تم جلب بيانات {symbol}")
+        # تقسيم الرموز إلى دفعات لتجنب rate limits
+        batch_size = 20  # 20 رمز في كل دفعة
+        batches = [symbols[i:i + batch_size] for i in range(0, len(symbols), batch_size)]
+        
+        all_results = []
+        
+        for batch_num, batch in enumerate(batches):
+            print(f"   🔄 معالجة الدفعة {batch_num + 1}/{len(batches)} ({len(batch)} عملة)...")
+            
+            # إنشاء مهام للدفعة الحالية بشكل متوازي
+            batch_tasks = []
+            for symbol in batch:
+                task = asyncio.create_task(self._fetch_complete_ohlcv_parallel(symbol))
+                batch_tasks.append(task)
+            
+            # انتظار انتهاء جميع مهام الدفعة الحالية
+            batch_results = await asyncio.gather(*batch_tasks, return_exceptions=True)
+            
+            # معالجة نتائج الدفعة
+            successful_count = 0
+            for i, result in enumerate(batch_results):
+                symbol = batch[i]
+                if isinstance(result, Exception):
+                    print(f"      ❌ فشل جلب بيانات {symbol}: {result}")
+                elif result is not None:
+                    all_results.append(result)
+                    successful_count += 1
+                    print(f"      ✅ تم جلب بيانات {symbol}")
                 else:
-                    print(f"   ❌ ({i+1}/{len(symbols)}) فشل جلب بيانات {symbol}")
-                
-                # وقت انتظار لتجنب rate limits
-                await asyncio.sleep(0.2)
-                
-            except Exception as symbol_error:
-                print(f"   ❌ ({i+1}/{len(symbols)}) خطأ في {symbol}: {symbol_error}")
-                continue
+                    print(f"      ❌ فشل جلب بيانات {symbol}: لا توجد بيانات")
+            
+            print(f"      ✅ اكتملت الدفعة {batch_num + 1}: {successful_count}/{len(batch)} ناجحة")
+            
+            # انتظار قصير بين الدفعات لتجنب rate limits
+            if batch_num < len(batches) - 1:
+                await asyncio.sleep(0.5)
         
-        print(f"✅ تم تجميع بيانات OHLCV كاملة لـ {len(results)} عملة")
-        return results
+        print(f"✅ تم تجميع بيانات OHLCV كاملة لـ {len(all_results)} عملة")
+        return all_results
 
-    async def _fetch_complete_ohlcv(self, symbol: str) -> Dict[str, Any]:
-        """جلب بيانات OHLCV كاملة مع جميع الإطارات الزمنية"""
+    async def _fetch_complete_ohlcv_parallel(self, symbol: str) -> Dict[str, Any]:
+        """جلب بيانات OHLCV كاملة مع جميع الإطارات الزمنية بشكل متوازي"""
         try:
             ohlcv_data = {}
             
@@ -642,19 +661,27 @@ class DataManager:
                 ('1w', 50),
             ]
             
+            # إنشاء مهام لجميع الإطارات الزمنية بشكل متوازي
+            timeframe_tasks = []
+            for timeframe, limit in timeframes:
+                task = asyncio.create_task(self._fetch_single_timeframe(symbol, timeframe, limit))
+                timeframe_tasks.append(task)
+            
+            # انتظار جميع المهام
+            timeframe_results = await asyncio.gather(*timeframe_tasks, return_exceptions=True)
+            
             has_sufficient_data = True
             
-            for timeframe, limit in timeframes:
-                try:
-                    ohlcv = self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
-                    
-                    if ohlcv and len(ohlcv) >= 20:
-                        ohlcv_data[timeframe] = ohlcv
-                    else:
-                        has_sufficient_data = False
-                        break
-                        
-                except Exception as e:
+            # معالجة النتائج
+            for i, (timeframe, limit) in enumerate(timeframes):
+                result = timeframe_results[i]
+                if isinstance(result, Exception) or result is None:
+                    has_sufficient_data = False
+                    break
+                
+                if result and len(result) >= 20:
+                    ohlcv_data[timeframe] = result
+                else:
                     has_sufficient_data = False
                     break
             
@@ -677,6 +704,13 @@ class DataManager:
         except Exception as e:
             return None
 
+    async def _fetch_single_timeframe(self, symbol: str, timeframe: str, limit: int):
+        """جلب بيانات إطار زمني واحد"""
+        try:
+            return self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
+        except Exception:
+            return None
+
     async def get_latest_price_async(self, symbol):
         """جلب السعر الحالي لعملة محددة"""
         try:
@@ -729,4 +763,4 @@ class DataManager:
             print(f"❌ خطأ في التحقق من الرمز {symbol}: {e}")
             return False
 
-print("✅ DataManager loaded - Multi-Method Volume Screening System")
+print("✅ DataManager loaded - Parallel OHLCV Fetching System")