Update ml_engine/oracle_engine.py

ml_engine/oracle_engine.py

@@ -10,14 +10,19 @@ from typing import Dict, Any, List, Optional
 # --- [ 0. إعدادات ] ---
 warnings.filterwarnings('ignore', category=FutureWarning)
 
+# (هذه هي نفس الإعدادات المستخدمة في التدريب)
 PIPELINE_SETTINGS = {
     'SWING_PROMINENCE_PCT': 0.02, # 2%
 }
 
-# (بناءً على تقريرك [cite: 5-8]، الدقة فوق 75% ممتازة)
+# (هذه هي العتبة التي سنثق بها في قرارات اللجنة)
+# [cite_start]بناءً على تقريرك، الدقة فوق 75% ممتازة [cite: 5-8]
 DECISION_CONFIDENCE_THRESHOLD = 0.75 
+
+# (عدد نماذج اللجنة)
 N_STRATEGY_MODELS = 11
 
+# (أسماء الفئات)
 STRATEGY_MAP = {
     0: 'WAIT',
     1: 'SWING_LONG',
@@ -32,12 +37,20 @@ TIMEBYTES_TO_PROCESS = ['15m', '1h', '4h']
 
 class OracleEngine:
     def __init__(self, model_dir: str = "ml_models/Unified_Models_V1"):
+        """
+        تهيئة "العقل" الاحتمالي (L3 Oracle).
+        
+        Args:
+            model_dir (str): المسار إلى المجلد الذي يحتوي على 
+                             الـ 15 نموذجاً المدربة.
+        """
         self.model_dir = model_dir
         self.strategy_boosters: List[lgb.Booster] = []
         self.quantile_boosters: Dict[str, lgb.Booster] = {}
+        
         self.feature_names: List[str] = []
         self.initialized = False
-        print("🧠 [OracleEngine V2] تم الإنشاء (Multi-Timeframe). جاهز للتهيئة.")
+        print("🧠 [OracleEngine V2.1] تم الإنشاء (Multi-Timeframe, Patched). جاهز للتهيئة.")
 
     async def initialize(self):
         """
@@ -46,7 +59,7 @@ class OracleEngine:
         if self.initialized:
             return True
             
-        print(f"🧠 [OracleEngine V2] جاري تحميل 15 نموذجاً من {self.model_dir}...")
+        print(f"🧠 [OracleEngine V2.1] جاري تحميل 15 نموذجاً من {self.model_dir}...")
         try:
             # 1. تحميل نماذج "لجنة القرار" (Strategy Ensemble)
             for i in range(N_STRATEGY_MODELS):
@@ -75,12 +88,12 @@ class OracleEngine:
             self.feature_names = self.strategy_boosters[0].feature_name()
             self.initialized = True
             
-            print(f"✅ [OracleEngine V2] جاهز. (Threshold: {DECISION_CONFIDENCE_THRESHOLD*100}%)")
+            print(f"✅ [OracleEngine V2.1] جاهز. (Threshold: {DECISION_CONFIDENCE_THRESHOLD*100}%)")
             print(f"   -> سيعمل على الأطر: {TIMEBYTES_TO_PROCESS}")
             return True
 
         except Exception as e:
-            print(f"❌ [OracleEngine V2] فشل فادح أثناء التهيئة: {e}")
+            print(f"❌ [OracleEngine V2.1] فشل فادح أثناء التهيئة: {e}")
             self.initialized = False
             return False
 
@@ -230,14 +243,25 @@ class OracleEngine:
             confidence = best_decision['confidence']
             best_tf = best_decision['timeframe']
 
-            # --- [ الخطوة 3: تطبيق فلتر الثقة (الأهم) ] ---
-            if confidence < DECISION_CONFIDENCE_THRESHOLD or strategy_name == 'WAIT':
+            # --- [ 🔴 🔴 🔴 التعديل: تطبيق الإصلاح (Patch) هنا ] ---
+            # (السبب 1: الثقة ضعيفة)
+            if confidence < DECISION_CONFIDENCE_THRESHOLD:
+                return {
+                    'action': 'IGNORE',
+                    'reason': f"Confidence ({confidence:.2f}) is below threshold ({DECISION_CONFIDENCE_THRESHOLD})",
+                    'confidence': confidence,
+                    'strategy': strategy_name
+                }
+            
+            # (السبب 2: النموذج واثق بأن الاستراتيجية هي "انتظار")
+            if strategy_name == 'WAIT':
                 return {
                     'action': 'IGNORE',
-                    'reason': f"Best signal ({strategy_name} @ {best_tf}) confidence ({confidence:.2f}) is below threshold ({DECISION_CONFIDENCE_THRESHOLD})",
+                    'reason': f"Oracle Consensus is 'WAIT' (Conf: {confidence:.2f}) @ {best_tf}",
                     'confidence': confidence,
                     'strategy': strategy_name
                 }
+            # --- [ نهاية التعديل ] ---
 
             # --- [ الخطوة 4: (نجحت الثقة) - تشغيل "لجنة الأهداف" ] ---
             winning_feature_vector = best_decision['feature_vector']
@@ -246,8 +270,8 @@ class OracleEngine:
                 preds_quantile[name] = booster.predict(winning_feature_vector, num_iteration=booster.best_iteration)[0]
 
             # --- [ الخطوة 5: تحديد الأهداف النهائية ] ---
-            tp_pct = preds_quantile['tp_p50'] # (الهدف الواقعي) [cite: 79]
-            sl_pct = preds_quantile['sl_p80'] # (وقف الخسارة الآمن) [cite: 80]
+            tp_pct = preds_quantile['tp_p50'] # (الهدف الواقعي)
+            sl_pct = preds_quantile['sl_p80'] # (وقف الخسارة الآمن)
             
             if tp_pct <= 0 or sl_pct <= 0:
                 return {'action': 'IGNORE', 'reason': f'Quantile model predicted negative TP/SL ({tp_pct=}, {sl_pct=})'}
@@ -261,6 +285,7 @@ class OracleEngine:
                 sl_price = current_price * (1 + sl_pct)
                 action_type = "SELL" # (إذا كان النظام يدعم البيع)
             else:
+                # (هذا السطر لن يتم الوصول إليه أبداً بسبب فلتر 'WAIT' أعلاه، لكنه حماية جيدة)
                 return {'action': 'IGNORE', 'reason': 'Strategy not actionable'}
 
             # --- [ الخطوة 6: إرجاع القرار الكامل ] ---
@@ -277,7 +302,7 @@ class OracleEngine:
             }
 
         except Exception as e:
-            print(f"❌ [OracleEngine V2] فشل فادح أثناء التنبؤ: {e}")
+            print(f"❌ [OracleEngine V2.1] فشل فادح أثناء التنبؤ: {e}")
             import traceback
             traceback.print_exc()
             return {'action': 'WAIT', 'reason': f'Exception: {e}'}