Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (Updated to V6.9 - Active Tactical Profit-Saver)
+# trade_manager.py (Updated to V7.0 - 5m Detector Profit-Saver)
 import asyncio
 import json
 import time
@@ -25,7 +25,17 @@ except ImportError:
 import numpy as np
 from helpers import safe_float_conversion
 
+# 🔴 --- START OF CHANGE (V7.0) --- 🔴
+# (استيراد المحللات لتشغيل الكاشف المصغر 5m)
+from ml_engine.indicators import AdvancedTechnicalAnalyzer
+from ml_engine.patterns import ChartPatternAnalyzer
+# 🔴 --- END OF CHANGE --- 🔴
+
 class TacticalData:
+    """
+    (محدث V7.0)
+    لتخزين بيانات 1m (للدخول) و 5m (لحماية الأرباح).
+    """
     def __init__(self, symbol):
         self.symbol = symbol
         self.order_book = None 
@@ -40,9 +50,17 @@ class TacticalData:
         self.last_kucoin_trade_id = None
         self.last_confirmation_trade_ids = defaultdict(lambda: None)
         
+        # (بيانات 1-دقيقة لزناد الدخول)
         self.ohlcv_1m = deque(maxlen=100) 
         self.indicators_1m = {} 
         self.last_1m_candle_timestamp = None
+        
+        # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+        # (بيانات 5-دقائق لحماية الأرباح)
+        self.ohlcv_5m = deque(maxlen=100) # (لتخزين 100 شمعة 5-دقائق)
+        self.last_5m_candle_timestamp = None
+        self.new_5m_data_added = False # (مؤشر لتشغيل الكاشف 5m)
+        # 🔴 --- END OF CHANGE --- 🔴
 
     def add_trade(self, trade):
         trade_id = trade.get('id')
@@ -91,6 +109,7 @@ class TacticalData:
         except Exception: return {"bids_depth": 0, "asks_depth": 0}
 
     def add_1m_ohlcv(self, ohlcv_data: List):
+        """إضافة شموع 1-دقيقة وحساب المؤشرات (للدخول)"""
         if not ohlcv_data:
             return
         
@@ -109,6 +128,7 @@ class TacticalData:
             self._analyze_1m_indicators()
 
     def _analyze_1m_indicators(self):
+        """حساب مؤشرات 1-دقيقة الحقيقية (للدخول)"""
         if ta is None or len(self.ohlcv_1m) < 26:
             self.indicators_1m = {}
             return
@@ -136,6 +156,24 @@ class TacticalData:
                 
         except Exception as e:
             self.indicators_1m = {}
+            
+    # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+    def add_5m_ohlcv(self, ohlcv_data: List):
+        """(جديد V7.0) إضافة شموع 5-دقائق (لحماية الأرباح)"""
+        if not ohlcv_data:
+            return
+        
+        for candle in ohlcv_data:
+            timestamp = candle[0]
+            if timestamp and timestamp != self.last_5m_candle_timestamp:
+                if self.ohlcv_5m and timestamp < self.ohlcv_5m[-1][0]:
+                    continue
+                
+                self.ohlcv_5m.append(candle)
+                self.last_5m_candle_timestamp = timestamp
+                # (تعيين المؤشر لإعلام حلقة التحليل بوجود بيانات جديدة)
+                self.new_5m_data_added = True
+    # 🔴 --- END OF CHANGE --- 🔴
 
     def get_tactical_snapshot(self):
         agg_cvd = sum(self.confirmation_cvd.values())
@@ -151,9 +189,7 @@ class TacticalData:
 
 
 class TradeManager:
-    # 🔴 --- START OF CHANGE (V6.9) --- 🔴
     def __init__(self, r2_service, learning_hub=None, data_manager=None, state_manager=None, callback_on_close=None):
-    # 🔴 --- END OF CHANGE --- 🔴
         if not CCXT_ASYNC_AVAILABLE:
             raise RuntimeError("مكتبة 'ccxt.async_support' غير متاحة.")
 
@@ -161,10 +197,7 @@ class TradeManager:
         self.learning_hub = learning_hub
         self.data_manager = data_manager
         self.state_manager = state_manager
-        
-        # 🔴 --- START OF CHANGE (V6.9) --- 🔴
         self.callback_on_close = callback_on_close
-        # 🔴 --- END OF CHANGE --- 🔴
         
         self.is_running = False
         self.sentry_watchlist = {}
@@ -177,6 +210,12 @@ class TradeManager:
         self.confirmation_exchanges = {}
         self.polling_interval = 1.5
         self.confirmation_polling_interval = 3.0
+        
+        # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+        # (تهيئة محللات الكاشف المصغر 5m)
+        self.sentry_technical_analyzer = AdvancedTechnicalAnalyzer()
+        self.sentry_pattern_analyzer = ChartPatternAnalyzer()
+        # 🔴 --- END OF CHANGE --- 🔴
 
     async def initialize_sentry_exchanges(self): 
         try:
@@ -325,7 +364,7 @@ class TradeManager:
                 del self.tactical_data_cache[symbol]
 
     async def _poll_kucoin_data(self, symbol):
-        """(محدث V6.7) حلقة استقصاء (Polling) لبيانات KuCoin (تتضمن 1m OHLCV)"""
+        """(محدث V7.0) حلقة استقصاء (Polling) لبيانات KuCoin (تتضمن 1m و 5m OHLCV)"""
         while self.is_running:
             try:
                 if not self.kucoin_rest:
@@ -333,11 +372,15 @@ class TradeManager:
                     await asyncio.sleep(10)
                     continue
 
+                # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+                # (جلب 4 أنواع بيانات بالتوازي)
                 tasks = {
                     'ob': asyncio.create_task(self.kucoin_rest.fetch_order_book(symbol, limit=20)),
                     'trades': asyncio.create_task(self.kucoin_rest.fetch_trades(symbol, since=int((time.time() - 60) * 1000), limit=50)),
-                    'ohlcv_1m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '1m', limit=50))
+                    'ohlcv_1m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '1m', limit=50)),
+                    'ohlcv_5m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '5m', limit=50))
                 }
+                # 🔴 --- END OF CHANGE --- 🔴
 
                 await asyncio.wait(tasks.values(), return_when=asyncio.ALL_COMPLETED)
                 
@@ -355,6 +398,11 @@ class TradeManager:
                 
                 if not tasks['ohlcv_1m'].exception():
                     self.tactical_data_cache[symbol].add_1m_ohlcv(tasks['ohlcv_1m'].result())
+                
+                # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+                if not tasks['ohlcv_5m'].exception():
+                    self.tactical_data_cache[symbol].add_5m_ohlcv(tasks['ohlcv_5m'].result())
+                # 🔴 --- END OF CHANGE --- 🔴
 
                 await asyncio.sleep(self.polling_interval)
 
@@ -411,7 +459,7 @@ class TradeManager:
     
 
     async def _run_tactical_analysis_loop(self, symbol: str, strategy_hint: str):
-        """(محدث V6.9) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
+        """(محدث V7.0) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
         while self.is_running:
             await asyncio.sleep(1) 
             try:
@@ -423,13 +471,15 @@ class TradeManager:
                 snapshot = tactical_data.get_tactical_snapshot()
                 
                 if trade:
-                    # 🔴 --- START OF CHANGE (V6.9) --- 🔴
                     # 1. التحقق من SL/TP (الأولوية القصوى)
                     exit_reason = self._check_exit_trigger(trade, snapshot, tactical_data)
                     
-                    # 2. إذا لم يتم ضرب SL/TP، تحقق من "مراقب حماية الأرباح"
-                    if not exit_reason:
-                        exit_reason = self._check_tactical_profit_save(trade, snapshot, tactical_data)
+                    # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+                    # 2. إذا لم يتم ضرب SL/TP، تحقق من "مراقب حماية الأرباح" 5m
+                    # (يتم تشغيله فقط إذا وصلت شمعة 5m جديدة)
+                    if not exit_reason and tactical_data.new_5m_data_added:
+                        exit_reason = await self._run_5m_profit_saver(trade, list(tactical_data.ohlcv_5m), tactical_data)
+                        tactical_data.new_5m_data_added = False # (إعادة ضبط المؤشر)
                     # 🔴 --- END OF CHANGE --- 🔴
                         
                     if exit_reason:
@@ -438,6 +488,7 @@ class TradeManager:
                         current_price_to_close = None
                         if "Take Profit" in exit_reason:
                             current_price_to_close = trade.get('take_profit')
+                        # (إذا كان الإغلاق تكتيكياً أو وقف خسارة، استخدم سعر Bid)
                         elif tactical_data.order_book and tactical_data.order_book.get('bids') and len(tactical_data.order_book['bids']) > 0:
                             current_price_to_close = tactical_data.order_book['bids'][0][0]
                         else:
@@ -542,43 +593,77 @@ class TradeManager:
         
         return None 
 
-    # 🔴 --- START OF CHANGE (V6.9) --- 🔴
-    def _check_tactical_profit_save(self, trade: Dict, data: Dict, tactical_data: TacticalData) -> str:
+    # 🔴 --- START OF CHANGE (V7.0) --- 🔴
+    def _create_dataframe_5m(self, candles: List) -> pd.DataFrame:
+        """(جديد V7.0) دالة مساعدة لإنشاء DataFrame لتحليل 5m"""
+        try:
+            if not candles: return pd.DataFrame()
+            df = pd.DataFrame(candles, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
+            df[['open', 'high', 'low', 'close', 'volume']] = df[['open', 'high', 'low', 'close', 'volume']].astype(float)
+            df.set_index('timestamp', inplace=True)
+            df.sort_index(inplace=True)
+            return df
+        except Exception:
+            return pd.DataFrame()
+
+    async def _run_5m_profit_saver(self, trade: Dict, ohlcv_5m_list: List, tactical_data: TacticalData) -> str:
         """
-        (جديد V6.9) "مراقب الانعكاس" 1-دقيقة.
-        يغلق الصفقة الرابح�� فقط عند أول علامة ضعف تكتيكية.
+        (جديد V7.0) "مراقب الانعكاس" 5m.
+        يستخدم الكاشف (مؤشرات + أنماط) على 5m لإغلاق الصفقات الرابحة.
         """
         try:
-            # --- 1. التحقق من الربحية ---
-            
-            # (نستخدم سعر Bid، لأنه السعر الفعلي الذي سنبيع به)
+            # --- 1. التحقق من الربحية (كما طلبت) ---
             best_bid_price = None
             if tactical_data.order_book and tactical_data.order_book.get('bids') and len(tactical_data.order_book['bids']) > 0:
                 best_bid_price = tactical_data.order_book['bids'][0][0]
             
             if best_bid_price is None:
-                return None # لا يمكن تحديد السعر
+                return None 
                 
             entry_price = trade.get('entry_price')
             if best_bid_price <= entry_price:
-                return None # الصفقة ليست رابحة، لا تفعل شيئاً (حسب الطلب)
+                return None # الصفقة ليست رابحة، لا تفعل شيئاً
 
-            # --- 2. الصفقة رابحة، التحقق من علامات الانهيار ---
-            indicators_1m = data.get('indicators_1m', {})
-            ema_9_1m = indicators_1m.get('ema_9')
-            ema_21_1m = indicators_1m.get('ema_21')
-            
-            if ema_9_1m is None or ema_21_1m is None:
-                return None # بيانات 1-دقيقة غير جاهزة بعد
+            # --- 2. الصفقة رابحة، تشغيل الكاشف 5m ---
+            if len(ohlcv_5m_list) < 20:
+                return None # بيانات غير كافية للتحليل
                 
-            # (علامة الانهيار: تقاطع 1-دقيقة الهبوطي)
-            if ema_9_1m < ema_21_1m:
-                return f"Tactical Profit Save: 1m trend break (EMA9 < EMA21) while profitable."
+            df_5m = self._create_dataframe_5m(ohlcv_5m_list)
+            if df_5m.empty:
+                return None
+
+            # (تشغيل المحللات - بدون مونت كارلو كما طلبت)
+            indicators_5m = self.sentry_technical_analyzer.calculate_all_indicators(df_5m, '5m')
+            pattern_analysis_5m = await self.sentry_pattern_analyzer.detect_chart_patterns({'5m': ohlcv_5m_list})
+
+            # --- 3. حساب درجة الانعكاس (Reversal Score) ---
+            reversal_score = 0.0
+            
+            # (التحقق من الأنماط الهبوطية)
+            pattern_name = pattern_analysis_5m.get('pattern_detected', '')
+            pattern_conf = pattern_analysis_5m.get('pattern_confidence', 0)
+            if pattern_name in ['Double Top', 'Downtrend', 'Breakout Down', 'Near Resistance'] and pattern_conf > 0.6:
+                reversal_score += 0.5
+
+            # (التحقق من المؤشرات السلبية)
+            rsi_5m = indicators_5m.get('rsi', 50)
+            macd_hist_5m = indicators_5m.get('macd_hist', 0)
+            
+            # (إشارة ضعف 1: RSI تحت 50 + MACD سلبي)
+            if rsi_5m < 45 and macd_hist_5m < 0:
+                reversal_score += 0.5
+            # (إشارة ضعف 2: تباعد هبوطي - RSI يفشل في تسجيل قمة جديدة)
+            elif rsi_5m < 60 and macd_hist_5m < 0:
+                 reversal_score += 0.3 # (إشارة ضعف متوسطة)
+
+            # --- 4. القرار ---
+            if reversal_score >= 0.8: # (يتطلب إشارتي ضعف قويتين)
+                return f"Tactical 5m Profit Save: Reversal signal detected (Score: {reversal_score})"
                 
             return None
             
         except Exception as e:
-            print(f"❌ [Sentry] خطأ في مراقب حماية الأرباح: {e}")
+            print(f"❌ [Sentry] خطأ في مراقب حماية الأرباح 5m: {e}")
             return None
     # 🔴 --- END OF CHANGE --- 🔴
 
@@ -765,11 +850,9 @@ class TradeManager:
                 await self.learning_hub.analyze_trade_and_learn(trade_to_close, reason)
             else: print("⚠️ [Sentry] LearningHub غير متاح، تم تخطي التعلم.")
             
-            # 🔴 --- START OF CHANGE (V6.9) --- 🔴
             if self.callback_on_close:
                 print("🔄 [Executor] Trade closed. Scheduling immediate Explorer cycle...")
                 asyncio.create_task(self.callback_on_close())
-            # 🔴 --- END OF CHANGE --- 🔴
             
             print(f"✅ [Executor] تم إغلاق الصفقة (الوهمية) {symbol} - السبب: {reason} - PnL: {pnl_percent:+.2f}%")
             return True
@@ -847,4 +930,4 @@ class TradeManager:
         except Exception as e: print(f"❌ Failed to get trade by symbol {symbol}: {e}"); return None
 
 
-print(f"✅ Trade Manager loaded - V6.9 (Active 1m Profit-Saver + Post-Close Cycle) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")
+print(f"✅ Trade Manager loaded - V7.0 (5m Detector Profit-Saver + Post-Close Cycle) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")