Update ml_engine/patterns.py

ml_engine/patterns.py

@@ -1,5 +1,5 @@
 # ml_engine/patterns.py
-# (V8.4 - إصلاح KeyError: استخدام .copy() لعزل السلاسل (Series) + فحوصات أقوى للأعمدة)
+# (V8.5 - الحل النهائي: إعادة الفهرس الزمني لـ VWAP + الإبقاء على .copy() لعزل المؤشرات)
 
 import pandas as pd
 import numpy as np
@@ -87,17 +87,17 @@ class ChartPatternAnalyzer:
             self.scaler = None
             return False
 
-    # 🔴 --- START OF CHANGE (V8.4) --- 🔴
-    # (V8.4 - إصلاح KeyError: استخدام .copy() لعزل السلاسل (Series) + فحوصات أقوى للأعمدة)
+    # (V8.4 - هذا الكود صحيح ويجب الإبقاء عليه كما هو)
     def _extract_features(self, df_window: pd.DataFrame) -> pd.DataFrame:
         """
-        (الوصفة V8 - معدلة - V8.4)
+        (الوصفة V8.4 - لا تغيير هنا)
         حساب الـ 30 مؤشراً (وظيفياً) مع عزل البيانات
         """
         if not ta:
             raise ImportError("مكتبة pandas-ta غير مثبتة.")
 
         # (إنشاء DF فارغ بنفس الفهرس (Index) الخاص بآخر صف)
+        # (مهم: df_window *يجب* أن يكون مفهرساً بالوقت هنا)
         df = pd.DataFrame(index=df_window.iloc[-1:].index)
         
         # (تمرير الأعمدة كـ "نسخ" (.copy()) لعزلها عن df_window)
@@ -107,12 +107,15 @@ class ChartPatternAnalyzer:
         l = df_window['low'].copy()
         v = df_window['volume'].copy()
         
+        # (V8.5) تمرير الفهرس الزمني صراحة إلى VWAP
+        # (على الرغم من أن .copy() قد تزيله، فإن df_window.index لا يزال متاحاً)
+        # (تحديث: يبدو أن ta.vwap يأخذ الفهرس من السلاسل (Series) h,l,c,v)
+        
         try:
             # --- حساب المؤشرات وظيفياً ---
             df['RSI_14'] = ta.rsi(c, length=14)
             
             macd_data = ta.macd(c, fast=12, slow=26, signal=9)
-            # (فحص الحماية V8.4)
             if macd_data is not None and not macd_data.empty and 'MACD_12_26_9' in macd_data.columns:
                 df['MACD_12_26_9'] = macd_data['MACD_12_26_9']
                 df['MACDh_12_26_9'] = macd_data['MACDh_12_26_9']
@@ -122,7 +125,6 @@ class ChartPatternAnalyzer:
             df['EMA_20'] = ta.ema(c, length=20)
             
             bb_data = ta.bbands(c, length=5, std=2.0)
-            # (فحص الحماية V8.4)
             if bb_data is not None and not bb_data.empty and 'BBL_5_2.0' in bb_data.columns:
                 df['BBL_5_2.0_2.0'] = bb_data['BBL_5_2.0'] 
                 df['BBM_5_2.0_2.0'] = bb_data['BBM_5_2.0']
@@ -131,20 +133,19 @@ class ChartPatternAnalyzer:
                 df['BBP_5_2.0_2.0'] = bb_data['BBP_5_2.0']
 
             stoch_data = ta.stoch(h, l, c, k=14, d=3, smooth_k=3)
-            # (فحص الحماية V8.4)
             if stoch_data is not None and not stoch_data.empty and 'STOCHk_14_3_3' in stoch_data.columns:
                 df['STOCHk_14_3_3'] = stoch_data['STOCHk_14_3_3']
                 df['STOCHd_14_3_3'] = stoch_data['STOCHd_14_3_3']
                 df['STOCHh_14_3_3'] = stoch_data['STOCHh_14_3_3']
 
             adx_data = ta.adx(h, l, c, length=14, adxr=2)
-            # (فحص الحماية V8.4)
             if adx_data is not None and not adx_data.empty and 'ADX_14' in adx_data.columns:
                 df['ADX_14'] = adx_data['ADX_14']
                 df['ADXR_14_2'] = adx_data['ADXR_14_2']
                 df['DMP_14'] = adx_data['DMP_14']
                 df['DMN_14'] = adx_data['DMN_14']
 
+            # (هنا يتم استخدام الفهرس الزمني الذي ورثته H,L,C,V)
             vwap_series = ta.vwap(h, l, c, v)
             if vwap_series is not None: df['VWAP_D'] = vwap_series
 
@@ -156,7 +157,6 @@ class ChartPatternAnalyzer:
             df['DPO_20'] = ta.dpo(c, length=20)
 
             kvo_data = ta.kvo(h, l, c, v, fast=34, slow=55, signal=13)
-            # (فحص الحماية V8.4)
             if kvo_data is not None and not kvo_data.empty and 'KVO_34_55_13' in kvo_data.columns:
                 df['KVO_34_55_13'] = kvo_data['KVO_34_55_13']
                 df['KVOs_34_55_13'] = kvo_data['KVOs_34_55_13']
@@ -166,17 +166,16 @@ class ChartPatternAnalyzer:
             df['WILLR_14'] = ta.willr(h, l, c, length=14)
         
         except Exception as e:
-            print(f"❌ [PatternEngineV8.4] خطأ أثناء حساب المؤشرات وظيفياً: {e}")
+            # (يجب أن نرى هذا الخطأ فقط إذا فشل VWAP مرة أخرى)
+            print(f"❌ [PatternEngineV8.5] خطأ أثناء حساب المؤشرات وظيفياً: {e}")
             pass
         # --- (نهاية حساب المؤشرات) ---
 
-        # (نأخذ الصف الأخير فقط)
         last_features = df.iloc[-1:].copy()
         
         last_features.ffill(inplace=True)
         last_features.fillna(0, inplace=True)
         
-        # (التأكد من أننا نمرر فقط الخصائص الـ 30 التي يتوقعها النموذج، وبالترتيب)
         final_features = pd.DataFrame(columns=self.indicator_features)
         
         for col in self.indicator_features:
@@ -186,7 +185,6 @@ class ChartPatternAnalyzer:
                 final_features[col] = 0 
 
         return final_features
-    # 🔴 --- END OF CHANGE (V8.4) --- 🔴
 
     async def detect_chart_patterns(self, ohlcv_data: dict) -> dict:
         """
@@ -214,10 +212,13 @@ class ChartPatternAnalyzer:
                     window_candles = candles[-200:]
                     df_window = pd.DataFrame(window_candles, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
                     
-                    # (ملاحظة V8.4: لا نزال لا نحتاج إلى set_index هنا، 
-                    # لأن _extract_features V8.4 يتعامل مع الفهرس الرقمي بشكل صحيح)
+                    # 🔴 --- START OF CHANGE (V8.5) --- 🔴
+                    # (إعادة تفعيل الفهرس الزمني. هذا ضروري لـ VWAP)
+                    df_window['timestamp'] = pd.to_datetime(df_window['timestamp'], unit='ms')
+                    df_window.set_index('timestamp', inplace=True)
+                    # 🔴 --- END OF CHANGE (V8.5) --- 🔴
                     
-                    # 1. استخراج الخصائص (الوصفة V8.4)
+                    # 1. استخراج الخصائص (الوصفة V8.4 لا تزال قيد الاستخدام)
                     features_df = self._extract_features(df_window)
                     
                     if features_df is None or features_df.empty:
@@ -242,8 +243,8 @@ class ChartPatternAnalyzer:
                         })
                         
                 except Exception as e:
-                    # (يجب أن تختفي أخطاء KeyError من هنا الآن)
-                    print(f"❌ [PatternEngineV8.4] فشل التنبؤ لـ {timeframe}: {e}")
+                    # (الآن يجب أن تختفي جميع الأخطاء السابقة)
+                    print(f"❌ [PatternEngineV8.5] فشل التنبؤ لـ {timeframe}: {e}")
                     
         # 4. اختيار أفضل نمط من *جميع* الأطر الزمنية
         if all_results:
@@ -261,4 +262,4 @@ class ChartPatternAnalyzer:
 
         return best_match
 
-print("✅ ML Module: Pattern Engine V8.4 (Isolated Series + Robust Checks) loaded")
+print("✅ ML Module: Pattern Engine V8.5 (Re-indexed + Isolated Series) loaded")