Update trade_manger.py

trade_manger.py

@@ -1,4 +1,5 @@
 import asyncio
+import json
 from datetime import datetime, timedelta
 from helpers import safe_float_conversion, _apply_patience_logic
 
@@ -11,13 +12,11 @@ class TradeManager:
         self.is_running = False
 
     async def open_trade(self, symbol, decision, current_price):
-        """فتح صفقة جديدة باستخدام رأس المال المتاح بالكامل"""
         try:
             portfolio_state = await self.r2_service.get_portfolio_state_async()
             available_capital = portfolio_state.get("current_capital_usd", 0)
 
             if available_capital < 1:
-                print(f"❌ رأس مال غير كافٍ (${available_capital:.2f}) لفتح صفقة جديدة.")
                 return None
 
             expected_target_minutes = decision.get('expected_target_minutes', 15)
@@ -27,7 +26,6 @@ class TradeManager:
             strategy = decision.get('strategy')
             if not strategy or strategy == 'unknown':
                 strategy = 'GENERIC'
-                print(f"⚠️ الاستراتيجية مفقودة أو غير معروفة. تعيين إلى GENERIC لـ {symbol}")
 
             trades = await self.r2_service.get_open_trades_async()
             new_trade = {
@@ -50,12 +48,6 @@ class TradeManager:
             trades.append(new_trade)
             await self.r2_service.save_open_trades_async(trades)
             
-            original_expected = decision.get('expected_target_minutes', 15)
-            if original_expected > 45:
-                print(f"⚠️ النموذج طلب {original_expected} دقيقة، تم التحديد إلى 45 دقيقة لتناسق الاستراتيجية")
-                
-            print(f"✅ صفقة جديدة لـ {symbol} محفوظة بحجم ${available_capital:.2f}. الاستراتيجية: {strategy}. النتائج المتوقعة في {expected_target_minutes} دقيقة.")
-
             portfolio_state["invested_capital_usd"] = available_capital
             portfolio_state["current_capital_usd"] = 0.0
             portfolio_state["total_trades"] = portfolio_state.get("total_trades", 0) + 1
@@ -73,11 +65,9 @@ class TradeManager:
             return new_trade
 
         except Exception as e:
-            print(f"❌ فشل فتح صفقة جديدة: {e}")
             raise
 
     async def close_trade(self, trade_to_close, close_price, reason="إغلاق بالنظام"):
-        """إغلاق صفقة وتحديث المحفظة وتحليل النتيجة"""
         try:
             trade_to_close['status'] = 'CLOSED'
             trade_to_close['close_price'] = close_price
@@ -100,17 +90,10 @@ class TradeManager:
                     elif trade_type == 'SHORT':
                         pnl_percent = ((entry_price - close_price) / entry_price) * 100
                         pnl = position_size * (pnl_percent / 100)
-                    
-                    print(f"💰 حساب PnL: الدخول=${entry_price:.6f}, الخروج=${close_price:.6f}, "
-                          f"الحجم=${position_size:.2f}, النوع={trade_type}, "
-                          f"PnL=${pnl:.4f} ({pnl_percent:+.4f}%)")
                           
                 except (TypeError, ZeroDivisionError) as calc_error:
-                    print(f"⚠️ خطأ في حساب PnL: {calc_error}")
                     pnl = 0.0
                     pnl_percent = 0.0
-            else:
-                print(f"⚠️ أسعار غير صالحة لحساب PnL: الدخول={entry_price}, الخروج={close_price}")
                     
             trade_to_close['pnl_usd'] = pnl
             trade_to_close['pnl_percent'] = pnl_percent
@@ -134,16 +117,11 @@ class TradeManager:
                 portfolio_state["total_loss_usd"] = portfolio_state.get("total_loss_usd", 0.0) + abs(pnl)
             
             await self.r2_service.save_portfolio_state_async(portfolio_state)
-            
-            print(f"📈 PnL الصفقة: ${pnl:.4f} ({pnl_percent:+.4f}%). "
-                  f"رأس المال الجديد المتاح: ${new_capital:.4f}. الاستراتيجية: {strategy}")
 
             open_trades = await self.r2_service.get_open_trades_async()
             trades_to_keep = [t for t in open_trades if t.get('id') != trade_to_close.get('id')]
             await self.r2_service.save_open_trades_async(trades_to_keep)
             
-            print(f"✅ تم إغلاق صفقة {trade_to_close.get('symbol')} وأرشفتها بنجاح. الاستراتيجية: {strategy}")
-
             await self.r2_service.save_system_logs_async({
                 "trade_closed": True,
                 "symbol": trade_to_close.get('symbol'),
@@ -164,11 +142,9 @@ class TradeManager:
             return True
 
         except Exception as e:
-            print(f"❌ فشل إغلاق الصفقة: {e}")
             raise
 
     async def update_trade(self, trade_to_update, re_analysis_decision):
-        """تحديث الصفقة بمعطيات جديدة من إعادة التحليل"""
         try:
             if re_analysis_decision.get('new_stop_loss'):
                 trade_to_update['stop_loss'] = re_analysis_decision['new_stop_loss']
@@ -180,7 +156,6 @@ class TradeManager:
                 new_expected_minutes = max(5, min(new_expected_minutes, 45))
                 trade_to_update['expected_target_minutes'] = new_expected_minutes
                 trade_to_update['expected_target_time'] = (datetime.now() + timedelta(minutes=new_expected_minutes)).isoformat()
-                print(f"⏰ تم تحديث وقت الصفقة المتوقع إلى {new_expected_minutes} دقيقة.")
 
             original_strategy = trade_to_update.get('strategy')
             if not original_strategy or original_strategy == 'unknown':
@@ -197,7 +172,6 @@ class TradeManager:
                     break
 
             await self.r2_service.save_open_trades_async(open_trades)
-            print(f"✅ تم تحديث صفقة {trade_to_update.get('symbol')} بنجاح. الاستراتيجية: {original_strategy}")
 
             await self.r2_service.save_system_logs_async({
                 "trade_updated": True,
@@ -210,11 +184,9 @@ class TradeManager:
             return True
 
         except Exception as e:
-            print(f"❌ فشل تحديث الصفقة: {e}")
             raise
 
     async def immediate_close_trade(self, symbol, close_price, reason="المراقبة الفورية"):
-        """إغلاق فوري لصفقة بدون إعادة تحليل كاملة"""
         try:
             open_trades = await self.r2_service.get_open_trades_async()
             trade_to_close = None
@@ -225,20 +197,16 @@ class TradeManager:
                     break
             
             if not trade_to_close:
-                print(f"❌ لم يتم العثور على صفقة مفتوحة لـ {symbol}")
                 return False
             
             await self.close_trade(trade_to_close, close_price, reason)
-            print(f"🚨 إغلاق فوري: {symbol} عند {close_price} - {reason}")
             
             return True
             
         except Exception as e:
-            print(f"❌ فشل الإغلاق الفوري لصفقة {symbol}: {e}")
             return False
 
     async def start_trade_monitoring(self):
-        """بدء مراقبة الصفقات المفتوحة"""
         self.is_running = True
         while self.is_running:
             try:
@@ -256,11 +224,9 @@ class TradeManager:
                 
                 await asyncio.sleep(10)
             except Exception as error:
-                print(f"خطأ في مراقبة الصفقات: {error}")
                 await asyncio.sleep(30)
 
     async def _monitor_single_trade(self, trade):
-        """مراقبة صفقة فردية"""
         symbol = trade['symbol']
         while symbol in self.monitoring_tasks and self.is_running:
             try:
@@ -301,16 +267,13 @@ class TradeManager:
                     
                 await asyncio.sleep(15)
             except Exception as error:
-                print(f"خطأ في مراقبة {symbol}: {error}")
                 await asyncio.sleep(30)
 
     def stop_monitoring(self):
-        """إيقاف مراقبة الصفقات"""
         self.is_running = False
         self.monitoring_tasks.clear()
 
     async def _archive_closed_trade(self, closed_trade):
-        """أرشفة الصفقة المغلقة"""
         try:
             key = "closed_trades_history.json"
             try:
@@ -325,12 +288,10 @@ class TradeManager:
             self.r2_service.s3_client.put_object(
                 Bucket="trading", Key=key, Body=data_json, ContentType="application/json"
             )
-            print(f"📚 تم أرشفة الصفقة. إجمالي الصفقات المؤرشفة: {len(history)}")
         except Exception as e:
-            print(f"❌ فشل أرشفة الصفقة: {e}")
+            pass
 
     async def _update_trade_summary(self, closed_trade):
-        """تحديث إحصائيات التداول"""
         try:
             key = "trade_summary.json"
             try:
@@ -370,21 +331,16 @@ class TradeManager:
             self.r2_service.s3_client.put_object(
                 Bucket="trading", Key=key, Body=data_json, ContentType="application/json"
             )
-            print(f"📊 تم تحديث ملخص التداول. معدل الربح: {summary['win_percentage']:.2f}%")
 
         except Exception as e:
-            print(f"❌ فشل تحديث ملخص التداول: {e}")
+            pass
 
     async def get_open_trades(self):
-        """الحصول على الصفقات المفتوحة"""
         return await self.r2_service.get_open_trades_async()
 
     async def get_trade_by_symbol(self, symbol):
-        """الحصول على صفقة بالرمز"""
         open_trades = await self.get_open_trades()
         for trade in open_trades:
             if trade['symbol'] == symbol and trade['status'] == 'OPEN':
                 return trade
-        return None
-
-print("✅ Trade Manager محمل - إدارة موحدة للصفقات")
+        return None