Update data_manager.py

data_manager.py

@@ -37,7 +37,7 @@ class DataManager:
     async def initialize(self):
         self.http_client = httpx.AsyncClient(timeout=30.0)
         await self._load_markets()
-        print("✅ DataManager initialized - Top 200 by Volume Focus")
+        print("✅ DataManager initialized - Efficient Volume-Based Screening")
 
     async def _load_markets(self):
         try:
@@ -208,16 +208,26 @@ class DataManager:
 
     async def layer1_rapid_screening(self) -> List[Dict[str, Any]]:
         """
-        الطبقة 1: فحص سريع - المرحلة 1: جلب أفضل 200 عملة حسب الحجم فقط
+        الطبقة 1: فحص سريع - جلب أفضل 200 عملة حسب الحجم مباشرة
         """
         print("📊 الطبقة 1: جلب أفضل 200 عملة حسب حجم التداول...")
         
-        # المرحلة 1: جلب أحجام التداول لجميع العملات بسرعة
-        print("   🔍 جلب أحجام التداول لجميع العملات...")
-        volume_data = await self._get_all_symbols_volume()
+        # المحاولة 1: الطريقة المثلى - استخدام fetch_tickers
+        print("   🔍 المحاولة 1: جلب جميع التاكرز مرة واحدة...")
+        volume_data = await self._get_volume_data_optimal()
         
         if not volume_data:
-            print("❌ فشل جلب بيانات الأحجام")
+            # المحاولة 2: الطريقة البديلة - استخدام API المباشر
+            print("   🔄 المحاولة 2: استخدام API المباشر...")
+            volume_data = await self._get_volume_data_direct_api()
+        
+        if not volume_data:
+            # المحاولة 3: الطريقة التقليدية (الاحتياطية)
+            print("   ⚠️ المحاولة 3: استخدام الطريقة التقليدية...")
+            volume_data = await self._get_volume_data_traditional()
+        
+        if not volume_data:
+            print("❌ فشل جميع محاولات جلب بيانات الأحجام")
             return []
         
         # أخذ أفضل 200 عملة حسب الحجم فقط
@@ -242,26 +252,36 @@ class DataManager:
         
         return final_candidates
 
-    async def _get_all_symbols_volume(self) -> List[Dict[str, Any]]:
-        """جلب أحجام التداول لجميع العملات بسرعة"""
-        volume_data = []
-        usdt_symbols = [
-            symbol for symbol in self.market_cache.keys() 
-            if symbol.endswith('/USDT') and self.market_cache[symbol].get('active', False)
-        ]
-        
-        print(f"   📊 معالجة {len(usdt_symbols)} عملة...")
-        
-        processed = 0
-        for symbol in usdt_symbols:
-            try:
-                ticker = self.exchange.fetch_ticker(symbol)
-                if not ticker:
+    async def _get_volume_data_optimal(self) -> List[Dict[str, Any]]:
+        """الطريقة المثلى: استخدام fetch_tickers لجميع البيانات مرة واحدة"""
+        try:
+            if not self.exchange:
+                return []
+                
+            print("      📊 جلب جميع بيانات التداول مرة واحدة...")
+            tickers = self.exchange.fetch_tickers()
+            
+            volume_data = []
+            processed = 0
+            
+            for symbol, ticker in tickers.items():
+                # تصفية أزواج USDT النشطة فقط
+                if not symbol.endswith('/USDT'):
+                    continue
+                    
+                if not ticker.get('active', True):
                     continue
                 
+                # استخدام quoteVolume (الحجم بالدولار) إذا متوفر
                 current_price = ticker.get('last', 0)
-                volume_24h = ticker.get('baseVolume', 0)
-                dollar_volume = volume_24h * current_price
+                quote_volume = ticker.get('quoteVolume', 0)
+                
+                if quote_volume > 0:
+                    dollar_volume = quote_volume
+                else:
+                    # fallback: baseVolume * السعر
+                    base_volume = ticker.get('baseVolume', 0)
+                    dollar_volume = base_volume * current_price
                 
                 # فلترة أولية: تجاهل العملات ذات الحجم المنخفض جداً
                 if dollar_volume < 50000:  # أقل من 50K دولار
@@ -271,18 +291,138 @@ class DataManager:
                     'symbol': symbol,
                     'dollar_volume': dollar_volume,
                     'current_price': current_price,
-                    'volume_24h': volume_24h
+                    'volume_24h': ticker.get('baseVolume', 0),
+                    'price_change_24h': (ticker.get('percentage', 0) or 0) * 100
                 })
                 
                 processed += 1
-                if processed % 100 == 0:
-                    print(f"      ✅ تم معالجة {processed} عملة...")
+            
+            print(f"      ✅ تم معالجة {processed} عملة من أصل {len(tickers)}")
+            return volume_data
+            
+        except Exception as e:
+            print(f"      ❌ فشل الطريقة المثلى: {e}")
+            return []
+
+    async def _get_volume_data_direct_api(self) -> List[Dict[str, Any]]:
+        """الطريقة الثانية: استخدام KuCoin API مباشرة"""
+        try:
+            print("      🌐 الاتصال بـ KuCoin API مباشرة...")
+            url = "https://api.kucoin.com/api/v1/market/allTickers"
+            
+            async with httpx.AsyncClient(timeout=15) as client:
+                response = await client.get(url)
+                response.raise_for_status()
+                data = response.json()
+                
+                if data.get('code') != '200000':
+                    raise ValueError(f"استجابة API غير متوقعة: {data.get('code')}")
+                
+                tickers = data['data']['ticker']
+                volume_data = []
+                
+                for ticker in tickers:
+                    symbol = ticker['symbol']
                     
-            except Exception as e:
-                continue
-        
-        print(f"   ✅ تم جمع بيانات {len(volume_data)} عملة مؤهلة")
-        return volume_data
+                    # تصفية أزواج USDT فقط
+                    if not symbol.endswith('USDT'):
+                        continue
+                    
+                    # تحويل الرمز للتنسيق القياسي (BTC-USDT → BTC/USDT)
+                    formatted_symbol = symbol.replace('-', '/')
+                    
+                    try:
+                        dollar_volume = float(ticker['volValue'])  # الحجم بالدولار
+                        current_price = float(ticker['last'])
+                        price_change = float(ticker['changeRate']) * 100
+                        
+                        if dollar_volume >= 50000:
+                            volume_data.append({
+                                'symbol': formatted_symbol,
+                                'dollar_volume': dollar_volume,
+                                'current_price': current_price,
+                                'volume_24h': float(ticker['vol']),
+                                'price_change_24h': price_change
+                            })
+                    except (ValueError, KeyError) as e:
+                        continue
+                
+                print(f"      ✅ تم جلب {len(volume_data)} عملة من API المباشر")
+                return volume_data
+                
+        except Exception as e:
+            print(f"      ❌ فشل API المباشر: {e}")
+            return []
+
+    async def _get_volume_data_traditional(self) -> List[Dict[str, Any]]:
+        """الطريقة التقليدية: جلب كل رمز على حدة (الاحتياطي)"""
+        try:
+            if not self.exchange or not self.market_cache:
+                return []
+                
+            usdt_symbols = [
+                symbol for symbol in self.market_cache.keys() 
+                if symbol.endswith('/USDT') and self.market_cache[symbol].get('active', False)
+            ]
+            
+            print(f"      🔄 معالجة {len(usdt_symbols)} عملة (طريقة تقليدية)...")
+            
+            volume_data = []
+            processed = 0
+            
+            # معالجة دفعات لتجنب rate limits
+            batch_size = 50
+            for i in range(0, len(usdt_symbols), batch_size):
+                batch = usdt_symbols[i:i + batch_size]
+                batch_tasks = [self._process_single_symbol(sym) for sym in batch]
+                batch_results = await asyncio.gather(*batch_tasks, return_exceptions=True)
+                
+                for result in batch_results:
+                    if isinstance(result, dict):
+                        volume_data.append(result)
+                
+                processed += len(batch)
+                print(f"         ✅ تم معالجة {processed}/{len(usdt_symbols)} عملة...")
+                
+                # انتظار قصير بين الدفعات
+                if i + batch_size < len(usdt_symbols):
+                    await asyncio.sleep(1)
+            
+            print(f"      ✅ تم جمع بيانات {len(volume_data)} عملة مؤهلة")
+            return volume_data
+            
+        except Exception as e:
+            print(f"      ❌ فشل الطريقة التقليدية: {e}")
+            return []
+
+    async def _process_single_symbol(self, symbol: str) -> Dict[str, Any]:
+        """معالجة رمز واحد لجلب بيانات الحجم"""
+        try:
+            ticker = self.exchange.fetch_ticker(symbol)
+            if not ticker:
+                return None
+            
+            current_price = ticker.get('last', 0)
+            quote_volume = ticker.get('quoteVolume', 0)
+            
+            if quote_volume > 0:
+                dollar_volume = quote_volume
+            else:
+                base_volume = ticker.get('baseVolume', 0)
+                dollar_volume = base_volume * current_price
+            
+            if dollar_volume < 50000:
+                return None
+            
+            return {
+                'symbol': symbol,
+                'dollar_volume': dollar_volume,
+                'current_price': current_price,
+                'volume_24h': ticker.get('baseVolume', 0),
+                'price_change_24h': (ticker.get('percentage', 0) or 0) * 100
+            }
+        except Exception:
+            return None
 
     async def _apply_advanced_indicators(self, volume_data: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
         """تطبيق المؤشرات المتقدمة على أفضل العملات حسب الحجم"""
@@ -329,7 +469,7 @@ class DataManager:
             high_24h = ticker.get('high', 0)
             low_24h = ticker.get('low', 0)
             open_price = ticker.get('open', 0)
-            price_change_24h = ticker.get('percentage', 0) or 0
+            price_change_24h = (ticker.get('percentage', 0) or 0) * 100
             
             # حساب المؤشرات المتقدمة
             volatility = self._calculate_volatility(high_24h, low_24h, current_price)
@@ -589,4 +729,4 @@ class DataManager:
             print(f"❌ خطأ في التحقق من الرمز {symbol}: {e}")
             return False
 
-print("✅ DataManager loaded - Efficient Top 200 Volume-Based Screening")
+print("✅ DataManager loaded - Multi-Method Volume Screening System")