Update app.py

app.py

@@ -44,6 +44,8 @@ def _后台任务(合约: str, 周期: int, 参数: dict):
     """
     global 引擎实例
     try:
+        # 注意：这里假设您的引擎代码位于 '插件_引擎' 和 '插件_交易' 模块中
+        # 在实际部署时，请确保这些模块可以被正确导入
         from 插件_引擎.多策略引擎 import 多策略引擎
         from 插件_交易.策略_自适应 import 自适应策略
 
@@ -66,6 +68,13 @@ def _后台任务(合约: str, 周期: int, 参数: dict):
                 _记录("引擎结束")
 
         loop.run_until_complete(主循环())
+    except ImportError:
+        _记录("错误：未能导入 '多策略引擎' 或 '自适应策略'。这是一个演示界面，请确保后台引擎代码存在。")
+        # 模拟运行一段时间然后停止
+        time.sleep(10)
+        with 状态锁:
+            运行状态["运行中"] = False
+        _记录("演示模式结束")
     except Exception as e:
         _记录(f"后台任务异常：{e}")
         with 状态锁:
@@ -117,6 +126,9 @@ def 停止模拟():
     """
     global 引擎实例
     if 引擎实例 is None:
+        _记录("当前没有运行中的任务")
+        with 状态锁:
+            运行状态["运行中"] = False # 强制更新状态
         return "当前没有运行中的任务"
     try:
         引擎实例.停止()
@@ -133,7 +145,7 @@ def 获取状态():
     with 状态锁:
         # 从引擎里读净值/回撤（如果有）
         try:
-            if 引擎实例 is not None and 引擎实例.交易所 is not None:
+            if 运行状态["运行中"] and 引擎实例 is not None and 引擎实例.交易所 is not None:
                 # 交易所.净值 会在引擎每根收盘时更新；此处只是读
                 nv = float(getattr(引擎实例.交易所, "净值", 1.0) or 1.0)
                 dd = float(getattr(引擎实例.交易所, "回撤", 0.0) or 0.0)
@@ -163,18 +175,16 @@ with gr.Blocks(title="模拟实盘（OKX 公共WS + 多策略引擎）") as demo
                 刷新按钮 = gr.Button("🔄 刷新状态")
 
         with gr.Column(scale=1):
-            状态显示 = gr.Textbox(label="运行状态", lines=1)
-            日志显示 = gr.Textbox(label="实时日志（最近120行）", lines=22)
+            状态显示 = gr.Textbox(label="运行状态", lines=1, interactive=False)
+            日志显示 = gr.Textbox(label="实时日志（最近120行）", lines=22, interactive=False)
 
     # 事件绑定
     启动按钮.click(fn=启动模拟, inputs=[合约输入, 周期选择, 参数输入], outputs=[状态显示, 日志显示])
     停止按钮.click(fn=停止模拟, outputs=状态显示)
     刷新按钮.click(fn=获取状态, outputs=[状态显示, 日志显示])
 
-    # 页面加载时刷新一次
-    demo.load(获取状态, outputs=[状态显示, 日志显示])
-    # Gradio 4：用 Timer 每2秒刷新
-    # 修改后的正确代码
-    状态显示.load(fn=获取状态, inputs=None, outputs=[状态显示, 日志显示], every_seconds=2)
+    # 页面加载时运行一次，并在此后每 2 秒持续刷新
+    demo.load(fn=获取状态, outputs=[状态显示, 日志显示], every=2)
+
 if __name__ == "__main__":
     demo.launch(server_name="0.0.0.0", server_port=7860)