"use client"; import { useState, useEffect } from "react"; import Link from "next/link"; import { authFetch, useAuth } from "@/lib/auth"; import { LineChart, Line, XAxis, YAxis, Tooltip, ResponsiveContainer, ReferenceLine, Area, AreaChart } from "recharts"; // ─── 工具函数 ──────────────────────────────────────────────────── function bjt(ms: number) { const d = new Date(ms + 8 * 3600 * 1000); return `${String(d.getUTCMonth() + 1).padStart(2, "0")}-${String(d.getUTCDate()).padStart(2, "0")} ${String(d.getUTCHours()).padStart(2, "0")}:${String(d.getUTCMinutes()).padStart(2, "0")}`; } function fmtPrice(p: number) { return p < 100 ? p.toFixed(4) : p.toLocaleString("en-US", { minimumFractionDigits: 1, maximumFractionDigits: 1 }); } // ─── 控制面板(开关+配置)────────────────────────────────────── function ControlPanel() { const [config, setConfig] = useState(null); const [saving, setSaving] = useState(false); useEffect(() => { const f = async () => { try { const r = await authFetch("/api/paper/config"); if (r.ok) setConfig(await r.json()); } catch {} }; f(); }, []); const toggle = async () => { setSaving(true); try { const r = await authFetch("/api/paper/config", { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ enabled: !config.enabled }), }); if (r.ok) setConfig(await r.json().then(j => j.config)); } catch {} finally { setSaving(false); } }; if (!config) return null; return (
{config.enabled ? "🟢 运行中" : "⚪ 已停止"}
初始资金: ${config.initial_balance?.toLocaleString()} 单笔风险: {(config.risk_per_trade * 100).toFixed(0)}% 最大持仓: {config.max_positions}
); } // ─── 总览面板 ──────────────────────────────────────────────────── function SummaryCards() { const [data, setData] = useState(null); useEffect(() => { const f = async () => { try { const r = await authFetch("/api/paper/summary"); if (r.ok) setData(await r.json()); } catch {} }; f(); const iv = setInterval(f, 10000); return () => clearInterval(iv); }, []); if (!data) return
加载中...
; return (

当前资金

= 10000 ? "text-emerald-600" : "text-red-500"}`}>${data.balance?.toLocaleString()}

总盈亏(R)

= 0 ? "text-emerald-600" : "text-red-500"}`}>{data.total_pnl >= 0 ? "+" : ""}{data.total_pnl}R

= 0 ? "text-emerald-500" : "text-red-400"}`}>{data.total_pnl_usdt >= 0 ? "+" : ""}${data.total_pnl_usdt}

胜率

{data.win_rate}%

总交易

{data.total_trades}

持仓中

{data.active_positions}

盈亏比(PF)

{data.profit_factor}

运行

{data.start_time ? "运行中 ✅" : "等待首笔"}

); } // ─── 最新信号状态 ──────────────────────────────────────────────── const COINS = ["BTCUSDT", "ETHUSDT", "XRPUSDT", "SOLUSDT"]; function LatestSignals() { const [signals, setSignals] = useState>({}); useEffect(() => { const f = async () => { for (const sym of COINS) { try { const r = await authFetch(`/api/signals/signal-history?symbol=${sym}&limit=1`); if (r.ok) { const j = await r.json(); if (j.data && j.data.length > 0) { setSignals(prev => ({ ...prev, [sym]: j.data[0] })); } } } catch {} } }; f(); const iv = setInterval(f, 15000); return () => clearInterval(iv); }, []); return (

最新信号

{COINS.map(sym => { const s = signals[sym]; const coin = sym.replace("USDT", ""); const ago = s?.ts ? Math.round((Date.now() - s.ts) / 60000) : null; return (
{coin} {s?.signal ? ( <> {s.signal === "LONG" ? "🟢" : "🔴"} {s.signal} {s.score}分 ) : ( ⚪ 无信号 )}
{ago !== null && {ago < 60 ? `${ago}m前` : `${Math.round(ago/60)}h前`}}
); })}
); } // ─── 当前持仓 ──────────────────────────────────────────────────── function ActivePositions() { const [positions, setPositions] = useState([]); const [wsPrices, setWsPrices] = useState>({}); // 从API获取持仓列表(10秒刷新) useEffect(() => { const f = async () => { try { const r = await authFetch("/api/paper/positions"); if (r.ok) { const j = await r.json(); setPositions(j.data || []); } } catch {} }; f(); const iv = setInterval(f, 10000); return () => clearInterval(iv); }, []); // WebSocket实时价格(aggTrade逐笔成交) useEffect(() => { const streams = ["btcusdt", "ethusdt", "xrpusdt", "solusdt"].map(s => `${s}@aggTrade`).join("/"); const ws = new WebSocket(`wss://fstream.binance.com/stream?streams=${streams}`); ws.onmessage = (e) => { try { const msg = JSON.parse(e.data); if (msg.data) { const sym = msg.data.s; const price = parseFloat(msg.data.p); if (sym && price > 0) setWsPrices(prev => ({ ...prev, [sym]: price })); } } catch {} }; return () => ws.close(); }, []); if (positions.length === 0) return (
暂无活跃持仓
); return (

当前持仓 ● 实时

{positions.map((p: any) => { const sym = p.symbol?.replace("USDT", "") || ""; const holdMin = Math.round((Date.now() - p.entry_ts) / 60000); const currentPrice = wsPrices[p.symbol] || p.current_price || 0; const entry = p.entry_price || 0; const atr = p.atr_at_entry || 1; const riskDist = 2.0 * 0.7 * atr; const unrealR = riskDist > 0 ? (p.direction === "LONG" ? (currentPrice - entry) / riskDist : (entry - currentPrice) / riskDist) : 0; const unrealUsdt = unrealR * 200; return (
{p.direction === "LONG" ? "🟢" : "🔴"} {sym} {p.direction} 评分{p.score} · {p.tier === "heavy" ? "加仓" : p.tier === "standard" ? "标准" : "轻仓"}
= 0 ? "text-emerald-600" : "text-red-500"}`}> {unrealR >= 0 ? "+" : ""}{unrealR.toFixed(2)}R = 0 ? "text-emerald-500" : "text-red-400"}`}> ({unrealUsdt >= 0 ? "+" : ""}${unrealUsdt.toFixed(0)}) {holdMin}m
入场: ${fmtPrice(p.entry_price)} 现价: ${currentPrice ? fmtPrice(currentPrice) : "-"} TP1: ${fmtPrice(p.tp1_price)}{p.tp1_hit ? " ✅" : ""} TP2: ${fmtPrice(p.tp2_price)} SL: ${fmtPrice(p.sl_price)}
); })}
); } // ─── 权益曲线 ──────────────────────────────────────────────────── function EquityCurve() { const [data, setData] = useState([]); useEffect(() => { const f = async () => { try { const r = await authFetch("/api/paper/equity-curve"); if (r.ok) { const j = await r.json(); setData(j.data || []); } } catch {} }; f(); const iv = setInterval(f, 30000); return () => clearInterval(iv); }, []); if (data.length < 2) return null; return (

权益曲线 (累计PnL)

bjt(v)} tick={{ fontSize: 10 }} /> `${v}R`} /> bjt(Number(v))} formatter={(v: any) => [`${v}R`, "累计PnL"]} />
); } // ─── 历史交易列表 ──────────────────────────────────────────────── type FilterSymbol = "all" | "BTC" | "ETH" | "XRP" | "SOL"; type FilterResult = "all" | "win" | "loss"; function TradeHistory() { const [trades, setTrades] = useState([]); const [symbol, setSymbol] = useState("all"); const [result, setResult] = useState("all"); useEffect(() => { const f = async () => { try { const r = await authFetch(`/api/paper/trades?symbol=${symbol}&result=${result}&limit=50`); if (r.ok) { const j = await r.json(); setTrades(j.data || []); } } catch {} }; f(); const iv = setInterval(f, 10000); return () => clearInterval(iv); }, [symbol, result]); return (

历史交易

{(["all", "BTC", "ETH", "XRP", "SOL"] as FilterSymbol[]).map(s => ( ))} | {(["all", "win", "loss"] as FilterResult[]).map(r => ( ))}
{trades.length === 0 ? (
暂无交易记录
) : ( {trades.map((t: any) => { const holdMin = t.exit_ts && t.entry_ts ? Math.round((t.exit_ts - t.entry_ts) / 60000) : 0; return ( ); })}
币种 方向 入场 出场 PnL(R) 状态 分数 时间
{t.symbol?.replace("USDT", "")} {t.direction === "LONG" ? "🟢" : "🔴"} {t.direction} {fmtPrice(t.entry_price)} {t.exit_price ? fmtPrice(t.exit_price) : "-"} 0 ? "text-emerald-600" : t.pnl_r < 0 ? "text-red-500" : "text-slate-500"}`}> {t.pnl_r > 0 ? "+" : ""}{t.pnl_r?.toFixed(2)} {t.status === "tp" ? "止盈" : t.status === "sl" ? "止损" : t.status === "sl_be" ? "保本" : t.status === "timeout" ? "超时" : t.status === "signal_flip" ? "翻转" : t.status} {t.score} {holdMin}m
)}
); } // ─── 统计面板 ──────────────────────────────────────────────────── function StatsPanel() { const [data, setData] = useState(null); useEffect(() => { const f = async () => { try { const r = await authFetch("/api/paper/stats"); if (r.ok) setData(await r.json()); } catch {} }; f(); const iv = setInterval(f, 30000); return () => clearInterval(iv); }, []); if (!data || data.error) return null; return (

详细统计

胜率

{data.win_rate}%

盈亏比

{data.win_loss_ratio}

平均盈利

+{data.avg_win}R

平均亏损

-{data.avg_loss}R

最大回撤

{data.mdd}R

夏普比率

{data.sharpe}

做多胜率

{data.long_win_rate}% ({data.long_count}笔)

做空胜率

{data.short_win_rate}% ({data.short_count}笔)

{data.by_symbol && Object.entries(data.by_symbol).map(([s, v]: [string, any]) => (
{s}胜率

{v.win_rate}% ({v.total}笔)

))} {data.by_tier && Object.entries(data.by_tier).map(([t, v]: [string, any]) => (
{t === "heavy" ? "加仓" : t === "standard" ? "标准" : "轻仓"}档

{v.win_rate}% ({v.total}笔)

))}
); } // ─── 主页面 ────────────────────────────────────────────────────── export default function PaperTradingPage() { const { isLoggedIn, loading } = useAuth(); if (loading) return
加载中...
; if (!isLoggedIn) return (
🔒

请先登录查看模拟盘

登录
); return (

📊 模拟盘

V5.1信号引擎自动交易 · 实时追踪 · 数据驱动优化

); }