Create app.py

app.py

@@ -0,0 +1,126 @@
+# -*- coding: utf-8 -*-
+import gradio as gr
+import asyncio
+import json
+import threading
+import time
+from datetime import datetime
+
+# 全局控制
+运行线程 = None
+运行状态 = {"运行中": False, "净值": 1.0, "回撤": 0.0, "日志": []}
+
+def 启动模拟(合约, 周期, 参数json):
+    global 运行线程, 运行状态
+    
+    if 运行状态["运行中"]:
+        return "已有任务运行中", "", ""
+    
+    # 解析参数
+    try:
+        参数 = json.loads(参数json) if 参数json else {}
+    except:
+        return "参数JSON格式错误", "", ""
+    
+    # 启动异步任务
+    def 运行任务():
+        from 插件_引擎.多策略引擎 import 多策略引擎
+        from 插件_交易.策略_自适应 import 自适应策略
+        
+        async def 主循环():
+            运行状态["运行中"] = True
+            运行状态["日志"] = []
+            
+            引擎 = 多策略引擎()
+            策略 = 自适应策略(f"{合约}_{周期}分", 参数)
+            引擎.注册策略(f"{合约}_{周期}", 策略, 合约, int(周期))
+            
+            try:
+                await 引擎.启动([合约])
+            except Exception as e:
+                运行状态["日志"].append(f"错误: {e}")
+            finally:
+                运行状态["运行中"] = False
+        
+        asyncio.run(主循环())
+    
+    运行线程 = threading.Thread(target=运行任务)
+    运行线程.start()
+    
+    return "模拟启动成功", "", ""
+
+def 停止模拟():
+    global 运行状态
+    运行状态["运行中"] = False
+    return "已发送停止信号"
+
+def 获取状态():
+    日志文本 = "\n".join(运行状态["日志"][-50:])  # 最近50条
+    状态文本 = f"运行中: {运行状态['运行中']} | 净值: {运行状态['净值']:.4f} | 回撤: {运行状态['回撤']:.2%}"
+    return 状态文本, 日志文本
+
+# 默认参数（你的60分钟V1参数）
+默认参数 = {
+    "ver": "v1",
+    "adx_thr": 25,
+    "atr_buf_tr": 0.05,
+    "rsi_low": 30,
+    "rsi_high": 70,
+    "mr_stop_atr": 2.0,
+    "trend_logic": "adx",
+    "alloc_mode": "fixed"
+}
+
+# Gradio界面
+with gr.Blocks(title="模拟实盘") as demo:
+    gr.Markdown("# 📈 加密货币模拟实盘交易")
+    
+    with gr.Row():
+        with gr.Column():
+            合约输入 = gr.Textbox(
+                label="合约ID",
+                value="UXLINK-USDT-SWAP",
+                placeholder="例: BTC-USDT-SWAP"
+            )
+            周期选择 = gr.Radio(
+                label="周期（分钟）",
+                choices=["30", "60", "120", "240"],
+                value="60"
+            )
+            参数输入 = gr.Textbox(
+                label="策略参数（JSON）",
+                value=json.dumps(默认参数, indent=2),
+                lines=10
+            )
+            
+            with gr.Row():
+                启动按钮 = gr.Button("🚀 启动模拟", variant="primary")
+                停止按钮 = gr.Button("⏹️ 停止模拟", variant="stop")
+        
+        with gr.Column():
+            状态显示 = gr.Textbox(label="运行状态", lines=1)
+            日志显示 = gr.Textbox(label="实时日志", lines=20)
+            刷新按钮 = gr.Button("🔄 刷新状态")
+    
+    # 事件绑定
+    启动按钮.click(
+        fn=启动模拟,
+        inputs=[合约输入, 周期选择, 参数输入],
+        outputs=[状态显示, 日志显示, gr.Textbox(visible=False)]
+    )
+    
+    停止按钮.click(
+        fn=停止模拟,
+        outputs=状态显示
+    )
+    
+    刷新按钮.click(
+        fn=获取状态,
+        outputs=[状态显示, 日志显示]
+    )
+    
+    # 自动刷新
+    demo.load(获取状态, outputs=[状态显示, 日志显示], every=2)
+
+if __name__ == "__main__":
+    demo.launch(server_name="0.0.0.0", server_port=7860)