Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (V15.5 - GEM-Architect Fix: Strict Singleton Locking)
+# trade_manager.py (V15.6 - GEM-Architect Fix: Precision Logging)
 import asyncio
 import json
 import uuid
@@ -22,7 +22,7 @@ class TradeManager:
         
         self.execution_lock = asyncio.Lock()
         
-        print(f"🛡️ [TradeManager V15.5] Sentry Module Initialized (Strict Single Trade).")
+        print(f"🛡️ [TradeManager V15.6] Sentry Module Initialized (Precision Logs).")
         if self.guard:
             print(f"   -> Guard V2 (Exit Protector) CREATED.")
         else:
@@ -39,7 +39,6 @@ class TradeManager:
     async def sync_internal_state_with_r2(self):
         try:
             open_trades_list = await self.r2.get_open_trades_async()
-            # تحويل القائمة إلى قاموس مع تنظيف البيانات
             self.open_positions = {trade['symbol']: trade for trade in open_trades_list}
             print(f"   -> [Sync] تم استعادة {len(self.open_positions)} صفقة مفتوحة من R2.")
         except Exception as e:
@@ -50,13 +49,6 @@ class TradeManager:
     # 🎯 دالة الفرز والتنفيذ
     # ==============================================================================
     async def select_and_execute_best_signal(self, oracle_approved_signals: List[Dict[str, Any]]):
-        """
-        1. يفحص جميع الإشارات المعتمدة من العقل باستخدام القناص.
-        2. يفرزها وينفذ الأفضل.
-        3. يتحقق من عدم وجود صفقات مفتوحة قبل البدء.
-        """
-        
-        # [GEM-FIX] تحقق سريع قبل بدء معالجة القناص
         if len(self.open_positions) > 0:
              print(f"⛔ [TradeManager] تم إلغاء الفرز. توجد صفقة مفتوحة بالفعل.")
              return
@@ -119,7 +111,6 @@ class TradeManager:
                 print(f"       -> (خسرت أمامها: {i+2}. {loser['symbol']} (Sniper: {loser['sniper_confidence']:.2f}, L2: {loser['final_total_score']:.2f}))")
 
         async with self.execution_lock:
-            # [GEM-FIX] تحقق مزدوج داخل القفل
             if len(self.open_positions) > 0:
                 print(f"⛔ [TradeManager] تم إلغاء التنفيذ في اللحظة الأخيرة. توجد صفقة مفتوحة.")
                 return
@@ -131,22 +122,14 @@ class TradeManager:
             await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
     async def _handle_new_signal(self, symbol, signal_data):
-        """
-        (Legacy) معالج الإشارات القديم.
-        """
         print(f"⚠️ [TradeManager] _handle_new_signal (Legacy) called for {symbol}. Redirecting to Batch Select Logic...")
         await self.select_and_execute_best_signal([signal_data])
 
     # ==============================================================================
-    # 🎯 تنفيذ الدخول (المعدل)
+    # 🎯 تنفيذ الدخول (المعدل لدقة الأرقام)
     # ==============================================================================
     async def _execute_entry_from_signal(self, symbol, signal_data):
-        """
-        تنفيذ عملية الدخول (وهمي حالياً) مع قفل صارم.
-        """
-        # ملاحظة: يجب استدعاء هذه الدالة داخل execution_lock من الدالة الأم، ولكن للسلامة نتحقق هنا أيضاً
         try:
-            # [GEM-FIX] قفل صارم جداً
             if len(self.open_positions) > 0:
                 print(f"⛔ [Entry BLOCKED] لا يمكن فتح {symbol}، توجد صفقة مفتوحة بالفعل.")
                 return
@@ -154,9 +137,7 @@ class TradeManager:
             trade_id = str(uuid.uuid4())
             current_price = float(signal_data.get('current_price', 0.0))
             
-            # [GEM-FIX] معالجة السعر الصفري
             if current_price <= 0.0:
-                 # محاولة طارئة
                  current_price = await self.data_manager.get_latest_price_async(symbol)
                  if current_price <= 0.0:
                     print(f"⚠️ [Entry ERROR] {symbol} السعر 0، لا يمكن التنفيذ.")
@@ -175,7 +156,6 @@ class TradeManager:
                 tp_price = current_price + (atr_mock * 2.0)
                 sl_price = current_price - (atr_mock * 1.0)
             
-            # [GEM-FIX] ضمان أن القيم Float
             tp_price = float(tp_price)
             sl_price = float(sl_price)
 
@@ -201,23 +181,21 @@ class TradeManager:
                 'l3_oracle_sl': float(signal_data.get('sl_price', 0.0) or 0.0),
             }
             
-            # 1. تحديث الحالة الداخلية
             self.open_positions[symbol] = new_trade
             
             if self.watchlist:
-                print(f"   -> [Watchlist] مسح {len(self.watchlist)} عنصر من قائمة المراقبة (للتركيز على الصفقة الجديدة).")
+                print(f"   -> [Watchlist] مسح {len(self.watchlist)} عنصر من قائمة المراقبة.")
                 self.watchlist.clear()
             
-            # 2. حفظ في R2
             await self.r2.save_open_trades_async(list(self.open_positions.values()))
             
-            # 3. بدء حارس الخروج
             if symbol in self.sentry_tasks:
                 self.sentry_tasks[symbol].cancel()
             
             self.sentry_tasks[symbol] = asyncio.create_task(self._guardian_loop(symbol))
             
-            print(f"✅ [ENTRY EXECUTED] {symbol} | Price: {current_price:.4f} | TP: {tp_price:.4f} | SL: {sl_price:.4f}")
+            # [GEM-FIX] استخدام تنسيق 8 خانات في السجلات
+            print(f"✅ [ENTRY EXECUTED] {symbol} | Price: {current_price:.8f} | TP: {tp_price:.8f} | SL: {sl_price:.8f}")
             print(f"   -> L2 Score: {new_trade['l1_score']:.2f}, L4 Conf: {new_trade['l2_sniper_confidence']:.2f}")
 
         except Exception as e:
@@ -291,13 +269,13 @@ class TradeManager:
                     continue 
 
                 if current_price >= trade['tp_price']:
-                    print(f"✅ [Sentry EXIT] {symbol} (TP Hit) at {current_price}")
+                    print(f"✅ [Sentry EXIT] {symbol} (TP Hit) at {current_price:.8f}")
                     async with self.execution_lock:
                         await self._execute_exit(symbol, current_price, "TP_HIT")
                     break 
 
                 if current_price <= trade['sl_price']:
-                    print(f"🛑 [Sentry EXIT] {symbol} (SL Hit) at {current_price}")
+                    print(f"🛑 [Sentry EXIT] {symbol} (SL Hit) at {current_price:.8f}")
                     async with self.execution_lock:
                         await self._execute_exit(symbol, current_price, "SL_HIT")
                     break 
@@ -352,9 +330,6 @@ class TradeManager:
             profit = (price - trade['entry_price']) / trade['entry_price']
             trade['profit_pct'] = profit * 100
             
-            # await self.r2.archive_closed_trade_async(trade)
-            print("   -> [Info] تم تخطي archive_closed_trade_async (غير موجودة في r2.py)")
-            
             await self.r2.save_open_trades_async(list(self.open_positions.values()))
             
             print(f"✅ [EXIT EXECUTED] {symbol} | Reason: {reason} | PnL: {trade['profit_pct']:.2f}%")
@@ -381,19 +356,17 @@ class TradeManager:
             self.open_positions[symbol] = trade
             await self.r2.save_open_trades_async(list(self.open_positions.values()))
             
-            print(f"🎯 [Targets Updated] {symbol} | TP: {old_tp:.4f}->{trade['tp_price']:.4f} | SL: {old_sl:.4f}->{trade['sl_price']:.4f} | Reason: {reason}")
+            print(f"🎯 [Targets Updated] {symbol} | TP: {old_tp:.8f}->{trade['tp_price']:.8f} | SL: {old_sl:.8f}->{trade['sl_price']:.8f} | Reason: {reason}")
         else:
             print(f"⚠️ [Target Update Failed] {symbol} is not currently open.")
 
     async def start_sentry_loops(self):
-        """بدء أو استئناف جميع مهام الحراسة"""
         for symbol in list(self.open_positions.keys()):
              if symbol not in self.sentry_tasks or self.sentry_tasks[symbol].done():
                  print(f"🛡️ [Sentry Restart] Activating guardian for existing trade: {symbol}")
                  self.sentry_tasks[symbol] = asyncio.create_task(self._guardian_loop(symbol))
 
     async def stop_sentry_loops(self):
-        """إيقاف نظيف لجميع المهام الخلفية"""
         print("🛑 [TradeManager] Stopping all sentry loops...")
         self.running = False
         for sym, task in self.sentry_tasks.items():