Update data_manager.py

data_manager.py

@@ -1,4 +1,4 @@
-# data_manager.py (Updated to V7.2 - Fixed Task Bug & Added Stablecoin Guard)
+# data_manager.py (Updated to V7.3 - Increased L1 Threshold to 0.50)
 import os
 import asyncio
 import httpx
@@ -52,7 +52,7 @@ class DataManager:
     async def initialize(self):
         self.http_client = httpx.AsyncClient(timeout=30.0)
         await self._load_markets()
-        print("✅ DataManager initialized - V7.2 (Stablecoin Guard Active)")
+        print("✅ DataManager initialized - V7.3 (L1 Threshold @ 0.50)")
 
     async def _load_markets(self):
         try:
@@ -80,7 +80,6 @@ class DataManager:
             except Exception as e:
                 print(f"   ⚠️ DataManager: Error closing ccxt.kucoin: {e}")
         
-    # (الدوال المساعدة لسياق السوق وأسعار BTC/ETH تبقى كما هي - لا تغيير)
     async def get_market_context_async(self):
         try:
             sentiment_data = await self.get_sentiment_safe_async()
@@ -198,7 +197,6 @@ class DataManager:
             'data_quality': 'LOW'
         }
 
-    # 🔴 --- START OF REFACTOR (V7.2 - Fixed Bugs) --- 🔴
     
     def _create_dataframe(self, candles: List) -> pd.DataFrame:
         """(V7.1) دالة مساعدة لإنشاء DataFrame لتحليل 1H"""
@@ -220,18 +218,15 @@ class DataManager:
         يحتوي الآن على "واقي العملات المستقرة"
         """
         try:
-            # 🔴 --- (FIX V7.2) واقي العملات المستقرة --- 🔴
-            # (يتم تشغيله قبل أي حساب آخر)
+            # (V7.2) واقي العملات المستقرة
             if 'ohlcv_1h' in analysis and '1h' in analysis['ohlcv_1h']:
                 closes_1h = [c[4] for c in analysis['ohlcv_1h']['1h']]
                 if len(closes_1h) > 20:
-                    # (نستخدم آخر 20 شمعة للتحقق من التقلب)
                     std_dev = np.std(closes_1h[-20:])
-                    if std_dev < 1e-5: # (تقلب شبه صفري)
+                    if std_dev < 1e-5: 
                         print(f"      - {analysis.get('symbol', 'N/A')}: تم الاستبعاد (عملة مستقرة)")
-                        return 0.0 # (إعطاء درجة صفر فوراً)
-            # 🔴 --- نهاية الإصلاح --- 🔴
-
+                        return 0.0 
+            
             # 1. درجة الأنماط (Pattern Score)
             pattern_confidence = analysis.get('pattern_analysis', {}).get('pattern_confidence', 0)
             
@@ -239,7 +234,7 @@ class DataManager:
             mc_distribution = analysis.get('monte_carlo_distribution')
             monte_carlo_score = 0
             
-            if mc_distribution and mc_distribution.get('error') is None: # (تحقق من عدم وجود خطأ)
+            if mc_distribution and mc_distribution.get('error') is None: 
                 prob_gain = mc_distribution.get('probability_of_gain', 0)
                 var_95_value = mc_distribution.get('risk_metrics', {}).get('VaR_95_value', 0)
                 current_price = analysis.get('current_price', 1)
@@ -262,10 +257,8 @@ class DataManager:
                 ema_9 = indicators.get('ema_9', 0)
                 ema_21 = indicators.get('ema_21', 0)
                 
-                # ملمح الزخم
                 if rsi > 55 and macd_hist > 0 and ema_9 > ema_21:
                     indicator_score = min(0.5 + (rsi - 55) / 50 + (macd_hist / (analysis.get('current_price', 1) * 0.001)), 1.0)
-                # ملمح الانعكاس
                 elif rsi < 35:
                     indicator_score = min(0.4 + (35 - rsi) / 35, 0.8)
 
@@ -291,9 +284,9 @@ class DataManager:
 
     async def layer1_rapid_screening(self) -> List[Dict[str, Any]]:
         """
-        الطبقة 1: فحص سريع - (محدث بالكامل V7.2)
+        الطبقة 1: فحص سريع - (محدث بالكامل V7.3)
         """
-        print("📊 الطبقة 1 (V7.2): بدء الغربلة (الكاشف المصغر 1H)...")
+        print("📊 الطبقة 1 (V7.3): بدء الغربلة (الكاشف المصغر 1H)...")
         
         # الخطوة 1: جلب أفضل 100 عملة حسب الحجم
         volume_data = await self._get_volume_data_optimal()
@@ -332,7 +325,6 @@ class DataManager:
                 if isinstance(candles, Exception) or not candles or len(candles) < 50:
                     continue
                 
-                # (إعداد البيانات للمحللات)
                 ohlcv_1h_only = {'1h': candles}
                 symbol_data['ohlcv_1h'] = ohlcv_1h_only 
                 symbol_data['current_price'] = candles[-1][4]
@@ -352,15 +344,15 @@ class DataManager:
                     print(f"      - {symbol}: فشل الكاشف المصغر ({analysis_output})")
                     continue
                 
-                # (تمرير ohlcv_1h إلى دالة حساب النقاط من أجل واقي العملات المستقرة)
                 analysis_output['ohlcv_1h'] = symbol_data['ohlcv_1h']
                 analysis_output['symbol'] = symbol
                 
-                # الخطوة 4: حساب النتيجة النهائية للفلتر
                 filter_score = self._calculate_1h_filter_score(analysis_output)
                 
-                # الخطوة 5: تطبيق العتبة (Threshold)
-                if filter_score >= 0.20:
+                # 🔴 --- START OF CHANGE (V7.3) --- 🔴
+                # (رفع العتبة من 0.20 إلى 0.50)
+                if filter_score >= 0.50:
+                # 🔴 --- END OF CHANGE --- 🔴
                     print(f"      ✅ {symbol}: نجح (الدرجة: {filter_score:.2f})")
                     symbol_data['layer1_score'] = filter_score
                     symbol_data['reasons_for_candidacy'] = [f'1H_DETECTOR_PASS']
@@ -368,11 +360,8 @@ class DataManager:
                     if 'ohlcv_1h' in symbol_data: del symbol_data['ohlcv_1h'] 
                     
                     final_candidates.append(symbol_data)
-                # else:
-                #    (تم إيقاف طباعة الفشل لتقليل التشويش)
-                #    print(f"      - {symbol}: فشل (الدرجة: {filter_score:.2f})")
 
-        print(f"🎯 اكتملت الغربلة (V7.2). تم تأهيل {len(final_candidates)} عملة من أصل 100 للطبقة 2.")
+        print(f"🎯 اكتملت الغربلة (V7.3). تم تأهيل {len(final_candidates)} عملة من أصل 100 للطبقة 2.")
         
         print("🏆 المرشحون الناجحون:")
         for k, candidate in enumerate(final_candidates[:15]):
@@ -393,7 +382,6 @@ class DataManager:
             
         analysis_dict = {'current_price': current_price}
 
-        # (ملاحظة: جعلنا دوال التحليل async في ملفاتها لتكون متوافقة)
         task_indicators = self.technical_analyzer.calculate_all_indicators(df, '1h')
         task_mc = self.monte_carlo_analyzer.generate_1h_price_distribution(ohlcv_1h)
         task_pattern = self.pattern_analyzer.detect_chart_patterns(ohlcv_1h)
@@ -421,7 +409,6 @@ class DataManager:
         except Exception:
             return None
 
-    # (دوال جلب الحجم تبقى كما هي لأنها فعالة)
     async def _get_volume_data_optimal(self) -> List[Dict[str, Any]]:
         try:
             if not self.exchange: return []
@@ -440,11 +427,8 @@ class DataManager:
                     dollar_volume = base_volume * current_price
                 if dollar_volume is None or dollar_volume < 50000: continue
                 
-                # 🔴 --- (FIX V7.2) إصلاح نسبة التغير المئوية --- 🔴
-                # (ccxt 'percentage' هي النسبة الفعلية، لا تحتاج للضرب في 100)
                 price_change_24h = ticker.get('percentage', 0) or 0
                 if price_change_24h is None: price_change_24h = 0
-                # 🔴 --- نهاية الإصلاح --- 🔴
 
                 volume_data.append({
                     'symbol': symbol, 'dollar_volume': dollar_volume,
@@ -479,10 +463,7 @@ class DataManager:
                         if vol_value is None or last_price is None or change_rate is None or vol is None: continue
                         dollar_volume = float(vol_value) if vol_value else 0
                         current_price = float(last_price) if last_price else 0
-                        
-                        # (الإصلاح هنا أيضاً: 'changeRate' هو النسبة العشرية، لذا نضرب في 100)
                         price_change = (float(change_rate) * 100) if change_rate else 0
-                        
                         volume_24h = float(vol) if vol else 0
                         if dollar_volume >= 50000 and current_price > 0:
                             volume_data.append({
@@ -497,7 +478,6 @@ class DataManager:
             print(f"❌ خطأ في جلب بيانات الحجم المباشر: {e}")
             return []
 
-    # (دالة تدفق الشموع تبقى كما هي - لا تغيير)
     async def stream_ohlcv_data(self, symbols: List[Dict[str, Any]], queue: asyncio.Queue):
         """
         (محدث V7.2)
@@ -515,13 +495,11 @@ class DataManager:
             
             batch_tasks = []
             
-            # 🔴 --- (FIX V7.2) إصلاح تمرير الوسيط --- 🔴
+            # (V7.2 FIX)
             for symbol_data in batch:
-                symbol_str = symbol_data['symbol'] # (استخراج النص)
-                # (تمرير النص فقط إلى الدالة التي تتوقع نصاً)
+                symbol_str = symbol_data['symbol'] 
                 task = asyncio.create_task(self._fetch_complete_ohlcv_parallel(symbol_str))
                 batch_tasks.append(task)
-            # 🔴 --- نهاية الإصلاح --- 🔴
 
             batch_results = await asyncio.gather(*batch_tasks, return_exceptions=True)
             
@@ -529,15 +507,12 @@ class DataManager:
             successful_count = 0
             for i, result in enumerate(batch_results):
                 
-                # 🔴 --- (FIX V7.2) مطابقة النتائج بالبيانات الأصلية --- 🔴
                 original_symbol_data = batch[i]
                 symbol_str = original_symbol_data['symbol']
-                # 🔴 --- نهاية الإصلاح --- 🔴
 
                 if isinstance(result, Exception):
                     print(f"      ❌ [المنتج] فشل جلب {symbol_str}: {result}")
                 elif result is not None:
-                    # (دمج الدرجة الأولية مع البيانات الكاملة)
                     result.update(original_symbol_data) 
                     successful_data_for_batch.append(result)
                     successful_count += 1
@@ -580,7 +555,6 @@ class DataManager:
             
             timeframe_tasks = []
             for timeframe, limit in timeframes:
-                # (هنا 'symbol' هو نص، وهو صحيح)
                 task = asyncio.create_task(self._fetch_single_timeframe_improved(symbol, timeframe, limit))
                 timeframe_tasks.append(task)
             
@@ -624,7 +598,6 @@ class DataManager:
         retry_delay = 2
         for attempt in range(max_retries):
             try:
-                # (هنا 'symbol' هو نص، وهو صحيح)
                 ohlcv_data = self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
                 if ohlcv_data and len(ohlcv_data) > 0:
                     return ohlcv_data
@@ -648,7 +621,6 @@ class DataManager:
             return float(current_price)
         except Exception as e: return None
 
-    # (دوال دعم بيانات الحيتان تبقى كما هي - لا تغيير)
     async def get_whale_data_for_symbol(self, symbol):
         try:
             if self.whale_monitor:
@@ -666,4 +638,4 @@ class DataManager:
         except Exception as e:
             return {'action': 'HOLD', 'confidence': 0.3, 'reason': f'Error: {str(e)}', 'source': 'whale_analysis'}
 
-print("✅ DataManager loaded - V7.2 (Stablecoin Guard Active + Task Bug Fixed)")
+print("✅ DataManager loaded - V7.3 (L1 Threshold @ 0.50)")