Update data_manager.py

data_manager.py

@@ -651,14 +651,14 @@ class DataManager:
         try:
             ohlcv_data = {}
             
-            # جميع الإطارات الزمنية الـ6
+            # ✅ تصحيح: جلب 200 شمعة لكل إطار زمني بدلاً من 100
             timeframes = [
-                ('5m', 100),
-                ('15m', 100), 
-                ('1h', 100),
-                ('4h', 100),
-                ('1d', 100),
-                ('1w', 50),
+                ('5m', 200),    # كان 100
+                ('15m', 200),   # كان 100  
+                ('1h', 200),    # كان 100
+                ('4h', 200),    # كان 100
+                ('1d', 200),    # كان 100
+                ('1w', 200),    # كان 50 - الآن 200
             ]
             
             # إنشاء مهام لجميع الإطارات الزمنية بشكل متوازي
@@ -676,12 +676,16 @@ class DataManager:
             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
                 
-                if result and len(result) >= 20:
+                # ✅ تخفيف الشرط من 20 إلى 50 شمعة كحد أدنى
+                if result and len(result) >= 50:
                     ohlcv_data[timeframe] = result
+                    print(f"      ✅ {symbol} - {timeframe}: {len(result)} شمعة")
                 else:
+                    print(f"      ⚠️ {symbol} - {timeframe}: بيانات غير كافية ({len(result) if result else 0} شمعة)")
                     has_sufficient_data = False
                     break
             
@@ -690,25 +694,36 @@ class DataManager:
                     ticker = self.exchange.fetch_ticker(symbol)
                     current_price = ticker.get('last', 0) if ticker else 0
                     
-                    return {
+                    result_data = {
                         'symbol': symbol,
                         'ohlcv': ohlcv_data,
                         'current_price': current_price,
-                        'timestamp': datetime.now().isoformat()
+                        'timestamp': datetime.now().isoformat(),
+                        'candles_count': {tf: len(data) for tf, data in ohlcv_data.items()}
                     }
+                    
+                    print(f"      ✅ اكتمل جلب بيانات {symbol}: {result_data['candles_count']}")
+                    return result_data
+                    
                 except Exception as price_error:
+                    print(f"      ❌ خطأ في جلب سعر {symbol}: {price_error}")
                     return None
             else:
+                print(f"      ❌ بيانات غير كافية لـ {symbol}")
                 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:
-            return self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
-        except Exception:
+            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 get_latest_price_async(self, symbol):
@@ -800,4 +815,4 @@ class DataManager:
                 'source': 'whale_analysis'
             }
 
-print("✅ DataManager loaded - Parallel OHLCV Fetching System with Whale Data Support")
+print("✅ DataManager loaded - Parallel OHLCV Fetching System with Whale Data Support & 200 Candles")