Update ml_engine/indicators.py

ml_engine/indicators.py

@@ -1,4 +1,4 @@
-# ml_engine/indicators.py (V5.2 - Fixed 'volume' not defined bug)
+# ml_engine/indicators.py (V5.3 - Fixed VWAP DatetimeIndex Bug)
 import pandas as pd
 import pandas_ta as ta
 import numpy as np
@@ -163,10 +163,8 @@ class AdvancedTechnicalAnalyzer:
         except Exception as e:
             print(f"⚠️ خطأ في حساب مؤشرات التقلب: {e}")
         
-        # 🔴 --- START OF CHANGE (V5.2 - FIX) --- 🔴
-        # (إصلاح: إعادة 'volatility' بدلاً من 'volume')
+        # (إصلاح V5.2: إعادة 'volatility' بدلاً من 'volume')
         return {key: value for key, value in volatility.items() if value is not None and not np.isnan(value)}
-        # 🔴 --- END OF CHANGE --- 🔴
     
     def _calculate_volume_indicators(self, dataframe, timeframe):
         """حساب مؤشرات الحجم"""
@@ -189,22 +187,27 @@ class AdvancedTechnicalAnalyzer:
                     
                     df_vwap.sort_index(inplace=True)
                     
-                    df_vwap_reset = df_vwap.reset_index()
+                    # 🔴 --- START OF CHANGE (V5.3 - FIX) --- 🔴
+                    # (إصلاح: إزالة reset_index() للحفاظ على DatetimeIndex لـ ta.vwap)
+                    # df_vwap_reset = df_vwap.reset_index() # <-- هذا السطر يسبب المشكلة
                     
                     volume_weighted_average_price = ta.vwap(
-                        high=df_vwap_reset['high'],
-                        low=df_vwap_reset['low'], 
-                        close=df_vwap_reset['close'],
-                        volume=df_vwap_reset['volume']
+                        high=df_vwap['high'],    # (استخدام df_vwap مباشرة)
+                        low=df_vwap['low'],     # (استخدام df_vwap مباشرة)
+                        close=df_vwap['close'],   # (استخدام df_vwap مباشرة)
+                        volume=df_vwap['volume']  # (استخدام df_vwap مباشرة)
                     )
+                    # 🔴 --- END OF CHANGE --- 🔴
                     
                     if volume_weighted_average_price is not None and not volume_weighted_average_price.empty and not pd.isna(volume_weighted_average_price.iloc[-1]): 
                         volume['vwap'] = float(volume_weighted_average_price.iloc[-1])
                         
                 except Exception as vwap_error:
-                    if "Index" not in str(vwap_error):
+                    # (تم تعديل الشرط لطباعة الخطأ إذا لم يكن التحذير المتوقع)
+                    if "VWAP requires an ordered DatetimeIndex" not in str(vwap_error) and "Index" not in str(vwap_error):
                         print(f"⚠️ خطأ في حساب VWAP لـ {timeframe}: {vwap_error}")
                     
+                    # (محاولة حساب احتياطي بسيط إذا فشل الحساب المعتمد على الفهرس)
                     if len(dataframe) >= 20:
                         try:
                             typical_price = (dataframe['high'] + dataframe['low'] + dataframe['close']) / 3
@@ -270,4 +273,4 @@ class AdvancedTechnicalAnalyzer:
         
         return {key: value for key, value in cycle.items() if value is not None and not np.isnan(value)}
 
-print("✅ ML Module: Technical Indicators loaded (V5.2 - 'volume' not defined Fix)")
+print("✅ ML Module: Technical Indicators loaded (V5.3 - VWAP DatetimeIndex Fix)")