Update data_manager.py

data_manager.py

@@ -1,4 +1,4 @@
-# data_manager.py (Updated to V7.8 - Added Pattern V8 Diagnostic Print)
+# data_manager.py (Updated to V7.9 - Re-balanced Spark Filter Weights)
 import os
 import asyncio
 import httpx
@@ -67,7 +67,7 @@ class DataManager:
             self.pattern_analyzer = ChartPatternAnalyzer(r2_service=None)
         # --- (نهاية الإضافة) ---
 
-        print("✅ DataManager initialized - V7.8 (Pattern V8 Diagnostic Print)")
+        print("✅ DataManager initialized - V7.9 (Re-balanced Spark Weights)")
 
     async def _load_markets(self):
         try:
@@ -323,12 +323,13 @@ class DataManager:
         except Exception as e:
             return 0.0
 
+    # 🔴 --- START OF CHANGE (V7.9) --- 🔴
     def _calculate_1h_reversal_spark_score(self, analysis: Dict) -> float:
         """
-        (جديد V7.7) - الفلتر الثاني: "فلتر شرارة الانعكاس" (بداية الزخم)
+        (محدث V7.9) - الفلتر الثاني: "فلتر شرارة الانعكاس" (أوزان معدلة)
         """
         try:
-            # (1. واقي العملات المستقرة - نفس الفلتر الأول)
+            # (1. واقي العملات المستقرة)
             ohlcv_candles = analysis.get('ohlcv_1h', {}).get('1h', [])
             if not ohlcv_candles or len(ohlcv_candles) < 30: 
                 return 0.0 
@@ -364,7 +365,6 @@ class DataManager:
             
             # --- (منطق فلترة "الشرارة") ---
             
-            # (النمط هو الأهم)
             pattern_score = 0.0
             if pattern_analysis.get('predicted_direction') == 'up':
                 pattern_score = pattern_analysis.get('pattern_confidence', 0)
@@ -389,12 +389,13 @@ class DataManager:
             if avg_volume > 0 and (current_volume / avg_volume) > 1.1:
                 vol_score = 0.5 # (مجرد اهتمام بسيط)
 
-            # (الأوزان لفلتر "الشرارة" - تعطي الأولوية للنمط والظروف)
-            WEIGHT_PATTERN = 0.40 # (الأهم)
-            WEIGHT_RSI_SPARK = 0.20
-            WEIGHT_ADX_COIL = 0.20
+            # (الأوزان الجديدة V7.9 - بناءً على طلبك)
+            WEIGHT_PATTERN = 0.10     # (تم الخفض)
+            WEIGHT_RSI_SPARK = 0.35   # (تم الرفع)
+            WEIGHT_ADX_COIL = 0.35    # (تم الرفع)
             WEIGHT_MC = 0.10
-            WEIGHT_VOL = 0.10 # (الأقل أهمية)
+            WEIGHT_VOL = 0.10
+            # (المجموع = 1.0)
 
             final_score = (
                 (pattern_score * WEIGHT_PATTERN) +
@@ -408,13 +409,14 @@ class DataManager:
             
         except Exception as e:
             return 0.0
+    # 🔴 --- END OF CHANGE (V7.9) --- 🔴
 
 
     async def layer1_rapid_screening(self) -> List[Dict[str, Any]]:
         """
-        الطبقة 1: فحص سريع - (محدث بالكامل V7.7 - فلتر مزدوج)
+        الطبقة 1: فحص سريع - (محدث بالكامل V7.9)
         """
-        print("📊 الطبقة 1 (V7.8): بدء الغربلة (الكاشف المزدوج + طباعة الأنماط)...")
+        print("📊 الطبقة 1 (V7.9): بدء الغربلة (الكاشف المزدوج + أوزان الشرارة المعدلة)...")
         
         # الخطوة 1: جلب أفضل 100 عملة حسب الحجم
         volume_data = await self._get_volume_data_optimal()
@@ -484,6 +486,7 @@ class DataManager:
 
                 # (2. إذا فشل فلتر الانفجار، جرب فلتر "الشرارة")
                 if burst_score < 0.50:
+                    # (استخدام V7.9 بالأوزان الجديدة)
                     spark_score = self._calculate_1h_reversal_spark_score(analysis_output)
                     
                     final_score = spark_score # (استخدام درجة الشرارة)
@@ -498,9 +501,8 @@ class DataManager:
                     if 'ohlcv_1h' in symbol_data: del symbol_data['ohlcv_1h'] 
                     
                     final_candidates.append(symbol_data)
-                # (else: فشل في كلا الفلترين، يتم تجاهله)
 
-        print(f"🎯 اكتملت الغربلة (V7.8). تم تأهيل {len(final_candidates)} عملة من أصل 100 للطبقة 2.")
+        print(f"🎯 اكتملت الغربلة (V7.9). تم تأهيل {len(final_candidates)} عملة من أصل 100 للطبقة 2.")
         
         if final_candidates:
             print("🏆 المرشحون الناجحون:")
@@ -511,7 +513,6 @@ class DataManager:
         
         return final_candidates
 
-    # 🔴 --- START OF CHANGE (V7.8) --- 🔴
     async def _run_mini_detector(self, symbol_data: Dict) -> Dict:
         """(محدث V7.8) يشغل المحللات + يطبع نتيجة الأنماط V8"""
         ohlcv_1h = symbol_data.get('ohlcv_1h')
@@ -540,31 +541,24 @@ class DataManager:
             pattern_result = results[1]
             analysis_dict['pattern_analysis'] = pattern_result
             
-            # (استخراج البيانات للطباعة)
             pattern_name = pattern_result.get('pattern_detected', 'no_clear_pattern')
             confidence = pattern_result.get('pattern_confidence', 0)
             tf = pattern_result.get('timeframe', 'N/A')
 
             if pattern_name != "Neutral / No Pattern" and confidence > 0.5:
-                # (نمط مفيد ومرتفع الثقة)
                 print(f"      💡 [ML Pattern] {symbol}: نمط مُكتشف! "
                       f"'{pattern_name}' (الثقة: {confidence:.2f}) على إطار {tf}")
             elif pattern_name == "Neutral / No Pattern":
-                # (لا يوجد نمط - لا نطبع شيئاً لتجنب إغراق السجل)
                 pass 
             else:
-                # (نمط ضعيف الثقة)
                 print(f"      - [ML Pattern] {symbol}: نمط ضعيف. "
                       f"'{pattern_name}' (الثقة: {confidence:.2f}) على إطار {tf}")
         
         else:
-            # (في حال فشل النموذج V8.8)
             print(f"      ❌ [ML Pattern] {symbol}: فشل تحليل الأنماط ({results[1]})")
-            analysis_dict['pattern_analysis'] = {} # (إضافة قاموس فارغ آمن)
-        # 🔴 --- END OF CHANGE (V7.8) --- 🔴
+            analysis_dict['pattern_analysis'] = {} 
             
         return analysis_dict
-    # 🔴 --- END OF CHANGE (V7.8) --- 🔴
 
 
     async def _fetch_1h_ohlcv_for_screening(self, symbol: str) -> List:
@@ -809,4 +803,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.8 (Pattern V8 Diagnostic Print)")
+print("✅ DataManager loaded - V7.9 (Re-balanced Spark Weights)")