Update data_manager.py

data_manager.py

@@ -607,7 +607,7 @@ class DataManager:
         print("   📈 الإطارات الزمنية: 5m, 15m, 1h, 4h, 1d, 1w")
         
         # تقسيم الرموز إلى دفعات لتجنب rate limits
-        batch_size = 20  # 20 رمز في كل دفعة
+        batch_size = 15  # تقليل حجم الدفعة لتحسين الاستقرار
         batches = [symbols[i:i + batch_size] for i in range(0, len(symbols), batch_size)]
         
         all_results = []
@@ -633,17 +633,17 @@ class DataManager:
                 elif result is not None:
                     all_results.append(result)
                     successful_count += 1
-                    print(f"      ✅ تم جلب بيانات {symbol}")
+                    print(f"      ✅ تم جلب بيانات {symbol} ({result.get('successful_timeframes', 0)}/6 أطر)")
                 else:
-                    print(f"      ❌ فشل جلب بيانات {symbol}: لا توجد بيانات")
-            
+                    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)
+                await asyncio.sleep(1)  # زيادة وقت الانتظار
         
-        print(f"✅ تم تجميع بيانات OHLCV كاملة لـ {len(all_results)} عملة")
+        print(f"✅ تم تجميع بيانات OHLCV كاملة لـ {len(all_results)} عملة من أصل {len(symbols)}")
         return all_results
 
     async def _fetch_complete_ohlcv_parallel(self, symbol: str) -> Dict[str, Any]:
@@ -651,45 +651,46 @@ class DataManager:
         try:
             ohlcv_data = {}
             
-            # ✅ تصحيح: جلب 200 شمعة لكل إطار زمني بدلاً من 100
+            # جلب 200 شمعة لكل إطار زمني مع تحسين التعامل مع الأخطاء
             timeframes = [
-                ('5m', 200),    # كان 100
-                ('15m', 200),   # كان 100  
-                ('1h', 200),    # كان 100
-                ('4h', 200),    # كان 100
-                ('1d', 200),    # كان 100
-                ('1w', 200),    # كان 50 - الآن 200
+                ('5m', 200),
+                ('15m', 200),  
+                ('1h', 200),
+                ('4h', 200),
+                ('1d', 200),
+                ('1w', 200),
             ]
             
             # إنشاء مهام لجميع الإطارات الزمنية بشكل متوازي
             timeframe_tasks = []
             for timeframe, limit in timeframes:
-                task = asyncio.create_task(self._fetch_single_timeframe(symbol, timeframe, limit))
+                task = asyncio.create_task(self._fetch_single_timeframe_improved(symbol, timeframe, limit))
                 timeframe_tasks.append(task)
             
             # انتظار جميع المهام
             timeframe_results = await asyncio.gather(*timeframe_tasks, return_exceptions=True)
             
-            has_sufficient_data = True
+            # تحسين: قبول البيانات حتى لو كانت غير مكتملة
+            successful_timeframes = 0
+            min_required_timeframes = 3  # على الأقل 3 أطر زمنية
             
             # معالجة النتائج
             for i, (timeframe, limit) in enumerate(timeframes):
                 result = timeframe_results[i]
-                if isinstance(result, Exception) or result is None:
-                    print(f"      ⚠️ فشل جلب بيانات {timeframe} لـ {symbol}")
-                    has_sufficient_data = False
-                    break
                 
-                # ✅ تخفيف الشرط من 20 إلى 50 شمعة كحد أدنى
-                if result and len(result) >= 50:
+                if isinstance(result, Exception):
+                    print(f"      ⚠️ فشل جلب بيانات {timeframe} لـ {symbol}: {result}")
+                    continue
+                
+                if result and len(result) >= 10:  # تخفيف الشرط من 50 إلى 10 شموع
                     ohlcv_data[timeframe] = result
+                    successful_timeframes += 1
                     print(f"      ✅ {symbol} - {timeframe}: {len(result)} شمعة")
                 else:
-                    print(f"      ⚠️ {symbol} - {timeframe}: بيانات غير كافية ({len(result) if result else 0} شمعة)")
-                    has_sufficient_data = False
-                    break
+                    print(f"      ⚠️ {symbol} - {timeframe}: بيانات محدودة ({len(result) if result else 0} شمعة)")
             
-            if has_sufficient_data and ohlcv_data:
+            # تحسين: قبول العملة إذا كان لديها عدد كافٍ من الأطر الزمنية
+            if successful_timeframes >= min_required_timeframes and ohlcv_data:
                 try:
                     ticker = self.exchange.fetch_ticker(symbol)
                     current_price = ticker.get('last', 0) if ticker else 0
@@ -699,32 +700,46 @@ class DataManager:
                         'ohlcv': ohlcv_data,
                         'current_price': current_price,
                         'timestamp': datetime.now().isoformat(),
-                        'candles_count': {tf: len(data) for tf, data in ohlcv_data.items()}
+                        'candles_count': {tf: len(data) for tf, data in ohlcv_data.items()},
+                        'successful_timeframes': successful_timeframes
                     }
                     
-                    print(f"      ✅ اكتمل جلب بيانات {symbol}: {result_data['candles_count']}")
+                    print(f"      ✅ اكتمل جلب بيانات {symbol}: {result_data['candles_count']} (نجح {successful_timeframes}/6)")
                     return result_data
                     
                 except Exception as price_error:
                     print(f"      ❌ خطأ في جلب سعر {symbol}: {price_error}")
                     return None
             else:
-                print(f"      ❌ بيانات غير كافية لـ {symbol}")
+                print(f"      ❌ بيانات غير كافية لـ {symbol}: {successful_timeframes} أطر ناجحة فقط (المطلوب: {min_required_timeframes})")
                 return None
                 
         except Exception as e:
             print(f"      ❌ خطأ عام في جلب بيانات {symbol}: {e}")
             return None
 
-    async def _fetch_single_timeframe(self, symbol: str, timeframe: str, limit: int):
-        """جلب بيانات إطار زمني واحد"""
-        try:
-            ohlcv_data = self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
-            print(f"        📊 {symbol} - {timeframe}: {len(ohlcv_data)} شمعة")
-            return ohlcv_data
-        except Exception as e:
-            print(f"        ❌ فشل جلب {timeframe} لـ {symbol}: {e}")
-            return None
+    async def _fetch_single_timeframe_improved(self, symbol: str, timeframe: str, limit: int):
+        """جلب بيانات إطار زمني واحد مع تحسين التعامل مع الأخطاء"""
+        max_retries = 3
+        retry_delay = 2
+        
+        for attempt in range(max_retries):
+            try:
+                ohlcv_data = self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
+                
+                if ohlcv_data and len(ohlcv_data) > 0:
+                    print(f"        📊 {symbol} - {timeframe}: {len(ohlcv_data)} شمعة (المحاولة {attempt + 1})")
+                    return ohlcv_data
+                else:
+                    print(f"        ⚠️ {symbol} - {timeframe}: لا توجد بيانات (المحاولة {attempt + 1})")
+                    return []
+                    
+            except Exception as e:
+                print(f"        ❌ فشل جلب {timeframe} لـ {symbol} (المحاولة {attempt + 1}): {e}")
+                if attempt < max_retries - 1:
+                    await asyncio.sleep(retry_delay * (attempt + 1))
+                else:
+                    return []
 
     async def get_latest_price_async(self, symbol):
         """جلب السعر الحالي لعملة محددة"""