Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (Updated to V7.1 - 4-Factor Trigger & 5m Logger)
+# trade_manager.py (Updated to V7.2 - Fixed 5m Profit-Saver Logic)
 import asyncio
 import json
 import time
@@ -442,7 +442,7 @@ class TradeManager:
     
 
     async def _run_tactical_analysis_loop(self, symbol: str, strategy_hint: str):
-        """(محدث V7.1) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
+        """(محدث V7.2) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
         while self.is_running:
             await asyncio.sleep(1) 
             try:
@@ -459,19 +459,21 @@ class TradeManager:
                     
                     # 2. إذا لم يتم ضرب SL/TP، تحقق من "مراقب حماية الأرباح" 5m
                     if not exit_reason and tactical_data.new_5m_data_added:
-                        # 🔴 --- START OF CHANGE (V7.1) --- 🔴
-                        # (تعديل لاستقبال النتيجة والطباعة)
+                        # 🔴 --- START OF CHANGE (V7.2) --- 🔴
+                        # (تعديل لاستيعاب المنطق الجديد لحامي الأرباح)
                         analysis_result = await self._run_5m_profit_saver(trade, list(tactical_data.ohlcv_5m), tactical_data)
                         tactical_data.new_5m_data_added = False # (إعادة ضبط المؤشر)
                         
                         if analysis_result:
+                            decision = analysis_result.get("decision")
                             score = analysis_result.get("score", 0)
-                            threshold = analysis_result.get("threshold", 0.8)
-                            if analysis_result.get("decision") == "EXIT":
-                                exit_reason = f"Tactical 5m Profit Save: Reversal Score {score:.2f} >= {threshold}"
+                            reason = analysis_result.get("reason", "N/A")
+                            
+                            if decision == "EXIT":
+                                exit_reason = f"Tactical 5m Profit Save: {reason} (Score: {score:.2f})"
                             else:
-                                # (هذه هي الطباعة المطلوبة للشفافية)
-                                print(f"   [Sentry 5m] {symbol} (Profit-Saver): HOLD. Reversal Score: {score:.2f} (Threshold: {threshold})")
+                                # (طباعة تشخيصية أفضل)
+                                print(f"   [Sentry 5m] {symbol} (Profit-Saver): {decision}. {reason} (Score: {score:.2f})")
                         # 🔴 --- END OF CHANGE --- 🔴
                         
                     if exit_reason:
@@ -617,29 +619,31 @@ class TradeManager:
         except Exception:
             return pd.DataFrame()
 
-    # 🔴 --- START OF CHANGE (V7.1) --- 🔴
+    # 🔴 --- START OF CHANGE (V7.2 - Logic Fix) --- 🔴
     async def _run_5m_profit_saver(self, trade: Dict, ohlcv_5m_list: List, tactical_data: TacticalData) -> Dict:
         """
-        (محدث V7.1) "مراقب الانعكاس" 5m.
-        يُرجع قاموساً بالنتيجة والقرار.
+        (محدث V7.2) "مراقب الانعكاس" 5m.
+        - يحسب درجة الخطر دائماً.
+        - يستخدم نظام تسجيل مرن وموزون.
+        - لا يخرج إلا إذا كان الخطر مرتفعاً *و* الصفقة رابحة.
         """
-        reversal_threshold = 0.8 # (عتبة الخروج)
+        reversal_threshold = 0.70 # (عتبة خروج مرنة للنظام الموزون)
         
         try:
-            # --- 1. التحقق من الربحية (كما طلبت) ---
+            # --- 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 {"decision": "HOLD", "score": 0.0, "threshold": reversal_threshold, "reason": "Trade not profitable"}
+            is_profitable = best_bid_price > entry_price
 
-            # --- 2. الصفقة رابحة، تشغيل الكاشف 5m ---
-            if len(ohlcv_5m_list) < 20:
+            # --- 2. تشغيل الكاشف 5m (يجب أن يعمل دائماً لحساب الخطر) ---
+            # (يتطلب 26 شمعة على الأقل لـ MACD)
+            if len(ohlcv_5m_list) < 26:
                 return None # بيانات غير كافية للتحليل
                 
             df_5m = self._create_dataframe_5m(ohlcv_5m_list)
@@ -649,32 +653,70 @@ class TradeManager:
             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
+            # --- 3. حساب درجة الانعكاس (Reversal Score) - نظام مرن وموزون ---
+            
+            # الأوزان
+            weights = {
+                'pattern': 0.40,
+                'rsi': 0.30,
+                'macd': 0.30
+            }
             
+            # الدرجة 1: الأنماط (Patterns)
+            pattern_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
-
+            # (الأنماط السلبية فقط تساهم في خطر الانعكاس)
+            if pattern_name in ['Double Top', 'Downtrend', 'Breakout Down', 'Near Resistance'] and pattern_conf > 0.5:
+                pattern_score = pattern_conf # (استخدام الثقة مباشرة كدرجة)
+            
+            # الدرجة 2: مؤشر القوة النسبية (RSI) - درجة متدرجة
+            rsi_score = 0.0
             rsi_5m = indicators_5m.get('rsi', 50)
+            if rsi_5m < 50:
+                # (كلما انخفض تحت 50، زادت درجة الخطر، تصل إلى 1.0 عند 30 أو أقل)
+                # (النطاق: 50 -> 30)
+                rsi_score = min(1.0, (50 - rsi_5m) / 20.0)
+            
+            # الدرجة 3: الماكد (MACD) - درجة متدرجة
+            macd_score = 0.0
             macd_hist_5m = indicators_5m.get('macd_hist', 0)
+            if macd_hist_5m < 0:
+                # (نحتاج إلى "تطبيع" قيمة الهيستوجرام. سنستخدم نسبة مئوية من السعر)
+                current_price = df_5m['close'].iloc[-1]
+                if current_price > 0:
+                    normalized_macd_hist = abs(macd_hist_5m) / current_price
+                    # (تقدير: إذا كان الهيستوجرام سلبي بنسبة 0.1% من السعر، فهذا خطر 100%)
+                    # (النطاق: 0 -> 0.001)
+                    macd_score = min(1.0, normalized_macd_hist / 0.001)
+
+            # الحساب النهائي للدرجة
+            reversal_score = (
+                (pattern_score * weights['pattern']) +
+                (rsi_score * weights['rsi']) +
+                (macd_score * weights['macd'])
+            )
             
-            if rsi_5m < 45 and macd_hist_5m < 0:
-                reversal_score += 0.5
-            elif rsi_5m < 60 and macd_hist_5m < 0:
-                 reversal_score += 0.3
-
-            # --- 4. القرار ---
+            # --- 4. القرار (المنطق الجديد) ---
+            
+            # (التحقق من زناد الخروج)
             if reversal_score >= reversal_threshold:
-                return {"decision": "EXIT", "score": reversal_score, "threshold": reversal_threshold, "reason": "Reversal signal detected"}
+                # (الخطر مرتفع. هل الصفقة رابحة؟)
+                if is_profitable:
+                    # (نعم، الخطر مرتفع والصفقة رابحة -> اخرج!)
+                    return {"decision": "EXIT", "score": reversal_score, "threshold": reversal_threshold, "reason": "Reversal signal detected and trade is profitable"}
+                else:
+                    # (الخطر مرتفع، لكن الصفقة خاسرة/متعادلة -> لا تخرج، فقط سجل)
+                    return {"decision": "HOLD", "score": reversal_score, "threshold": reversal_threshold, "reason": "Reversal signal detected, but trade is not profitable"}
             else:
-                return {"decision": "HOLD", "score": reversal_score, "threshold": reversal_threshold, "reason": "Trend intact"}
+                # (الخطر منخفض -> لا تخرج)
+                return {"decision": "HOLD", "score": reversal_score, "threshold": reversal_threshold, "reason": "Trend intact / Reversal score low"}
             
         except Exception as e:
             print(f"❌ [Sentry] خطأ في مراقب حماية الأرباح 5m: {e}")
-            return None
-    # 🔴 --- END OF CHANGE --- 🔴
+            # (إرجاع نتيجة آمنة)
+            return {"decision": "HOLD", "score": 0.0, "threshold": reversal_threshold, "reason": f"Error in 5m analysis: {e}"}
+    # 🔴 --- END OF CHANGE (V7.2) --- 🔴
 
 
     async def _execute_smart_entry(self, symbol: str, strategy_hint: str, tactical_data: Dict, explorer_context: Dict):
@@ -939,4 +981,4 @@ class TradeManager:
         except Exception as e: print(f"❌ Failed to get trade by symbol {symbol}: {e}"); return None
 
 
-print(f"✅ Trade Manager loaded - V7.1 (4-Factor Trigger + 5m Profit-Saver Logger) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")
+print(f"✅ Trade Manager loaded - V7.2 (Fixed 5m Profit-Saver Logic) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")