Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py (V17.9 - GEM-Architect: Full Stack + Intelligent Management)
+# app.py (V18.0 - GEM-Architect: Full Stack + UI Enhancements)
 import os
 import sys
 import traceback
@@ -492,22 +492,97 @@ async def get_full_status():
     }
 
 # ==============================================================================
-# 📊 [ 💡 GEM-ARCHITECT FIX: FULL PRICE PRECISION ]
+# 📊 [ 💡 GEM-ARCHITECT: NEW UI LOGIC ]
 # ==============================================================================
 
+async def manual_close_current_trade():
+    """
+    دالة زر الإغلاق اليدوي
+    """
+    if not trade_manager.open_positions:
+        return "⚠️ لا توجد صفقة مفتوحة لإغلاقها."
+    
+    symbol = list(trade_manager.open_positions.keys())[0]
+    await trade_manager.force_exit_by_manager(symbol, reason="MANUAL_UI_BUTTON")
+    return f"✅ تم إرسال أمر إغلاق فوري لـ {symbol}."
+
 async def check_live_pnl_and_status():
     """
-    [جديد] دالة يتم استدعاؤها كل 10 ثواني لتحديث الواجهة.
-    (إصلاح: يستخدم 8 خانات عشرية لعرض العملات الصغيرة مثل SHIB)
+    تحديث الواجهة الدورية (الرسوم، الحالة، الإحصائيات، المحفظة)
     """
-    global trade_manager, data_manager, sys_state
+    global trade_manager, data_manager, sys_state, r2
     
     empty_watchlist = pd.DataFrame(columns=["عملات المراقبة"])
+    
+    # Default Values for Stats
+    wallet_md = "### 💰 جاري التحميل..."
+    history_md = "### 📊 جاري التحميل..."
 
     if not sys_state.ready:
-        return "النظام قيد التهيئة...", "...", "...", "...", "...", None, empty_watchlist
+        return "النظام قيد التهيئة...", "...", "...", "...", "...", None, empty_watchlist, wallet_md, history_md
+
+    # 1. جلب بيانات المحفظة والإحصائيات من R2
+    try:
+        portfolio_state = await r2.get_portfolio_state_async()
+        current_capital = portfolio_state.get('current_capital_usd', 0.0)
+        total_trades = portfolio_state.get('total_trades', 0)
+        winning_trades = portfolio_state.get('winning_trades', 0)
+        total_profit = portfolio_state.get('total_profit_usd', 0.0)
+        
+        win_rate = (winning_trades / total_trades * 100) if total_trades > 0 else 0.0
+        
+        # Dynamic Wallet Calculation
+        dynamic_balance = current_capital
+        pnl_unrealized = 0.0
+        
+        if trade_manager.open_positions:
+            symbol = list(trade_manager.open_positions.keys())[0]
+            trade = trade_manager.open_positions[symbol]
+            entry_price = float(trade.get('entry_price', 0.0))
+            
+            curr_price = await data_manager.get_latest_price_async(symbol)
+            if curr_price > 0 and entry_price > 0:
+                # نفترض استثمار كامل رأس المال (للمحاكاة) أو نستخدم logic آخر
+                # هنا سنحسب نسبة الربح ونضيفها كرصيد وهمي للعرض
+                pnl_pct = (curr_price - entry_price) / entry_price
+                pnl_unrealized = current_capital * pnl_pct
+                dynamic_balance = current_capital + pnl_unrealized
+
+        # تنسيق عرض المحفظة
+        wallet_color = "#00ff00" if pnl_unrealized >= 0 else "#ff0000"
+        wallet_md = f"""
+        <div style='background-color: #1a1a1a; padding: 15px; border-radius: 8px; border: 1px solid #333;'>
+            <h3 style='margin-top:0; color: #888;'>💰 المحفظة الحية</h3>
+            <div style='font-size: 24px; font-weight: bold; color: white;'>
+                ${dynamic_balance:,.2f}
+            </div>
+            <div style='font-size: 14px; color: {wallet_color};'>
+                ({pnl_unrealized:+\,.2f} USD غير محقق)
+            </div>
+             <div style='font-size: 12px; color: #666; margin-top:5px;'>
+                الرصيد الأساسي: ${current_capital:,.2f}
+            </div>
+        </div>
+        """
 
-    # 1. تحديث حالة النظام وقائمة المراقبة
+        # تنسيق عرض الإحصائيات
+        history_md = f"""
+        <div style='background-color: #1a1a1a; padding: 15px; border-radius: 8px; border: 1px solid #333;'>
+            <h3 style='margin-top:0; color: #888;'>📊 الأداء التاريخي</h3>
+            <table style='width:100%; color:white;'>
+                <tr><td>إجمالي الصفقات:</td><td style='text-align:left; font-weight:bold;'>{total_trades}</td></tr>
+                <tr><td>نسبة الفوز:</td><td style='text-align:left; font-weight:bold; color:#00ff00;'>{win_rate:.1f}%</td></tr>
+                <tr><td>الرابحة:</td><td style='text-align:left;'>{winning_trades}</td></tr>
+                <tr><td>صافي الربح:</td><td style='text-align:left; color: {"#00ff00" if total_profit>=0 else "#ff0000"};'>${total_profit:,.2f}</td></tr>
+            </table>
+        </div>
+        """
+        
+    except Exception as e:
+        wallet_md = f"Error: {e}"
+        history_md = "Error loading stats"
+
+    # 2. الحالة العامة
     try:
         status_text = sys_state.last_cycle_logs 
         trade_count = len(trade_manager.open_positions)
@@ -517,25 +592,20 @@ async def check_live_pnl_and_status():
         **الصفقات المفتوحة:** {trade_count} | 
         **قائمة المراقبة:** {watch_count}
         """
-        
         watchlist_items = list(trade_manager.watchlist.keys())
         watchlist_df = pd.DataFrame(watchlist_items, columns=["عملات المراقبة"])
-        
-    except Exception as e:
-        return f"خطأ في جلب الحالة: {e}", "...", "...", "...", "...", None, empty_watchlist
+    except Exception:
+        return "Error", "...", "...", "...", "...", None, empty_watchlist, wallet_md, history_md
 
-    # 2. التحقق من الصفقة المفتوحة
+    # 3. التحقق من الصفقة المفتوحة (للشارت والـ PnL)
     if not trade_manager.open_positions:
-        return status_text, status_md, "### 💤 لا توجد صفقة مفتوحة", "---", "---", None, watchlist_df
+        return status_text, status_md, "### 💤 لا توجد صفقة مفتوحة", "---", "---", None, watchlist_df, wallet_md, history_md
 
     try:
         symbol = list(trade_manager.open_positions.keys())[0]
         trade = trade_manager.open_positions[symbol]
         
-        # 3. [GEM-FIX] جلب السعر الحي ومعالجة الأصفار
         current_price = await data_manager.get_latest_price_async(symbol)
-        
-        # إذا فشل الجلب (0.0)، نستخدم سعر الدخول للعرض فقط
         if current_price <= 0.0:
             current_price = float(trade.get('entry_price', 0.0))
             color = "gray"
@@ -543,22 +613,12 @@ async def check_live_pnl_and_status():
         else:
             entry_price = float(trade['entry_price'])
             pnl_pct = ((current_price - entry_price) / entry_price) * 100
-            
-            # 4. تحديد اللون
-            if pnl_pct > 0:
-                color = "#00ff00" # Green
-                pnl_text = f"ربح +{pnl_pct:.2f}% 🚀"
-            elif pnl_pct < 0:
-                color = "#ff0000" # Red
-                pnl_text = f"خسارة {pnl_pct:.2f}% 🔻"
-            else:
-                color = "white"
-                pnl_text = "تعادل 0.00%"
+            color = "#00ff00" if pnl_pct > 0 else "#ff0000"
+            pnl_text = f"{pnl_pct:+.2f}%"
 
         symbol_md = f"# {symbol}"
-        pnl_md = f"<div style='font-size: 30px; color:{color}; text-align:center; font-weight:bold;'>{pnl_text}</div>"
+        pnl_md = f"<div style='font-size: 40px; color:{color}; text-align:center; font-weight:bold;'>{pnl_text}</div>"
         
-        # 5. [GEM-FIX] تنسيق الأرقام باستخدام الدالة الجديدة (Full Precision)
         entry_fmt = format_crypto_price(trade['entry_price'])
         curr_fmt = format_crypto_price(current_price)
         tp_fmt = format_crypto_price(trade['tp_price'])
@@ -566,54 +626,44 @@ async def check_live_pnl_and_status():
 
         details_md = f"""
         <div style='background-color: #222; padding: 10px; border-radius: 5px;'>
-        <b>سعر الدخول:</b> {entry_fmt}<br>
-        <b>السعر الحالي:</b> {curr_fmt}<br>
+        <b>دخول:</b> {entry_fmt}<br>
+        <b>حالياً:</b> {curr_fmt}<br>
         <span style='color:#00ff00;'><b>TP:</b> {tp_fmt}</span><br>
         <span style='color:#ff0000;'><b>SL:</b> {sl_fmt}</span>
         </div>
         """
 
-        # 6. رسم المخطط
+        # Chart
         fig = None
         try:
             ohlcv = await data_manager.get_latest_ohlcv(symbol, '5m', 100)
             if ohlcv and len(ohlcv) > 0:
                 df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
                 df['datetime'] = pd.to_datetime(df['timestamp'], unit='ms')
-                
                 fig = plt.figure(figsize=(10, 5))
                 ax = fig.add_subplot(111)
-                
                 fig.patch.set_facecolor('#0b0f19')
                 ax.set_facecolor('#0b0f19')
-                
                 ax.plot(df['datetime'], df['close'], label=f'{symbol}', color='#00e5ff')
                 ax.axhline(y=float(trade['entry_price']), color='white', linestyle='--', label='Entry')
                 ax.axhline(y=float(trade['tp_price']), color='#00ff00', linestyle='-', label='TP')
                 ax.axhline(y=float(trade['sl_price']), color='#ff0000', linestyle='-', label='SL')
-                
                 ax.tick_params(axis='x', colors='white')
                 ax.tick_params(axis='y', colors='white')
                 ax.xaxis.set_major_formatter(mdates.DateFormatter('%H:%M'))
                 ax.legend(facecolor='#222', labelcolor='white')
-                
                 plt.tight_layout()
             else:
                 fig = None
-                
-        except Exception as e:
-            print(f"❌ خطأ في رسم المخطط: {e}")
-            fig = None
+        except Exception: fig = None
             
-        return status_text, status_md, symbol_md, pnl_md, details_md, fig, watchlist_df
+        return status_text, status_md, symbol_md, pnl_md, details_md, fig, watchlist_df, wallet_md, history_md
 
     except Exception as e:
-        print(f"❌ خطأ فادح في check_live_pnl: {e}")
-        return status_text, status_md, f"خطأ: {e}", "...", "...", None, empty_watchlist
+        return status_text, status_md, f"Error: {e}", "...", "...", None, empty_watchlist, wallet_md, history_md
 
 async def run_cycle_from_gradio():
-    if sys_state.cycle_running:
-        return "الدورة قيد التشغيل بالفعل. يرجى الانتظار."
+    if sys_state.cycle_running: return "الدورة تعمل بالفعل."
     await run_unified_cycle()
     return sys_state.last_cycle_logs
 
@@ -621,58 +671,104 @@ async def run_cycle_from_gradio():
 # 🚀 بناء وتثبيت واجهة Gradio
 # ==============================================================================
 def create_gradio_ui():
-    css = "#pnl_md { text-align: center; }"
+    css = """
+    #pnl_md { text-align: center; }
+    .gradio-container { background-color: #0b0f19; }
+    """
 
-    with gr.Blocks(title="لوحة تحكم Titan", css=css, theme=gr.themes.Monochrome()) as demo:
-        gr.Markdown("# 📊 لوحة تحكم Titan (مدمجة مع FastAPI)")
+    with gr.Blocks(title="Titan V18 Pro Dashboard", css=css, theme=gr.themes.Monochrome()) as demo:
+        gr.Markdown("# 🚀 Titan V18 Pro Trading Terminal")
         
+        # --- الصف العلوي: الشارت + الإحصائيات الحية ---
         with gr.Row():
+            # العمود الأيسر: الشارت والمعلومات الفنية
             with gr.Column(scale=3):
-                live_chart = gr.Plot(label="المخطط الحي للصفقة")
+                live_chart = gr.Plot(label="Chart")
+                with gr.Row():
+                     live_symbol = gr.Markdown("### No Active Trade")
+                     live_pnl = gr.Markdown("---", elem_id="pnl_md")
+                live_details = gr.Markdown("Waiting for data...")
+
+            # العمود الأيمن: المحفظة والإحصائيات
             with gr.Column(scale=1):
-                live_symbol = gr.Markdown("### لا توجد صفقة")
-                live_pnl = gr.Markdown("---", elem_id="pnl_md")
-                live_details = gr.Markdown("---")
+                wallet_output = gr.HTML(label="Wallet")
+                history_output = gr.HTML(label="Stats")
+                watchlist_output = gr.DataFrame(label="Watchlist")
                 
         gr.HTML("<hr>")
         
+        # --- الصف السفلي: التحكم والسجلات ---
         with gr.Row():
             with gr.Column(scale=1):
-                gr.Markdown("## ⚙️ لوحة التحكم")
-                run_cycle_btn = gr.Button("🚀 (1) بدء دورة التحليل يدوياً")
-                gr.Markdown("## 📝 حالة النظام")
-                status_markdown = gr.Markdown(f"**الحالة:** {'جاري التهيئة...' if not sys_state.ready else 'جاهز'}")
-                watchlist_output = gr.DataFrame(label="قائمة المراقبة (Watchlist)")
+                gr.Markdown("## 🎮 التحكم (Controls)")
+                
+                with gr.Row():
+                    run_cycle_btn = gr.Button("🚀 (1) بدء الدورة (Scan)", variant="primary")
+                    close_trade_btn = gr.Button("🚨 (2) إغلاق الصفقة (Panic)", variant="stop")
+                
+                gr.Markdown("## 📡 حالة النظام")
+                status_markdown = gr.Markdown("جاري التهيئة...")
+                
+                # رسائل التنبيه
+                alert_box = gr.Textbox(label="تنبيهات النظام", interactive=False)
 
             with gr.Column(scale=3):
-                gr.Markdown("## 📜 سجلات آخر دورة تحليل")
+                gr.Markdown("## 📜 سجلات النظام (System Logs)")
                 cycle_logs_output = gr.Textbox(
-                    label="السجلات", 
-                    lines=20, 
+                    lines=15, 
                     autoscroll=True,
                     max_lines=100,
-                    value="...يتم تحميل السجلات عند انتهاء التهيئة..."
+                    value="..."
                 )
 
+        # --- التفاعلات (Interactions) ---
+        
+        # زر تشغيل الدورة
         run_cycle_btn.click(
             fn=run_cycle_from_gradio, 
             inputs=None, 
-            outputs=cycle_logs_output,
-            api_name="run_cycle_manual"
+            outputs=cycle_logs_output
         )
         
+        # زر الإغلاق اليدوي
+        close_trade_btn.click(
+            fn=manual_close_current_trade,
+            inputs=None,
+            outputs=alert_box
+        )
+        
+        # التحديث الدوري (Timer)
         demo.load(
             fn=check_live_pnl_and_status,
             inputs=None,
-            outputs=[cycle_logs_output, status_markdown, live_symbol, live_pnl, live_details, live_chart, watchlist_output]
+            outputs=[
+                cycle_logs_output, 
+                status_markdown, 
+                live_symbol, 
+                live_pnl, 
+                live_details, 
+                live_chart, 
+                watchlist_output,
+                wallet_output,   # New
+                history_output   # New
+            ]
         )
 
-        timer = gr.Timer(10) 
-
+        timer = gr.Timer(5) # تحديث كل 5 ثواني
         timer.tick(
             fn=check_live_pnl_and_status,
             inputs=None,
-            outputs=[cycle_logs_output, status_markdown, live_symbol, live_pnl, live_details, live_chart, watchlist_output]
+            outputs=[
+                cycle_logs_output, 
+                status_markdown, 
+                live_symbol, 
+                live_pnl, 
+                live_details, 
+                live_chart, 
+                watchlist_output,
+                wallet_output,   # New
+                history_output   # New
+            ]
         )
         
     return demo
@@ -681,7 +777,7 @@ gradio_dashboard = create_gradio_ui()
 app = gr.mount_gradio_app(app, gradio_dashboard, path="/")
 
 # ==============================================================================
-# 🏁 تشغيل الخادم المدمج
+# 🏁 تشغيل الخادم
 # ==============================================================================
 if __name__ == "__main__":
     import uvicorn