Static files not found
") + + +@app.get("/api/status") +async def get_status(): + """获取模拟盘状态""" + state = load_trading_state() + signal = load_latest_signal() + + # 计算总收益率 + initial_balance = 10000.0 + total_return = (state.get('balance', initial_balance) - initial_balance) / initial_balance * 100 + + return { + 'timestamp': datetime.now().isoformat(), + 'balance': state.get('balance', initial_balance), + 'initial_balance': initial_balance, + 'total_return': total_return, + 'position': state.get('position'), + 'stats': state.get('stats', {}), + 'last_updated': state.get('last_updated'), + } + + +@app.get("/api/trades") +async def get_trades(limit: int = 50): + """获取交易记录""" + state = load_trading_state() + trades = state.get('trades', []) + return { + 'total': len(trades), + 'trades': trades[-limit:] if limit > 0 else trades, + } + + +@app.get("/api/equity") +async def get_equity_curve(limit: int = 500): + """获取权益曲线""" + state = load_trading_state() + equity_curve = state.get('equity_curve', []) + return { + 'total': len(equity_curve), + 'data': equity_curve[-limit:] if limit > 0 else equity_curve, + } + + +@app.get("/api/signal") +async def get_signal(): + """获取最新信号""" + signal = load_latest_signal() + + # 提取关键信息 + agg = signal.get('aggregated_signal', {}) + llm = agg.get('llm_signal', {}) + quant = agg.get('quantitative_signal', {}) + market = signal.get('market_analysis', {}) + + return { + 'timestamp': agg.get('timestamp'), + 'final_signal': agg.get('final_signal'), + 'final_confidence': agg.get('final_confidence'), + 'consensus': agg.get('consensus'), + 'current_price': agg.get('levels', {}).get('current_price'), + 'llm': { + 'signal': llm.get('signal_type'), + 'confidence': llm.get('confidence'), + 'reasoning': llm.get('reasoning'), + 'opportunities': llm.get('opportunities', {}), + 'recommendations': llm.get('recommendations_by_timeframe', {}), + }, + 'quantitative': { + 'signal': quant.get('signal_type'), + 'confidence': quant.get('confidence'), + 'composite_score': quant.get('composite_score'), + 'scores': quant.get('scores', {}), + }, + 'market': { + 'price': market.get('price'), + 'trend': market.get('trend', {}), + 'momentum': market.get('momentum', {}), + }, + } + + +@app.get("/api/position") +async def get_position(): + """获取当前持仓详情""" + state = load_trading_state() + position = state.get('position') + + if not position: + return {'has_position': False, 'position': None} + + return { + 'has_position': position.get('side') != 'FLAT' and position.get('total_size', 0) > 0, + 'position': position, + } + + +@app.websocket("/ws") +async def websocket_endpoint(websocket: WebSocket): + """WebSocket 实时推送""" + await manager.connect(websocket) + + try: + # 发送初始状态 + state = load_trading_state() + signal = load_latest_signal() + await websocket.send_json({ + 'type': 'init', + 'state': state, + 'signal': signal, + }) + + # 持续推送更新 + last_state_mtime = STATE_FILE.stat().st_mtime if STATE_FILE.exists() else 0 + last_signal_mtime = SIGNAL_FILE.stat().st_mtime if SIGNAL_FILE.exists() else 0 + + while True: + await asyncio.sleep(1) # 每秒检查一次 + + # 检查状态文件更新 + current_state_mtime = STATE_FILE.stat().st_mtime if STATE_FILE.exists() else 0 + current_signal_mtime = SIGNAL_FILE.stat().st_mtime if SIGNAL_FILE.exists() else 0 + + if current_state_mtime > last_state_mtime: + last_state_mtime = current_state_mtime + state = load_trading_state() + await websocket.send_json({ + 'type': 'state_update', + 'state': state, + }) + + if current_signal_mtime > last_signal_mtime: + last_signal_mtime = current_signal_mtime + signal = load_latest_signal() + await websocket.send_json({ + 'type': 'signal_update', + 'signal': signal, + }) + + except WebSocketDisconnect: + manager.disconnect(websocket) + except Exception as e: + print(f"WebSocket error: {e}") + manager.disconnect(websocket) + + +# 静态文件 +static_dir = Path(__file__).parent / 'static' +if static_dir.exists(): + app.mount("/static", StaticFiles(directory=str(static_dir)), name="static") + + +if __name__ == "__main__": + import uvicorn + uvicorn.run(app, host="0.0.0.0", port=8080) diff --git a/web/static/index.html b/web/static/index.html new file mode 100644 index 0000000..0617229 --- /dev/null +++ b/web/static/index.html @@ -0,0 +1,781 @@ + + + + + +BTC/USDT Perpetual
+No Position
+Waiting for signal...
+Loading Signal
+Fetching latest analysis...
+| ID | +Side | +Entry | +Exit | +Size | +PnL | +Reason | +Time | +
|---|---|---|---|---|---|---|---|
|
+
+ No trades yet + |
+ |||||||