Update trade_manager.py

trade_manager.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V37.0 - GEM-Architect: Governance Integrated)
+# 🛡️ trade_manager.py (V37.1 - GEM-Architect: Governance Data Loop)
 # ============================================================
 
 import asyncio
@@ -12,7 +12,7 @@ from typing import List, Dict, Any
 # استيراد المكونات الأساسية
 from smart_portfolio import SmartPortfolio
 from ml_engine.processor import SystemLimits 
-# ✅ استيراد محرك الحوكمة الجديد (مجلس الشيوخ)
+# ✅ استيراد محرك الحوكمة الجديد
 from governance_engine import GovernanceEngine
 
 class TradeManager:
@@ -45,7 +45,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V37.0] Full System Online (Governance Layer Active).")
+        print(f"🛡️ [TradeManager V37.1] Full System Online (Governance Learning Loop Active).")
 
     async def initialize_sentry_exchanges(self):
         """تهيئة المحفظة واستعادة الحالة"""
@@ -112,7 +112,7 @@ class TradeManager:
                 print(f"   -> ⚠️ [Skip] {symbol}: Insufficient 1m data.")
                 continue
             
-            # فحص Sniper (يستخدم الآن الإعدادات المحقونة في Processor)
+            # فحص Sniper
             sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book)
             sniper_signal = sniper_result.get('signal', 'WAIT')
             final_conf = sniper_result.get('confidence_prob', 0.0)
@@ -147,7 +147,6 @@ class TradeManager:
         """تنفيذ الدخول الفعلي مع فحص الحوكمة وإدارة المحفظة"""
         try:
             # 🏛️ الخطوة 1: استشارة مجلس الحوكمة (Governance Layer)
-            # نحتاج إلى تجميع البيانات المطلوبة للحوكمة (خاصة فريم 15 دقيقة)
             print(f"   🏛️ [Governance] Convening Senate for {symbol}...")
             
             t15_task = self.data_manager.get_latest_ohlcv(symbol, '15m', 200)
@@ -167,12 +166,12 @@ class TradeManager:
 
             print(f"   ✅ [Governance PASS] Grade: {gov_decision['grade']} | Score: {gov_decision['governance_score']:.1f}")
             
-            # دمج نتائج الحوكمة في بيانات الإشارة لتراها المحفظة
+            # دمج نتائج الحوكمة في بيانات الإشارة
             signal_data['governance_grade'] = gov_decision['grade']
             signal_data['governance_score'] = gov_decision['governance_score']
             signal_data['governance_details'] = gov_decision['components']
 
-            # 💰 الخطوة 2: طلب الموافقة من المحفظة الذكية (تستخدم الـ Grade لتحديد الحجم)
+            # 💰 الخطوة 2: طلب الموافقة من المحفظة الذكية
             is_approved, plan = await self.smart_portfolio.request_entry_approval(signal_data, len(self.open_positions))
             
             if not is_approved:
@@ -196,6 +195,7 @@ class TradeManager:
                 'oracle_conf': signal_data.get('confidence', 0),
                 'governance_grade': gov_decision['grade'], # تسجيل الجودة
                 'governance_score': gov_decision['governance_score'],
+                'governance_details': gov_decision['components'], # تفاصيل الـ 156 مؤشر (مختصرة في المجالات)
                 'system_confidence': system_conf,
                 'market_mood': market_mood,
                 'regime_at_entry': getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN')
@@ -213,13 +213,8 @@ class TradeManager:
                 'last_update': datetime.now().isoformat(), 
                 'last_oracle_check': datetime.now().isoformat(),
                 'strategy': 'OracleV4_Governance_Hydra',
-                'initial_oracle_strength': float(signal_data.get('strength', 0.5)),
-                'initial_oracle_class': signal_data.get('target_class', 'TP2'),
-                'oracle_tp_map': signal_data.get('tp_map', {}),
                 'entry_capital': approved_size_usd, 
                 'entry_fee_usd': entry_fee_usd,
-                'l1_score': float(signal_data.get('enhanced_final_score', 0.0)),
-                'target_class_int': 3,
                 'decision_data': decision_snapshot, 
                 'highest_price': current_price
             }
@@ -303,7 +298,7 @@ class TradeManager:
                             'volume_30m_usd': vol_30m_sum
                         }
 
-                        # ✅ استدعاء الحراس (يستخدمون SystemLimits المحدثة ديناميكياً)
+                        # ✅ استدعاء الحراس
                         decision = self.processor.consult_dual_guardians(symbol, d1, d5, d15, context_data, order_book_snapshot=d_ob)
                         action = decision.get('action', 'HOLD')
                         reason = decision.get('reason', '')
@@ -322,7 +317,7 @@ class TradeManager:
                     last_ai_check_time = time.time()
                     self.open_positions[symbol]['last_update'] = datetime.now().isoformat()
                 
-                # 3. إعادة فحص Oracle (كل 15 دقيقة)
+                # 3. إعادة فحص Oracle
                 last_oracle = datetime.fromisoformat(trade.get('last_oracle_check', datetime.now().isoformat()))
                 if (datetime.now() - last_oracle).total_seconds() > self.ORACLE_CHECK_INTERVAL:
                     self.open_positions[symbol]['last_oracle_check'] = datetime.now().isoformat()
@@ -351,7 +346,6 @@ class TradeManager:
                     await self.r2.save_open_trades_async(list(self.open_positions.values()))
 
     async def _consult_oracle_strategy_update(self, symbol, trade):
-        """إعادة استشارة Oracle أثناء الصفقة"""
         try:
             tasks = [self.data_manager.get_latest_ohlcv(symbol, tf, limit=100) for tf in ["15m", "1h", "4h"]]
             results = await asyncio.gather(*tasks)
@@ -367,13 +361,6 @@ class TradeManager:
                 print(f"🚨 [Oracle] Outlook Bearish. Exiting {symbol}...")
                 await self.force_exit_by_manager(symbol, reason="Oracle_Bearish_Flip")
                 return
-
-            if oracle.get('strength', 0.5) < (trade.get('initial_oracle_strength', 0.5) * 0.6):
-                tp_map = trade.get('oracle_tp_map', {})
-                cons_tp = tp_map.get('TP1')
-                if cons_tp and cons_tp > curr_p and cons_tp < trade['tp_price']:
-                    print(f"⚠️ [Oracle] Weakening. Lowering TP to {cons_tp}")
-                    self.open_positions[symbol]['tp_price'] = cons_tp
         except Exception: pass
 
     def _launch_post_exit_analysis(self, symbol, exit_price, exit_time, position_size_usd, ai_scores=None, trade_obj=None):
@@ -398,10 +385,6 @@ class TradeManager:
             is_good_exit = change_pct < 0 
             
             self._update_specific_stat("hybrid", is_good_exit, usd_impact)
-            if ai_scores:
-                if ai_scores.get('crash', 0) >= 0.60: self._update_specific_stat("crash", is_good_exit, usd_impact)
-                if ai_scores.get('giveback', 0) >= 0.70: self._update_specific_stat("giveback", is_good_exit, usd_impact)
-                if ai_scores.get('stagnation', 0) >= 0.50: self._update_specific_stat("stagnation", is_good_exit, usd_impact)
             
             record = {"symbol": symbol, "exit_price": exit_price, "price_15m": curr, "usd_impact": usd_impact, "verdict": "SUCCESS" if is_good_exit else "MISS"}
             await self.r2.append_deep_steward_audit(record)
@@ -415,7 +398,7 @@ class TradeManager:
             entry_price = float(trade['entry_price']); exit_price = float(price)
             entry_capital = float(trade.get('entry_capital', 100.0)); entry_fee = float(trade.get('entry_fee_usd', 0.0))
             
-            # Gross & Net Calculation
+            # حساب الأرباح
             exit_val_gross = (exit_price / entry_price) * entry_capital
             exit_fee = exit_val_gross * self.FEE_RATE
             total_fees = entry_fee + exit_fee
@@ -424,7 +407,7 @@ class TradeManager:
             true_net_pnl_usd = gross_pnl_usd - total_fees
             true_net_pct = (true_net_pnl_usd / entry_capital) * 100
             
-            # Update Portfolio with Net PnL
+            # تحديث المحفظة
             await self.smart_portfolio.register_closed_position(entry_capital, gross_pnl_usd, total_fees)
             
             trade.update({
@@ -451,16 +434,37 @@ class TradeManager:
             
             print(f"✅ [EXIT] {symbol} | Net PnL: {true_net_pct:.2f}% (${true_net_pnl_usd:.2f}) | {reason}")
             
-            self._launch_post_exit_analysis(symbol, exit_price, trade.get('exit_time'), entry_capital, ai_scores, trade)
-            
+            # ==========================================================
+            # 🏛️ إرسال البيانات لملف تدريب الحوكمة (Governance Training Data)
+            # ==========================================================
+            try:
+                decision_data = trade.get('decision_data', {})
+                if 'governance_grade' in decision_data:
+                    training_record = {
+                        "symbol": symbol,
+                        "entry_time": trade['entry_time'],
+                        "exit_time": trade['exit_time'],
+                        "governance_grade": decision_data['governance_grade'],
+                        "governance_score": decision_data.get('governance_score', 0),
+                        "governance_components": decision_data.get('governance_details', {}), # تفاصيل الـ 156 مؤشر
+                        "entry_price": trade['entry_price'],
+                        "exit_price": trade['exit_price'],
+                        "profit_pct": true_net_pct,
+                        "result": trade['result']
+                    }
+                    # إرسال إلى R2 في الخلفية
+                    asyncio.create_task(self.r2.append_governance_training_data(training_record))
+            except Exception as ge:
+                print(f"⚠️ [Learning Error] Failed to save governance training data: {ge}")
+
             # ==========================================================
             # 🧠 THE TACTICAL LEARNING LINK
             # ==========================================================
             if self.learning_hub:
-                print(f"🎓 [Learning] Reporting trade outcome to AdaptiveHub...")
                 asyncio.create_task(self.learning_hub.register_trade_outcome(trade))
-            # ==========================================================
 
+            self._launch_post_exit_analysis(symbol, exit_price, trade.get('exit_time'), entry_capital, ai_scores, trade)
+            
             self.latest_guardian_log = f"✅ Closed {symbol} ({reason})"
             if symbol in self.sentry_tasks: self.sentry_tasks[symbol].cancel(); del self.sentry_tasks[symbol]