Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (V19.8 - GEM-Architect: Deep Steward V2 + USD Audit)
+# trade_manager.py (V20.0 - GEM-Architect: Final Production - V2/USD/Timers)
 import asyncio
 import json
 import uuid
@@ -13,12 +13,12 @@ class TradeManager:
         self.titan = titan_engine
         self.pattern_engine = pattern_engine
         
-        # ⚠️ GuardEngine (Old V2) - مرجع فقط، معطل في الحلقة
+        # ⚠️ GuardEngine (Old V1) - معطل تماماً وتم استبداله بـ V2
         self.guard = guard_engine 
         
         self.sniper = sniper_engine 
         
-        # [NEW] DeepSteward V2 - The Multi-Scale Boss
+        # [ 🧠 ] DeepSteward V2 - The Multi-Scale Boss
         self.deep_steward = deep_steward
         
         self.open_positions = {}
@@ -26,29 +26,26 @@ class TradeManager:
         self.sentry_tasks = {}
         self.running = True
         
-        # [NEW] إحصائيات DeepSteward الحية للوحة التحكم (مع الدولار)
+        # [ 🧠 IQ Stats ] إحصائيات الذكاء الاصطناعي (مع الدولار)
         self.ds_stats = {
             "total_exits": 0,
             "good_exits": 0,   # السعر هبط بعد الخروج (حمانا)
             "bad_exits": 0,    # السعر صعد بعد الخروج (فوتنا ربح)
             "saved_loss_cum": 0.0,      # مجموع نسبة الخسائر التي تجنبناها
             "missed_profit_cum": 0.0,   # مجموع نسبة الأرباح التي فوتناها
-            "saved_loss_usd_cum": 0.0,  # [NEW] مجموع الدولارات التي حمانا منها
-            "missed_profit_usd_cum": 0.0 # [NEW] مجموع الدولارات الضائعة
+            "saved_loss_usd_cum": 0.0,  # مجموع الدولارات التي حمانا منها
+            "missed_profit_usd_cum": 0.0 # مجموع الدولارات الضائعة
         }
         
         self.execution_lock = asyncio.Lock()
         
-        print(f"🛡️ [TradeManager V19.8] Initialized. Guardian Interval: 1 Minute (V2 Speed).")
+        print(f"🛡️ [TradeManager V20.0] Initialized. Guardian Interval: 1 Minute (V2 Speed).")
         
         if self.deep_steward:
             print(f"   -> 🧠 DeepSteward V2 (Multi-Scale) ACTIVE. Taking full control.")
         else:
             print(f"   -> ⚠️ DeepSteward NOT AVAILABLE. Reverting to basic limits.")
 
-        if self.sniper:
-            print(f"   -> 🎯 Sniper V3 (Entry Sniper) CREATED.")
-        
     async def initialize_sentry_exchanges(self):
         print("🛡️ [TradeManager] Initializing and syncing state with R2...")
         await self.sync_internal_state_with_r2()
@@ -138,10 +135,6 @@ class TradeManager:
             
             await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
-    async def _handle_new_signal(self, symbol, signal_data):
-        print(f"⚠️ [TradeManager] _handle_new_signal (Legacy) called for {symbol}. Redirecting to Batch Select Logic...")
-        await self.select_and_execute_best_signal([signal_data])
-
     # ==============================================================================
     # 🎯 تنفيذ الدخول (Entry Execution)
     # ==============================================================================
@@ -204,6 +197,16 @@ class TradeManager:
                 print(f"   -> [Watchlist] مسح {len(self.watchlist)} عنصر من قائمة المراقبة.")
                 self.watchlist.clear()
             
+            # ============================================================
+            # 🕒 [جديد] تسجيل وقت أول صفقة في تاريخ النظام (للعداد)
+            # ============================================================
+            portfolio = await self.r2.get_portfolio_state_async()
+            if portfolio.get('first_trade_timestamp') is None:
+                portfolio['first_trade_timestamp'] = new_trade['entry_time']
+                await self.r2.save_portfolio_state_async(portfolio)
+                print(f"🕒 [System Info] تم تسجيل توقيت أول صفقة في النظام: {new_trade['entry_time']}")
+            # ============================================================
+
             await self.r2.save_open_trades_async(list(self.open_positions.values()))
             
             if symbol in self.sentry_tasks:
@@ -266,14 +269,14 @@ class TradeManager:
             await self.select_and_execute_best_signal(signals_from_watchlist)
 
     # ==============================================================================
-    # 🛡️ دوال حارس الخروج (Sentry & Guard) - [معدل: كل 1 دقيقة لنموذج V2]
+    # 🛡️ دوال حارس الخروج (Sentry & Guard) - [V2: كل 1 دقيقة]
     # ==============================================================================
     async def _guardian_loop(self, symbol: str):
         print(f"🛡️ [Sentry Activated] بدء الحراسة لـ {symbol} (فحص كل 60 ثانية).")
         
         while self.running and symbol in self.open_positions:
             try:
-                # 🚀 1. الانتظار لمدة 60 ثانية (V2 يستطيع العمل بدقة دقيقة)
+                # 🚀 1. الانتظار لمدة 60 ثانية (V2 يعمل بدقة دقيقة)
                 await asyncio.sleep(60) 
                 
                 trade = self.open_positions.get(symbol)
@@ -295,12 +298,12 @@ class TradeManager:
                         await self._execute_exit(symbol, current_price, "SL_HIT_HARD")
                     break 
 
-                # 🚀 3. [NEW] DeepSteward V2 (Multi-Scale Logic)
+                # 🚀 3. [ 🧠 ] DeepSteward V2 (Multi-Scale Logic)
                 # النموذج الجديد يحتاج لثلاثة أطر زمنية: 1m, 5m, 15m
                 
                 if self.deep_steward and self.deep_steward.initialized:
                     # جلب البيانات بشكل متوازي
-                    task1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 120) # احتياطي لضمان الـ Lag
+                    task1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 120) # احتياطي للـ Lags
                     task5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 100)
                     task15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 50)
                     
@@ -310,16 +313,13 @@ class TradeManager:
                     if d1 and d5 and d15 and len(d1) >= 60 and len(d5) >= 30 and len(d15) >= 20:
                         decision = self.deep_steward.analyze(d1, d5, d15)
                         
-                        # سجل نبض خفيف
-                        # print(f"🧠 [DeepSteward V2] {symbol} | Action: {decision['action']} | Conf: {decision['confidence']:.1%}")
-                        
                         if decision['action'] == 'EXIT':
                             print(f"🤖 [DeepSteward V2] 🚨 أمر خروج طارئ لـ {symbol}! ({decision['reason']})")
                             async with self.execution_lock:
                                 await self._execute_exit(symbol, current_price, "DEEP_STEWARD_V2_EXIT")
                             break
                     else:
-                        print(f"⚠️ [Sentry] بيانات V2 غير مكتملة لـ {symbol}.")
+                        print(f"⚠️ [Sentry] بيانات V2 غير مكتملة لـ {symbol}. تخطي الدورة.")
                 else:
                     pass # لا يوجد نموذج فعال
 
@@ -333,10 +333,10 @@ class TradeManager:
                 await asyncio.sleep(10) 
 
     # ==============================================================================
-    # 👻 المراقب الشبحي (Ghost Monitor) - Post-Exit Analysis
+    # 👻 المراقب الشبحي (Ghost Monitor) - Post-Exit Analysis (USD Version)
     # ==============================================================================
     def _launch_post_exit_analysis(self, symbol, exit_price, exit_time, position_size_usd):
-        """يطلق مهمة خلفية لمراقبة السعر بعد الخروج"""
+        """يطلق مهمة خلفية لمراقبة السعر بعد الخروج وحساب الأثر بالدولار"""
         asyncio.create_task(self._analyze_after_exit_task(symbol, exit_price, exit_time, position_size_usd))
 
     async def _analyze_after_exit_task(self, symbol, exit_price, exit_time, position_size_usd):
@@ -350,11 +350,10 @@ class TradeManager:
             # حساب الفرق: (السعر الحالي - سعر الخروج) / سعر الخروج
             change_pct = (current_price - exit_price) / exit_price
             
-            # حساب الأثر بالدولار
+            # 💰 حساب الأثر بالدولار
             usd_impact = change_pct * position_size_usd
             
-            # تصنيف القرار
-            # إذا هبط السعر (change_pct < 0) -> قرار جيد (حمانا)
+            # تصنيف القرار: إذا هبط السعر (change_pct < 0) -> قرار جيد (حمانا)
             is_good_exit = change_pct < 0 
             
             # تحديث الإحصائيات الحية (للوحة التحكم)
@@ -381,7 +380,7 @@ class TradeManager:
             }
             
             await self.r2.append_deep_steward_audit(audit_record)
-            print(f"👻 [Ghost Monitor] {symbol}: بعد ساعة {change_pct*100:+.2f}% | الحكم: {audit_record['verdict']}")
+            print(f"👻 [Ghost Monitor] {symbol}: بعد ساعة {change_pct*100:+.2f}% (${usd_impact:+.2f}) | الحكم: {audit_record['verdict']}")
 
         except Exception as e:
             print(f"⚠️ [Ghost Error] فشل تحليل ما بعد الخروج لـ {symbol}: {e}")
@@ -414,6 +413,7 @@ class TradeManager:
 
             # 4. 💰 [المحاسبة] تحديث المحفظة وحساب PnL بالدولار
             portfolio = await self.r2.get_portfolio_state_async()
+            # رأس المال قبل هذه الصفقة هو حجم الصفقة تقريباً
             current_capital = float(portfolio.get('current_capital_usd', 100.0))
             
             # حساب الربح بالدولار
@@ -447,9 +447,9 @@ class TradeManager:
             
             print(f"✅ [EXIT EXECUTED] {symbol} | Reason: {reason} | PnL: {profit_pct_display:.2f}% (${pnl_usd:.2f}) | New Cap: ${new_capital:.2f}")
 
-            # 6. [NEW] إطلاق المراقب الشبحي (Ghost Monitor) مع تمرير حجم الصفقة
+            # 6. [ 🧠 ] إطلاق المراقب الشبحي إذا كان الخروج بسبب الوصي
             if "DEEP_STEWARD" in reason:
-                # هنا نعتبر current_capital (رأس المال قبل الربح/الخسارة) هو حجم الصفقة
+                # نمرر حجم الصفقة (current_capital) لحساب الأثر بالدولار
                 self._launch_post_exit_analysis(symbol, exit_price, trade['exit_time'], current_capital)
 
             # 7. تنظيف مهام الحارس