修复中控保本状态

manual_trading_hub/hub.py

@@ -626,6 +626,51 @@ def _merge_flask_order_price_fields(hub_mon: dict | None, snap: dict | None) ->
             o["sl_breakeven_secured"] = bool(op["sl_breakeven_secured"])
 
 
+def _merge_flask_position_breakeven(agent_row: dict, snap: dict | None, hub_mon: dict | None) -> None:
+    """将 price_snapshot 的已保本状态同步到 agent 持仓，供中控首页表格展示。"""
+    ag = agent_row.get("agent")
+    if not isinstance(ag, dict) or not isinstance(snap, dict):
+        return
+    positions = ag.get("positions")
+    if not isinstance(positions, list) or not positions:
+        return
+    order_prices = snap.get("order_prices") or []
+    hub_orders = []
+    if isinstance(hub_mon, dict):
+        hub_orders = hub_mon.get("orders") or []
+    op_by_id = {
+        op.get("id"): op
+        for op in order_prices
+        if isinstance(op, dict) and op.get("id") is not None
+    }
+    for p in positions:
+        if not isinstance(p, dict):
+            continue
+        sym = p.get("symbol") or ""
+        side = (p.get("side") or "").lower()
+        matched = None
+        for o in hub_orders:
+            if not isinstance(o, dict):
+                continue
+            o_sym = o.get("exchange_symbol") or o.get("symbol") or ""
+            if not _symbols_match(sym, o_sym):
+                continue
+            if (o.get("direction") or "").lower() != side:
+                continue
+            matched = op_by_id.get(o.get("id"))
+            break
+        if matched is None:
+            for op in order_prices:
+                if not isinstance(op, dict):
+                    continue
+                if not _symbols_match(sym, op.get("symbol") or ""):
+                    continue
+                matched = op
+                break
+        if isinstance(matched, dict) and "sl_breakeven_secured" in matched:
+            p["sl_breakeven_secured"] = bool(matched["sl_breakeven_secured"])
+
+
 def _merge_flask_exchange_tpsl(agent_row: dict, snap: dict | None, hub_mon: dict | None) -> None:
     """子代理挂单为空时，用实例 Flask 已算好的 exchange_tpsl 补全展示。"""
     ag = agent_row.get("agent")
@@ -684,6 +729,7 @@ async def _assemble_board_row(
     if isinstance(hub_mon, dict):
         _merge_flask_order_price_fields(hub_mon, snap)
     _merge_flask_exchange_tpsl(agent_row, snap, hub_mon if isinstance(hub_mon, dict) else None)
+    _merge_flask_position_breakeven(agent_row, snap, hub_mon if isinstance(hub_mon, dict) else None)
     flask_ok = isinstance(hub_mon, dict) and hub_mon.get("ok") is not False
     raw_review = (ex.get("review_url") or "").strip()
     review_link = browser_url(raw_review) if raw_review else default_review_url(