订单跟踪系统BUG35

订单跟踪严重 Bug 完整因果链分析

本文档汇总当前系统订单跟踪存在的严重 bug,按「输入 → 状态变化 → 调用路径 → 出错点 → 根因」建立完整因果链。


架构与数据流概览

flowchart LR
  subgraph input [输入源]
    WS_Order[orderUpdates WS]
    WS_Fill[userFills WS]
  end
  subgraph pub [发布端]
    EWM[EnhancedWebSocketManager]
    EB_WS[EventBus_WS]
  end
  subgraph sub [订阅端]
    EB_Exec[EventBus_Exec]
    WOM[WebSocketOrderManager]
    Exec[Executor]
  end
  WS_Order --> EWM
  WS_Fill --> EWM
  EWM --> EB_WS
  EB_WS -.->|"无连接"| EB_Exec
  EB_Exec --> WOM
  EB_Exec --> Exec
  • 发布端:交易 WS 在 src/utils/websocket/enhanced_ws_manager.py 内创建自己的 self._event_bus = EventBus()(L315),在 _cache_latest_data 中根据 channel 调用 _publish_order_status_events / _publish_fill_events,向该实例发布事件。
  • 订阅端:Executor 在 src/trading/executor.py L89 创建 self._event_bus = EventBus(),L146 将该实例传给 WebSocketOrderManager(executor=self, event_bus=self._event_bus),L98-99 在 WebSocketOrderManager 内订阅 OrderStatusEvent / OrderFilledEvent
  • 创建交易 WS 时src/services/realtime_kline_service_base.py L358-375 调用 EnhancedWebSocketManager(...)未传入任何 event_bus,因此交易 WS 使用内部新建的 EventBus,与 Executor 的 EventBus 不是同一实例。

Bug 1(P0):双 EventBus 隔离 —— 订单/成交事件从未被消费

因果链

阶段 说明
输入 交易所通过交易 WebSocket 推送 orderUpdatesuserFills 原始消息。
状态变化 交易 WS 的 _on_message_cache_latest_dataenhanced_ws_manager.py L391-426)根据 channel 调用 _publish_order_status_events(data)_publish_fill_events(data),向 ws_trading_manager 内部的 self._event_bus 发布 OrderStatusEvent / OrderFilledEvent
调用路径 ws_trading_manager._on_message_cache_latest_data_publish_order_status_events / _publish_fill_eventsself._event_bus.publish(...)(发布到 EventBus_A)。
消费端:WebSocketOrderManager 订阅的是 Executor 的 executor._event_bus(EventBus_B)
出错点 发布与订阅使用两条不同的 EventBus 实例,事件只在 EventBus_A 上广播,EventBus_B 上无任何订单/成交事件。
根因 1)enhanced_ws_manager.py 构造函数无 event_bus 参数,内部写死 self._event_bus = EventBus()(L315)。
2)realtime_kline_service_base.py 创建交易 WS 时未注入 Executor 的 event_bus,导致发布端与订阅端使用不同总线。

实际行为与影响

  • WebSocketOrderManager 从未收到任何 OrderStatusEvent / OrderFilledEvent,因此:
    • _ws_status 不会更新,宽限期/填单逻辑不触发;
    • _accumulate_fill 不执行,has_fill_price 始终为 False,成交价依赖 2s 早期 HTTP 或超时后 HTTP 兜底。
  • 等价于「WS 订单追踪静默失效」,仅靠 HTTP 路径工作。
  • 同源影响:同一交易 WS 发布的 WebSocketReconnectedEventPositionUpdatedEventBalanceChangedEvent 等若仅由 Executor 通过 executor._event_bus 订阅,同样收不到(重连后补查依赖的 WebSocketReconnectedEvent 也不会到达 Executor)。

Bug 2(P1):空 fill_id 导致去重失效、少计成交

因果链

阶段 说明
输入 某条 OrderFilledEventfill_id == ""(当前 userFills 发布端用 fill_id=f"tid:{tid}" 故正常情况非空;若未来其他来源或测试/回放未设 fill_id 则会出现)。
状态变化 WebSocketOrderManager._on_order_filled_eventwebsocket_order_manager.py L370-408)中先判断 event.fill_id in tracking._fill_ids,再 tracking._fill_ids.add(event.fill_id)
调用路径 EventBus 派发 OrderFilledEvent_on_order_filled_event → 锁内 if event.fill_id in tracking._fill_ids: returntracking._fill_ids.add(event.fill_id)_accumulate_fill
出错点 多条 fill_id=="" 的事件共享同一 key,第一条加入后,后续所有空 fill_id 事件在 if event.fill_id in tracking._fill_ids 时被误判为重复而 return,不再累计。
根因 去重完全依赖 fill_id,未对空 fill_id 做备用 key 或拒绝处理,导致重复 fill 被误去重,少算成交量、均价偏差

当前发布端情况

  • enhanced_ws_manager.py_publish_fill_events 仅在 tid is not None 时发布,且 fill_id=f"tid:{tid}",故当前从 userFills 来的事件不会出现空 fill_id;问题会在其他来源或未设 fill_id 时暴露。

Bug 3(P2):重连后仅「PENDING 且 _ws_status is None」才被 HTTP 补查

因果链

阶段 说明
输入 交易 WS 重连,发布 WebSocketReconnectedEvent(在修复 Bug1 前该事件也到不了 Executor;修复后才会触发补查)。
状态变化 Executor 的 _on_websocket_reconnectedexecutor.py L1789-1829)在 source=="trading" 时启动线程,调用 verify_pending_orders() 两次(中间间隔 WS_RECONNECT_VERIFY_DELAY)。
调用路径 verify_pending_orderswebsocket_order_manager.py L132-170)中 pending 列表为:t.status == PENDING and t._ws_status is None(L139-142)。
出错点 若某单在断线前已通过 orderUpdates 收到 "filled"_ws_status = FILLED),但尚未收到 userFills,则处于宽限期,不满足 _ws_status is None,不会被选入补查列表,只能等 5s 宽限期结束后用 fallback 价解析。
根因 补查条件过窄,只针对「完全未收到 WS 终态」的订单;已收 orderUpdates 未收 userFills 的订单被排除,在「断线期间已完全成交」场景下会多等最多 5s 才用兜底价结算。

与历史文档的对应关系

  • BUG-1(userFills 解析):设计上已改为 EventBus 路径,直连 handle_message/_on_user_fill 已删;发布端 _publish_fill_events 使用 data.get("fills", [])order_id=str(oid)fill_id=f"tid:{tid}" 已正确。当前真正的问题是事件送不到 WebSocketOrderManager(Bug1 双 EventBus)。
  • BUG-2(orderUpdates 拒绝状态):当前 _on_order_status_event 已用 "rejected" in status_str 覆盖 minTradeNtlRejected 等,已修复。
  • BUG-3(order_id 类型):发布端已统一 order_id=str(oid),已修复。
  • BUG-5(fill_id):发布端有一等字段 fill_id=f"tid:{tid}";消费端需防空 fill_id(即本分析中的 Bug2)。

修复优先级与要点

优先级 问题 根因摘要 修复要点
P0 双 EventBus 隔离 交易 WS 与 Executor 各用一条 EventBus,事件不互通 EnhancedWebSocketManager 支持可选 event_bus 注入;创建交易 WS 时传入 executor 的 _event_bus(需在 realtime 服务/orchestrator 中拿到 executor 并传入)
P1 空 fill_id 去重 空 fill_id 导致多条 fill 共用一个 key,少计 _on_order_filled_event 中对空 fill_id 使用备用 key(如 f"oid:{oid}:px:{event.filled_price}:sz:{event.filled_qty}" 或带时间戳)或拒绝并打日志
P2 重连补查范围 仅 PENDING 且 _ws_status is None 才补查,宽限期内的单不补查 可选:扩展条件为「PENDING 且尚未 resolve」或缩短宽限期;在修好 P0 后此类情况会减少

建议先做 P0:在 realtime 服务创建交易 WS 时注入 executor 的 _event_bus,并让 EnhancedWebSocketManager 支持可选 event_bus 参数;再在 WebSocketOrderManager 侧对空 fill_id 做防护(P1)。

Read more

跑步的技巧(滚动落地)

“滚动落地(rolling contact / rolling foot strike)”不是一种教条式的“脚法”,而是一种 让冲击沿着整只脚、整条后链逐级传递的落地机制。 它的核心不是“你先用哪儿着地”,而是: 你的脚落地之后,冲击是不是像轮子一样滚过去,而不是像锤子一样砸下去。 这就是滚动落地的本质。 一、什么叫“滚动落地”? 你可以把它理解成两种完全不同的落地方式: 1. 砸地(撞击式) 脚像锤子一样拍到地上: * 要么后跟先砸 * 要么前掌先戳 * 冲击集中在一个点 * 一个结构瞬间吃掉大部分载荷 结果就是: * 后跟砸 → 膝盖难受 * 前掌戳 → 前脚掌磨烂 * 都不是长跑友好模式 这叫 撞击式着地(impact strike)。 2. 滚地(滚动式) 脚像轮胎一样“滚”过地面: * 不是某一点硬砸 * 而是外侧中足先轻触 * 再向前滚到前掌 * 最后从大脚趾蹬离

By SHI XIAOLONG

AMI的优越性

世界模型(World Models)的具体例子 如下,我按类型分类,便于理解。每类都附带实际实现、演示效果和应用场景。 1. Yann LeCun / Meta 的 JEPA 系列(最直接对应“世界模型”概念) 这些是 LeCun 主张的非生成式抽象预测世界模型代表。 * I-JEPA(Image JEPA,2023) 输入一张图像,模型把不同区域(context 和 target)编码成抽象表示,然后预测 target 的表示(不在像素级别重建)。 例子:给定一张遮挡了部分物体的图片,模型能预测“被遮挡物体的大致位置和属性”,构建对物体持久性和空间关系的理解。 这是一个“原始世界模型”,能学习物理常识(如物体不会凭空消失)。 * V-JEPA / V-JEPA 2(Video JEPA,

By SHI XIAOLONG

什么是:“世界模型(World Models)”

世界模型(World Models) 是人工智能领域的一个核心概念,尤其在 Yann LeCun 等研究者推动的下一代 AI 架构中占据中心位置。它指的是 AI 系统在内部构建的对现实世界的抽象模拟或内部表示,让机器能够像人类或动物一样“理解”物理世界、预测未来、规划行动。 简单比喻 想象你闭上眼睛也能“看到”房间里的物体会如何移动、碰撞或掉落——这就是你大脑里的世界模型。AI 的世界模型就是类似的“数字孪生”(digital twin)或“内部模拟器”:它不是简单记住数据,而是学习世界的动态、因果关系和物理直觉(如重力、物体持久性、遮挡、因果等)。 为什么需要世界模型? 当前主流的大型语言模型(LLM) 擅长处理文本(统计模式预测),但存在根本局限: * 缺乏对物理世界的真正理解 → 容易“幻觉”、无法可靠规划。 * 样本效率低 → 人类/

By SHI XIAOLONG

K线周期可配置化设计方案

K线周期可配置化设计方案 1. 背景与目标 当前 Beta 套利策略的 K 线周期硬编码为 "1h",分散在多个文件中。需要: 1. 将 K 线周期从 1h 改为 2h 2. 提取为环境变量 BETA_ARB_KLINE_INTERVAL,使其可在 .env 中配置 2. 影响范围分析 2.1 需要修改的文件(共 6 个) 文件 硬编码位置 修改内容 src/trading/config.py BetaArbConfig dataclass 新增 kline_interval 字段,

By SHI XIAOLONG