ek_ui/render.rs
1//! 唯一渲染入口(L2):真实 eframe App 与 kittest 建构走同一个 `render_body`。
2//!
3//! 布局 v7(0.4.1 BD-UI-54:拆停靠库、回归原生容器;蓝本 = Python 主窗 mainwindow.py):
4//! **TopBottomPanel(菜单) → TopBottomPanel(行情带) → SidePanel(下单) →
5//! CentralPanel(数据区 2×2 = 薄 QSplitter 两刀) → Window 弹窗**。
6//! - 行情带 = 六所固定 tab 条(`state::MARKET_ORDER`,用户裁定「每个交易所都要一个」;
7//! 标签 = 交易所**中文名**,条在**表之下**且先给它预留高度不许外溢 —— 九期 BD-UI-62)
8//! 加当前所的行情表;每个所都有自己的表与空态。只有 tick 表,没有按所的滚动表
9//! —— 唯一源 = `eTick.` 订阅流,不从 bar 回。行内任意格单击 = 带入下单面板
10//! (ek 增值,方案钉:盘口四列带方向,买1 价/量 → 卖,卖1 价/量 → 买,价格列
11//! 顺带填价,其余列方向保持默认 —— 0.2.1 `import_tick`),双击 = 弹 K线窗。
12//! - 下单侧(`SidePanel::left`,缺省 300 ≈ Python `setFixedWidth(300)`):下单面板
13//! (Python TradingWidget 等价:9 字段 + 委托 + 全撤;表单 = 网格,按钮/提示语都是
14//! 网格行;网格后置 err label 由 ScrollArea 吸收 sizing 退让,BD-UI-27)+
15//! 盘口(买5卖5,Python TradingWidget 内序:字段钮 → 盘口)。
16//! - 数据区组容器:委托|未成交 / 成交 / 持仓 / 资金|日志 四组(Python 四个 QTabWidget
17//! 等价,tab 条 = 自绘 `tab_label`),2×2 两刀 = `crate::splitters`(份额可拖,
18//! 态在 `shared.data_split`,恢复布局回 50:50);撤单钮仅活动行,既有 s11 钉口径;
19//! 委托行双击 = 撤单,Python OrderMonitor 等价;格内宽表走横向滚动,D7 口径)。
20//! - 弹窗两式(BD-UI-32):运维窗(菜单「运维」:插件/服务/依赖;0.2.10 起
21//! 流控查询钮随 sim 退场撤除)、
22//! CTP 配置窗(菜单「网关」,CTP 插件自己的界面)= egui::Window 依附主窗;
23//! 查询合约窗(菜单「查询合约」:查询 + 勾选 + 订阅钮,Python ContractManager
24//! 等价)、K线窗(双击弹出,按合约多开)= 独立 OS 窗(show_viewport_immediate,
25//! 原生最小化/最大化/关闭,可拖出主窗;后端不支持多窗自动回退 egui::Window,
26//! kittest 走回退面断言)。
27//! - 订阅两入口(用户裁定,网关窗不定死订阅):下单面板代码框**回车**订阅
28//! (Python returnPressed 等价);查询合约窗**勾选订阅**。合约数据 =
29//! `eContract.` 自动回流(ek-ctp 登录后自动查询,UI 只收不催)。
30//! - 回灌表单与票据文本框已退役(界面面);总线口(`UiCmd::Reload` 等)保留。
31//!
32//! kittest 断言面:各单元格独立 Label(`get_by_label` 直查);操作走
33//! `push_cmd` 入队(ui 插件 eTimer 辞行出队),确认状态就地翻位,零自制通道。
34//! 隔离红标:行状态含 Quarantin(快照扫描,BD-UI-17)。
35
36use ek_data::constant::{Direction, Offset, OrderType};
37use ek_station::SVCTL_NAME;
38use ek_station::wire::PlugRow;
39
40use crate::plugin::UI_NAME;
41use crate::state::{
42 BottomRightTab, CellView, ConfirmStep, TopLeftTab, UiCmd, UiShared, beijing_tz, is_quarantined,
43};
44
45/// 取消待确认按钮标签。
46pub const BTN_CANCEL_CONFIRM: &str = "取消确认";
47/// 下单提交按钮标签(v4 = Python「委托」钮)。
48pub const BTN_SEND_ORDER: &str = "委托";
49/// 全撤按钮标签(v4;活动委托逐个走既有撤单 ask)。
50pub const BTN_CANCEL_ALL: &str = "全撤";
51/// 撤单按钮前缀(S5;行级标签 = `撤单 {orderid}`)。
52pub const BTN_CANCEL_ORDER: &str = "撤单";
53/// 账户面板:添加账户钮(派生注册名 → svctl.start + {gw}.configure)。
54pub const BTN_ACCOUNT_ADD: &str = "添加账户";
55/// 菜单项:运维(弹运维窗)。
56pub const MENU_OPS: &str = "运维";
57/// 菜单项:账户(弹账户面板;多账号面入口,规划 §5.B。旧「网关」单账号窗
58/// 已退役收纳进账户面板的添加/编辑表单,旧常量随之删除)。
59pub const MENU_ACCOUNTS: &str = "账户";
60/// 菜单项:帮助。
61pub const MENU_HELP: &str = "帮助";
62/// 菜单项:查询合约(弹查询合约窗;Python ContractManager 等价)。
63pub const MENU_CONTRACTS: &str = "查询合约";
64/// 菜单项 → 弹窗入口钮(BD-UI-31 一键直达:菜单钮即入口,一步弹窗,
65/// 不再挂下拉层;入口钮标签 = 菜单名本身)。
66/// 查询合约窗订阅钮(勾选集 → ask ctp.subscribe)。
67pub const BTN_SUBSCRIBE_SELECTED: &str = "订阅选中";
68/// 运维窗:装配显形手动重问钮(0.5 M3 —— 管线读数改吃事件后唯一的手动口子)。
69pub const BTN_PIPELINE_REFRESH: &str = "重问管线";
70/// 运维窗「配置托底」节:段目录刷新钮(0.6.0 环节8)。
71pub const BTN_CFG_REFRESH: &str = "刷新段落目录";
72
73/// F4 口径句(0.2.20,D-UI-F4-SCOPE):账户面板底部与配置弹窗**共用这一条常量**。
74/// 两处各写一遍字面量 = 将来不同式的坑(s57 数的是"两处都在")。
75pub const TXT_PRODUCT_CLASS_SCOPE: &str = "收录勾选只管该网关自己收录并上抛的合约;公用合约表 = 在场各网关的并集(合约与行情公用,规划 D3)。改勾选须『连接/重试』才下发到网关。";
76
77fn remove_button_label(name: &str, armed_on: Option<&str>) -> String {
78 if armed_on == Some(name) {
79 format!("确认移除 {name} ?")
80 } else {
81 format!("移除 {name}")
82 }
83}
84
85/// 订阅路由(规划 §5.C):行情订阅一律发往**行情元账号**。
86///
87/// 未指定行情源时回 `Err` —— 不静默发给某个从账号(纯 TD 账号收到订阅会
88/// 恒 `ok:true` 但永远不来 tick,是观测黑洞)。
89fn subscribe_target(shared: &UiShared) -> Result<String, String> {
90 let md = shared.md_source();
91 if md.is_empty() {
92 return Err("未指定行情源:账户面板点某账户的『设为行情源』后再订阅".to_string());
93 }
94 Ok(md)
95}
96
97fn state_text(r: &PlugRow) -> String {
98 r.state.clone()
99}
100
101/// 运维窗「统计」列的颜色(0.4.5 P7d 首发;0.5 M6 加容量参数;0.7.0 背压刀改吃水位)。
102///
103/// 新口径(随 ek-core 0.5.0 无界邮箱):判据的**主角是积压**(`pending`),
104/// 阈值吃**这一行自己的软顶**(`soft_cap`,由 ek-station 0.4.0 随快照带来):
105/// - `panics > 0` / `spilled > 0`(已触顶丢新帧)/ 积压越红阈 → ERROR;
106/// - 积压越黄阈 → WARN;
107/// - 全 0 → MUTED(这一格的意思是「没事」,不是数据)。
108///
109/// 软顶必须传进来:界面自己 10 万、网关吃缺省 262144,同一根绝对线在一边是
110/// 「快炸了」在另一边是「刚起步」(阈值口径见 `state::pending_thresholds`)。
111/// 公开是为了让这一判据可钉 —— 颜色本身在 kittest 里只能靠形状颜色判,
112/// 把决策抽成纯函数才能直接断言。
113pub fn stat_color(
114 theme: crate::tokens::Theme,
115 spilled: u64,
116 panics: u64,
117 pending: u64,
118 soft_cap: u64,
119) -> egui::Color32 {
120 let (warn, crit) = crate::state::pending_thresholds(soft_cap);
121 let s = crate::tokens::semantic_of_theme(theme);
122 if panics > 0 || spilled > 0 || pending >= crit {
123 s.error
124 } else if pending >= warn {
125 s.warn
126 } else {
127 s.muted
128 }
129}
130
131// 0.3.1(Wave D,BD-UI-49):时间列格式收进 `crate::format::time_hms_millis`(`HH:MM:SS.mmm`)。
132// 口径没变:北京时间 +08,数据面时间戳统一存 UTC 纳秒 —— CTP 回报的自然日本就是北京钟面,
133// 入账按 +08 换算存 UTC,展示面换回来,表内时间列与交易员作息同钟面,且与日志同源。
134
135// 展示面统一时区 = `crate::state::beijing_tz`(0.2.27 提到 state:日志入环打戳
136// 与表格时间列必须同一个口径,一份实现两处共用)。这里不留 doc comment ——
137// 它后面没有 item,clippy `empty_lines_after_doc_comment` 正是钉这种。
138
139// ---- BD-UI-31(R3)行高亮:由表格层承担(0.2.29 BD-UI-44 定口径,0.4.1 BD-UI-55 换库)----
140// 原来这里有两支手绘助手:`paint_row_bg`(行底色 = 各格响应矩形并集 + 硬编码半透明蓝)
141// 和 `click_cell`(在标签矩形上叠一层点击感应)。两支助手在 BD-UI-44 撤除:底色改吃主题
142// (`visuals.selection.bg_fill` / `widgets.hovered.bg_fill`,整行连续),格可点 = 表格层
143// 自己给的 Response。BD-UI-55 迁 egui_table 之后这条口径没变,只是实现搬到 delegate 的
144// `row_ui`(选中 / 悬停底色,行带全宽)与 `pin_cell`(格点击感应)。行底色仍跟主题
145// (0.2.27 斑马纹同口径:唯一主题下 `visuals.striped = false`,不许硬开)。
146
147/// 委托是否可撤(与 ek-data ACTIVE_STATUSES 同口径)。
148fn order_active(status: ek_data::constant::Status) -> bool {
149 ek_data::constant::ACTIVE_STATUSES.contains(&status)
150}
151
152/// 行情带入(0.2.1 扩展):任意列单击 = 带入合约+交易所;盘口四列带方向
153/// (买1价/买1量 → 卖,卖1价/卖1量 → 买 —— 吃对手挂价口径),两个价格列
154/// 顺带把该价填进价格格;其余列方向/价格保持表单默认(用户裁定)。
155pub fn import_tick(shared: &UiShared, t: &ek_data::tick::TickData, exchange: &str, col: usize) {
156 let mut f = shared.order_form();
157 f.symbol = t.symbol.clone();
158 f.exchange = exchange.to_string();
159 match col {
160 8 => {
161 f.direction = Direction::SHORT;
162 f.price = crate::format::price(t.bid_price_1);
163 }
164 9 => f.direction = Direction::SHORT,
165 10 => {
166 f.direction = Direction::LONG;
167 f.price = crate::format::price(t.ask_price_1);
168 }
169 11 => f.direction = Direction::LONG,
170 _ => {}
171 }
172 shared.set_order_form(f);
173}
174
175/// 按合约找最新 tick(下单面板名称/盘口/随价共用)。
176/// 交易所非空 = 精确 EX.symbol 匹配(跨所同码不串);空 = 仅按代码找。
177fn tick_of(shared: &UiShared, exchange: &str, symbol: &str) -> Option<ek_data::tick::TickData> {
178 if symbol.is_empty() {
179 return None;
180 }
181 shared.tick_rows().into_iter().find(|t| {
182 t.symbol == symbol
183 && (exchange.is_empty() || t.exchange.as_str().eq_ignore_ascii_case(exchange))
184 })
185}
186
187/// 字号 + 间距 + 控件规格 + 主题视觉(0.2.30 起全部走 `crate::tokens`;主题只有一套
188/// Qt深色,`Theme` 枚举与菜单循环钮已删 —— 裁定 8)。真实 App、独立子窗(immediate
189/// 共享同一 Context)、kittest 三处同源。
190/// 语义色(涨红跌绿 / 多红空绿 / 警告橙 / 错误深红 / 成功深绿 / 次级灰)**不在这一层**:
191/// 它们在 `tokens::semantic` 里恒定 —— 0.8.0 的口径是「**hue 恒定、明度跟档**」
192/// (判据 `u11` 钉着:浅档也不许把跌染成蓝),渲染侧走 `tokens::rise(ctx)` 等访问器取当前档。
193pub fn apply_ui_style(ctx: &egui::Context, theme: crate::tokens::Theme) {
194 ctx.style_mut(|style| {
195 crate::tokens::apply(style);
196 });
197 // 0.8.0 双档:档写进 Context::data(渲染侧取色访问器的唯一读源)+ 装这一档的 Visuals。
198 crate::tokens::set_theme(ctx, theme);
199 ctx.set_visuals(crate::tokens::visuals_for(theme));
200}
201
202/// 表格与页签的「chrome」配色(表头带、分隔线、tab 头底、选中 tab 下划线)。
203///
204/// 为什么要有这个结构:shadcn 有「表头带底」(`secondary` `#262626`)和「选中 tab 底 +
205/// 下划线」这两个概念,Python 侧对应 qdarkstyle 的 `QHeaderView::section`
206/// (表头带底 `#455364`)与 `QTabBar::tab:top:selected`(选中 tab `#54687A` 底 + 3px
207/// `#259AE9` 下划线),**egui 的 `Visuals` 里没有对应字段**(它只有 `selection.bg_fill`
208/// 一根,且 `selectable_label` 只能整块填充)。所以这一层只能在渲染侧直绘。
209///
210/// 取色口径(审计「多余」条):不新造颜色,全部从主题**已经声明过**的字段里取 ——
211/// 带底取 `widgets.inactive.bg_fill`,描边取 `noninteractive.bg_stroke`,表头文字取
212/// `noninteractive.fg_stroke`,选中 tab 底取 `widgets.hovered.bg_fill`,下划线取
213/// `hyperlink_color`。0.2.30 起主题只有一套,原来「按主题分叉」的那条 match 随之消失。
214///
215/// 0.4.1 四期(BD-UI-57)拆掉一根旧耦合:旧 qdark 里 `BG4` **同时**是表头带底和一切描边
216/// (`noninteractive.bg_stroke` = `#455364` = 带底),所以 `line` 一支两用。Nova 把这两件事
217/// 分成 `secondary` `#262626`(带底)与 `border`(白 10%,一切描边)→ 于是多出 `band_fill`
218/// 这一支,`line` 只管线不管底。
219///
220/// 0.4.0 期间 tab 那四支随「组内二级 tab 条撤除、tab 归 dock」删过一轮;0.4.1
221/// (BD-UI-54)tab 形态回归原生(自绘 `tab_label`),四支原样归位 —— 派生路径
222/// (同一份 `visuals`,`s67` 钉住)不变。
223#[derive(Clone, Copy)]
224struct Chrome {
225 /// 一切分隔线 / 网格线 / 行线 / 窗框(1px)。旧口径这一支兼做表头带底,现已拆开。
226 line: egui::Color32,
227 /// 表头带底 + 未选中 tab 的头底。
228 band_fill: egui::Color32,
229 /// 表头带文字。
230 header_text: egui::Color32,
231 /// 选中 tab 的底。
232 tab_fill: egui::Color32,
233 /// 选中 tab 的文字。
234 tab_text: egui::Color32,
235 /// 选中 tab 的下划线(qss 3px 那支)。
236 tab_underline: egui::Color32,
237}
238
239impl Chrome {
240 /// 从当前 visuals + 当前档派生(0.8.0 双档:派生规则唯一,只是入参多了一个档)。
241 ///
242 /// 0.8.0 新增的口径:**表头文字走次级色 `text3`**(参考站 `th{color:var(--st-ink-muted)}`
243 /// 口径,也是裁定 C 引入三层文字后的一层落点)。旧口径表头文字 = `noninteractive.fg_stroke`
244 /// = 正文色,与表体同色 = 层级塌一档。
245 fn of(v: &egui::Visuals, theme: crate::tokens::Theme) -> Self {
246 Self {
247 line: v.widgets.noninteractive.bg_stroke.color,
248 band_fill: v.widgets.inactive.bg_fill,
249 header_text: theme.palette().text3,
250 tab_fill: v.widgets.hovered.bg_fill,
251 tab_text: v.widgets.hovered.fg_stroke.color,
252 tab_underline: v.hyperlink_color,
253 }
254 }
255}
256
257/// 页签(BD-UI-41,对照 qdarkstyle `QTabBar::tab:top`)。
258///
259/// Python 侧四个区全是 QTabWidget(`mainwindow.py:106-204`,连只有一个 tab 的
260/// 「成交」「持仓」也带 tab 头),qss 给 tab 的形态是:
261/// 未选中 `QTabBar::tab:top { background #455364; padding 2px 4px }` +
262/// `!selected { border-bottom: 2px solid #19232D }`(qss:1579 / 1559)
263/// 选中 `QTabBar::tab:top:selected { background #54687A;
264/// border-bottom: 3px solid #259AE9; 上圆角 4px }`(qss:1592)
265/// egui 的 `selectable_label` 只有「整块 selection 填充」,画不出下划线,也没有
266/// 「未选中也有头底」这一层。所以这里照 pinned_table 表头带同一套路子:
267/// **控件仍走 selectable_label**(可访问性标签 / 点击 / 键盘都不换),只是随后用
268/// painter 盖上头底 + 下划线,并重画文字(epaint 0.33 没有 z-order,后画的填充
269/// 会盖住先画的文字,所以文字必须重画 —— 与表头带同一处理)。
270fn tab_label(ui: &mut egui::Ui, selected: bool, text: impl Into<String>) -> egui::Response {
271 let ch = Chrome::of(ui.visuals(), crate::tokens::theme_of(ui.ctx()));
272 let text: String = text.into();
273 let resp = ui.selectable_label(selected, text.clone());
274 let r = resp.rect;
275 let radius = ui.visuals().widgets.inactive.corner_radius;
276 let font = ui.style().text_styles[&egui::TextStyle::Button].clone();
277 let p = ui.painter();
278 let (fill, ink, underline) = if selected {
279 (
280 ch.tab_fill,
281 ch.tab_text,
282 egui::Stroke::new(3.0_f32, ch.tab_underline), // qss 的 3px 那支
283 )
284 } else {
285 (
286 ch.band_fill,
287 ch.header_text,
288 egui::Stroke::new(2.0_f32, ch.line), // 未选中 tab 的 2px 下边线
289 )
290 };
291 p.rect_filled(r, radius, fill);
292 p.hline(r.x_range(), r.max.y, underline);
293 p.text(
294 r.center(),
295 egui::Align2::CENTER_CENTER,
296 text.as_str(),
297 font,
298 ink,
299 );
300 resp
301}
302
303/// 普通 Grid 的表头带(BD-UI-41)。
304///
305/// 与 `pinned_table` 的覆盖带同一套路子:头行照常在 grid 里占格(列宽由它量出来,
306/// 这是唯一权威源),随后 painter 盖上带底 + 下边线并重画文字(epaint 0.33 无 z-order,
307/// 填充盖字 → 文字必须重画)。
308///
309/// 为什么这三处不走 `pinned_table`:它们是**自动尺寸浮动窗里的短表**(账户清单 /
310/// 运维插件表 / 服务目录)。0.2.17 实锤(s39):`pinned_table` =
311/// `auto_shrink(false)` 滚动区吃满整块可用高 + 覆盖式表头带,在自动尺寸浮动窗里
312/// 两者凑不出正确高度 → 表行与其后的口径句互相压字。账户行最多几个,不需要固定
313/// 表头滚动面,只要那根带。
314///
315/// 0.2.29(BD-UI-44)把这条边界写死:数据监控表(行情/委托/成交/持仓/日志/合约/资金)
316/// 一律走表格层(0.4.1 BD-UI-55 = egui_table 的 `pinned_table`);自动尺寸浮动窗里的
317/// 短表一律 Grid + 这根带。资金表原来在第三类里,实测它和日志表共用同一块 tab 容器
318/// (不是浮动窗)→ 已并入表格层一侧。
319fn header_band(
320 ui: &mut egui::Ui,
321 heads: &[(egui::Rect, String)],
322 content_right: f32,
323) -> egui::Rect {
324 if heads.is_empty() {
325 return egui::Rect::NOTHING;
326 }
327 let ch = Chrome::of(ui.visuals(), crate::tokens::theme_of(ui.ctx()));
328 // 带的横向范围 = **整行**(这一格 / 这一窗的可用宽),不是表头文字矩形的并集。
329 // 根因(0.2.28 用户实看指出「运维窗表头背景没按整行、最后一列只有文字有背景」):
330 // `Response::rect` 是控件自己的矩形,不是列框(grid.rs:180-193 —— `next_cell`
331 // 给出列框,`align_size_within_rect` 按 LEFT_CENTER 对齐后返回子控件尺寸)。
332 // 表头 label 的 rect 宽 = 文字宽。原来按表头 rect 的并集算带 → 带只盖到
333 // 最后一列**表头文字**的右端,列内比它宽的部分(运维窗『操作』列的两个按钮、
334 // 服务目录的空实例列、资金格右侧)没有带 = 看上去断开一截。
335 // 口径照 Python:QHeaderView 铺满整个表视口;也与 `pinned_table` 那条带一致
336 // (那条铺的是 ScrollArea 的 inner_rect = 整格宽)。
337 let left = ui.max_rect().min.x;
338 // 0.2.30(BD-UI-47):带的右端取「可用宽」与**表体实际右端**的较大者。
339 // 浮动窗是自动尺寸的,而 `header_band` 在 Grid 之后才画 —— 令牌把控件交互宽
340 // 从 egui 缺省 128 收到 40 后,窗内 Grid 的实际宽度比窗的可用宽更宽(s69 实测
341 // 带 640 / 体表 727),带就盖不住最后一列。口径不变:带必须盖住整行。
342 let right = ui.max_rect().max.x.max(content_right);
343 // 带高与表格层**同一个数**(0.4.1 八期 BD-UI-61,用户问「表头的高度都一样吗」):
344 // 表格层带高 = 表头行高 `head_h`(26)+ `clip_rect_margin`(3)= 29;短表层原来取
345 // 「文字高 + 上下各半间距」= 22 → 同一屏里菜单窗的表头比主窗矮 7 px(探针实测 22.0 vs 29.0)。
346 // 现在按同一条公式算,并以**表头行的垂直中心**为带中心 → 带高一致、文字在带里居中。
347 let head_h = table_heights(ui).1;
348 let band_h = head_h + ui.visuals().clip_rect_margin;
349 let mid = heads[0].0.center().y;
350 let top = mid - band_h * 0.5;
351 let bottom = mid + band_h * 0.5;
352 let strip = egui::Rect::from_min_max(egui::pos2(left, top), egui::pos2(right, bottom));
353 let p = ui.painter();
354 p.rect_filled(strip, 0.0, ch.band_fill);
355 p.hline(
356 strip.x_range(),
357 strip.max.y,
358 egui::Stroke::new(1.0_f32, ch.line),
359 );
360 let font = ui.style().text_styles[&egui::TextStyle::Small].clone();
361 // 表头文字的锚定线 = **带的垂直中心**(0.4.1 七期 BD-UI-60)。旧口径取 galley 中心
362 // `(top + heads[0].0.max.y)/2`,比带中心高 2.5 px → 文字在带里偏上(实测上隙 4.5 / 下隙 8.5)。
363 let mid_y = (strip.min.y + strip.max.y) * 0.5;
364 for (rect, text) in heads {
365 p.text(
366 egui::pos2(rect.min.x, mid_y),
367 egui::Align2::LEFT_CENTER,
368 text.as_str(),
369 font.clone(),
370 ch.header_text,
371 );
372 }
373 strip
374}
375
376/// 判据侧读口(0.4.1 七期 BD-UI-60):这张表这一拍的「列宽总和」与「补宽目标宽」。
377///
378/// 目标宽 = 所在区域可用宽 − 这张表自己的滚动条占位。判据钉的是「补过之后 Σ ≥ 目标 9 成」
379/// —— 表宽 = 所在区域 100% 这条裁定在 kittest 里唯一不靠猜的读法(列线撤除后,列边界
380/// 在形状表里已经没有落点了)。
381pub fn table_fill_probe(ctx: &egui::Context, table_id: &str) -> (f32, f32) {
382 let fill_id = egui::Id::new(("table_fill", table_id));
383 ctx.data(|d| {
384 (
385 d.get_temp::<f32>(fill_id.with("stored")).unwrap_or(0.0),
386 d.get_temp::<f32>(fill_id).unwrap_or(0.0),
387 )
388 })
389}
390
391/// Grid 短表的网格线(0.4.1 五期 BD-UI-58,用户裁定「网格线在黑色背景下反而显得整齐」
392/// → 表格层与短表层同一口径:每行一根行线、每两列一根列线)。
393///
394/// - 行线 = 这一行内容底沿往下半个 `item_spacing.y`。Grid 的行间距就是 `item_spacing`
395/// (grid.rs:113 / 432),半个间距 = 两行正中;最后一行的行线就是这张表的底边线,
396/// 与 `pinned_table` 里「行线画在行底」同一条不变式(那边行间距为 0)。
397/// - 列线 = 第 2..n 列表头矩形的左沿往左半个 `item_spacing.x`。Grid 格内是 LEFT 对齐
398/// (`align_size_within_rect`),控件左沿就是列左沿 → 半个间距正是两列正中。
399/// - 表头行那根下边线由 `header_band` 画,这里不重复画第二根。
400///
401/// `row_bottoms` = 各**表体行**在 `end_row` 前测到的 `ui.min_rect().max.y`。空态(0 行)
402/// 时它是空的:没有行线可画,列线只到表头带底(0.4.1 六期 BD-UI-59 起空态不画提示行,短表空态
403/// = 只有表头那一行)。
404fn grid_chrome(
405 ui: &egui::Ui,
406 band: egui::Rect,
407 heads: &[(egui::Rect, String)],
408 row_bottoms: &[f32],
409) {
410 if !band.is_positive() || heads.is_empty() {
411 return;
412 }
413 let ch = Chrome::of(ui.visuals(), crate::tokens::theme_of(ui.ctx()));
414 let sp = ui.spacing().item_spacing;
415 let p = ui.painter();
416 for &rb in row_bottoms {
417 p.hline(
418 band.x_range(),
419 rb + sp.y * 0.5,
420 egui::Stroke::new(1.0_f32, ch.line),
421 );
422 }
423 // 列线(0.4.1 七期 BD-UI-60,用户裁定「表格里所有的列分割线都去掉,只要行的分割线」):
424 // 短表层这套自绘列线直接撤除,`heads` 从此只用来判「有没有表头」与定带的宽。
425}
426
427/// 画一窗(官方面板组合:render_body 直接开顶层面板,不自嵌 CentralPanel)。
428///
429/// v7 框架(0.4.1,BD-UI-54):TopBottomPanel(菜单) → TopBottomPanel(行情带) →
430/// SidePanel(下单)| CentralPanel(数据区 2×2 薄 QSplitter) → 弹窗。
431/// 0.4.0 的整窗 dock 拆除。官方纪律(panel.rs 模块文档):顶层面板不得互相嵌套、
432/// CentralPanel 最后加、Window 挂在所有面板之后。
433pub fn render_body(ctx: &egui::Context, shared: &UiShared) {
434 apply_ui_style(ctx, shared.theme());
435 // 0.3.1(Wave D,BD-UI-49)退出确认:关窗先问一句(照 Python `closeEvent`)。
436 // 拦关闭用的是 egui 0.33 的 `ViewportCommand::CancelClose`;用户在窗里点「确认退出」
437 // 才置放行位并重发 `Close` —— 否则确认完也关不掉。
438 let close_requested = ctx.input(|i| i.viewport().close_requested());
439 if close_requested && !shared.exit_confirmed() && !shared.exit_confirm_open() {
440 ctx.send_viewport_cmd(egui::ViewportCommand::CancelClose);
441 shared.open_exit_confirm();
442 }
443 // 0.3.2(Wave E,BD-UI-50)告警 toast 每帧收口(队列常驻在 UiShared,不是这里的局部变量)。
444 crate::toast::drain_and_show(ctx, shared);
445 if shared.exit_confirm_open() {
446 egui::Window::new("退出确认")
447 .collapsible(false)
448 .resizable(false)
449 .show(ctx, |ui| {
450 ui.label("确认退出 ek-ui?");
451 ui.horizontal(|ui| {
452 if ui.button("取消").clicked() {
453 shared.close_exit_confirm();
454 }
455 if ui.button("确认退出").clicked() {
456 shared.confirm_exit();
457 shared.close_exit_confirm();
458 ctx.send_viewport_cmd(egui::ViewportCommand::Close);
459 }
460 });
461 });
462 }
463 // ---- 菜单栏(顶层面板,最先 = 最外) ----
464 egui::TopBottomPanel::top("menu_bar").show(ctx, |ui| {
465 render_menu_bar(ui, shared);
466 });
467
468 // ---- 上带:行情带(全宽独占,可拖分隔条;缺省高 = Python v_splitter 30:70 分带) ----
469 egui::TopBottomPanel::top("market_band")
470 .resizable(true)
471 .default_height(crate::tokens::MARKET_BAND_HEIGHT)
472 .show(ctx, |ui| {
473 // 外层 ScrollArea auto_shrink(false) = resizable 面板吃满前提(BD-UI-27
474 // 口径;s3 实锤:撤掉后空态带塌成一行,2×2 行位全漂移)。内层
475 // pinned_table 自己会收缩适配 → 外层滚动条永不出现。
476 egui::ScrollArea::both()
477 .id_salt("market_band_scroll")
478 .auto_shrink([false, false])
479 .show(ui, |ui| {
480 render_market_band(ui, shared);
481 });
482 });
483
484 // ---- 下带左侧:下单面板 + 盘口(Python TradingWidget setFixedWidth(300)) ----
485 egui::SidePanel::left("order_side")
486 .resizable(true)
487 .default_width(crate::tokens::ORDER_SIDE_WIDTH)
488 .show(ctx, |ui| {
489 // ScrollArea 吸收 sizing 退让(BD-UI-27):网格后置 err label 不再叠回网格
490 egui::ScrollArea::vertical()
491 .id_salt("order_side_scroll")
492 .auto_shrink([false, false])
493 .show(ui, |ui| {
494 render_order_panel(ui, shared);
495 ui.separator();
496 render_book_frame(ui, shared);
497 });
498 });
499
500 // ---- 下带右侧:数据区 2×2(薄 QSplitter 两刀;份额可拖,态在 UiShared) ----
501 egui::CentralPanel::default().show(ctx, |ui| {
502 render_data_area(ui, shared);
503 });
504
505 // ---- 弹窗面(官方口径:Window 在顶层面板之后) ----
506 render_windows(ctx, shared);
507}
508
509/// 行情带 = 当前所的行情表 + 六所固定 tab 条(0.4.1 BD-UI-54 回归原生容器;
510/// 「每交易所一格」= 六个 tab,每个 tab 都有自己的表与空态,s73 口径不变)。
511///
512/// 0.4.1 用户裁定(2026-10-22):**tab 条放在表下面**(原来在表上面)。
513/// 这是对 Python 侧 `QTabWidget` 缺省 tabPosition=North 的一处偏离,记 DESIGN。
514/// 判据面不受影响:六所 tab 序钉(V2)与「行情带横跨全宽」钉(s3)取的都是
515/// tab 标签在场 + 格内容左沿/高度关系,与 tab 条在表的哪一侧无关。
516/// 交易所 tab 名 = **中文名**(0.4.1 九期 BD-UI-62,用户裁定「不要显示交易所的代码,
517/// 而是显示交易所的名字」)。叫法照 Python 侧(`xt_gateway.py:1089-1094` 与
518/// `datafeed/ak/futures_member_pos.py:14-19` 的映射:中金所=CFFEX / 上期所=SHFE /
519/// 郑商所=CZCE / 大商所=DCE / 广期所=GFEX,INE = 能源中心)。
520pub fn exchange_tab_name(ex: ek_data::constant::Exchange) -> &'static str {
521 use ek_data::constant::Exchange as E;
522 match ex {
523 E::SHFE => "上期所",
524 E::DCE => "大商所",
525 E::CZCE => "郑商所",
526 E::CFFEX => "中金所",
527 E::GFEX => "广期所",
528 E::INE => "能源中心",
529 // 行情带只有上面六所(`state::MARKET_ORDER`);其余变体回落线上代码。
530 other => other.as_str(),
531 }
532}
533
534fn render_market_band(ui: &mut egui::Ui, shared: &UiShared) {
535 let active = shared.selected_exchange();
536 let active_ex = crate::state::MARKET_ORDER
537 .iter()
538 .copied()
539 .find(|e| e.as_str() == active)
540 .unwrap_or(crate::state::MARKET_ORDER[0]);
541 // **先给 tab 条留出高度,再让表吃剩下的**(0.4.1 九期 BD-UI-62,用户实看:「表格被下面
542 // 标签给挡住了,只有滚动才能看到」)。根因:表(内层 ScrollArea)先分配 = 把整块面板高
543 // 吃干,tab 条排在它后面就被推到面板底边之外(探针实测 1280×860:面板底 ≈275,
544 // tab 标签落在 y 274..300 = 面板之外,还与数据区「委托」tab 头 278..304 压在一起)。
545 // tab 条是固定条,不该跟表格滚动抢地方。
546 // 预留高度照 `tab_label` 真正用的那一档:`selectable_label` 走 `TextStyle::Button`
547 // + `button_padding`(不是 Small —— 用 Small 会少算,窗口一窄就又开始外溢)。
548 let tab_h = ui.text_style_height(&egui::TextStyle::Button)
549 + ui.spacing().button_padding.y * 2.0_f32
550 + 4.0_f32;
551 let avail = ui.available_size();
552 let table_rect = egui::Rect::from_min_size(
553 ui.cursor().min,
554 egui::vec2(avail.x, (avail.y - tab_h).max(40.0)),
555 );
556 ui.scope_builder(egui::UiBuilder::new().max_rect(table_rect), |ui| {
557 // 表头带的上隙(`clip_rect_margin`)要在子 ui 里留出地方:子 ui 的 clip = 这块
558 // max_rect,若表从 cursor 顶开始画,带顶那 3 px 会被裁掉(带高 26 而不是 29,
559 // s79「所有表头带同一档」当场红)。
560 ui.add_space(ui.visuals().clip_rect_margin);
561 render_market_pane(ui, shared, active_ex);
562 });
563 ui.horizontal(|ui| {
564 for ex in crate::state::MARKET_ORDER {
565 if tab_label(ui, ex == active_ex, exchange_tab_name(ex)).clicked() {
566 shared.set_selected_exchange(ex.as_str());
567 }
568 }
569 });
570}
571
572/// 数据区 2×2 = 上下(顶部:委托|未成交 | 成交;底部:持仓 | 资金|日志),
573/// 两刀都是可拖的薄 QSplitter(份额在 `shared.data_split`,恢复布局回 0.5)。
574fn render_data_area(ui: &mut egui::Ui, shared: &UiShared) {
575 let split = shared.data_split();
576 // 0.4.1 九期 BD-UI-62:2×2 改走 `splitters::quad`(一根贯穿横线 + 一根贯穿竖线)。
577 // 旧口径 = `split_v` 上下分完再在每排里各来一刀 `split_h` → 「竖刀」实为两条独立线段,
578 // 悬 / 拖只有被碰的那半亮(用户实看)。份额仍是同一对 `DataSplit { row, col }`。
579 crate::splitters::quad(
580 ui,
581 egui::Id::new("ek_data_quad"),
582 split.row,
583 split.col,
584 |row| {
585 shared.set_data_split(crate::state::DataSplit {
586 col: split.col,
587 row,
588 });
589 },
590 |col| {
591 shared.set_data_split(crate::state::DataSplit {
592 col,
593 row: split.row,
594 });
595 },
596 |ui| render_topleft_group(ui, shared),
597 |ui| render_trades_group(ui, shared),
598 |ui| render_positions_group(ui, shared),
599 |ui| render_bottomright_group(ui, shared),
600 );
601}
602
603/// 委托|未成交 组(Python tab_widget1:两 tab 同一容器)。
604fn render_topleft_group(ui: &mut egui::Ui, shared: &UiShared) {
605 let tab = shared.topleft_tab();
606 ui.horizontal(|ui| {
607 if tab_label(ui, tab == TopLeftTab::Orders, TopLeftTab::Orders.label()).clicked() {
608 shared.set_topleft_tab(TopLeftTab::Orders);
609 }
610 if tab_label(ui, tab == TopLeftTab::Active, TopLeftTab::Active.label()).clicked() {
611 shared.set_topleft_tab(TopLeftTab::Active);
612 }
613 });
614 render_orders_table(ui, shared, tab == TopLeftTab::Active);
615}
616
617/// 资金|日志 组(Python tab_widget4;Account 分支 = 0.4.0 修好的「空态带表头」版)。
618fn render_bottomright_group(ui: &mut egui::Ui, shared: &UiShared) {
619 let tab = shared.bottomright_tab();
620 ui.horizontal(|ui| {
621 if tab_label(
622 ui,
623 tab == BottomRightTab::Account,
624 BottomRightTab::Account.label(),
625 )
626 .clicked()
627 {
628 shared.set_bottomright_tab(BottomRightTab::Account);
629 }
630 if tab_label(
631 ui,
632 tab == BottomRightTab::Logs,
633 BottomRightTab::Logs.label(),
634 )
635 .clicked()
636 {
637 shared.set_bottomright_tab(BottomRightTab::Logs);
638 }
639 });
640 match tab {
641 BottomRightTab::Account => render_funds_pane(ui, shared),
642 BottomRightTab::Logs => render_logs(ui, shared),
643 }
644}
645
646// 0.4.1(BD-UI-54):数据区组的容器 = 薄 QSplitter 的两块内容区(sql)。格边框与
647// 分隔线走色板令牌(`splitters::run_split` 只吃 `tokens::shadcn`,V5 钉住);
648// 0.3.0 dock 容器曾接管过这层,0.4.1 拆 dock 后归位。
649// 0.2.30 那条教训仍然成立并记在 DESIGN.md:egui 0.33.3 的 `Frame` 没有 `min_size`,
650// `Frame::paint` 的描边按**内容** min_rect 算(frame.rs:486)——内容少的格边框会跟着缩。
651
652// 表头固定表(BD-UI-34 用户裁定「每个表的表头都要固定」;0.2.29 BD-UI-44 起换成表格库,
653// 0.4.1 BD-UI-55 表格库 = `egui_table 0.7`,用户裁定「表格使用 egui_table」)。
654//
655// 为什么要表格库(实拍毛病 2/3/5,对照 Python 的 QTableView):
656// - **列宽跟内容**:手绘 Grid 的列宽只能取各格 `Response::rect` 的最大值,而
657// `Response::rect` 是控件矩形不是列框(0.2.28 实锤,egui grid.rs:180-193)
658// → 列宽只能"差不多",数字列对不齐。表格库的列宽是库自己量出来的(egui_table:
659// `Column::range` 夹 `max_column_widths`,table.rs:816-843 写回 `ColumnState.width`)。
660// - **表头天生固定**:表头行画在体表滚动区之外(egui_table `Table::show` 先 `header_ui`
661// 再 `SplitScroll`,table.rs:470-537)→ 0.2.8 起那块「ScrollArea 之后重画覆盖带 +
662// 重画表头文字」的 DIY 全撤(当年 DIY 是因为 egui 没有表;scroll_area.rs:412
663// 那句「painting a sticky header on top of it」就是 DIY 的出处)。
664// - **横向溢出**:成交表 14 列比格子宽,Python 出横向滚动条(毛病 5)。egui_table 的
665// `SplitScroll` 自带横 + 纵两条滚动条:表头跟着体表一起横滚(不错位),竖滚仍归表体
666// (表头不动)。
667// - **选中 / 悬停底色吃主题**:egui_table 不提供行选中(全库无 `set_selected`)→ 底色由
668// delegate 的 `row_ui` 自己画,色仍取 `visuals.selection.bg_fill` /
669// `widgets.hovered.bg_fill`,且按行带全宽画 = 整行底色连续
670// → 手绘 `paint_row_bg` 那支硬编码半透明蓝撤掉(与 0.2.27「斑马纹跟主题」同口径)。
671// - **网格线(0.4.1 五期 BD-UI-58 起:全部表统一都有)**:列线 = 可拖列边界那根线
672// (egui_table `Column::resizable` + `chrome().line`),行线 = delegate 每行的行底。
673// 旧口径是「只有合约表开网格」(Python `widget.py:367` 的 `setShowGrid(False)` 只加在
674// 交易表上,合约表 `widget.py:2423`/`2621` 没关,qss `gridline-color:#455364`)——
675// 用户 2026-10-22 实看后裁定撤掉这条分叉:「网格线在黑色背景下比较暗,有横向竖向这些线
676// 反而显得整齐」→ 交易表跟合约表一样都画,`GridLines` 这个开关随之退役。
677//
678// body 闭包在表体内执行(行循环归闭包);行高由本模块统一算,body 只写每格内容。
679// pub(crate):`pinned_table_impl_cols` 是 pub(crate)(日志表字体量宽入口要用)。
680
681/// 行高 / 表头高 = 字号 + 6。Python QTableView 的 sizeHint ≈ 字体高 + 4~6;
682/// 0.2.28 之前 Grid 自然行高在 kittest 实测行间距 21 = 正文 14.7 + 6,同值。
683fn table_heights(ui: &egui::Ui) -> (f32, f32) {
684 let st = ui.style();
685 // 行高必须取「文字高 + 6」与**控件交互高令牌**的较大者。格里有钮 / 勾选框时
686 // 表格层的实际行高 = max(请求值, 格内最高控件):请求值 22 < 实际 26 时,
687 // 行线公式按假行高算 —— 0.2.30 实锤:行线画在 y=514 而第 3 行文字中心在 511
688 // = 0.2.28 治过的毛病 8(行线压到文字中心上)复发。别把这个 max 拆掉。
689 let floor_h = crate::tokens::INTERACT_HEIGHT;
690 (
691 (st.text_styles[&egui::TextStyle::Body].size + 6.0).max(floor_h),
692 (st.text_styles[&egui::TextStyle::Small].size + 6.0).max(floor_h),
693 )
694}
695
696// ================= egui_table 0.7.0 适配层(BD-UI-55,用户裁定「表格使用 egui_table」) =========
697//
698// egui_table 的形制是「拉」:建 `Table`(列/表头/行数)+ `TableDelegate`(表头/行/格的
699// 逐个绘制回调);egui_extras::TableBuilder 的形制是「推」(调用点闭包直接喂行)。
700// 本层把推改成拉:调用点的 body 闭包**原样保留**(行循环 + 每格内容),只是行收进
701// `PinBody`/`PinRow` 的延迟画笔,show 时由 delegate 逐格执行 —— 每张表调用点只多写
702// `selected` 一个参数与 `pin_cell` 一层包装。
703//
704// 每格左内边距 = 6px(egui_table 离 battery 之外不加 margins,old TableBuilder 的
705// item_spacing 缩进由 Frame::inner_margin 补回来,不然文字贴列边框)。
706
707/// 单格延迟画笔(行收集物;腰上 `'b` = pinned_table_impl 的本次调用)。
708/// **FnMut 不是 FnOnce**:egui_table 首帧在同一帧里把每格跑两遍(全量量内容的
709/// invisible sizing pass + 真绘 pass,库自己 `request_discard`)—— FnOnce 在
710/// sizing pass 里就被消费掉,真绘 pass 会全空(0.4.1 实锤:所有格文字消失)。
711/// 格内动作要幂等(select_row/set_order_form 等同帧重放语义不变;egui 的
712/// request_discard 本来就是「整帧重来」)。
713/// 第二个参数 = 这一格的上下文(满格命中层),由 delegate 的 `cell_ui` 造,见 `PinCellCtx`。
714pub(crate) type PinCell<'b> = Box<dyn FnMut(&mut egui::Ui, &PinCellCtx) + 'b>;
715
716/// 一格真实绘制时由 delegate 递给调用点的上下文(BD-UI-55)。
717pub(crate) struct PinCellCtx {
718 /// 满格命中层:在**格那一层**注册的响应(`Ui::interact`,矩形 = 整格)。
719 ///
720 /// 为什么不是 `ui.allocate_rect(ui.max_rect(), ..)`(BD-UI-55 最大拦路虎,已修):
721 /// `allocate_rect` 的口径是「忽略布局,这块地归我」—— 布局 cursor 被推到整格之外,
722 /// 之后格内的内容排到**下一格**去。实锤(临时探针 + vendor 出来的 egui 打点,
723 /// 脚手架已随本次提交拆除,读数留档在交接报告 §4.1 / 交接报告主文 §21.3):
724 /// 格 clip `[901..1001]`,格内 label 的实际矩形 `[1003..1088]` = 错开一整列宽 →
725 /// `Label` 的绘制门 `ui.is_rect_visible(response.rect)` 判假 → 表体文字既不画、
726 /// 也不进语义树。`interact` 不推进布局(ui.rs:1131 只 `create_widget`),
727 /// 满格命中与格内真控件的响应照旧两层并立 = 0.2.29「两边都看」口径不变。
728 ///
729 /// `interact_rect` = 注册处 ui 的 clip ∩ 矩形(ui.rs:1140),所以这颗必须注册在
730 /// **格那一层**(clip = 整格),不能注册在 Frame 内层(clip 已被内边距缩掉 6px)。
731 pub hit: egui::Response,
732}
733
734/// 一行(PinBody 收集物)。行高统一走 delegate 的 `row_h`(`table_heights`),
735/// egui_table 的行是相邻接等高带 —— `body.row(h, ..)` 的 h 现在只是调用点形状兼容,
736/// 不再逐行生效(0.4.1 适配层口径)。
737struct PinRow<'b> {
738 selected: bool,
739 cells: Vec<PinCell<'b>>,
740}
741
742/// 体表 push 收集器(替代 `egui_extras::TableBody` 的角色;BD-UI-55)。
743#[derive(Default)]
744pub(crate) struct PinBody<'b> {
745 rows: Vec<PinRow<'b>>,
746}
747
748impl<'b> PinBody<'b> {
749 /// 与旧 `body.row(h, |mut row| ..)` 同形,多一个 `selected`
750 /// (选中底色从构建时的 `set_selected` 改为收集物,绘制时 `row_ui` 画)。
751 pub fn row(&mut self, _h: f32, selected: bool, add: impl FnOnce(&mut PinRowAdd<'b>)) {
752 let mut r = PinRowAdd {
753 selected,
754 cells: Vec::new(),
755 };
756 add(&mut r);
757 self.rows.push(r.finish());
758 }
759}
760
761/// 行头的 `PinRow::row` 闭包参数,负责收格。
762pub(crate) struct PinRowAdd<'b> {
763 selected: bool,
764 cells: Vec<PinCell<'b>>,
765}
766
767impl<'b> PinRowAdd<'b> {
768 /// 一格,与旧 `row.col(|ui| ..)` 同形(形态不同点:内容延迟到体表真实绘制时跑,
769 /// 且首帧同帧跑两遍 —— FnMut,见 `PinCell`;多出来的第二个参数 = 这一格的
770 /// `PinCellCtx`,由 delegate 的 `cell_ui` 造)。
771 pub fn cell(&mut self, make: impl FnMut(&mut egui::Ui, &PinCellCtx) + 'b) {
772 self.cells.push(Box::new(make));
773 }
774 fn finish(self) -> PinRow<'b> {
775 PinRow {
776 selected: self.selected,
777 cells: self.cells,
778 }
779 }
780}
781
782/// 与旧 `tcell(row, right, make)` 等价的一格:格响应 = 整格可点那一层
783/// (`PinCellCtx::hit`,在格那一层注册的 `interact`),格内控件自己的响应跟随
784/// `CellOutcome::response()`;命中判定(旧宏里 `cell_r.clicked() || inner_r.clicked()`)
785/// 由这两个响应合成:返回 `(cell_r, inner_r)`,闭包内接着写行动作 ——
786/// 与 0.2.29 的「两边都看」完全同口径(egui 一颗点击只发给一个响应,见 `CellOutcome`)。
787///
788/// **0.8.0 对齐统一:撤掉 `right_align` 形参。** 旧口径六张表各有一份 `RIGHT_COLS`
789/// (行情 10 / 持仓 11 / 委托 4 / 成交 3 / 资金 3 / 合约 2 = 35 个右对齐格位)经
790/// `RIGHT_COLS.contains(&$col)` 传进来,而表头 100% 左对齐 —— 用户报的
791/// 「表头和表的内容对齐方式不一致」的真身。裁定 D = **全左对齐** → 右对齐那半退役,
792/// 「数字成列」由 `tokens::num_text`(等宽数字)那一半守(代价与口径见 `num_text` 注释)。
793pub(crate) fn pin_cell<R: CellOutcome>(
794 ui: &mut egui::Ui,
795 ctx: &PinCellCtx,
796 make: impl FnOnce(&mut egui::Ui) -> R,
797) -> (egui::Response, Option<egui::Response>) {
798 let inner = make(ui);
799 (ctx.hit.clone(), inner.response())
800}
801
802/// SplitScroll 的**退化象限**判定(BD-UI-55 实查;`row_ui` 用)。
803///
804/// `num_sticky_cols = 0` 时左上/左下象限的 rect 恒零宽,可 egui_table 无条件调四个
805/// 象限的 delegate(split_scroll.rs:79-151)→ 左下象限里每一行都会调一次 `row_ui`。
806/// 那里画不出任何东西(裁剪矩形零面积 → tessellator.rs:1367 直接丢),但选中底色 /
807/// 行线仍会被登记进本帧形状表 —— 判据读的正是形状表,所以就地不画。
808///
809/// 判据 = 「clip 与格矩形**共边**(宽恰为 0)而格矩形本身正」。这与「格在视口之外」
810/// (clip 与格矩形不相交 → 宽为**负**)是两种不同的退化,后者不能砍:首帧列宽量测靠的
811/// 就是「全列都跑一遍」(table.rs:633-637 的 `do_full_sizing_pass` → `col_range = 0..len`)。
812/// 表头那一侧这两种退化在几何上长得一样,分不开 → `header_cell_ui` 改用调用序判据。
813fn quadrant_is_degenerate(ui: &egui::Ui) -> bool {
814 let c = ui.clip_rect();
815 let m = ui.max_rect();
816 (c.width() == 0.0 && m.width() > 0.0) || (c.height() == 0.0 && m.height() > 0.0)
817}
818
819impl egui_table::TableDelegate for PinDelegate<'_, '_> {
820 fn header_cell_ui(&mut self, ui: &mut egui::Ui, cell: &egui_table::HeaderCellInfo) {
821 // 表头在 SplitScroll 里被画**两遍**:调用序 = right_bottom → left_top → right_top
822 // → left_bottom(split_scroll.rs:79-151)。`num_sticky_cols = 0` → left_top 那一遍
823 // 在零宽象限里:形状画不出(裁剪退化 → tessellator.rs:1367 直接丢),可 egui 的
824 // `Rect::intersects` 用 `<=`(零宽 clip 与文字矩形「相切」也算相交)→
825 // `is_rect_visible` 判真 → 同一颗表头在 AccessKit 语义树里两颗(0.4.1 实锤:
826 // s3/s26/s63/s71 的「成交金额 / 成交号 / 信息 / 最小变动」各两颗)。
827 //
828 // 判据用**调用序**而不是几何:退化象限里 clip 与格矩形相交时宽恰为 0、不相交时
829 // 为负,而「格在视口之外」的 clip 也是负 —— 几何上分不开(本轮实撞:按几何判
830 // 要么漏掉 left_top 的第 2 列起,要么把视口外的表头一起砍掉)。left_top 恒在
831 // right_top 之前 → 本 pass 里这一列的第一次调用就是退化象限,不画。
832 //
833 // 第二遍(视口那一层)**照画,视口外的列也画**:首帧列宽量测靠的就是「全列都跑
834 // 一遍」(table.rs:633-637 的 `do_full_sizing_pass` → `col_range = 0..len`);
835 // 漏掉表头,那一列就只量到体表内容(0.4.1 实锤:「成交金额」列 24px 而表头文字
836 // 57px,表头文字压进隔壁列)。视口外的格 `is_rect_visible` 判假 → 不画也不建
837 // 语义节点,所以照画不会带回双节点。
838 let i = cell.col_range.start;
839 let Some(seen) = self.header_drawn.get(i) else {
840 return;
841 };
842 let seen = *seen;
843 if !seen {
844 self.header_drawn[i] = true;
845 return;
846 }
847 // 表头格:文字(0.4.0 前的形制 == strong + small)+ 可点(排序入口)。
848 // 带色底与铺满全宽的带已在 pinned_table_impl 里画好(在表 show 之前 =
849 // z 序在下),这里只画文字 + register 点击。
850 let i = cell.col_range.start;
851 let mark = match self.sort {
852 Some((c, asc)) if c == i => {
853 if asc {
854 " ▲"
855 } else {
856 " ▼"
857 }
858 }
859 _ => "",
860 };
861 // 表头文字上下居中(0.4.1 七期 BD-UI-60,用户裁定「表格里的文字包括抬头都要上下居中」)。
862 // 旧口径:库给的表头格 child ui 起笔在格顶 → 实测带高 29 时文字视觉盒上隙 11 / 下隙 4。
863 // 光靠格内起笔调不出来(galley 的**视觉盒**比它的行盒偏下几 px)→ 直接把这一颗文字
864 // 按带的垂直中心摆:在 `band_mid ∓ 行高/2` 处开一个与格同宽的子 ui。
865 let cell = ui.max_rect();
866 let gh = ui.text_style_height(&egui::TextStyle::Small);
867 // **表头文字起笔 = 格左缘 + 格内内边距**(0.8.0 对齐统一,判据 s91):体表格每一格
868 // 套了 `Frame::inner_margin(left = CELL_INSET_X)`(见 `cell_ui`),旧口径表头从
869 // `cell.min.x` 起笔 → 表头比表体内容**靠左 6px**,就是用户报的「表头和表的内容
870 // 对齐方式不一致」。两处吃同一个常量,逐列左沿对齐(竖线共用)。
871 let target = egui::Rect::from_min_size(
872 egui::pos2(
873 cell.min.x + crate::tokens::CELL_INSET_X,
874 self.band_mid - gh * 0.5,
875 ),
876 egui::vec2(cell.width() - crate::tokens::CELL_INSET_X, gh),
877 );
878 ui.scope_builder(egui::UiBuilder::new().max_rect(target), |ui| {
879 ui.label(
880 egui::RichText::new(format!("{}{mark}", self.headers[i]))
881 .strong()
882 .small(),
883 );
884 });
885 // 点表头 = 排序。id 用「这颗表头格自己的 ui id」:egui_table 给表头格的 child ui
886 // 带 `id_salt(("header", row_nr, group_index))`(table.rs:586-593)→ 列间唯一、
887 // 帧间稳定;旧口径(`ui.id().with(("ek_table_header", table_id, i))`)的等价物。
888 let id = ui.id().with(("hdr_click", i));
889 if ui
890 .interact(ui.max_rect(), id, egui::Sense::click())
891 .clicked()
892 {
893 self.clicked.get_or_insert(i);
894 }
895 }
896
897 fn row_ui(&mut self, ui: &mut egui::Ui, row_nr: u64) {
898 // 左下象限(零宽,`num_sticky_cols = 0`)也会逐行调到这里 —— 与表头同理,
899 // 别让它把选中底色 / 行线登记进形状表。
900 if quadrant_is_degenerate(ui) {
901 return;
902 }
903 let r = ui.max_rect();
904 // **整行**底色,不是「有内容的那几格」(0.4.1 九期 BD-UI-62,用户裁定「我们选的是整行,
905 // 包括空行的也一起给它标上颜色」)。库给的行矩形 = `col_x[0]..=col_x[last]`
906 // (table.rs:689-690) = 所有列的宽度并集;列总宽窄于可视区时(日志表两列、接管版
907 // 列宽的表),行矩形右边就比可视区短一截 → 高亮只到最后一列右边,右边空余不亮。
908 // 补法:右边至少铺到「与表头带同宽」(带 = 可视区宽,`band_x` 构造时已捕获)。
909 let band_w = self.band_x.max - self.band_x.min;
910 let fill = egui::Rect::from_min_max(
911 egui::pos2(r.min.x, r.min.y),
912 egui::pos2(r.max.x.max(r.min.x + band_w), r.max.y),
913 );
914 // 选中底色(0.2.29 口径 = 主题 `selection.bg_fill`,不再手绘蓝)。
915 if let Some(row) = self.rows.get(row_nr as usize) {
916 if row.selected {
917 ui.painter()
918 .rect_filled(fill, 0.0, ui.visuals().selection.bg_fill);
919 } else if ui.rect_contains_pointer(fill) {
920 // 悬停判定也用 `fill`(整行)而不是 `r`(内容宽):否则「行尾空余」这一带
921 // 鼠标放进去根本不会亮 —— 那等于只把颜色补宽了,裁定没做全。
922 ui.painter()
923 .rect_filled(fill, 0.0, ui.visuals().widgets.hovered.bg_fill);
924 }
925 // 行线(0.4.1 五期 BD-UI-58:全部表都有,不再是合约表专属)。
926 // x 横跨**表体可视宽**而不是这一行的内容宽:旧口径取 TableBuilder body 的
927 // `max_rect().x_range()` = 横向 ScrollArea 内层 ui 的可用宽 = 整张表宽;
928 // 按单行内容宽画,列内容窄于面板时行线只到最后一列右边,与表头带不同宽
929 // (0.4.1 实锤:合约表行线 427..825,带 423..991 → 判据里 13 行数成 1 根)。
930 // 行线(0.4.1 五期 BD-UI-58:全部表都有;六期 BD-UI-60 起它是**唯一**的网格线,
931 // 列线按用户裁定撤除)。颜色取 delegate 构造时捕获的 `line` —— 表 scope 里
932 // `noninteractive.bg_stroke` 已被改成透明(见 `pinned_table_impl`),在这里现取
933 // 会连行线一起抹掉。
934 ui.painter()
935 .hline(self.band_x, r.max.y, egui::Stroke::new(1.0_f32, self.line));
936 }
937 }
938
939 fn cell_ui(&mut self, ui: &mut egui::Ui, cell: &egui_table::CellInfo) {
940 // 每格左内边距 6(注释见模块头);按列取出延迟画笔就地执行(FnMut,
941 // 首帧两遍都跑;不 replace —— FnOnce 那套会让第二遍全空,0.4.1 实锤)。
942 let Some(row) = self.rows.get_mut(cell.row_nr as usize) else {
943 return;
944 };
945 let Some(slot) = row.cells.get_mut(cell.col_nr) else {
946 // 空态行只推了首格(§4.2 低优):缺格静默跳过。
947 return;
948 };
949 // 满格命中层(见 `PinCellCtx::hit`):注册在格这一层 —— 这层的 clip 就是整格,
950 // `interact` 的 interact_rect = clip ∩ 整格 = 整格。id 用这层自己的 ui.id():
951 // egui_table 给格 child ui 带 `id_salt((row_nr, col_nr))`(table.rs:713-720)
952 // → 格间唯一、帧间稳定(旧 `TableRow::col` 那颗格响应的等价物)。
953 let hit = ui.interact(
954 ui.max_rect(),
955 ui.id().with("pin_cell"),
956 egui::Sense::click(),
957 );
958 let ctx = PinCellCtx { hit };
959 // 格内左右内边距 = `tokens::CELL_INSET_X`(0.8.0 对齐统一:表头文字起笔吃的是
960 // **同一个常量**,旧口径两处各写 6 → 表头比表体靠左 6px = 用户报的对不齐)。
961 let inset = crate::tokens::CELL_INSET_X as i8;
962 egui::Frame::new()
963 .inner_margin(egui::Margin {
964 left: inset,
965 right: inset,
966 top: 0,
967 bottom: 0,
968 })
969 .show(ui, |ui| slot(ui, &ctx));
970 }
971
972 fn default_row_height(&self) -> f32 {
973 self.row_h
974 }
975}
976
977/// pinned_table 用的 delegate(见模块头说明;字段随 `pinned_table_impl` 收集)。
978struct PinDelegate<'d, 'b> {
979 headers: &'d [&'d str],
980 sort: Option<(usize, bool)>,
981 rows: &'d mut [PinRow<'b>],
982 row_h: f32,
983 clicked: Option<usize>,
984 /// 本 pass 里每列表头已画过没有(表头在 SplitScroll 里被画两遍,见 `header_cell_ui`)。
985 header_drawn: Vec<bool>,
986 /// 表头带的 x 范围 = 表体可视宽。行线按它画,不按单行的内容宽(旧口径,见 `row_ui`)。
987 line: egui::Color32,
988 band_x: egui::Rangef,
989 /// 表头带的垂直中心(0.4.1 七期 BD-UI-60:表头文字按它上下居中,见 `header_cell_ui`)。
990 band_mid: f32,
991}
992
993/// 行高/表头高 = 字号 + 6(`table_heights` 见上;两值直接进 `HeaderRow`/行收集)。
994///
995/// 四个入口都要带自由 `'p`:行收集物 `PinBody<'p>` 的行延迟画笔寿命 = **调用方帧**
996/// (add_body 闭包里的格闭包借用外层局部 —— `'p` 由调用点挑一个盖住它们的生命周期)。
997/// 写成匿名的 `PinBody<'_>`(HRTB ⇒ for<'x> 任一寿命)会让借用逃逸出函数体
998/// (E0521/E0597,本轮实撞)。
999fn pinned_table<'p>(
1000 ui: &mut egui::Ui,
1001 table_id: &str,
1002 headers: &[&str],
1003 body: impl FnOnce(&mut PinBody<'p>, f32),
1004) -> Option<usize> {
1005 pinned_table_impl(ui, table_id, headers, None, body)
1006}
1007
1008/// 0.3.1(Wave D,BD-UI-49)可排序表:`sort` = 当前排序键,返回**这一拍被点过的表头列**。
1009/// 排序键由调用方从 `UiShared::table_sort` 取、点完表头再写回 `toggle_table_sort`.
1010fn pinned_table_sorted<'p>(
1011 ui: &mut egui::Ui,
1012 table_id: &str,
1013 headers: &[&str],
1014 sort: Option<(usize, bool)>,
1015 body: impl FnOnce(&mut PinBody<'p>, f32),
1016) -> Option<usize> {
1017 pinned_table_impl(ui, table_id, headers, sort, body)
1018}
1019
1020/// pinned_table 的共用实现(0.4.1 BD-UI-55 起换 egui_table 0.7.0):
1021/// - **表头天生粘顶**(egui_table `headers` 半 sticky row,0.2.6 DIY 覆盖带撤除)。
1022/// - **横向溢出**:SplitScroll 的右下象限 = 横向滚动区,表头(右象限)与体表同滚不错位,
1023/// 表头带照画全宽(带底画在 show 之前 = z 序最底)。
1024/// - **列宽**:库的首帧全量量测(do_full_sizing_pass)+ 之后冻结可持续拖/resizable 列。
1025/// 没有「每帧 auto_size_this_frame」:那会让 delegate(连同我们的action闭包)每帧跑两遍
1026/// —— egui 的 sizing pass = request_discard 重跑一遍帧,行动作一切两半(0.4.1 实查:
1027/// table.rs:384-443 的 discard 挂 per-column,content 变化重测路径库注释自己也标
1028/// TODO)。内容超宽的列(日志正文)由调用方传列宽。
1029/// - **行交互**:egui_table 不给格/行级 Response —— 每格用 `pin_cell` 自己建「满格
1030/// allocate + 控件响应」的两层判定(与 0.2.29 的旧「格响应+控件响应」等价)。
1031/// - **选中/悬停**:delegate 的 `row_ui`(行带全宽;旧 TableBuilder 的 expand 缝补
1032/// 不再需要 —— egui_table 行与行零间隙)。
1033/// - **斑马纹依旧没有**(0.2.27 起跟主题 = visuals.striped = false)。
1034fn pinned_table_impl<'p>(
1035 ui: &mut egui::Ui,
1036 table_id: &str,
1037 headers: &[&str],
1038 sort: Option<(usize, bool)>,
1039 add_body: impl FnOnce(&mut PinBody<'p>, f32),
1040) -> Option<usize> {
1041 pinned_table_impl_cols(ui, table_id, headers, sort, None, add_body)
1042}
1043
1044/// 空态列宽(0.4.1 五期 BD-UI-58,用户裁定「按表头分配各列比例,等有数据再按数据调整」):
1045/// 按**表头文字宽的比例**把这一拍的可用宽分掉。表头总宽 > 可用宽时不放大(照内容走横向
1046/// 滚动,与 Python `ResizeToContents` 同形)。`+12` = 格左右内边距 6+6(`cell_ui` 的
1047/// `inner_margin`),下限 24 = `Column::range` 下限。
1048fn header_proportional_widths(ui: &egui::Ui, headers: &[&str], available: f32) -> Vec<f32> {
1049 let head_font = ui.style().text_styles[&egui::TextStyle::Small].clone();
1050 let head_w = |s: &str| -> f32 {
1051 let g = ui.painter().layout_no_wrap(
1052 s.to_string(),
1053 head_font.clone(),
1054 egui::Color32::TRANSPARENT,
1055 );
1056 (g.size().x + 12.0).max(24.0)
1057 };
1058 fill_proportional(headers.iter().map(|h| head_w(h)).collect(), available)
1059}
1060
1061/// 表头份额不足可用宽时按比例放大到刚好填满;够宽(会溢出)时原样返回(走横向滚动)。
1062fn fill_proportional(mut base: Vec<f32>, available: f32) -> Vec<f32> {
1063 let sum: f32 = base.iter().sum();
1064 if sum > 0.0 && sum < available {
1065 let k = available / sum;
1066 for w in base.iter_mut() {
1067 *w *= k;
1068 }
1069 }
1070 base
1071}
1072
1073/// 列宽接管版(BD-UI-55 适配层第二入口):内容**逐帧生长**的表(日志正文)由调用方
1074/// 传列当前宽 —— 字体量串走 egui 的 galley 缓存(同串命中),不走库的
1075/// auto_size_this_frame(那条路 = request_discard 每帧双 pass,action 闭包跑两遍)。
1076/// 空态(这一拍没有数据行,由 `n_rows == 0` 现场判定,不用调用方声明)且没传列宽时,
1077/// 按表头比例分配(见 `header_proportional_widths`)。
1078pub(crate) fn pinned_table_impl_cols<'p>(
1079 ui: &mut egui::Ui,
1080 table_id: &str,
1081 headers: &[&str],
1082 sort: Option<(usize, bool)>,
1083 col_current: Option<Vec<f32>>,
1084 add_body: impl FnOnce(&mut PinBody<'p>, f32),
1085) -> Option<usize> {
1086 let ch = Chrome::of(ui.visuals(), crate::tokens::theme_of(ui.ctx()));
1087 let (row_h, head_h) = table_heights(ui);
1088 let sp = ui.spacing().item_spacing;
1089 let m = ui.visuals().clip_rect_margin;
1090 // 表头带:整行宽(Python QHeaderView 铺满表视口;0.2.28 给浮动窗短表补的
1091 // header_band 铺整行是同一件事)。画在表之前 = 在表头文字之下,零布局副作用
1092 // (0.2.6「资金右多一根竖线」那类 min_rect 被撑宽的病在这里不会再犯)。
1093 let left = ui.cursor().min.x - sp.x * 0.5;
1094 let top = ui.cursor().top();
1095 // 带底 = 表头行底边,egui_table 的表头行高就是 `head_h` 且**体表紧接着开始**
1096 // (行与行、表头与体表都不留 item_spacing,table.rs:404-411 `header_row_y` 累加
1097 // `header.height()`)。旧 TableBuilder 在表头与首行之间留了一格 `sp.y`,带底才多画
1098 // 那 6 px —— 照搬过来带底就压进首行(0.4.1 实锤:带 407..442,首行 436..462,
1099 // 首行文字 440..458 被带底横线从中间切过)。
1100 let band = egui::Rect::from_min_max(
1101 egui::pos2(left, top - m),
1102 egui::pos2(left + ui.available_width() + sp.x, top + head_h),
1103 );
1104 ui.painter().rect_filled(band, 0.0, ch.band_fill);
1105 // 带底下边线:表头带与体表的分界(Python 的表头带与体表是两种底色,天然有界;
1106 // 我们只有一根带,补线才有界)。
1107 ui.painter().hline(
1108 band.x_range(),
1109 band.max.y,
1110 egui::Stroke::new(1.0_f32, ch.line),
1111 );
1112 // 滚动条形态:全局一处口径(`tokens::apply` 的 `spacing.scroll`,0.4.1 七期 BD-UI-60
1113 // 起 5 px 细 + BG4 暗把手)。SplitScroll 内部是标准 ScrollArea,吃同一套 spacing。
1114 let mut body = PinBody::default();
1115 add_body(&mut body, row_h);
1116 let n_rows = body.rows.len() as u64;
1117
1118 // 列(0.4.1 五期 BD-UI-58,用户裁定):`resizable` **恒开**,两个理由绑在一起 ——
1119 // ① 列线:库只在 resizable 列上画那根可拖边界线(table.rs:740-749 登记 + 896 画线),
1120 // 这就是用户要的「竖向线显得整齐」;旧口径只有合约表 + 日志表 + 开了右键开关的
1121 // 成交表有列线,委托/持仓/资金/行情没有 → 形制不统一。
1122 // ② 列宽随内容生长:`finish` 的 grow-only 分支(table.rs:840-843)只对 resizable 列
1123 // 生效,旧口径非 resizable 的表列宽只在**首帧**量一次(首帧空态 → 列宽 = 表头
1124 // 文字宽,数据进来也不长;BD-UI-56 实测:成交表首帧空态列宽 [63.3, 28.4, 43.4,
1125 // …] 喂进「螺纹钢2605 / 71230.5 / 142461.0」再跑三帧,一模一样)。这条缺陷跟着
1126 // 恒开一起修掉。右键菜单里那个「调整列宽」开关因此失去意义 → 一并退役。
1127 let mut delegate = PinDelegate {
1128 headers,
1129 sort,
1130 rows: &mut body.rows,
1131 row_h,
1132 clicked: None,
1133 header_drawn: vec![false; headers.len()],
1134 band_x: band.x_range(),
1135 line: ch.line,
1136 band_mid: band.center().y,
1137 };
1138 // egui_table 的表 scope **不带 id_salt**:SplitScroll 内部 `ui.new_child()`
1139 // 的 ScrollArea auto-id 由父 ui 的 child 计数器派生 —— 2×2 各格的表(
1140 // order_grid 与 log_grid)实测滚出同一个 id(17412…5594)—— 滚动状态互相
1141 // 污染 → `ScrollArea::show_scroll` 每帧交替翻转 → request_repaint 死循环
1142 // (kittest max_steps 实锤,本轮 `[scrollflip]` 打点)。所以这里显式
1143 // scope 一层,把每张表的整个子 ui 树根挂在以 table_id 命名的盐上,
1144 // 滚动 id 与列宽状态各自独立。
1145 let _ret = ui.scope_builder(
1146 egui::UiBuilder::new()
1147 .id_salt(("pinned_table", table_id))
1148 // scope 的可用区必须从**当前 cursor** 起,不是从 max_rect 左上角:
1149 // `Table::show` 的 col_x / 表头行 y 都取 `ui.cursor().min`(table.rs:393-411),
1150 // 而上面那条表头带是按 cursor 画的 —— 用 `ui.max_rect()` 会让表画到
1151 // cursor **上方**去,带与表头行错开(0.4.1 实锤 s70:资金表头格 y 568..594,
1152 // 带却画在 y 597..632 = 差一整行)。
1153 .max_rect(egui::Rect::from_min_max(ui.cursor().min, ui.max_rect().max)),
1154 |ui| {
1155 // 列宽校准(BD-UI-58 立,BD-UI-60 补全):表宽 = 所在区域的 100%。
1156 // Python 侧交易表是 `resizeSections(ResizeToContents)`(widget.py:646)+ Qt
1157 // `stretchLastSection` 默认 True(全仓只有 portfoliomanager 的树控件显式关掉它)
1158 // → 列按内容量,剩余宽由**最后一列**吃掉,表宽恒等于视口宽;列总宽超过视口时
1159 // Qt 不压缩、出横向滚动条 —— 我们照这个口径,超宽不压。
1160 // 为什么必须**写进 `TableState`**而不是只传 `Column::new(w)`:库只在状态里
1161 // 没有这张表时才读 `column.current`(table.rs:370-375),而那一刻恰好就是首帧
1162 // ——首帧库给每列打上 `auto_size_this_frame`(table.rs:377-379),`finish` 于是
1163 // 走「按内容收缩」那一支(table.rs:837-839)把种子覆盖掉(0.4.1 五期实测:只传
1164 // 种子,空态右侧照样空 663 px)。先写状态,`TableState::load` 就不再是 None。
1165 // 只在「状态里的列宽总和还填不满可用宽」时动手:用户手动拖宽之后不再跟他抢。
1166 let state_id = egui_table::TableState::id(ui, egui::Id::new(table_id));
1167 // 目标宽要扣掉这张表自己的滚动条占位(`floating = false` 时 ScrollArea 会真的
1168 // 留出 bar_width + 内外边距):不扣就会把列总宽做到「比可视区还宽」,最后一列
1169 // 被推到视口外,egui_table 剔掉视口外的列 → 那一列上的撤单钮 / 时间格直接消失
1170 // (0.4.1 七期实撞:s11 撤单钮、s38 已摘除标注、w6 成交时间列同因)。
1171 let sc = &ui.style().spacing.scroll;
1172 let reserve = if sc.floating {
1173 0.0
1174 } else {
1175 sc.bar_width + sc.bar_inner_margin + sc.bar_outer_margin
1176 };
1177 let target = (ui.available_width() - reserve).max(0.0);
1178 // 补宽**一次只补一次**,不每帧补:库的 `finish` 把列宽写回成 `max(可视内容宽)`,
1179 // 被剔出视口的列写回的是它这一帧的量测宽 → 每帧补就「补宽 → 更挤 → 更多列被剔 →
1180 // 存宽更小 → 再补」滚起来(0.4.1 七期实撞:每帧补时 s11/s21/t3/f2/w6 同时丢格)。
1181 // 判据 = 「区域宽变了」或「存宽变了」(= 数据变了)才重新允许补一次;最后一列最多
1182 // 吃掉半张表,补不出无限宽的列。
1183 let fill_id = egui::Id::new(("table_fill", table_id));
1184 let (last_target, last_stored, filled) = ui.ctx().data(|d| {
1185 (
1186 d.get_temp::<f32>(fill_id).unwrap_or(0.0),
1187 d.get_temp::<f32>(fill_id.with("stored")).unwrap_or(0.0),
1188 d.get_temp::<bool>(fill_id.with("filled")).unwrap_or(false),
1189 )
1190 });
1191 let mut st = egui_table::TableState::load(ui.ctx(), state_id).unwrap_or_default();
1192 let stored: f32 = st.col_widths.values().sum();
1193 let may_fill = !filled
1194 && ((target - last_target).abs() > 8.0 || (stored - last_stored).abs() > 0.5);
1195 let mut did_fill = false;
1196 let mut new_stored = stored;
1197 if col_current.is_none() && may_fill && stored < target {
1198 if stored <= 0.0 {
1199 // 这一张表还没量过列宽。**只有空态**才在这里按表头比例下种子(BD-UI-58
1200 // 口径);有数据时不写,让库在首帧做全量内容量测(`do_full_sizing_pass`)
1201 // —— 提前下种子会把「时间」「接口」这类窄表头列压成 26 px,格内文字被
1202 // 列宽裁掉(0.4.1 七期实撞:w6 成交时间列、s38 已摘除标注)。
1203 if n_rows == 0 {
1204 for (i, w) in header_proportional_widths(ui, headers, target)
1205 .into_iter()
1206 .enumerate()
1207 {
1208 st.col_widths.insert(egui::Id::new(i), w);
1209 }
1210 did_fill = true;
1211 }
1212 } else {
1213 // 已有列宽(按内容量过):剩余补给最后一列 = stretchLastSection 等价。
1214 let last = egui::Id::new(headers.len() - 1);
1215 let cur = st.col_widths.get(&last).copied().unwrap_or(24.0);
1216 let add = (target - stored).min((target * 0.5 - cur).max(0.0));
1217 if add > 0.5 {
1218 st.col_widths.insert(last, cur + add);
1219 did_fill = true;
1220 }
1221 }
1222 if did_fill {
1223 new_stored = st.col_widths.values().sum::<f32>();
1224 st.store(ui.ctx(), state_id);
1225 }
1226 }
1227 ui.ctx().data_mut(|d| {
1228 d.insert_temp(fill_id, target);
1229 d.insert_temp(fill_id.with("stored"), new_stored);
1230 d.insert_temp(fill_id.with("filled"), did_fill || filled);
1231 });
1232 let seed: Option<Vec<f32>> = col_current;
1233 // 列线(0.4.1 七期 BD-UI-60,用户裁定「表格里所有的列分割线都去掉,只要行的分割线」):
1234 // 库里那根线撤不掉 —— 它只在**可拖列边界**上画(table.rs:738-749 登记 + 896 画线),
1235 // 而 `resizable` 必须恒开(列宽随内容生长靠它,BD-UI-56 那条缺陷就堵在这)。
1236 // 做法 = 把它的**常态**描边改成全透明 → 平时看不见;hover / 拖拽仍走
1237 // `widgets.hovered` / `widgets.active` 的描边 → 拖列宽时那根线亮出来(用户裁定保留)。
1238 // 只改这一支,不改 `BORDER` 本体:行线、表头带底边线、窗框都另有取色(行线取
1239 // delegate 里捕获的 `line`)。
1240 ui.style_mut().visuals.widgets.noninteractive.bg_stroke =
1241 egui::Stroke::new(1.0_f32, egui::Color32::TRANSPARENT);
1242 // 列宽从哪来(0.4.1 实查,库侧两条硬事实):
1243 // ① `Table::show` 只在**首帧**(`TableState::load` 为 None)做全量内容量测
1244 // (`do_full_sizing_pass`,table.rs:365-379);
1245 // ② 量出来的宽度只有 **resizable 列**才会写回 `TableState` —— `finish`
1246 // (table.rs:816-843)只遍历 `visible_column_lines`,而这两根线只在
1247 // `column.resizable` 时登记(table.rs:614、table.rs:738-749)。
1248 // 0.4.1 五期(BD-UI-58)起 `resizable` 恒开:①②两条从此**每张表都吃到**
1249 // (列宽随内容生长 + 每列一根可拖列线),不再需要「首帧临时全标 resizable」
1250 // 那套补丁。起手宽 = 空态种子(按表头比例)或 100(库随后按内容量测覆盖)。
1251 let columns: Vec<egui_table::Column> = match &seed {
1252 Some(ws) => headers
1253 .iter()
1254 .zip(ws.iter().copied())
1255 .enumerate()
1256 .map(|(i, (_, w))| {
1257 egui_table::Column::new(w)
1258 .range(24.0..=f32::INFINITY)
1259 .id(egui::Id::new(i))
1260 .resizable(true)
1261 })
1262 .collect(),
1263 None => headers
1264 .iter()
1265 .enumerate()
1266 .map(|(i, _)| {
1267 egui_table::Column::new(100.0)
1268 .range(24.0..=f32::INFINITY)
1269 .id(egui::Id::new(i))
1270 .resizable(true)
1271 })
1272 .collect(),
1273 };
1274 egui_table::Table::new()
1275 .id_salt(table_id)
1276 .num_rows(n_rows)
1277 .columns(columns)
1278 .headers([egui_table::HeaderRow::new(head_h)])
1279 .auto_size_mode(egui_table::AutoSizeMode::Never)
1280 .show(ui, &mut delegate);
1281 },
1282 );
1283 delegate.clicked
1284}
1285/// 为什么要这个:egui 的点击只发给**一个**响应 —— `context.rs:1384`
1286/// `let clicked = Some(id) == viewport.interact_widgets.clicked;` 比的是单个 Id,
1287/// 后加的控件优先。格里有真控件(钮 / 勾选框)时,点击归那个控件,归不到
1288/// `TableRow::col` 返回的「格响应」。所以行动作必须两边都看(0.2.29 实锤:
1289/// 只看格响应 → 行情首列钮、委托撤单钮、合约勾选框三处点击全丢)。
1290/// `pin_cell` 是 pub(crate)(kittest 判据要用),所以本 trait 也要 pub(crate)
1291/// (否则 clippy private-trait 警报)。
1292pub(crate) trait CellOutcome {
1293 fn response(&self) -> Option<egui::Response>;
1294}
1295
1296impl CellOutcome for egui::Response {
1297 fn response(&self) -> Option<egui::Response> {
1298 Some(self.clone())
1299 }
1300}
1301
1302impl CellOutcome for () {
1303 fn response(&self) -> Option<egui::Response> {
1304 None
1305 }
1306}
1307
1308impl<T: CellOutcome> CellOutcome for egui::InnerResponse<T> {
1309 fn response(&self) -> Option<egui::Response> {
1310 self.inner
1311 .response()
1312 .or_else(|| Some(self.response.clone()))
1313 }
1314}
1315
1316/// 喂表前的快照副本排序(W2 的判据对象)。`key` 返回**可比较字符串**;数字列调用方给
1317/// 零填充串(`{:020.4}`)保证字典序 == 数值序。`sort` 为 `None` = 原序,一行都不动。
1318fn sorted_rows<'a, T>(
1319 rows: &'a [T],
1320 sort: Option<(usize, bool)>,
1321 key: impl Fn(&T, usize) -> String,
1322) -> Vec<&'a T> {
1323 let mut out: Vec<&'a T> = rows.iter().collect();
1324 if let Some((col, asc)) = sort {
1325 out.sort_by(|a, b| {
1326 let (ka, kb) = (key(a, col), key(b, col));
1327 if asc { ka.cmp(&kb) } else { kb.cmp(&ka) }
1328 });
1329 }
1330 out
1331}
1332
1333/// 成交行的展示字符串(`TRADE_HEADERS` 同序)。**排序键与「保存数据」CSV 共用这一份口径** ——
1334/// 表里看见什么,导出来就是什么,不留第二套格式化。
1335/// 0.3.3 Wave F:这一份的顺序就是 `TRADE_HEADERS` 的顺序(判据 F1 钉「内容与表头同列」,
1336/// 两处不同序 = CSV 与屏幕不一致)。
1337fn trade_cells(t: &ek_data::trade::TradeData) -> Vec<String> {
1338 vec![
1339 t.symbol.clone(),
1340 if t.name.is_empty() {
1341 // 0.11.0 第5刀 R6:导出与屏幕同口径 —— 缺名兜底 = 代码
1342 t.symbol.clone()
1343 } else {
1344 t.name.clone()
1345 },
1346 t.exchange.as_str().to_string(),
1347 t.direction
1348 .map(|d| d.as_str().to_string())
1349 .unwrap_or_else(|| "-".to_string()),
1350 t.offset.as_str().to_string(),
1351 crate::format::price(t.price),
1352 crate::format::volume(t.volume),
1353 crate::format::price(t.traded_amount),
1354 crate::format::time_hms_millis(t.datetime),
1355 t.tradeid.clone(),
1356 t.orderid.clone(),
1357 t.gateway_name.clone(),
1358 ]
1359}
1360
1361/// 排序键:数字列给**零填充串**(`{:020.4}`)保证字典序 == 数值序;文本列直接比。
1362/// 注意不能直接拿 `trade_cells` 的显示串当排序键 —— "101" < "12.345" < "3.5" 是字典序,
1363/// 不是价格序(本轮实撞,判据 W1 当场红出来的)。
1364/// 列序 0.3.3 Wave F 跟着 `TRADE_HEADERS` 走:5 = 价格,6 = 数量,7 = 成交金额,8 = 时间。
1365fn trade_sort_key(t: &ek_data::trade::TradeData, col: usize) -> String {
1366 match col {
1367 5 => format!("{:020.4}", t.price),
1368 6 => format!("{:020.4}", t.volume),
1369 7 => format!("{:020.4}", t.traded_amount),
1370 8 => t.datetime.map(|ns| format!("{ns:025}")).unwrap_or_default(),
1371 c => trade_cells(t).get(c).cloned().unwrap_or_default(),
1372 }
1373}
1374
1375/// 「保存数据」:当前表(已按界面排序键排好的那份副本)写成 CSV 到 `target/ek-ui-<表>.csv`。
1376/// 只写界面看见的内容,不碰后端、不碰数据模型。
1377fn save_table_csv<T>(
1378 table: &str,
1379 headers: &[&str],
1380 rows: &[&T],
1381 cells: impl Fn(&T) -> Vec<String>,
1382) -> std::io::Result<()> {
1383 let mut s = headers.join(",");
1384 s.push('\n');
1385 for r in rows {
1386 s.push_str(&cells(r).join(","));
1387 s.push('\n');
1388 }
1389 let dir = std::env::current_dir()?.join("target");
1390 std::fs::create_dir_all(&dir)?;
1391 std::fs::write(dir.join(format!("ek-ui-{table}.csv")), s)
1392}
1393
1394// ================= 菜单栏 =================
1395
1396fn render_menu_bar(ui: &mut egui::Ui, shared: &UiShared) {
1397 ui.horizontal(|ui| {
1398 // BD-UI-31(R1):一键直达 —— 菜单钮即入口,单击直接弹窗(去下拉层)。
1399 if ui.button(MENU_OPS).clicked() {
1400 shared.set_ops_window_open(true);
1401 }
1402 if ui.button(MENU_ACCOUNTS).clicked() {
1403 shared.set_accounts_window_open(true);
1404 }
1405 if ui.button(MENU_CONTRACTS).clicked() {
1406 shared.set_contracts_window_open(true);
1407 }
1408 // 0.3.0(Wave C,BD-UI-48)→ 0.4.1(BD-UI-54):布局可复位 —— 一键回
1409 // Python 框架等价(分刀份额 50:50 + 三个 tab 态回缺省;行情带/下单侧两块
1410 // 顶层面板的记忆尺寸一并清掉 = 下帧回 default_height/default_width)。
1411 if ui.button("恢复布局").clicked() {
1412 shared.reset_layout();
1413 ui.ctx().data_mut(|d| {
1414 d.remove::<egui::containers::panel::PanelState>(egui::Id::new("market_band"));
1415 d.remove::<egui::containers::panel::PanelState>(egui::Id::new("order_side"));
1416 });
1417 }
1418 // **0.8.0 配色双档(BD-UI-61):两档切换钮 —— 裁定 8 的改判点。**
1419 // 0.2.30(裁定 8,BD-UI-46)删掉的是「五套主题一键循环」;0.4.1(BD-UI-57)
1420 // 把那一套定成 Nova 深色。本轮用户实看判词「这个配色特别刺眼睛」+ 指定参考站
1421 // 要「白色和黑色两款」→ 深色档重调 + 新增浅色档 + 菜单放**一颗**两档钮。
1422 // 标签 = **要去的那一档**(参考站「图标指向目标档」的语义,我们用中文,不引图标字体)。
1423 // 入口只有这一颗(参考站那两处是它的长设置页,我们的设置面就是菜单这一行)。
1424 let theme = shared.theme();
1425 let to = theme.flipped();
1426 if ui
1427 .button(format!(
1428 "主题:{}",
1429 match to {
1430 crate::tokens::Theme::Light => "浅色",
1431 crate::tokens::Theme::Dark => "深色",
1432 }
1433 ))
1434 .clicked()
1435 {
1436 let next = shared.toggle_theme();
1437 ui.ctx().request_repaint();
1438 shared.log_line(format!(
1439 "[ui] 主题:{}(下一帧生效,已记 ui.theme)",
1440 match next {
1441 crate::tokens::Theme::Light => "浅色",
1442 crate::tokens::Theme::Dark => "深色",
1443 }
1444 ));
1445 }
1446 ui.menu_button(MENU_HELP, |ui| {
1447 ui.label(format!("ek-station 观测台 v{}", env!("CARGO_PKG_VERSION")));
1448 ui.label("布局 = Python 主窗框架等价(行情带/交易带/弹窗)");
1449 ui.label("配色 = 深/浅两档(缺省深色),菜单「主题:」钮切换,存 ui.theme");
1450 });
1451 });
1452}
1453
1454// ================= 行情格 =================
1455
1456/// 行情表头(14 列,与 `tick_sort_key` 同序)。
1457const TICK_HEADERS: [&str; 14] = [
1458 "代码",
1459 "名称",
1460 "最新价",
1461 "涨跌幅",
1462 "成交量",
1463 "今开",
1464 "最高",
1465 "最低",
1466 "买1价",
1467 "买1量",
1468 "卖1价",
1469 "卖1量",
1470 "时间",
1471 "行情源",
1472];
1473
1474/// 行情格:一个交易所一格(0.4.0)。组内那条「按所二级 tab」条已撤除 —— 所的身份由
1475/// dock tab 承担(该格只画本所的行;哪一所在前台由 dock 树记)。
1476pub(crate) fn render_market_pane(
1477 ui: &mut egui::Ui,
1478 shared: &UiShared,
1479 ex: ek_data::constant::Exchange,
1480) {
1481 // 表状态按格分开:6 个所的行情格各有各的排序与列宽(同一个 id 会被 egui 当重复)。
1482 let table_id = format!("tick_{}", ex.as_str());
1483 let groups = shared.tick_groups();
1484 let ticks: Vec<ek_data::tick::TickData> = groups
1485 .iter()
1486 .find(|(e, _)| e == ex.as_str())
1487 .map(|(_, v)| v.clone())
1488 .unwrap_or_default();
1489 // 空态口径(0.4.1 五期 BD-UI-58 + 六期 BD-UI-59 两次裁定合起来):表头恒在(s73 钉),但**不画那一行
1490 // 「(无数据)」提示** —— 表体就是空的,用户看得见;列宽这一拍按表头比例填满(s74 钉)。
1491 // 「这一拍没有数据行」由 `pinned_table_impl_cols` 现场数 `n_rows == 0` 判定,
1492 // 调用方不再分支:空与非空走同一条路,body 收出 0 行就是空表。
1493 // (0.4.0 那条「空态不得吞掉表头」的修正仍然成立:这里原来直接 `muted_label + return`,
1494 // 整张表含表头都不画,六个行情格在没有订阅时全是光秃秃一句提示。Python 也是空表照画表头。)
1495 // 0.3.3(收 Wave D 欠账):行情格也吃「点表头排序」(缺省序 = 按所/symbol)。
1496 let sort = shared.table_sort(&table_id);
1497 let ticks = sorted_rows(&ticks, sort, tick_sort_key);
1498 let clicked = pinned_table_sorted(ui, &table_id, &TICK_HEADERS, sort, |body, row_h| {
1499 for t in &ticks {
1500 // 行交互(BD-UI-31 扩展):行内任何一格单击 = 带入下单面板
1501 // (盘口四列带方向:买1价/买1量 → 卖,卖1价/卖1量 → 买,价格列
1502 // 顺带填价;其余列方向/价格保持默认——用户裁定);任何一格双击
1503 // = 弹 K线窗。选中行 = 下单面板当前合约(带入即跳色)。
1504 let row_sel = shared.order_form().symbol == t.symbol;
1505 body.row(row_h, row_sel, |r| {
1506 // 延迟画笔(BD-UI-55):格内容在体表真实绘制时跑;点击/双击与
1507 // 行动作的判定照旧在「格响应 || 控件响应」两边看,BD-UI-55 实查:
1508 // egui_table 每帧只跑一遍(不用 auto_size_this_frame,那会双跑)。
1509 // 闭包不 move(借用 shared / t / key —— 它们都是外层的只读局部,
1510 // 出不了 pinned_table_impl 的调用帧,借给 'b 完全合法)。
1511 macro_rules! cell {
1512 ($make:expr, $col:expr) => {{
1513 r.cell(|ui, ctx| {
1514 let (cell_r, inner_r) = pin_cell(ui, ctx, $make);
1515 let hit =
1516 cell_r.clicked() || inner_r.as_ref().is_some_and(|r| r.clicked());
1517 if hit {
1518 // import_tick(用户裁定:0.4.1 行单击不再切交易所 ——
1519 // 本格已是该所;这里只把合约带进下单面板)。
1520 import_tick(shared, t, ex.as_str(), $col);
1521 }
1522 let dbl = cell_r.double_clicked()
1523 || inner_r.as_ref().is_some_and(|r| r.double_clicked());
1524 if dbl {
1525 shared.open_kline(t.symbol.clone());
1526 }
1527 });
1528 }};
1529 }
1530 cell!(|ui| ui.button(t.symbol.clone()), 0);
1531 cell!(
1532 |ui| ui.label(if t.name.is_empty() {
1533 // 0.11.0 第5刀 R6:名称兜底 = 代码(不是「-」;行永不因缺名被丢)
1534 t.symbol.clone()
1535 } else {
1536 t.name.clone()
1537 }),
1538 1
1539 );
1540 cell!(
1541 |ui| ui.label(crate::tokens::num_text(crate::format::price(t.last_price))),
1542 2
1543 );
1544 cell!(
1545 |ui| ui.label(
1546 crate::tokens::num_text(crate::format::pct(t.pct_change))
1547 .color(crate::tokens::rise_fall(ui.ctx(), t.pct_change)),
1548 ),
1549 3
1550 );
1551 cell!(
1552 |ui| ui.label(crate::tokens::num_text(crate::format::volume(t.volume))),
1553 4
1554 );
1555 cell!(
1556 |ui| ui.label(crate::tokens::num_text(crate::format::price(t.open_price))),
1557 5
1558 );
1559 cell!(
1560 |ui| ui.label(crate::tokens::num_text(crate::format::price(t.high_price))),
1561 6
1562 );
1563 cell!(
1564 |ui| ui.label(crate::tokens::num_text(crate::format::price(t.low_price))),
1565 7
1566 );
1567 cell!(
1568 |ui| ui.label(
1569 crate::tokens::num_text(crate::format::price(t.bid_price_1))
1570 .color(crate::tokens::rise(ui.ctx())),
1571 ),
1572 8
1573 );
1574 cell!(
1575 |ui| ui.label(
1576 crate::tokens::num_text(crate::format::volume(t.bid_volume_1))
1577 .color(crate::tokens::rise(ui.ctx())),
1578 ),
1579 9
1580 );
1581 cell!(
1582 |ui| ui.label(
1583 crate::tokens::num_text(crate::format::price(t.ask_price_1))
1584 .color(crate::tokens::fall(ui.ctx())),
1585 ),
1586 10
1587 );
1588 cell!(
1589 |ui| ui.label(
1590 egui::RichText::new(crate::format::volume(t.ask_volume_1))
1591 .color(crate::tokens::fall(ui.ctx())),
1592 ),
1593 11
1594 );
1595 cell!(
1596 |ui| ui.label(if t.update_time.is_empty() {
1597 crate::format::time_hms_millis(Some(t.datetime))
1598 } else {
1599 t.update_time.clone()
1600 }),
1601 12
1602 );
1603 cell!(|ui| ui.label(t.gateway_name.clone()), 13);
1604 });
1605 }
1606 });
1607 if let Some(col) = clicked {
1608 shared.toggle_table_sort(&table_id, col);
1609 }
1610}
1611
1612/// 行情行的排序键(列序 == 行情带 14 列):数字列零填充,时间列纳秒零填充。
1613fn tick_sort_key(t: &ek_data::tick::TickData, col: usize) -> String {
1614 match col {
1615 0 => t.symbol.clone(),
1616 1 => t.name.clone(),
1617 2 => format!("{:020.4}", t.last_price),
1618 3 => format!("{:020.4}", t.pct_change),
1619 4 => format!("{:020.4}", t.volume),
1620 5 => format!("{:020.4}", t.open_price),
1621 6 => format!("{:020.4}", t.high_price),
1622 7 => format!("{:020.4}", t.low_price),
1623 8 => format!("{:020.4}", t.bid_price_1),
1624 9 => format!("{:020.4}", t.bid_volume_1),
1625 10 => format!("{:020.4}", t.ask_price_1),
1626 11 => format!("{:020.4}", t.ask_volume_1),
1627 12 => {
1628 if t.update_time.is_empty() {
1629 format!("{:025}", t.datetime)
1630 } else {
1631 t.update_time.clone()
1632 }
1633 }
1634 13 => t.gateway_name.clone(),
1635 _ => String::new(),
1636 }
1637}
1638
1639// ================= 下单面板(常驻;0.4.1 BD-UI-54 回原生 SidePanel) =================
1640
1641fn render_order_panel(ui: &mut egui::Ui, shared: &UiShared) {
1642 // BD-UI-31(R4):面板题字撤除(下单侧栏即身份)。
1643 let mut f = shared.order_form();
1644 let before = f.clone();
1645 let mut err: Option<String> = None;
1646
1647 // 随价勾选:价格框随该合约最新 tick(勾选态)
1648 if f.follow_price
1649 && let Some(t) = tick_of(shared, &f.exchange, &f.symbol)
1650 && t.last_price > 0.0
1651 {
1652 f.price = crate::format::price(t.last_price);
1653 }
1654
1655 // 交易所下拉:有 tick 的所 ∪ 六家常用所(操作面默认,不是配置面)
1656 let mut ex_opts: Vec<String> = shared
1657 .tick_groups()
1658 .iter()
1659 .map(|(e, _)| e.clone())
1660 .collect();
1661 for e in ["SHFE", "DCE", "CZCE", "CFFEX", "INE", "GFEX"] {
1662 if !ex_opts.iter().any(|x| x == e) {
1663 ex_opts.push(e.to_string());
1664 }
1665 }
1666 if !ex_opts.contains(&f.exchange) {
1667 ex_opts.insert(0, f.exchange.clone());
1668 }
1669 // 接口下拉:账户清册(注册序)∪ trade_snap 网关去重集(B3 退役:
1670 // 不再硬编码 `["ctp"]`;0.2.10 BD-UI-38 sim 纸面网关退场同口径)。
1671 let ts = shared.trade_snap();
1672 let mut gw_opts: Vec<String> = Vec::new();
1673 // 0.2.18(规划 Q4):下单归属只列**已装配**账户 —— 只添加了还没连接的账户
1674 // 进了下拉,选它下单只会撞 `unknown:gateway`。
1675 // 账本侧历史网关名的口径(执行核查补的洞):清册非空时,**不在清册的历史网关
1676 // = 已摘除账户**,它留在下拉里同样是选它下单撞 `unknown:gateway` → 不进下拉
1677 // (撤单不受影响:撤单归属按每笔单自己的网关走,与这里的下拉无关)。
1678 // 清册为空 = 不干预(纯账本巡回钉 s27/s14 那类无账户配置面的形)。
1679 let known_gws = account_gateways(shared);
1680 for g in shared
1681 .accounts()
1682 .iter()
1683 .filter(|a| a.connected)
1684 .map(|a| a.gateway.clone())
1685 .chain(
1686 ts.orders
1687 .iter()
1688 .map(|o| o.gateway_name.clone())
1689 .chain(ts.trades.iter().map(|t| t.gateway_name.clone()))
1690 .chain(ts.accounts.iter().map(|a| a.gateway_name.clone()))
1691 .filter(|g| known_gws.is_empty() || known_gws.contains(g)),
1692 )
1693 {
1694 if !g.is_empty() && !gw_opts.contains(&g) {
1695 gw_opts.push(g);
1696 }
1697 }
1698 if !gw_opts.contains(&f.gateway)
1699 && !f.gateway.is_empty()
1700 && (known_gws.is_empty() || known_gws.contains(&f.gateway))
1701 {
1702 gw_opts.insert(0, f.gateway.clone());
1703 }
1704 // 手动选过的网关若已不在可选面(被摘除 / 未装配)= 就地回落到默认阶梯:
1705 // 否则下拉里挂着一个注定 `unknown:gateway` 的选项,且它会成为下一笔单的归属。
1706 if !f.gateway.is_empty() && !gw_opts.contains(&f.gateway) {
1707 f.gateway = shared.default_gateway().unwrap_or_default();
1708 }
1709 // 表单网关位为空 = 未手动选过:回填默认账户阶梯(上次选择 → 首个已连接 → 首个)。
1710 // 只改本地 `f` 副本 —— 面板末尾的 `f != before` 写回负责落盘,不在这里重复写。
1711 if f.gateway.is_empty()
1712 && let Some(def) = shared.default_gateway()
1713 {
1714 f.gateway = def;
1715 }
1716 let no_accounts = gw_opts.is_empty();
1717
1718 // 表单网格(Python TradingWidget 字段排;委托/全撤 = 网格行;
1719 // 网格后不挂面板内容 —— 帧内 sizing 退让会把后置行叠回网格,盘口独立帧)。
1720 egui::Grid::new("order_form_grid")
1721 .num_columns(2)
1722 .show(ui, |ui| {
1723 ui.label("交易所");
1724 egui::ComboBox::from_id_salt("of_exchange")
1725 .selected_text(f.exchange.clone())
1726 .show_ui(ui, |ui| {
1727 for e in &ex_opts {
1728 ui.selectable_value(&mut f.exchange, e.clone(), e.clone());
1729 }
1730 });
1731 ui.end_row();
1732 ui.label("代码");
1733 let sym_resp = ui.add(
1734 egui::TextEdit::singleline(&mut f.symbol)
1735 .hint_text("cu2709")
1736 .desired_width(150.0),
1737 );
1738 // 代码回车 = 订阅(Python TradingWidget returnPressed → set_en_symbol 等价)。
1739 // egui 单行 TextEdit 遇 Enter 即 surrender_focus,has_focus 在检查时已
1740 // false —— 规范口径 lost_focus + key_pressed(第五轮审计钉:s20 实测
1741 // has_focus 口径回车订阅从不触发)。
1742 if sym_resp.lost_focus() && ui.input(|i| i.key_pressed(egui::Key::Enter)) {
1743 let s = f.symbol.trim().to_string();
1744 // 与查询合约窗同口径:输入带 EX. 前缀则剥成裸代码(ctp.subscribe
1745 // 收裸码);剥后回写表单,名称/盘口/随价的 tick 查找同步可用。
1746 let bare = match s.split_once('.') {
1747 Some((_, b)) => b.trim().to_string(),
1748 None => s,
1749 };
1750 if !bare.is_empty() {
1751 f.symbol = bare.clone();
1752 // 订阅一律路由到行情元账号(规划 §5.C:单源;从账号无 MD 会话,
1753 // 发给它只会静默成功 = 观测黑洞,所以路由在界面侧定死)。
1754 match subscribe_target(shared) {
1755 Ok(gw) => {
1756 shared.push_cmd(UiCmd::CtpSubscribe {
1757 gateway: gw.clone(),
1758 symbols: vec![bare.clone()],
1759 });
1760 shared
1761 .log_line(format!("[ops] 订阅已入列 {bare} → {gw}(代码回车订阅)"));
1762 }
1763 Err(e) => shared.log_line(format!("[订阅] {e}")),
1764 }
1765 }
1766 }
1767 ui.end_row();
1768 ui.label("名称");
1769 ui.label(
1770 tick_of(shared, &f.exchange, &f.symbol)
1771 .map(|t| {
1772 if t.name.is_empty() {
1773 // 0.11.0 第5刀 R6:缺名兜底 = 代码
1774 t.symbol.clone()
1775 } else {
1776 t.name
1777 }
1778 })
1779 .unwrap_or_else(|| "无行情".to_string()),
1780 );
1781 ui.end_row();
1782 ui.label("方向");
1783 egui::ComboBox::from_id_salt("of_direction")
1784 .selected_text(f.direction.as_str())
1785 .show_ui(ui, |ui| {
1786 for d in [Direction::LONG, Direction::SHORT] {
1787 ui.selectable_value(&mut f.direction, d, d.as_str());
1788 }
1789 });
1790 ui.end_row();
1791 ui.label("开平");
1792 ui.horizontal(|ui| {
1793 egui::ComboBox::from_id_salt("of_offset")
1794 .selected_text(f.offset.as_str())
1795 .show_ui(ui, |ui| {
1796 for o in [
1797 Offset::OPEN,
1798 Offset::CLOSE,
1799 Offset::CLOSETODAY,
1800 Offset::CLOSEYESTERDAY,
1801 ] {
1802 ui.selectable_value(&mut f.offset, o, o.as_str());
1803 }
1804 });
1805 // 0.1.1 BD-UI-30:自动开平勾选(开 = Auto 走拆单器;关 = None 原样)。
1806 ui.checkbox(&mut f.auto_split, "自动开平");
1807 });
1808 ui.end_row();
1809 ui.label("类型");
1810 egui::ComboBox::from_id_salt("of_order_type")
1811 .selected_text(f.order_type.as_str())
1812 .show_ui(ui, |ui| {
1813 for ot in [OrderType::LIMIT, OrderType::MARKET] {
1814 ui.selectable_value(&mut f.order_type, ot, ot.as_str());
1815 }
1816 });
1817 ui.end_row();
1818 ui.label("价格");
1819 ui.horizontal(|ui| {
1820 ui.add(
1821 egui::TextEdit::singleline(&mut f.price)
1822 .hint_text("107660")
1823 .desired_width(90.0),
1824 );
1825 ui.checkbox(&mut f.follow_price, "随价");
1826 });
1827 ui.end_row();
1828 ui.label("数量");
1829 ui.add(
1830 egui::TextEdit::singleline(&mut f.volume)
1831 .hint_text("1")
1832 .desired_width(90.0),
1833 );
1834 ui.end_row();
1835 ui.label("接口");
1836 egui::ComboBox::from_id_salt("of_gateway")
1837 .selected_text(if f.gateway.is_empty() {
1838 "(未选账户)".to_string()
1839 } else {
1840 f.gateway.clone()
1841 })
1842 .show_ui(ui, |ui| {
1843 for g in &gw_opts {
1844 ui.selectable_value(&mut f.gateway, g.clone(), g.clone());
1845 }
1846 });
1847 ui.end_row();
1848 ui.label("操作");
1849 ui.horizontal(|ui| {
1850 // 无账户 = 无网关可下单(旧「空 → 字面量 ctp」兜底已退役,B4)。
1851 let send = ui
1852 .add_enabled_ui(!no_accounts, |ui| {
1853 crate::ui_ext::primary_button(ui, BTN_SEND_ORDER)
1854 })
1855 .inner
1856 .clicked();
1857 if send {
1858 match f.to_request() {
1859 Ok(req) => {
1860 let fallback = shared.default_gateway();
1861 match crate::state::parse_gateway(&f.gateway, fallback.as_deref()) {
1862 Ok(gateway) => {
1863 shared.push_cmd(UiCmd::SendOrder {
1864 req,
1865 gateway,
1866 mode: if f.auto_split {
1867 ek_oms::LockMode::Auto
1868 } else {
1869 ek_oms::LockMode::None
1870 },
1871 });
1872 shared.log_line("[ops] 下单请求已入列(等 eTimer 请辞)");
1873 }
1874 Err(e) => {
1875 shared.log_line(format!("[下单] {e}"));
1876 err = Some(e);
1877 }
1878 }
1879 }
1880 Err(e) => {
1881 shared.log_line(format!("[下单] {e}"));
1882 err = Some(e);
1883 }
1884 }
1885 }
1886 if ui.button(BTN_CANCEL_ALL).clicked() {
1887 // 全撤 = 活动委托逐个走 oms.cancel_order(界面侧扇出;
1888 // 守卫逐单计数在 oms,不可绕过——0.1.1 BD-UI-30)
1889 let mut n = 0usize;
1890 for o in ts.orders.iter().filter(|o| order_active(o.status)) {
1891 // 撤单跟着**这笔单自己的网关**走(多账号面:不再回落 ctp)。
1892 let gw = if !o.gateway_name.is_empty() {
1893 o.gateway_name.clone()
1894 } else {
1895 shared.default_gateway().unwrap_or_default()
1896 };
1897 if gw.is_empty() {
1898 continue;
1899 }
1900 shared.push_cmd(UiCmd::CancelOrder {
1901 orderid: o.orderid.clone(),
1902 gateway: gw,
1903 });
1904 n += 1;
1905 }
1906 shared.log_line(format!("[ops] 全撤入列 {n} 笔(等 eTimer 请辞)"));
1907 }
1908 });
1909 ui.end_row();
1910 crate::ui_ext::muted_label(ui, "代码回车 = 订阅");
1911 ui.label("");
1912 ui.end_row();
1913 });
1914 if let Some(e) = err {
1915 ui.label(egui::RichText::new(e).color(crate::tokens::error(ui.ctx())));
1916 }
1917 if no_accounts {
1918 // 侧栏底部独立行(不落钮行内:会把「全撤」推出侧栏宽域,s3 结构钉)。
1919 ui.label(
1920 egui::RichText::new("无账户:先在「账户」面板添加账户(委托钮已禁用)")
1921 .color(crate::tokens::warn(ui.ctx())),
1922 );
1923 }
1924 if f != before {
1925 shared.set_order_form(f.clone());
1926 }
1927}
1928
1929/// 盘口帧(选中合约 tick 五档;Python 买5卖5 等价;独立帧避网格叠行)。
1930/// BD-UI-31(R4):题字撤除(含括号合约代码——选中合约已由下单面板代码格与
1931/// 行情带跳色行指认,盘口帧不重复报幕)。
1932/// 盘口买 / 卖侧色(0.8.0:走当前档的访问器,浅档才会跟档 —— 旧口径是 `const`,
1933/// const 拿不到 `Context`,直用深档常量 = 浅色档下这两支不跟档)。
1934/// 卖 = 跌绿,买 = 涨红(hue 恒定,明度跟档,判据 `u11`)。
1935fn book_ask_color(ctx: &egui::Context) -> egui::Color32 {
1936 crate::tokens::fall(ctx)
1937}
1938fn book_bid_color(ctx: &egui::Context) -> egui::Color32 {
1939 crate::tokens::rise(ctx)
1940}
1941
1942/// 盘口一行 = 三格:档位标签 / 价 / 量(BD-UI-55:egui_extras 退役,盘口换
1943/// `egui::Grid` 三列 —— 它只是一块自适应小表,没有表头/粘顶/角色,够不上
1944/// egui_table 的 delegate 拉动化)。
1945/// **0.8.0 对齐统一(裁定 D):价与量不再右对齐** —— 与档位标签同一左沿,数字走
1946/// `tokens::num_text`(等宽)。这一块的数字仍成列,靠的是等宽不是贴右(毛病 6
1947/// 「盘口贴左缘」由三列小表解决,右对齐退役后由等宽接着守)。
1948fn book_row(row: &mut egui::Ui, tag: String, color: egui::Color32, price: f64, volume: f64) {
1949 row.label(egui::RichText::new(tag).color(color));
1950 row.label(crate::tokens::num_text(crate::format::price(price)).color(color));
1951 row.label(crate::tokens::num_text(crate::format::volume(volume)).color(color));
1952}
1953
1954fn render_book_frame(ui: &mut egui::Ui, shared: &UiShared) {
1955 let f = shared.order_form();
1956 let Some(t) = tick_of(shared, &f.exchange, &f.symbol) else {
1957 crate::ui_ext::muted_label(ui, "(无 tick)");
1958 return;
1959 };
1960 // 0.2.29 Wave A 尾巴(BD-UI-45,毛病 6 的本体):五档盘口原来是一支文本
1961 // `ui.label("卖5 101.5 3")` —— 价与量靠**空格**对齐,位数一变(101.5 → 12345.5)
1962 // 整块就错位、贴左缘。换成三列小表(档 / 价 / 量),价与量右对齐成列。
1963 // 这里**不**用 `pinned_table`:下单侧是窄列 + 外层已有 ScrollArea,`pinned_table`
1964 // 的 `auto_shrink([false, false])` 会吃满整块可用高(0.2.17 s39 那条教训同型)。
1965 // 表头也不加:Python 侧没有五档盘口这个块(只有行情表的买1价/买1量/卖1价/卖1量
1966 // 四列),这是我们自加的常驻盘口,保持无表头。
1967 let (_, _head_h) = table_heights(ui);
1968 let asks: [(f64, f64); 5] = [
1969 (t.ask_price_5, t.ask_volume_5),
1970 (t.ask_price_4, t.ask_volume_4),
1971 (t.ask_price_3, t.ask_volume_3),
1972 (t.ask_price_2, t.ask_volume_2),
1973 (t.ask_price_1, t.ask_volume_1),
1974 ];
1975 let bids: [(f64, f64); 5] = [
1976 (t.bid_price_1, t.bid_volume_1),
1977 (t.bid_price_2, t.bid_volume_2),
1978 (t.bid_price_3, t.bid_volume_3),
1979 (t.bid_price_4, t.bid_volume_4),
1980 (t.bid_price_5, t.bid_volume_5),
1981 ];
1982 // 取色**提到 Grid 之前**(0.8.0):`book_ask_color` 要读 `ui.ctx()`,在 `show` 的闭包里
1983 // 读会和 `grid` 的可变借用撞(E0502);一帧里档不会变,取两次就够。
1984 let ask_color = book_ask_color(ui.ctx());
1985 let bid_color = book_bid_color(ui.ctx());
1986 // `num_columns` 会让**最后一列吃掉父 ui 剩下的宽度**(egui grid.rs:144-154 +
1987 // Grid::num_columns 的注释)→ 「量」贴到面板右缘,价与量之间空出一大截。旧口径是
1988 // TableBuilder 三列 `Column::auto()`(列宽 = 内容)→ 这里不给列数,列宽回到内容驱动
1989 // (0.4.1 实锤 t8:十行里只有 3 个量格还在 x<280 的盘口块里)。
1990 egui::Grid::new("book_grid")
1991 .spacing([4.0, 0.0])
1992 .show(ui, |grid| {
1993 for (k, (p, v)) in asks.iter().enumerate() {
1994 book_row(grid, format!("卖{}", 5 - k), ask_color, *p, *v);
1995 grid.end_row();
1996 }
1997 for (k, (p, v)) in bids.iter().enumerate() {
1998 book_row(grid, format!("买{}", k + 1), bid_color, *p, *v);
1999 grid.end_row();
2000 }
2001 });
2002}
2003
2004// ================= 数据格(2×2;0.4.1 回原生:tab 条在 render_topleft_group 等) =================
2005
2006/// 委托表(17 列逐值 = Python OrderMonitor 蓝图:代码/名称/交易所/类型/方向/
2007/// 开平/价格/总量/已成/成交均价/状态/状态描述/时间/委托号/来源/接口 + 操作;
2008/// 活动行撤单钮 + 双击撤单,终态行只读)。
2009fn render_orders_table(ui: &mut egui::Ui, shared: &UiShared, active_only: bool) {
2010 let ts = shared.trade_snap();
2011 // 摘除标注口径(规划 U8):清册非空时,账本行网关不在清册 = 该账户已摘除。
2012 let known_gws = account_gateways(shared);
2013 // 表题撤除(第五轮审计):格身份就是 dock tab,再挂同名 label = 三重撞名
2014 // (下单钮/tab/表题),纯冗余。
2015 let rows: Vec<_> = ts
2016 .orders
2017 .iter()
2018 .filter(|o| !active_only || order_active(o.status))
2019 .collect();
2020 // 委托表列头单源(空/非空两分支同源,0.2.7 审计口径)。
2021 const ORDER_HEADERS: [&str; 17] = [
2022 "代码",
2023 "名称",
2024 "交易所",
2025 "类型",
2026 "方向",
2027 "开平",
2028 "价格",
2029 "总量",
2030 "已成",
2031 "成交均价",
2032 "状态",
2033 "状态描述",
2034 "时间",
2035 "委托号",
2036 "来源",
2037 "接口",
2038 "操作",
2039 ];
2040 // 0.3.3(收 Wave D 欠账):委托表也吃「点表头排序」—— 表 id 先算出来,
2041 // 空态与非空态共用一份(排序键住在 UiShared,按表 id 分槽)。
2042 let table_id = if active_only {
2043 "active_grid"
2044 } else {
2045 "order_grid"
2046 };
2047 let sort = shared.table_sort(table_id);
2048 // 空态不再分支、不再画提示行(0.4.1 六期 BD-UI-59):body 收出 0 行 = 空表,
2049 // 列宽由 `pinned_table_impl_cols` 按表头比例填满。
2050 // 排序只作用在「喂表前的快照副本」上(W2 口径,数据模型不被界面排序改写)。
2051 let rows = sorted_rows(&rows, sort, |o, col| order_sort_key(o, col));
2052 let clicked = pinned_table_sorted(ui, table_id, &ORDER_HEADERS, sort, |body, row_h| {
2053 // move 格闭包要把这几样所有权收进去 —— 预先用引用整形(move 闭包拷贝引用,
2054 // 不搬 Vec;known_gws/rows 都活到调用帧外,E0382/E0505 实撞)。
2055 let known_gws = &known_gws;
2056 for o in &rows {
2057 // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
2058 // 任何一格双击 = 撤单(Python OrderMonitor itemDoubleClicked→
2059 // cancel_order 等价,活动行限定;显式撤单钮同令并存)。
2060 let key = format!("{}.{}", o.gateway_name, o.orderid);
2061 let row_sel = shared.row_selected("orders", &key);
2062 body.row(row_h, row_sel, |r| {
2063 macro_rules! cell {
2064 ($make:expr, $col:expr) => {{
2065 // key 是**行内局部**:格延迟画笔要活到 show,必须自带 key 的
2066 // 所有权(每格一份克隆;借用会随 add_body 帧悬空,E0373 实撞)。
2067 let key = key.clone();
2068 r.cell(move |ui, ctx| {
2069 let (cell_r, inner_r) =
2070 pin_cell(ui, ctx, $make);
2071 let hit =
2072 cell_r.clicked() || inner_r.as_ref().is_some_and(|r| r.clicked());
2073 if hit {
2074 shared.select_row("orders", &key);
2075 }
2076 let dbl = cell_r.double_clicked()
2077 || inner_r.as_ref().is_some_and(|r| r.double_clicked());
2078 if dbl && order_active(o.status) {
2079 // 双击撤单同按钮口径:跟着这笔单自己的网关(空串回落默认账户阶梯)。
2080 let gw = if !o.gateway_name.is_empty() {
2081 o.gateway_name.clone()
2082 } else {
2083 shared.default_gateway().unwrap_or_default()
2084 };
2085 if !gw.is_empty() {
2086 shared.push_cmd(UiCmd::CancelOrder {
2087 orderid: o.orderid.clone(),
2088 gateway: gw,
2089 });
2090 }
2091 }
2092 });
2093 }};
2094 }
2095 cell!(|ui| ui.label(o.symbol.clone()), 0);
2096 cell!(
2097 |ui| ui.label(if o.name.is_empty() {
2098 // 0.11.0 第5刀 R6:名称兜底 = 代码(不是「-」;行永不因缺名被丢)
2099 o.symbol.clone()
2100 } else {
2101 o.name.clone()
2102 }),
2103 1
2104 );
2105 cell!(|ui| ui.label(o.exchange.as_str().to_string()), 2);
2106 cell!(|ui| ui.label(o.order_type.as_str().to_string()), 3);
2107 cell!(
2108 |ui| ui.label(
2109 egui::RichText::new(o.direction.map(|d| d.as_str()).unwrap_or("-")).color(
2110 if o.direction == Some(Direction::SHORT) {
2111 crate::tokens::fall(ui.ctx())
2112 } else {
2113 crate::tokens::rise(ui.ctx())
2114 },
2115 ),
2116 ),
2117 4
2118 );
2119 cell!(|ui| ui.label(o.offset.as_str().to_string()), 5);
2120 cell!(
2121 |ui| ui.label(crate::tokens::num_text(crate::format::price(o.price))),
2122 6
2123 );
2124 cell!(
2125 |ui| ui.label(crate::tokens::num_text(crate::format::volume(o.volume))),
2126 7
2127 );
2128 cell!(
2129 |ui| ui.label(crate::tokens::num_text(crate::format::volume(o.traded))),
2130 8
2131 );
2132 cell!(
2133 |ui| ui.label(crate::tokens::num_text(crate::format::price(
2134 o.traded_price
2135 ))),
2136 9
2137 );
2138 cell!(
2139 |ui| ui.label(egui::RichText::new(o.status.as_str()).color(
2140 if o.status == ek_data::constant::Status::REJECTED {
2141 crate::tokens::rise(ui.ctx())
2142 } else if o.status == ek_data::constant::Status::ALLTRADED {
2143 crate::tokens::fall(ui.ctx())
2144 } else {
2145 crate::tokens::warn(ui.ctx())
2146 },
2147 )),
2148 10
2149 );
2150 cell!(|ui| ui.label(o.status_msg.clone()), 11);
2151 cell!(
2152 |ui| ui.label(crate::format::time_hms_millis(o.datetime)),
2153 12
2154 );
2155 cell!(|ui| ui.label(o.orderid.clone()), 13);
2156 cell!(
2157 |ui| ui.label(if o.reference.is_empty() {
2158 "-".to_string()
2159 } else {
2160 o.reference.clone()
2161 }),
2162 14
2163 );
2164 cell!(
2165 |ui| ui.label(ledger_gw_label(&o.gateway_name, known_gws)),
2166 15
2167 );
2168 // 「操作」列 = 活动行的撤单钮(延迟画笔:借用 o/key,出不了调用帧)。
2169 r.cell(|ui, _ctx| {
2170 ui.horizontal(|ui| {
2171 if order_active(o.status)
2172 && ui
2173 .small_button(format!("{BTN_CANCEL_ORDER} {}", o.orderid))
2174 .clicked()
2175 {
2176 // 撤单跟随委托的来路网关(行级 gateway_name;
2177 // 多账号面:空串回落默认账户阶梯,不再硬编码 ctp)
2178 let gw = if !o.gateway_name.is_empty() {
2179 o.gateway_name.clone()
2180 } else {
2181 shared.default_gateway().unwrap_or_default()
2182 };
2183 if gw.is_empty() {
2184 shared.log_line(format!(
2185 "[撤单] {} 无网关可撤(账户清册空)",
2186 o.orderid
2187 ));
2188 } else {
2189 shared.push_cmd(UiCmd::CancelOrder {
2190 orderid: o.orderid.clone(),
2191 gateway: gw,
2192 });
2193 }
2194 }
2195 });
2196 });
2197 });
2198 }
2199 });
2200 if let Some(col) = clicked {
2201 shared.toggle_table_sort(table_id, col);
2202 }
2203}
2204
2205/// 委托行的排序键(列序 == `ORDER_HEADERS`):数字列给零填充串保证字典序 == 数值序
2206/// (`价格/总量/已成/成交均价`),时间列给纳秒零填充,其余给该列的文本。
2207/// 0.3.3 收 Wave D 欠账时新增 —— 与成交表的 `trade_sort_key` 同一口径。
2208fn order_sort_key(o: &ek_data::order::OrderData, col: usize) -> String {
2209 match col {
2210 0 => o.symbol.clone(),
2211 1 => o.name.clone(),
2212 2 => o.exchange.as_str().to_string(),
2213 3 => o.order_type.as_str().to_string(),
2214 4 => o
2215 .direction
2216 .map(|d| d.as_str().to_string())
2217 .unwrap_or_default(),
2218 5 => o.offset.as_str().to_string(),
2219 6 => format!("{:020.4}", o.price),
2220 7 => format!("{:020.4}", o.volume),
2221 8 => format!("{:020.4}", o.traded),
2222 9 => format!("{:020.4}", o.traded_price),
2223 10 => o.status.as_str().to_string(),
2224 11 => o.status_msg.clone(),
2225 12 => o.datetime.map(|ns| format!("{ns:025}")).unwrap_or_default(),
2226 13 => o.orderid.clone(),
2227 14 => o.reference.clone(),
2228 15 => o.gateway_name.clone(),
2229 // 第 17 列是「操作」= 撤单钮,没有可排的数据 → 空串(点它排序等于不动)。
2230 _ => String::new(),
2231 }
2232}
2233
2234/// 成交格(12 列逐值 = Python TradeMonitor 蓝图)。
2235pub(crate) fn render_trades_group(ui: &mut egui::Ui, shared: &UiShared) {
2236 // 单 tab(Python `tab_widget2.addTab(trade_widget, "成交")`:那区也是 QTabWidget,
2237 // 只有一个 tab 也带 tab 头 —— BD-UI-41 补齐;0.4.0 删过,0.4.1 回归原生后恢复)。
2238 tab_label(ui, true, "成交");
2239 let ts = shared.trade_snap();
2240 // 摘除标注口径(规划 U8):清册非空时,账本行网关不在清册 = 该账户已摘除。
2241 let known_gws = account_gateways(shared);
2242 // 成交表列头单源(空/非空两分支同源,0.2.7 审计口径)。
2243 // 0.3.3 Wave F(BD-UI-51):列序照 Python `TradeMonitor.headers`(widget.py:1270-1283)——
2244 // 代码在首列,成交号在第 10 列;原来我们把「成交号」放首列,是差集里唯一一条纯 UI 差集。
2245 // 列名「成交额」→「成交金额」同 Python。
2246 const TRADE_HEADERS: [&str; 12] = [
2247 "代码",
2248 "名称",
2249 "交易所",
2250 "方向",
2251 "开平",
2252 "价格",
2253 "数量",
2254 "成交金额",
2255 "时间",
2256 "成交号",
2257 "委托号",
2258 "接口",
2259 ];
2260 // 空态不再分支、不再画提示行(0.4.1 六期 BD-UI-59,同未成交口径)。
2261 let sort = shared.table_sort("trade_grid");
2262 let rows = sorted_rows(&ts.trades, sort, trade_sort_key);
2263 let clicked = pinned_table_sorted(ui, "trade_grid", &TRADE_HEADERS, sort, |body, row_h| {
2264 // move 格闭包要把这几样所有权收进去 —— 预先引用整形(同委托表口径)。
2265 let rows = &rows;
2266 let known_gws = &known_gws;
2267 for t in rows.iter().copied() {
2268 // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
2269 // 方向列上色(R2,与委托/持仓表同口径:空绿/多红)。
2270 let key = format!("{}.{}", t.gateway_name, t.tradeid);
2271 let row_sel = shared.row_selected("trades", &key);
2272 body.row(row_h, row_sel, |r| {
2273 macro_rules! cell {
2274 ($make:expr, $col:expr) => {{
2275 // key 是行内局部:格延迟画笔要活到 show,每格自备克隆(见委托表)。
2276 let key = key.clone();
2277 r.cell(move |ui, ctx| {
2278 let (cell_r, inner_r) =
2279 pin_cell(ui, ctx, $make);
2280 let hit =
2281 cell_r.clicked() || inner_r.as_ref().is_some_and(|r| r.clicked());
2282 if hit {
2283 shared.select_row("trades", &key);
2284 }
2285 // 0.3.1(Wave D,BD-UI-49)双击联动:双击成交行 = 该合约进下单面板
2286 // (Python 双击成交/持仓行带入下单,`mainwindow.py:276` 等价)。
2287 let dbl = cell_r.double_clicked()
2288 || inner_r.as_ref().is_some_and(|r| r.double_clicked());
2289 if dbl {
2290 let mut f = shared.order_form();
2291 f.symbol = t.symbol.clone();
2292 if let Some(d) = t.direction {
2293 f.direction = d;
2294 }
2295 shared.set_order_form(f);
2296 }
2297 // 0.3.1(Wave D)右键菜单(照 Python 表上右键:调整列宽 / 保存数据)。
2298 // 只挂首列 = 一行一颗菜单,不在每格挂一颗。
2299 // 0.3.3(收 Wave D 欠账):菜单挂在**真控件**上 —— 首格内容是
2300 // `Label::new(..).sense(Sense::click())`(有 AccessKit 动作的真控件),
2301 // 菜单由它自己的 `context_menu` 开。
2302 // 0.4.1 五期(BD-UI-58):菜单里的「调整列宽」退役 —— 列边界可拖
2303 // 与列线现在是全部表的固定形制(见 `pinned_table_impl_cols`),
2304 // 一个只影响这一张表、还只影响「能不能拖」的开关成了空壳钮。
2305 });
2306 }};
2307 }
2308 // 首格是**真控件**(可点 + 可右键):右键菜单挂在这颗 Label 上。
2309 cell!(
2310 |ui| {
2311 let r = ui
2312 .add(egui::Label::new(t.symbol.clone()).sense(egui::Sense::click()))
2313 .on_hover_text("右键:保存数据");
2314 r.context_menu(|ui| {
2315 if ui.button("保存数据").clicked() {
2316 let _ =
2317 save_table_csv("trade_grid", &TRADE_HEADERS, rows, trade_cells);
2318 ui.close();
2319 }
2320 });
2321 r
2322 },
2323 0
2324 );
2325 cell!(
2326 |ui| ui.label(if t.name.is_empty() {
2327 // 0.11.0 第5刀 R6:名称兜底 = 代码(不是「-」;行永不因缺名被丢)
2328 t.symbol.clone()
2329 } else {
2330 t.name.clone()
2331 }),
2332 1
2333 );
2334 cell!(|ui| ui.label(t.exchange.as_str().to_string()), 2);
2335 cell!(
2336 |ui| ui.label(
2337 egui::RichText::new(t.direction.map(|d| d.as_str()).unwrap_or("-")).color(
2338 if t.direction == Some(Direction::SHORT) {
2339 crate::tokens::fall(ui.ctx())
2340 } else {
2341 crate::tokens::rise(ui.ctx())
2342 },
2343 ),
2344 ),
2345 3
2346 );
2347 cell!(|ui| ui.label(t.offset.as_str().to_string()), 4);
2348 cell!(
2349 |ui| ui.label(crate::tokens::num_text(crate::format::price(t.price))),
2350 5
2351 );
2352 cell!(
2353 |ui| ui.label(crate::tokens::num_text(crate::format::volume(t.volume))),
2354 6
2355 );
2356 cell!(
2357 |ui| ui.label(crate::tokens::num_text(crate::format::price(
2358 t.traded_amount
2359 ))),
2360 7
2361 );
2362 // 「时间」列(第 8 列)0.8.0 **不进等宽改造**:这一列旧口径就是左对齐
2363 // (不在六张表的右对齐格位清单里),本轮改造范围 = 旧右对齐格位 + 盘口
2364 // (方案 §5 的 R8 范围钉)。实撞:给它上等宽(FONT_MONO 15px)把列撑宽 →
2365 // 列被推出视口 → 判据 W6 的标签数变 0。
2366 cell!(|ui| ui.label(crate::format::time_hms_millis(t.datetime)), 8);
2367 cell!(|ui| ui.label(t.tradeid.clone()), 9);
2368 cell!(|ui| ui.label(t.orderid.clone()), 10);
2369 cell!(
2370 |ui| ui.label(ledger_gw_label(&t.gateway_name, known_gws)),
2371 11
2372 );
2373 });
2374 }
2375 // 右键菜单已挂在第 1 格那颗真控件上(见体表 cell!(.., 0))。
2376 });
2377 if let Some(col) = clicked {
2378 shared.toggle_table_sort("trade_grid", col);
2379 }
2380}
2381
2382/// 持仓格(16 列逐值 = Python PositionMonitor 蓝图;双击行带入下单面板,
2383/// Python mainwindow.py:276 等价,不开 K线)。
2384pub(crate) fn render_positions_group(ui: &mut egui::Ui, shared: &UiShared) {
2385 // 单 tab(Python `tab_widget3.addTab(position_widget, "持仓")`;BD-UI-41 补齐,
2386 // 0.4.0 删过,0.4.1 回归原生后恢复)。
2387 tab_label(ui, true, "持仓");
2388 let ts = shared.trade_snap();
2389 // 摘除标注口径(规划 U8):清册非空时,账本行网关不在清册 = 该账户已摘除。
2390 let known_gws = account_gateways(shared);
2391 // 持仓表列头单源(空/非空两分支同源,0.2.7 审计口径)。
2392 const POS_HEADERS: [&str; 16] = [
2393 "代码",
2394 "名称",
2395 "交易所",
2396 "方向",
2397 "数量",
2398 "昨仓",
2399 "可用",
2400 "冻结",
2401 "在途",
2402 "市值",
2403 "成本",
2404 "均价",
2405 "最新价",
2406 "盈亏",
2407 "盈亏比",
2408 "接口",
2409 ];
2410 // 空态不再分支、不再画提示行(0.4.1 六期 BD-UI-59,同未成交口径)。
2411 // 0.3.3(收 Wave D 欠账):持仓表也吃「点表头排序」。
2412 let sort = shared.table_sort("pos_grid");
2413 let rows = sorted_rows(&ts.positions, sort, pos_sort_key);
2414 let clicked = pinned_table_sorted(ui, "pos_grid", &POS_HEADERS, sort, |body, row_h| {
2415 // move 格闭包要把这几样所有权收进去 —— 预先引用整形(同委托表口径)。
2416 let known_gws = &known_gws;
2417 for p in &rows {
2418 // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
2419 // 任何一格双击 = 带入下单面板(Python mainwindow.py:276 等价,
2420 // 不开 K线;方向随持仓方向,Python 同口径)。
2421 let key = format!("{}.{}.{}", p.gateway_name, p.symbol, p.direction.as_str());
2422 let row_sel = shared.row_selected("positions", &key);
2423 body.row(row_h, row_sel, |r| {
2424 macro_rules! cell {
2425 ($make:expr, $col:expr) => {{
2426 // key 是行内局部:格延迟画笔要活到 show,每格自备克隆(见委托表)。
2427 let key = key.clone();
2428 r.cell(move |ui, ctx| {
2429 let (cell_r, inner_r) =
2430 pin_cell(ui, ctx, $make);
2431 let hit =
2432 cell_r.clicked() || inner_r.as_ref().is_some_and(|r| r.clicked());
2433 if hit {
2434 shared.select_row("positions", &key);
2435 }
2436 let dbl = cell_r.double_clicked()
2437 || inner_r.as_ref().is_some_and(|r| r.double_clicked());
2438 if dbl {
2439 let mut f = shared.order_form();
2440 f.symbol = p.symbol.clone();
2441 f.exchange = p.exchange.as_str().to_string();
2442 f.direction = p.direction;
2443 // B1 修:行级网关带入(旧实现不带网关 → 平掉哪条腿由上一单残留决定)。
2444 if !p.gateway_name.is_empty() {
2445 f.gateway = p.gateway_name.clone();
2446 }
2447 shared.set_order_form(f);
2448 shared.log_line(format!(
2449 "[ops] 持仓带入下单面板 {}(接口 {})",
2450 p.symbol, p.gateway_name
2451 ));
2452 }
2453 });
2454 }};
2455 }
2456 cell!(|ui| ui.label(p.symbol.clone()), 0);
2457 cell!(
2458 |ui| ui.label(if p.name.is_empty() {
2459 // 0.11.0 第5刀 R6:名称兜底 = 代码
2460 p.symbol.clone()
2461 } else {
2462 p.name.clone()
2463 }),
2464 1
2465 );
2466 cell!(|ui| ui.label(p.exchange.as_str().to_string()), 2);
2467 cell!(
2468 |ui| ui.label(egui::RichText::new(p.direction.as_str()).color(
2469 if p.direction == ek_data::constant::Direction::SHORT {
2470 crate::tokens::fall(ui.ctx())
2471 } else {
2472 crate::tokens::rise(ui.ctx())
2473 },
2474 )),
2475 3
2476 );
2477 cell!(
2478 |ui| ui.label(crate::tokens::num_text(crate::format::volume(p.volume))),
2479 4
2480 );
2481 cell!(
2482 |ui| ui.label(crate::tokens::num_text(crate::format::volume(p.yd_volume))),
2483 5
2484 );
2485 cell!(
2486 |ui| ui.label(crate::tokens::num_text(crate::format::volume(
2487 p.can_use_volume
2488 ))),
2489 6
2490 );
2491 cell!(
2492 |ui| ui.label(crate::tokens::num_text(crate::format::volume(p.frozen))),
2493 7
2494 );
2495 cell!(
2496 |ui| ui.label(crate::tokens::num_text(crate::format::volume(
2497 p.on_road_volume
2498 ))),
2499 8
2500 );
2501 cell!(
2502 |ui| ui.label(crate::tokens::num_text(crate::format::price(
2503 p.market_value
2504 ))),
2505 9
2506 );
2507 // 0.3.3 Wave F(BD-UI-51)两处收口:
2508 // ① 成本 / 均价原来**取值互换** —— ek-data 里 `avg_price` = 成本价、
2509 // `price` = 持仓均价(position.rs:22-23 / 38-39),Python 也是
2510 // 成本 ← avg_price、均价 ← price(widget.py:1491-1492)。判据 F2 抓到这条。
2511 // ② 五处裸 `format!("{:.2}")` / `{:+.1}` / `{:+.4}` 改走 `format.rs`
2512 // (Python BaseCell 是 `round(content, 3)`,同一张表里三种精度就是毛病 3)。
2513 cell!(
2514 |ui| ui.label(crate::tokens::num_text(crate::format::price(p.avg_price))),
2515 10
2516 );
2517 cell!(
2518 |ui| ui.label(crate::tokens::num_text(crate::format::price(p.price))),
2519 11
2520 );
2521 cell!(
2522 |ui| ui.label(crate::tokens::num_text(crate::format::price(p.last_price))),
2523 12
2524 );
2525 cell!(
2526 |ui| ui.label(crate::tokens::num_text(crate::format::price(p.pnl)).color(
2527 if p.pnl < 0.0 {
2528 crate::tokens::fall(ui.ctx())
2529 } else {
2530 crate::tokens::rise(ui.ctx())
2531 }
2532 ),),
2533 13
2534 );
2535 cell!(
2536 |ui| ui.label(crate::tokens::num_text(crate::format::price(p.profit_rate))),
2537 14
2538 );
2539 cell!(
2540 |ui| ui.label(ledger_gw_label(&p.gateway_name, known_gws)),
2541 15
2542 );
2543 });
2544 }
2545 });
2546 if let Some(col) = clicked {
2547 shared.toggle_table_sort("pos_grid", col);
2548 }
2549}
2550
2551/// 持仓行的排序键(列序 == `POS_HEADERS`;与屏幕取值同源:
2552/// 成本 = `avg_price`、均价 = `price`,0.3.3 Wave F 修的那一对)。
2553fn pos_sort_key(p: &ek_data::position::PositionData, col: usize) -> String {
2554 match col {
2555 0 => p.symbol.clone(),
2556 1 => p.name.clone(),
2557 2 => p.exchange.as_str().to_string(),
2558 3 => p.direction.as_str().to_string(),
2559 4 => format!("{:020.4}", p.volume),
2560 5 => format!("{:020.4}", p.yd_volume),
2561 6 => format!("{:020.4}", p.can_use_volume),
2562 7 => format!("{:020.4}", p.frozen),
2563 8 => format!("{:020.4}", p.on_road_volume),
2564 9 => format!("{:020.4}", p.market_value),
2565 10 => format!("{:020.4}", p.avg_price),
2566 11 => format!("{:020.4}", p.price),
2567 12 => format!("{:020.4}", p.last_price),
2568 13 => format!("{:020.4}", p.pnl),
2569 14 => format!("{:020.4}", p.profit_rate),
2570 15 => p.gateway_name.clone(),
2571 _ => String::new(),
2572 }
2573}
2574
2575/// 资金格(0.4.0:独立 dock 格 —— 原来它是「资金|日志」组内 tab 的一半)。
2576pub(crate) fn render_funds_pane(ui: &mut egui::Ui, shared: &UiShared) {
2577 let ts = shared.trade_snap();
2578 // 0.2.29(BD-UI-44):资金表跟着日志表换 TableBuilder —— 同一套固定表头 + 按内容
2579 // 列宽;余额/可用/冻结是数字列(右对齐成列)。
2580 //
2581 // 0.4.0 修正(用户实看:「资金…表头都没有」):空态**不得吞掉表头**。原来这里
2582 // `if accounts.is_empty() { muted_label; return; }` —— 没有网关时整张表连表头一起
2583 // 消失,而它就是「资金|日志」格默认前台的那一格,用户第一眼看到的就是一句空态。
2584 // 口径统一成「表头恒在」(委托/成交/持仓/日志同此);0.4.1 六期(BD-UI-59)起空态
2585 // 那一行提示文字也撤了 —— 表体就是空的,列宽按表头比例填满。
2586 pinned_table_impl(
2587 ui,
2588 "acct_grid",
2589 &["账号", "接口", "余额", "可用", "冻结"],
2590 None,
2591 |body, row_h| {
2592 for a in &ts.accounts {
2593 body.row(row_h, false, |r| {
2594 macro_rules! cell {
2595 ($make:expr, $col:expr) => {{
2596 r.cell(|ui, ctx| {
2597 let _ = pin_cell(ui, ctx, $make);
2598 });
2599 }};
2600 }
2601 cell!(|ui| ui.label(a.accountid.clone()), 0);
2602 cell!(|ui| ui.label(a.gateway_name.clone()), 1);
2603 // 0.3.3 Wave F:三处裸 `{:.2}` 改走 `format.rs`(同一口径,毛病 3)。
2604 cell!(
2605 |ui| ui.label(crate::tokens::num_text(crate::format::price(a.balance))),
2606 2
2607 );
2608 cell!(
2609 |ui| ui.label(crate::tokens::num_text(crate::format::price(a.available()))),
2610 3
2611 );
2612 cell!(
2613 |ui| ui.label(crate::tokens::num_text(crate::format::price(a.frozen))),
2614 4
2615 );
2616 });
2617 }
2618 },
2619 );
2620}
2621
2622/// 日志表(BD-UI-41,对照 Python 版)。
2623///
2624/// Python 侧「日志」tab 里放的是 `LogMonitor` —— 一个带 **时间/信息/接口** 表头的
2625/// QTableWidget(`widget.py:1167-1180`,BaseMonitor 子类),跟着 Dock 一起伸展。
2626/// 我们原来是一坨 monospace 行 + `ScrollArea::max_height(180.0)` 硬顶:窗口最大化
2627/// 它还是 180px —— 用户报的「整体放到最大,日志那边表格还是很小」根因就是那 180。
2628/// 现在走 `pinned_table`(与委托/成交/持仓同一套容器:表头固定 + 体滚 + 横滚),
2629/// 硬顶撤除 → 格多大,表多大。
2630///
2631/// 两处偏离(记 DESIGN BD-UI-41):
2632/// ① Python 有第三列「接口」;我们的 `log_line` 调用点不带网关(正文自带 `[ops]` /
2633/// `[订阅]` 这类前缀),硬造一列空列不如不造,所以只有两列。
2634/// ② `stick_to_bottom` 撤除:Python 的 QTableWidget 也不自动跟到最后一行,
2635/// 要看最新行自己滚到底(与那张表同口径)。
2636fn render_logs(ui: &mut egui::Ui, shared: &UiShared) {
2637 // 「清空日志」钮已撤除(0.4.1 用户裁定 2026-10-22:日志面不要这个钮)。
2638 // 状态层的 `UiShared::clear_logs()` 保留(它是状态口,测试与后续「日志面重置」
2639 // 都用得上),只是界面不再给入口。
2640 let (entries, spilled) = shared.logs_entries();
2641 if spilled > 0 {
2642 // 口径写明(G1 实连证据的收口):回扫日志取证不可靠 —— 巡回里「重加后 90 秒
2643 // 没抓到『交易服务器登录成功』行」不是没登录,是这一环被状态推送流挤满了。
2644 // 登录/掉线/查询被拒这些事实的事实源是账户面板的状态列与状态细节(网关状态口),
2645 // 不是日志窗。单独一行,不挤在钮旁:长文案在横向行里会被压(s39 那类实锤)。
2646 ui.label(format!(
2647 "已丢弃 {spilled} 条(环形 {}):日志窗是窗口不是历史 —— 登录/掉线/查询被拒看账户面板的状态列与状态细节,别回扫这里",
2648 crate::state::RING_CAP
2649 ));
2650 }
2651 // BD-UI-55(egui_table 迁入):日志正文逐帧生长 → 列宽走**接管版**(字体量串,
2652 // egui galley 缓存受益;不走库 per-frame auto-size,那条路 = 每帧双 pass,
2653 // 行动作用闭包会跑两遍 —— 适配层注释)。时间列定宽 90,信息列 = 最宽正文。
2654 let mono_font = egui::TextStyle::Monospace.resolve(ui.style());
2655 // 空态不接管列宽 —— 走「按表头比例分配」那条路(BD-UI-58)。
2656 let widths: Option<Vec<f32>> = if entries.is_empty() {
2657 None
2658 } else {
2659 Some(vec![
2660 {
2661 let g = ui.painter().layout_no_wrap(
2662 "18:00:00.000".to_string(),
2663 mono_font.clone(),
2664 egui::Color32::TRANSPARENT,
2665 );
2666 g.size().x + 12.0
2667 },
2668 {
2669 let mut w: f32 = 120.0;
2670 for e in &entries {
2671 let g = ui.painter().layout_no_wrap(
2672 e.text.clone(),
2673 mono_font.clone(),
2674 egui::Color32::TRANSPARENT,
2675 );
2676 w = w.max(g.size().x + 12.0);
2677 }
2678 w
2679 },
2680 ])
2681 };
2682 pinned_table_impl_cols(
2683 ui,
2684 "log_grid",
2685 &["时间", "信息"],
2686 None,
2687 widths,
2688 |body, row_h| {
2689 for e in &entries {
2690 body.row(row_h, false, |r| {
2691 r.cell(|ui, _ctx| {
2692 ui.monospace(e.at.clone());
2693 });
2694 r.cell(|ui, _ctx| {
2695 ui.monospace(e.text.clone());
2696 });
2697 });
2698 }
2699 },
2700 );
2701}
2702
2703// ================= 独立窗面(BD-UI-32/33)=================
2704
2705/// 独立窗几何(BD-UI-34:助手参数收敛,8→6 闸 clippy too_many_arguments)。
2706struct WinGeom {
2707 inner: [f32; 2],
2708 min_inner: [f32; 2],
2709 maximized: bool,
2710}
2711
2712/// 独立 OS 窗统一开法(BD-UI-33,四窗一型:运维/CTP/查询合约/K线)。
2713///
2714/// - **守卫(0.2.3 教训内建):** 调用方按状态位辞行——位关不调本函数 =
2715/// viewport 本拍未 used = egui/eframe GC 销毁 OS 窗(销毁判据源码
2716/// context.rs「never used this pass」)。
2717/// - Embedded 回退(后端不支持多窗:kittest/WEB)= 主窗内 egui::Window 同本体,
2718/// 回退面关闭 = embedded 闭包返回 true。
2719/// - Immediate 面 OS X = close_requested → 返回 true(调用方翻负状态位)。
2720/// - `geom.maximized` = 打开即最大化(BD-UI-34,K线窗用户裁定;OS 窗属性,
2721/// Embedded 回退面无此概念 = 忽略)。
2722/// - `body` 返回 true = 内容侧请求关闭(BD-UI-34:K线窗 ESC 键快捷关闭;
2723/// 键事件按子窗焦点路由,主窗按键不会误关)。
2724///
2725/// 返回 = "本拍该窗被关"(调用方负责状态位/列表出表)。
2726fn show_independent_window(
2727 ctx: &egui::Context,
2728 id_salt: impl std::hash::Hash,
2729 title: &str,
2730 geom: &WinGeom,
2731 embedded: impl Fn(&egui::Context) -> bool,
2732 body: impl Fn(&mut egui::Ui) -> bool,
2733) -> bool {
2734 let closed = std::cell::Cell::new(false);
2735 let mut builder = egui::ViewportBuilder::default()
2736 .with_title(title)
2737 .with_inner_size(geom.inner)
2738 .with_min_inner_size(geom.min_inner)
2739 .with_minimize_button(true)
2740 .with_maximize_button(true)
2741 .with_close_button(true);
2742 if geom.maximized {
2743 builder = builder.with_maximized(true);
2744 }
2745 ctx.show_viewport_immediate(
2746 egui::ViewportId::from_hash_of(id_salt),
2747 builder,
2748 |ctx2, class| {
2749 if class == egui::ViewportClass::Embedded {
2750 closed.set(embedded(ctx2));
2751 return;
2752 }
2753 if ctx2.input(|i| i.viewport().close_requested()) {
2754 closed.set(true);
2755 return;
2756 }
2757 egui::CentralPanel::default().show(ctx2, |ui| {
2758 if body(ui) {
2759 closed.set(true);
2760 }
2761 });
2762 },
2763 );
2764 closed.get()
2765}
2766
2767fn render_windows(ctx: &egui::Context, shared: &UiShared) {
2768 // 运维窗(菜单「运维」;BD-UI-33 转独立 OS 窗,用户裁定「四窗皆可脱离主窗」)。
2769 if shared.ops_window_open() {
2770 let closed = show_independent_window(
2771 ctx,
2772 "ops_win",
2773 "运维窗",
2774 &WinGeom {
2775 inner: [680.0, 420.0],
2776 min_inner: [420.0, 260.0],
2777 maximized: false,
2778 },
2779 |ctx2| {
2780 let mut open = shared.ops_window_open();
2781 egui::Window::new("运维窗")
2782 .id(egui::Id::new("ops_win"))
2783 .default_pos([80.0, 320.0])
2784 .default_size([640.0, 380.0])
2785 .open(&mut open)
2786 .show(ctx2, |ui| {
2787 render_ops_window(ui, shared);
2788 });
2789 shared.set_ops_window_open(open);
2790 !open
2791 },
2792 |ui| {
2793 render_ops_window(ui, shared);
2794 false
2795 },
2796 );
2797 if closed {
2798 shared.set_ops_window_open(false);
2799 }
2800 }
2801
2802 // 账户面板(菜单「账户」;多账号面:账户清单 + 行情源选择 + 添加/编辑表单;
2803 // 旧「CTP 网关配置窗」退役收纳于此窗,BD-UI-33 独立 OS 窗形态沿用)。
2804 if shared.accounts_window_open() {
2805 let closed = show_independent_window(
2806 ctx,
2807 "account_win",
2808 "账户面板",
2809 &WinGeom {
2810 inner: [760.0, 520.0],
2811 min_inner: [520.0, 320.0],
2812 maximized: false,
2813 },
2814 |ctx2| {
2815 let mut open = shared.accounts_window_open();
2816 egui::Window::new("账户面板")
2817 .id(egui::Id::new("account_win"))
2818 .default_pos([640.0, 320.0])
2819 .default_size([720.0, 470.0])
2820 .open(&mut open)
2821 .show(ctx2, |ui| {
2822 render_accounts_window(ui, shared);
2823 });
2824 shared.set_accounts_window_open(open);
2825 !open
2826 },
2827 |ui| {
2828 render_accounts_window(ui, shared);
2829 false
2830 },
2831 );
2832 if closed {
2833 shared.set_accounts_window_open(false);
2834 }
2835 }
2836
2837 // 账户配置弹窗(0.2.18 Commit B,规划裁定「一张列表 + 配置弹窗」):
2838 // 『添加账户』与『编辑 <账户>』开同一个弹窗的两种模式;**非 modal**(不阻塞主窗与行情观察)。
2839 // 关闭(窗 × 或『取消』)= 放弃未保存(规划 Q24),绝不静默写入清册留档。
2840 if shared.account_edit_open() {
2841 let closed = show_independent_window(
2842 ctx,
2843 "account_edit_win",
2844 "账户配置",
2845 &WinGeom {
2846 inner: [680.0, 340.0],
2847 min_inner: [480.0, 240.0],
2848 maximized: false,
2849 },
2850 |ctx2| {
2851 let mut open = shared.account_edit_open();
2852 let title = match shared.editing_account() {
2853 Some(gw) => format!("账户配置 — 编辑 {gw}"),
2854 None => "账户配置 — 添加".to_string(),
2855 };
2856 egui::Window::new(title)
2857 .id(egui::Id::new("account_edit_win"))
2858 .default_pos([700.0, 380.0])
2859 .default_size([660.0, 320.0])
2860 .open(&mut open)
2861 .show(ctx2, |ui| {
2862 render_account_edit_window(ui, shared);
2863 });
2864 if !open {
2865 shared.end_account_edit();
2866 }
2867 !open
2868 },
2869 |ui| {
2870 render_account_edit_window(ui, shared);
2871 false
2872 },
2873 );
2874 if closed && shared.account_edit_open() {
2875 shared.end_account_edit();
2876 }
2877 }
2878
2879 // 查询合约窗(菜单「查询合约」;Python ContractManager 等价:查询 + 勾选 + 订阅)。
2880 if shared.contracts_window_open() {
2881 let closed = show_independent_window(
2882 ctx,
2883 "contracts_win",
2884 "查询合约窗",
2885 &WinGeom {
2886 inner: [620.0, 460.0],
2887 min_inner: [420.0, 260.0],
2888 maximized: false,
2889 },
2890 |ctx2| {
2891 let mut open = shared.contracts_window_open();
2892 egui::Window::new("查询合约窗")
2893 .id(egui::Id::new("contracts_win"))
2894 .default_pos([420.0, 300.0])
2895 .default_size([560.0, 420.0])
2896 .open(&mut open)
2897 .show(ctx2, |ui| {
2898 render_contracts_window(ui, shared);
2899 });
2900 shared.set_contracts_window_open(open);
2901 !open
2902 },
2903 |ui| {
2904 render_contracts_window(ui, shared);
2905 false
2906 },
2907 );
2908 if closed {
2909 shared.set_contracts_window_open(false);
2910 }
2911 }
2912
2913 // K线窗(双击弹出,按合约多开;出 kline_symbols 列表 = 不再 show = 销毁)。
2914 // BD-UI-34:打开即最大化(maximized)+ ESC 键快捷关闭(body 请求关闭;
2915 // 键按子窗焦点路由,主窗按键不误关)。
2916 let mut closed: Vec<String> = Vec::new();
2917 for sym in shared.kline_symbols() {
2918 let is_closed = show_independent_window(
2919 ctx,
2920 format!("kline_win:{sym}"),
2921 &format!("K线 — {sym}"),
2922 &WinGeom {
2923 inner: [560.0, 360.0],
2924 min_inner: [360.0, 220.0],
2925 maximized: true,
2926 },
2927 |ctx2| {
2928 let esc = ctx2.input(|i| i.key_pressed(egui::Key::Escape));
2929 let resp = egui::Window::new(format!("K线 — {sym}"))
2930 .id(egui::Id::new(("kline_win", sym.clone())))
2931 .default_pos([300.0, 340.0])
2932 .default_size([540.0, 330.0])
2933 .show(ctx2, |ui| {
2934 let cell = shared
2935 .market()
2936 .cells()
2937 .into_iter()
2938 .find(|c| c.symbol == sym);
2939 render_kline_cell(ui, cell.as_ref());
2940 });
2941 esc || resp.is_none()
2942 },
2943 |ui| {
2944 if ui.input(|i| i.key_pressed(egui::Key::Escape)) {
2945 return true;
2946 }
2947 let cell = shared
2948 .market()
2949 .cells()
2950 .into_iter()
2951 .find(|c| c.symbol == sym);
2952 render_kline_cell(ui, cell.as_ref());
2953 false
2954 },
2955 );
2956 if is_closed {
2957 closed.push(sym);
2958 }
2959 }
2960 for s in closed {
2961 shared.close_kline(&s);
2962 }
2963}
2964
2965/// 运维窗:插件表(svctl 操作 + 二次确认)+ 待确认横幅 + 服务目录(三列)
2966/// + 依赖图。回灌界面面已退役(总线口保留;流控查询钮 0.2.10 随 sim 退场撤除)。
2967fn render_ops_window(ui: &mut egui::Ui, shared: &UiShared) {
2968 crate::ui_ext::section_title(ui, "插件");
2969 // 0.5 M3:装配显形改吃事件(启动 / `ePlugUp.oms`),这里只留一个手动口子。
2970 // 为什么放在「插件」节而不是「oms 管线」节:问不到时那一节整节不画(s87b 口径),
2971 // 钮挂在那儿就等于「有读数才给重问」—— 恰恰在没读数的时候最需要重问。
2972 ui.horizontal(|ui| {
2973 if ui.small_button(BTN_PIPELINE_REFRESH).clicked() {
2974 shared.request_pipeline_refresh();
2975 }
2976 ui.label(
2977 egui::RichText::new("管线读数只在 oms 上线 / 启动 / 这里手动触发时问一次")
2978 .color(crate::tokens::info(ui.ctx())),
2979 );
2980 });
2981 let snap = shared.snapshot();
2982 // 账户清册里的实例名(一次取好,别在每行每帧各 clone 一遍整表)。
2983 let account_gateways: std::collections::HashSet<String> = shared
2984 .accounts()
2985 .iter()
2986 .map(|a| a.gateway.clone())
2987 .collect();
2988 let mut plug_heads: Vec<(egui::Rect, String)> = Vec::new();
2989 let mut plug_rows: Vec<f32> = Vec::new();
2990 // 列宽下限(BD-UI-60:短表表宽 = 所在区域 100%,口径与实现见 `ui_ext::grid_col_width`)。
2991 let plug_col_w = crate::ui_ext::grid_col_width(ui, "plug_grid", 6);
2992 // 行高下限与表格层同一口径(BD-UI-61:`table_heights` 同一对数,短表行高 = 主表行高)。
2993 let plug_row_h = table_heights(ui).0;
2994 egui::Grid::new("plug_grid")
2995 .num_columns(6)
2996 .min_col_width(plug_col_w)
2997 .min_row_height(plug_row_h)
2998 .show(ui, |ui| {
2999 for h in ["名称", "状态", "版本", "依赖", "统计", "操作"] {
3000 let r = ui.label(egui::RichText::new(h).strong().small());
3001 plug_heads.push((r.rect, h.to_string()));
3002 }
3003 ui.end_row();
3004 // 空态不再画提示行(0.4.1 六期 BD-UI-59):快照空 = 这张表只有表头那一行。
3005 for r in &snap.rows {
3006 if is_quarantined(&r.state) {
3007 ui.label(
3008 egui::RichText::new(r.name.clone()).color(crate::tokens::error(ui.ctx())),
3009 );
3010 ui.label(
3011 egui::RichText::new(state_text(r))
3012 .color(crate::tokens::error(ui.ctx()))
3013 .strong(),
3014 );
3015 } else {
3016 ui.label(r.name.clone());
3017 ui.label(state_text(r));
3018 }
3019 ui.label(r.version.clone());
3020 ui.label(format!("deps:[{}]", r.deps.join(",")));
3021 // 统计列(0.4.5 P7d 首发;0.7.0 背压刀加水位):丢=软顶触发的丢弃累计,
3022 // 爆=panic 累计,积压=当前邮箱深度,峰=历史峰值,软=该插件自己的软顶。
3023 // 上色按最坏一项(判据纯函数 stat_color);只上色不改布局。
3024 ui.label(
3025 egui::RichText::new(format!(
3026 "丢:{} 爆:{} 积压:{} 峰:{} 软:{}",
3027 r.spilled, r.panics, r.pending, r.peak, r.soft_cap
3028 ))
3029 .color(stat_color(
3030 crate::tokens::theme_of(ui.ctx()),
3031 r.spilled,
3032 r.panics,
3033 r.pending,
3034 r.soft_cap,
3035 )),
3036 );
3037 ui.horizontal(|ui| {
3038 // Q17 收口(0.2.20):账户清册里的实例不在运维窗起停。
3039 // 账户面板的『移除』带全套守卫(活跃委托闸 + 二次确认 + 持仓提示),
3040 // 运维窗这条是同一动作的无守卫副本 —— 同一个实例两条移除路、守卫只长在
3041 // 一条上,等于守卫可以绕过(规划 Q17 的边界就在这)。
3042 // 清册外的 `ctp_*` 实例(手工起的 / 旧流程残留)仍留这条出口,否则没有退路。
3043 if account_gateways.contains(&r.name) {
3044 ui.label(
3045 egui::RichText::new("起停归『账户』面板(带撤单守卫)")
3046 .color(crate::tokens::info(ui.ctx())),
3047 );
3048 } else if r.name == UI_NAME || r.name == SVCTL_NAME {
3049 // 管制面与观测面自身不给移除钮(0.4.3 BD-UI-64,审核 P1)。
3050 // 摘 svctl = 单向门:工厂表(default_kinds / ui_kinds)都不登记 "svctl",
3051 // 摘掉后连『重注入 svctl』也只会回 unknown factory,启停面没有恢复入口。
3052 // 摘 ui = 自己等自己:这条指令正是 ui 自己的 worker 在执行,只能走到
3053 // ek-core close_one 的 2 秒超时 detach 分支,窗口还在但不再刷新。
3054 // 插件侧同一道闸:supervisor 拒摘 svctl(ek-station 0.2.11)、
3055 // UiPlugin 直拒摘 ui(本 crate plugin.rs)。
3056 ui.label(
3057 egui::RichText::new("管制面/观测面自身:不在运维窗摘除")
3058 .color(crate::tokens::info(ui.ctx())),
3059 );
3060 if ui.small_button(format!("重注入 {}", r.name)).clicked() {
3061 shared.push_cmd(UiCmd::Start {
3062 factory: r.name.clone(),
3063 name: String::new(),
3064 });
3065 }
3066 } else {
3067 if ui.small_button(format!("重注入 {}", r.name)).clicked() {
3068 // 运维窗按「注册名 = 工厂名」的旧插件重注入(dm/oms/ui);
3069 // 命名网关实例(`ctp_<broker>_<账号>`)不是工厂名,会被
3070 // supervisor 回拒 unknown factory —— 那类实例的起停归「账户」面板。
3071 shared.push_cmd(UiCmd::Start {
3072 factory: r.name.clone(),
3073 name: String::new(),
3074 });
3075 }
3076 let armed = shared.pending_confirm();
3077 let armed_here = ui
3078 .small_button(remove_button_label(&r.name, armed.as_deref()))
3079 .clicked()
3080 && shared.confirm_step(&r.name) == ConfirmStep::Fired;
3081 if armed_here {
3082 shared.push_cmd(UiCmd::Remove {
3083 name: r.name.clone(),
3084 });
3085 }
3086 }
3087 });
3088 plug_rows.push(ui.min_rect().max.y);
3089 ui.end_row();
3090 }
3091 });
3092 let plug_band = header_band(ui, &plug_heads, ui.min_rect().max.x);
3093 grid_chrome(ui, plug_band, &plug_heads, &plug_rows);
3094
3095 if let Some(name) = shared.pending_confirm() {
3096 ui.horizontal(|ui| {
3097 ui.label(
3098 egui::RichText::new(format!("待二次确认:再次点击『移除 {name}』完成"))
3099 .color(crate::tokens::warn(ui.ctx())),
3100 );
3101 if ui.small_button(BTN_CANCEL_CONFIRM).clicked() {
3102 shared.confirm_cancel();
3103 }
3104 });
3105 }
3106
3107 // oms 管线(0.4.4,P5-a 裁定接的那条服务):装配显形。
3108 // 插件表给「谁在场」,这一节给「oms 里面装了什么」——五段管线 / 限速与撤单守卫 /
3109 // 拆单器 / 每道风控闸一行(工厂注入 ek_risk::standard_gates 缺省限额那四道)。
3110 // 问不到(oms 不在场 → TargetGone 快错,或超时)整节不画:这里没有表、没有可空的
3111 // 东西,与六期 BD-UI-59「空态 = 表头 + 0 行」不是同一种空。
3112 let pipeline = shared.pipeline_lines();
3113 if !pipeline.is_empty() {
3114 crate::ui_ext::space_group(ui);
3115 crate::ui_ext::section_title(ui, "oms 管线");
3116 for line in &pipeline {
3117 ui.label(egui::RichText::new(line).monospace());
3118 }
3119 }
3120
3121 // 配置托底(0.6.0,BD-CFG 环节8):段落目录(零值面)+ 清段/重存段。
3122 // save 联线的另一半长在网关自己身上(`{gw}.configure` 受理成功 → 三行序,
3123 // ek-station DESIGN BD-CFG-14 的 0.10.1 扩)。这里给的是运维面:
3124 // 看段落目录(哪个 ns 有哪些键、哪些是引用)、修格式 rev、误配后抹段。
3125 crate::ui_ext::space_group(ui);
3126 crate::ui_ext::section_title(ui, "配置托底");
3127 ui.horizontal(|ui| {
3128 if ui.small_button(BTN_CFG_REFRESH).clicked() {
3129 shared.arm_cfg_delete(None);
3130 shared.request_cfg_refresh();
3131 }
3132 ui.label(
3133 egui::RichText::new(format!(
3134 "段落目录零值面(只要键名/形态;小键名 = 明面,(引用) = {} 形)",
3135 ek_cfg::REF_PREFIX
3136 ))
3137 .color(crate::tokens::info(ui.ctx())),
3138 );
3139 });
3140 match shared.cfg_briefs() {
3141 None => {
3142 ui.label(
3143 egui::RichText::new("(未问过段落目录;点『刷新段落目录』再画)")
3144 .color(crate::tokens::muted(ui.ctx())),
3145 );
3146 }
3147 Some(briefs) if briefs.is_empty() => {
3148 ui.label(
3149 egui::RichText::new("(无段落;配置受理成功后会出现)")
3150 .color(crate::tokens::muted(ui.ctx())),
3151 );
3152 }
3153 Some(briefs) => {
3154 let b_col_w = crate::ui_ext::grid_col_width(ui, "cfgb_grid", 4);
3155 let b_row_h = table_heights(ui).0;
3156 egui::Grid::new("cfgb_grid")
3157 .num_columns(4)
3158 .min_col_width(b_col_w)
3159 .min_row_height(b_row_h)
3160 .show(ui, |ui| {
3161 for h in ["ns", "rev", "键", "操作"] {
3162 ui.label(egui::RichText::new(h).strong().small());
3163 }
3164 ui.end_row();
3165 for b in &briefs {
3166 ui.label(b.ns.clone());
3167 ui.label(b.rev.to_string());
3168 ui.label(format!(
3169 "{} 条:{}",
3170 b.keys.len(),
3171 b.keys
3172 .iter()
3173 .map(|k| if k.secret {
3174 format!("{}(引用)", k.key)
3175 } else {
3176 k.key.clone()
3177 })
3178 .collect::<Vec<_>>()
3179 .join("、"),
3180 ));
3181 ui.horizontal(|ui| {
3182 let armed = shared.cfg_delete_armed();
3183 let label = if armed.as_deref() == Some(b.ns.as_str()) {
3184 format!("再次点击 清段 {}", b.ns)
3185 } else {
3186 format!("清段 {}", b.ns)
3187 };
3188 if ui.small_button(label).clicked() {
3189 if armed.as_deref() == Some(b.ns.as_str()) {
3190 shared.arm_cfg_delete(None);
3191 shared.push_cmd(UiCmd::CfgDelete { ns: b.ns.clone() });
3192 } else {
3193 shared.arm_cfg_delete(Some(b.ns.clone()));
3194 }
3195 }
3196 if ui.small_button(format!("重存段 {}", b.ns)).clicked() {
3197 shared.push_cmd(UiCmd::CfgResave { ns: b.ns.clone() });
3198 }
3199 });
3200 ui.end_row();
3201 }
3202 });
3203 }
3204 }
3205
3206 crate::ui_ext::space_group(ui);
3207 crate::ui_ext::section_title(ui, "服务");
3208 let flat: Vec<String> = snap
3209 .services
3210 .iter()
3211 .flat_map(|(n, ids)| {
3212 if ids.is_empty() {
3213 vec![format!("{n} 服务"), "-".to_string()]
3214 } else {
3215 ids.iter()
3216 .flat_map(|id| [format!("{n} 服务"), id.clone()])
3217 .collect()
3218 }
3219 })
3220 .collect();
3221 // 表头(BD-UI-41,用户指出「配置那边表格也要有表头」):这张表原来六列纯数据没有头行,
3222 // 列语义 = 三对「服务名 / 实例 id」,头就照这个写。
3223 // 0.4.0 修正(用户实看:「运维…的表格也都要处理」):空态**不得吞掉表头**。原来空态只剩
3224 // 一句「(无服务目录)」,表头带与列宽全没了 —— 与资金格同一个病;口径 = 表头恒画。
3225 // (当时补的那句「空态是表体内的一行」到六期 BD-UI-59 撤除:空态 = 表头 + 0 行。)
3226 let mut svc_heads: Vec<(egui::Rect, String)> = Vec::new();
3227 let mut svc_rows: Vec<f32> = Vec::new();
3228 // 列宽下限同 plug_grid(BD-UI-60)。
3229 let svc_col_w = crate::ui_ext::grid_col_width(ui, "svc_grid", 6);
3230 let svc_row_h = table_heights(ui).0;
3231 egui::Grid::new("svc_grid")
3232 .num_columns(6)
3233 .min_col_width(svc_col_w)
3234 .min_row_height(svc_row_h)
3235 .show(ui, |ui| {
3236 for _ in 0..3 {
3237 for h in ["服务", "实例"] {
3238 let r = ui.label(egui::RichText::new(h).strong().small());
3239 svc_heads.push((r.rect, h.to_string()));
3240 }
3241 }
3242 ui.end_row();
3243 // 空态不再画提示行(0.4.1 六期 BD-UI-59):目录空 = 这张表只有表头那一行
3244 // (`rows = 0` → 循环不跑),表头带照画。
3245 let rows = flat.len().div_ceil(6); // 每列 2 字段 × 3 列
3246 for r in 0..rows {
3247 for c in 0..3 {
3248 let i = c * rows * 2 + r * 2;
3249 if i < flat.len() {
3250 ui.label(flat[i].clone());
3251 ui.label(flat[i + 1].clone());
3252 } else {
3253 ui.label("");
3254 ui.label("");
3255 }
3256 }
3257 svc_rows.push(ui.min_rect().max.y);
3258 ui.end_row();
3259 }
3260 });
3261 let svc_band = header_band(ui, &svc_heads, ui.min_rect().max.x);
3262 grid_chrome(ui, svc_band, &svc_heads, &svc_rows);
3263
3264 ui.label("依赖");
3265 if !snap.rows.iter().any(|r| !r.deps.is_empty()) {
3266 ui.label("(全部无依赖)");
3267 }
3268 for r in &snap.rows {
3269 if !r.deps.is_empty() {
3270 ui.label(format!("{} → {}", r.name, r.deps.join(" + ")));
3271 }
3272 }
3273}
3274
3275/// 账户面板(0.2.18 Commit B,规划裁定「一张列表 + 配置弹窗」):
3276/// 列表上方 = 行情源一览 + 账户计数(软上限)+ 『添加账户』入口;
3277/// 列表 = **跨账户一览**(状态 / 行情源 / 收录勾选与网关实际收录 / 行操作);
3278/// 配置表单**移入独立弹窗**(`render_account_edit_window`)—— 本窗不再内嵌表单,
3279/// 旧「窗内一张共享表单」退役(消 U4 凭据串味 / U6 取消编辑不清空的界面根)。
3280fn render_accounts_window(ui: &mut egui::Ui, shared: &UiShared) {
3281 let accounts = shared.accounts();
3282 let locked = shared.accounts_locked();
3283 let md = shared.md_source();
3284 let snap = shared.trade_snap();
3285
3286 // 行内显示名(别名优先,空回退账号;重名回退派生名)。
3287 // 同一行里『编辑 X』与『移除 X』必须用同一个 X(规划 U10 口径齐),
3288 // 而寻址恒用派生名 —— 别名只是显示,不参与寻址(规划 Q3)。
3289 let row_label: std::collections::BTreeMap<String, String> = accounts
3290 .iter()
3291 .map(|a| {
3292 let d = a.display_name();
3293 let dup = accounts.iter().filter(|x| x.display_name() == d).count() > 1;
3294 (a.gateway.clone(), if dup { a.gateway.clone() } else { d })
3295 })
3296 .collect();
3297
3298 // 列表上方:行情源一览(订阅一律走它,与账户增删无关)+ 计数 + 添加入口。
3299 ui.horizontal(|ui| {
3300 ui.label(
3301 egui::RichText::new(format!(
3302 "当前行情源 = {}",
3303 if md.is_empty() {
3304 "(未指定)".to_string()
3305 } else {
3306 md.clone()
3307 }
3308 ))
3309 .strong(),
3310 );
3311 ui.label(format!(
3312 "账户 {}/{}",
3313 accounts.len(),
3314 crate::state::MAX_ACCOUNTS
3315 ));
3316 if shared.can_add_account() {
3317 if ui.button(BTN_ACCOUNT_ADD).clicked() {
3318 shared.begin_account_edit(None);
3319 }
3320 } else {
3321 ui.label(
3322 egui::RichText::new(format!(
3323 "账户已达软上限 {} 个:先移除一个再添加(『添加账户』已禁用)",
3324 crate::state::MAX_ACCOUNTS
3325 ))
3326 .color(crate::tokens::warn(ui.ctx())),
3327 );
3328 }
3329 });
3330
3331 const ACCOUNT_HEADERS: [&str; 8] = [
3332 "网关(派生名)",
3333 "别名",
3334 "账号",
3335 "状态",
3336 "阶段",
3337 "行情源",
3338 "收录(勾→实)",
3339 "操作",
3340 ];
3341 // 0.2.17 布局修复:账户清单不用 pinned_table。pinned_table = ScrollArea
3342 // (auto_shrink=false,吃掉整块可用高)+ 覆盖式表头带;账户窗是**自动尺寸浮动窗**,
3343 // 两者凑不出正确高度 → 表行与其后的口径句**互相压字**(快照钉 s39 实锤)。
3344 // 账户行最多个位数,普通 Grid 就够,不需要固定表头滚动面 —— 但表头带照补
3345 // (BD-UI-41:走 `header_band`,它正是为「自动尺寸浮动窗里的短表」准备的)。
3346 let mut acct_heads: Vec<(egui::Rect, String)> = Vec::new();
3347 let mut acct_rows: Vec<f32> = Vec::new();
3348 // 列宽下限同 plug_grid(BD-UI-60)。
3349 let acct_col_w = crate::ui_ext::grid_col_width(ui, "account_grid", 8);
3350 let acct_row_h = table_heights(ui).0;
3351 egui::Grid::new("account_grid")
3352 .num_columns(8)
3353 .min_col_width(acct_col_w)
3354 .min_row_height(acct_row_h)
3355 .show(ui, |ui| {
3356 for h in &ACCOUNT_HEADERS {
3357 let r = ui.label(egui::RichText::new(*h).strong().small());
3358 acct_heads.push((r.rect, h.to_string()));
3359 }
3360 ui.end_row();
3361 // 空态不再画提示行(0.4.1 六期 BD-UI-59):清册空 = 这张表只有表头那一行。
3362 for a in &accounts {
3363 let is_md = a.gateway == md;
3364 let name = row_label
3365 .get(&a.gateway)
3366 .cloned()
3367 .unwrap_or_else(|| a.gateway.clone());
3368 ui.label(a.gateway.clone());
3369 // 别名(空 = 显示 "—";寻址恒用派生名,别名不参与,规划 Q3)。
3370 ui.label(if a.alias.trim().is_empty() {
3371 "—".to_string()
3372 } else {
3373 a.alias.clone()
3374 });
3375 ui.label(a.account.clone());
3376 // 状态列(0.2.19 起两段):装配态(svctl 在场位)+ **登录态**(`{gw}.status` 读数)。
3377 // 登录成败不再靠猜:ek-ctp 0.9.0 的 `{gw}.status` 是事实源(规划 P3 / 裁定 3),
3378 // 没有读数时仍写「已装配·登录态未知」,不得写成「已连接」(规划 U5 口径不变)。
3379 // 文案一律 `Extend`(不换行):账户面板是 Grid,状态列被挤窄时逐字竖排
3380 // 会把一行撑成十几行高(s39 快照实锤过)。
3381 match a.stage {
3382 crate::state::AccountStage::AssembleFailed => {
3383 ui.add(
3384 egui::Label::new(
3385 egui::RichText::new(format!(
3386 "装配失败:{}",
3387 a.fail_note.clone().unwrap_or_else(|| "未知原因".to_string())
3388 ))
3389 .color(crate::tokens::error(ui.ctx())),
3390 )
3391 .wrap_mode(egui::TextWrapMode::Extend),
3392 );
3393 }
3394 _ => {
3395 let color = match a.login {
3396 crate::state::LoginState::Online => crate::tokens::ok(ui.ctx()),
3397 crate::state::LoginState::LoginFailed
3398 | crate::state::LoginState::FrontDown => {
3399 crate::tokens::error(ui.ctx())
3400 }
3401 crate::state::LoginState::QueryStarved => {
3402 crate::tokens::warn(ui.ctx())
3403 }
3404 // Unknown / Stopped:灰 —— 没有证据与主动停会话都不该着色成"出事"
3405 _ => crate::tokens::muted(ui.ctx()),
3406 };
3407 // 0.4.1 十期 BD-UI-63(用户裁定):登录被拒时,**柜台原因直接跟着红字打在账户行上**
3408 // (实连实锤:220380 在 7×24 套被柜台拒「不合法的登录(3)」,而账户行只写
3409 // 「已装配·登录失败」—— 用户只看到"登不上",看不到"为什么登不上")。
3410 // 只跟短标签(整句在窗下方「状态细节」那一行给全):Grid 状态列被长句挤宽
3411 // 会把别的列顶窄(s39 口径)。
3412 let text = match (a.login.is_alarm(), a.login_brief.as_ref()) {
3413 (true, Some(brief)) => format!("{}·{}", a.status_label(), brief),
3414 _ => a.status_label(),
3415 };
3416 ui.add(
3417 egui::Label::new(egui::RichText::new(text).color(color))
3418 .wrap_mode(egui::TextWrapMode::Extend),
3419 );
3420 }
3421 }
3422 // 阶段列(0.5.0,用户定「链进行的状态改为事件日志推送」):该网关最近一条 `[链] `
3423 // 状态行的正文(ek-ctp 0.9.8 推的链状态)。`None` = 这一条会话还没推过,或实例已不在场
3424 // (`sync_accounts_connected` 一并作废)→ 「—」。
3425 // 它只是显示:不参与状态列那套在线/断供判据。与状态列一样 `Extend`——Grid 里
3426 // 被挤窄会逐字竖排(s39 实锤)。
3427 ui.add(
3428 egui::Label::new(
3429 egui::RichText::new(a.chain_note.clone().unwrap_or_else(|| "—".to_string()))
3430 .color(crate::tokens::muted(ui.ctx()))
3431 .small(),
3432 )
3433 .wrap_mode(egui::TextWrapMode::Extend),
3434 );
3435 // 行情元账号:配置阶段任选;任何账户已装配即锁定(规划 D3)。
3436 ui.horizontal(|ui| {
3437 if is_md {
3438 ui.label(egui::RichText::new("● 行情源").strong());
3439 }
3440 let resp = ui.add_enabled_ui(!locked || is_md, |ui| {
3441 ui.small_button(if is_md {
3442 "已是行情源"
3443 } else {
3444 "设为行情源"
3445 })
3446 });
3447 if resp.inner.clicked() {
3448 match shared.set_md_source(&a.gateway) {
3449 Ok(()) => shared.log_line(format!("[账户] 行情源 = {}", a.gateway)),
3450 Err(e) => shared.log_line(format!("[账户] {e}")),
3451 }
3452 }
3453 });
3454 // 收录:勾选(意图)→ 网关实际回带(事实),并排显示(规划 U9)。
3455 // 旧口径:`ConfigureReply.product_classes` 既不回填也不显示,勾选是否生效无从判断。
3456 ui.vertical(|ui| {
3457 ui.add(
3458 egui::Label::new(egui::RichText::new(format!(
3459 "勾:{}",
3460 classes_label(&a.form.product_classes())
3461 )))
3462 .wrap_mode(egui::TextWrapMode::Extend),
3463 );
3464 ui.add(
3465 egui::Label::new(egui::RichText::new(format!(
3466 "实:{}",
3467 if a.effective_classes.is_empty() {
3468 "—".to_string()
3469 } else {
3470 classes_label(&a.effective_classes)
3471 }
3472 )))
3473 .wrap_mode(egui::TextWrapMode::Extend),
3474 );
3475 });
3476 // 操作:连接/重试(四态分离的『连接』入口)/ 断开(0.2.19 停会话)/ 编辑(开配置弹窗)/ 移除(守卫 + 先撤入口)。
3477 ui.horizontal(|ui| {
3478 let failed = a.stage == crate::state::AccountStage::AssembleFailed;
3479 let idle = a.stage == crate::state::AccountStage::NotAssembled;
3480 // 会话被主动停掉(『断开』)但实例还在:恢复入口仍是这一颗『连接』
3481 // (走 `UiCmd::Connect` → svctl 回「已在场」→ 插件侧改走重投凭据,规划裁定 1)。
3482 let stopped = a.login == crate::state::LoginState::Stopped;
3483 if failed || idle || stopped {
3484 // 规划 U3 定盘:装配失败**不回滚清册行**,行留着给『重试』
3485 // (旧口径"必须先移除才能重试"作废)。
3486 let label = if failed {
3487 format!("重试 {name}")
3488 } else {
3489 format!("连接 {name}")
3490 };
3491 if ui.small_button(label).clicked() {
3492 push_connect(shared, &a.gateway, &a.form);
3493 }
3494 }
3495 // 该账户的活跃委托数(『断开』与『移除』共用同一道守卫,见下)。
3496 let open = snap
3497 .orders
3498 .iter()
3499 .filter(|o| o.gateway_name == a.gateway && o.is_active())
3500 .count();
3501 // 『断开』(0.2.19,规划裁定 1「断开 = 停会话,移除 = 停实例」):
3502 // 只对**已装配、会话还活着、且没有活跃委托**的行开。
3503 // - 未装配没有会话可停(规划 Q21:口不存在时不留死钮;现在口已实现,钮才允许出现);
3504 // - 有活跃委托时不给断开 —— 会话一停就撤不了单、也不再回报,与『移除』
3505 // 要挡的是同一个观测黑洞(规划 §5.B),出口同样是旁边那句『先撤 N 笔』。
3506 // `&&` 短路即"条件不成立就不画这颗钮",不是画出来再禁用。
3507 if a.stage == crate::state::AccountStage::Assembled
3508 && a.login != crate::state::LoginState::Stopped
3509 && open == 0
3510 && ui.small_button(format!("断开 {name}")).clicked()
3511 {
3512 shared.push_cmd(UiCmd::Disconnect {
3513 gateway: a.gateway.clone(),
3514 });
3515 shared.log_line(format!(
3516 "[账户] 断开 {gateway}:已入列(停会话;实例与订阅保留,『连接』可恢复)",
3517 gateway = a.gateway
3518 ));
3519 }
3520 if ui.small_button(format!("编辑 {name}")).clicked() {
3521 // 编辑 = 开配置弹窗(草稿 = 该账户自己的留档)。
3522 // 旧的 `select_row("account_grid", …)` 行选记槽已无读者(内嵌表单时代遗留)→ 撤除。
3523 shared.begin_account_edit(Some(&a.gateway));
3524 }
3525 let has_pos = snap
3526 .positions
3527 .iter()
3528 .any(|p| p.gateway_name == a.gateway && (p.volume + p.yd_volume) > 0.0);
3529 if open > 0 {
3530 // 守卫硬挡:柜台还在跑单而没人能撤 = 观测黑洞(规划 §5.B)。
3531 ui.label(
3532 egui::RichText::new(format!("有 {open} 笔活跃委托:先撤单才能移除"))
3533 .color(crate::tokens::warn(ui.ctx())),
3534 );
3535 // 规划 U10:守卫不能只把用户堵在门口,要给出口 ——
3536 // 『先撤 N 笔』按该账户的活跃委托逐笔入列(与「全撤」同一条 oms 通道,
3537 // 走每笔单自己的网关,撞撤单计数守卫时显形 limit:cancel-guard)。
3538 if ui.small_button(format!("先撤 {open} 笔")).clicked() {
3539 for o in snap
3540 .orders
3541 .iter()
3542 .filter(|o| o.gateway_name == a.gateway && o.is_active())
3543 {
3544 shared.push_cmd(UiCmd::CancelOrder {
3545 orderid: o.orderid.clone(),
3546 gateway: a.gateway.clone(),
3547 });
3548 }
3549 shared.log_line(format!(
3550 "[账户] 先撤 {}:{} 笔活跃委托已入列(撤完才可移除)",
3551 a.gateway, open
3552 ));
3553 }
3554 } else {
3555 // 二次确认的记槽按**派生名**(寻址主键),按钮文案用显示名 ——
3556 // 两者必须在这里对上,否则首点后按钮永远翻不到『确认移除』(Commit B 自查抓到的坑)。
3557 let armed = shared.pending_confirm();
3558 let armed_here = armed.as_deref() == Some(a.gateway.as_str());
3559 let fired = ui
3560 .small_button(remove_button_label(
3561 &name,
3562 if armed_here { Some(name.as_str()) } else { None },
3563 ))
3564 .clicked()
3565 && shared.confirm_step(&a.gateway) == ConfirmStep::Fired;
3566 if fired {
3567 shared.push_cmd(UiCmd::Remove {
3568 name: a.gateway.clone(),
3569 });
3570 shared.remove_account(&a.gateway);
3571 // 弹窗是非 modal:若这行正在被编辑,摘除必须连带关弹窗放弃,
3572 // 否则弹窗会静默退化成「添加模式」,点『保存』会拿旧凭据建新账户。
3573 shared.end_account_edit_if_editing(&a.gateway);
3574 if has_pos {
3575 shared.log_line(format!(
3576 "[账户] 移除 {}:有持仓 —— 柜台侧不受影响,重加该账户后由轮转查询重建视图",
3577 a.gateway
3578 ));
3579 }
3580 }
3581 }
3582 });
3583 acct_rows.push(ui.min_rect().max.y);
3584 ui.end_row();
3585 }
3586 });
3587 let acct_band = header_band(ui, &acct_heads, ui.min_rect().max.x);
3588 grid_chrome(ui, acct_band, &acct_heads, &acct_rows);
3589
3590 if let Some(gw) = shared.pending_confirm() {
3591 // 提示句与行内钮同一显示名(行里写『移除 220380』,提示就不能写『移除 ctp_9999_220380』)。
3592 let shown = row_label.get(&gw).cloned().unwrap_or(gw.clone());
3593 ui.horizontal(|ui| {
3594 ui.label(
3595 egui::RichText::new(format!("待二次确认:再次点击『移除 {shown}』完成"))
3596 .color(crate::tokens::warn(ui.ctx())),
3597 );
3598 if ui.small_button(BTN_CANCEL_CONFIRM).clicked() {
3599 shared.confirm_cancel();
3600 }
3601 });
3602 }
3603
3604 ui.label(if locked {
3605 "行情源已锁定(有账户已装配):换源需先移除该账户 → 改配置 → 重连(规划 D3)"
3606 } else {
3607 "行情源:配置阶段任选;非源账户的 md 前置一律留空(单源纪律 §5.C)"
3608 });
3609 // 状态口径统一说明(面板底部一句,不逐行重复 —— 逐行会把状态列撑成竖排):
3610 ui.label(
3611 egui::RichText::new(format!(
3612 "状态列 = 实例装配 + 网关状态口 {{gw}}.status(每拍最多问 {} 个账户,环形轮询);阶段列 = 网关推送的 `[链] ` 链状态行(结算单确认 → 查合约 → 资金/持仓轮询走到哪一步);『断开』= 停会话(实例与订阅保留),『移除』= 停实例",
3613 crate::state::STATUS_ASKS_PER_TICK
3614 ))
3615 .color(crate::tokens::info(ui.ctx())),
3616 );
3617 // F4 口径显形(0.2.20):多账户下「谁查谁过滤」此前只能靠猜 —— 实连 S14b 里
3618 // 账户 B 把勾选改成「期货+期权」,公用合约表仍是 852 条、期权 0 条,用户没有任何
3619 // 办法判断是自己没生效、还是网关没查到。这里把口径写死成一句(不靠界面猜):
3620 // 勾选只管**这个网关自己**收录并上抛的部分,公用表是在场各网关的并集。
3621 ui.label(egui::RichText::new(TXT_PRODUCT_CLASS_SCOPE).color(crate::tokens::info(ui.ctx())));
3622 // 状态细节(0.2.19):凡是有话可说的行都给一句(带次数、带秒数、带原因)。
3623 // 为什么不在状态列里带:Grid 列宽实测会被长文案挤成竖排(s39 实锤)。
3624 // 为什么不只给告警行:「状态口问不到」与「纯行情账户」也是事实 ——
3625 // 灰色徽标不给原因,用户就只能猜「是没问到还是没登录」。
3626 // 只给已装配的行:会话读数属于那个实例,行都「未装配」了还印「掉线 2 次」
3627 // 就是在替一个不存在的会话说话(状态侧由 `sync_accounts_connected` 一并作废,
3628 // 这里是不对称时刻——快照还没刷——的第二道闸)。
3629 // 健康行没有细节(`count_note(…, 0) = None`),所以这一段不会随账户数无谓变长。
3630 for a in accounts
3631 .iter()
3632 .filter(|a| a.stage == crate::state::AccountStage::Assembled && a.status_note.is_some())
3633 {
3634 let note = a.status_note.clone().unwrap_or_default();
3635 let alarm = a.login.is_alarm() || a.login == crate::state::LoginState::QueryStarved;
3636 let color = if alarm {
3637 crate::tokens::error(ui.ctx())
3638 } else {
3639 crate::tokens::info(ui.ctx())
3640 };
3641 ui.label(egui::RichText::new(format!("状态细节 {}:{}", a.gateway, note)).color(color));
3642 // 0.3.2(Wave E,BD-UI-50):告警 toast **不在这里产生**。产生口只有一处
3643 // = `UiShared::note_gateway_status`(轮询一拍),判据 e6 钉着这条归属。
3644 // 在这里弹 = 账户窗没开就没有告警,而 Python 的 AlertEngine 与哪个窗在不在无关。
3645 }
3646 // 元账号 md 前置为空 = 永远收不到 tick(添加时被单源纪律清空,须编辑页补填)。
3647 if let Some(src) = accounts.iter().find(|a| a.gateway == md)
3648 && src.form.md_addr.trim().is_empty()
3649 {
3650 ui.label(
3651 egui::RichText::new(format!(
3652 "元账号 {} 的 md 前置为空:点『编辑 {}』补填 md 前置,否则行情不会出数",
3653 src.gateway,
3654 row_label
3655 .get(&src.gateway)
3656 .cloned()
3657 .unwrap_or_else(|| src.account.clone())
3658 ))
3659 .color(crate::tokens::warn(ui.ctx())),
3660 );
3661 }
3662}
3663
3664/// 账户配置弹窗(0.2.18 Commit B,规划裁定「一张列表 + 配置弹窗」):『添加账户』与
3665/// 『编辑 <账户>』开**同一个弹窗的两种模式**;非 modal(不阻塞主窗与行情观察)。
3666/// 账号/前置全部界面手工输入,插件不读文件;密码位掩码;**无订阅字段** ——
3667/// 用户裁定:订阅走下单面板代码回车或查询合约窗勾选。
3668/// 关闭(『取消』或窗 ×)= **放弃未保存**(规划 Q24);被拦 → 弹窗不关 + 原因上屏(规划 Q26)。
3669/// 账户表单的标签列(0.4.1 九期 BD-UI-62,用户裁定「这几个字段全部放成一列,数值也放成一列,
3670/// 每一个字段一行」):标签占固定宽,数值列因此对齐成一列。
3671///
3672/// 为什么不用 `Grid`:0.2.17 实锤(s39 同一段)—— 表单 Grid 的列宽在测量期被「窗宽 / 列数」
3673/// 夹死(实测每格 ≈120px),`desired_width` 永不生效,一根真实前置 `tcp://182.254.242.81:30001`
3674/// 只显示出 "tcp:/"。固定宽的标签格 + 同一行剩下的宽度给数值,两头都不夹。
3675const ACCT_FORM_LABEL_W: f32 = 86.0;
3676
3677fn acct_form_label(ui: &mut egui::Ui, text: &str) {
3678 ui.scope_builder(
3679 egui::UiBuilder::new().max_rect(egui::Rect::from_min_size(
3680 ui.cursor().min,
3681 egui::vec2(
3682 ACCT_FORM_LABEL_W,
3683 ui.text_style_height(&egui::TextStyle::Body),
3684 ),
3685 )),
3686 |ui| {
3687 ui.label(text);
3688 },
3689 );
3690}
3691
3692fn render_account_edit_window(ui: &mut egui::Ui, shared: &UiShared) {
3693 let editing: Option<crate::state::AccountRow> =
3694 shared.editing_account().and_then(|g| shared.account(&g));
3695 let editing_on = editing.is_some();
3696 let md = shared.md_source();
3697 let locked = shared.accounts_locked();
3698 let mut form: crate::state::CtpForm = shared.ctp_form();
3699 let mut alias = shared.edit_alias();
3700 // 被拦原因上屏(形制校验 / 清册守卫 / 装配被拒):弹窗不关(规划 U3 / Q26)。
3701 if let Some(e) = shared.edit_error() {
3702 ui.label(egui::RichText::new(format!("拦下:{e}")).color(crate::tokens::error(ui.ctx())));
3703 }
3704 // 0.2.17 布局口径:表单用 horizontal 行不用 Grid —— Grid 列宽在测量期被
3705 // 「窗宽 / 列数」夹死(实测每格 ≈120px),`desired_width` 永不生效,
3706 // 一根真实前置 `tcp://182.254.242.81:30001`(30 字符)只显示出 "tcp:/"。
3707 // 身份行:别名(仅显示用,不参与寻址,规划 Q3)+ broker + td 前置 + td 用户。
3708 // 编辑模式 broker / td 用户**只读**(规划 Q25:它们决定派生注册名,就地改 = 孤儿实例 + 账本错配)。
3709 // 0.4.1 九期 BD-UI-62:一字段一行(原来四个字段挤在一行,窄窗里数值列互相挤)。
3710 ui.horizontal(|ui| {
3711 acct_form_label(ui, "别名");
3712 if ui
3713 .add(
3714 egui::TextEdit::singleline(&mut alias)
3715 .hint_text("显示用,可空")
3716 .desired_width(120.0),
3717 )
3718 .changed()
3719 {
3720 shared.set_edit_alias(alias.clone());
3721 }
3722 });
3723 ui.horizontal(|ui| {
3724 acct_form_label(ui, "broker");
3725 ui.add_enabled_ui(!editing_on, |ui| {
3726 ctp_edit(ui, shared, &mut form.broker_id, "9999", CtpField::Broker);
3727 });
3728 });
3729 ui.horizontal(|ui| {
3730 acct_form_label(ui, "td 前置");
3731 ctp_edit(
3732 ui,
3733 shared,
3734 &mut form.td_addr,
3735 "tcp://host:40001",
3736 CtpField::TdAddr,
3737 );
3738 });
3739 ui.horizontal(|ui| {
3740 acct_form_label(ui, "td 用户");
3741 ui.add_enabled_ui(!editing_on, |ui| {
3742 ctp_edit(ui, shared, &mut form.td_user, "用户号", CtpField::TdUser);
3743 });
3744 });
3745 if let Some(r) = &editing {
3746 // 只读口径说明(规划 Q25):派生注册名由 broker + 账号决定,就地改会留下
3747 // 跑着旧名的孤儿实例(svctl 侧无改名口),账本里的归属也会错配。
3748 ui.label(
3749 egui::RichText::new(format!(
3750 "派生注册名 = {}(由 broker + 账号决定):要改这两格请『移除后重加』",
3751 r.gateway
3752 ))
3753 .color(crate::tokens::warn(ui.ctx())),
3754 );
3755 }
3756 ui.horizontal(|ui| {
3757 acct_form_label(ui, "td 密码");
3758 ctp_edit(
3759 ui,
3760 shared,
3761 &mut form.td_password,
3762 "密码",
3763 CtpField::TdPassword,
3764 );
3765 });
3766 ui.horizontal(|ui| {
3767 acct_form_label(ui, "AppID");
3768 ctp_edit(ui, shared, &mut form.td_app_id, "app", CtpField::AppId);
3769 });
3770 ui.horizontal(|ui| {
3771 acct_form_label(ui, "AuthCode");
3772 ctp_edit(
3773 ui,
3774 shared,
3775 &mut form.td_auth_code,
3776 "授权码",
3777 CtpField::AuthCode,
3778 );
3779 });
3780 // 单源纪律(规划 Q12):编辑模式下「非行情源账户 + 行情源已锁定」→ md 位置灰。
3781 // 它当不了源,填了也会在装配侧被清空;要换源须先移除在场账户(规划 D3)。
3782 let md_editable = match &editing {
3783 None => true,
3784 Some(r) => !locked || r.gateway == md,
3785 };
3786 // md 账号 / 密码**不再单列**(0.4.1 九期 BD-UI-62,用户裁定「MD 的那个账号和密码不要单独列了,
3787 // 默认的就是不用登录嘛,我们就不用填」)。口径与 Python 一致:Python 侧 CTP 配置只有
3788 // 一套账号/密码(`trader/utility.py:339` 一带,`appID` 那一格),行情会话复用同一套凭据 ——
3789 // 全仓 grep 不到任何 `md_user` / `md_password`。我们的 `CtpForm.md_user/md_password` 因此
3790 // 退回成「装配侧内部字段」:表单不给填,留空 = 回落 td 凭据(与 Python 同一行为)。
3791 ui.horizontal(|ui| {
3792 acct_form_label(ui, "md 前置");
3793 ui.add_enabled_ui(md_editable, |ui| {
3794 ctp_edit(
3795 ui,
3796 shared,
3797 &mut form.md_addr,
3798 "tcp://host:40011",
3799 CtpField::MdAddr,
3800 );
3801 });
3802 });
3803 if !md_editable {
3804 ui.horizontal(|ui| {
3805 acct_form_label(ui, "");
3806 ui.label(
3807 egui::RichText::new("非行情源账户:md 位留空(换源需先移除在场账户)")
3808 .color(crate::tokens::warn(ui.ctx())),
3809 );
3810 });
3811 }
3812 // 收录勾选(ek-ctp 0.6.0 D-PC-FILTER):网关收录哪些产品类。勾选变更立刻回写共享表单
3813 // —— 与 ctp_edit 同一口径,否则下一帧从 shared 重读就把这次点击丢了。
3814 ui.horizontal(|ui| {
3815 ui.label("收录勾选:");
3816 let fut = ui.checkbox(&mut form.accept_futures, "期货('1')").changed();
3817 let opt = ui.checkbox(&mut form.accept_options, "期权('2')").changed();
3818 if fut || opt {
3819 shared.set_ctp_form(form.clone());
3820 }
3821 ui.label("都不勾 = 回落默认期货;未勾选的合约收到即丢(其持仓/成交/tick 一并不上账)");
3822 });
3823 // F4 口径(0.2.20,与账户面板底部同一句 —— 共用 `TXT_PRODUCT_CLASS_SCOPE` 常量)。
3824 // 公用合约表是在场各网关的并集:从账户改了勾选、行情源账户没改,表就不会多一行期权。
3825 ui.label(egui::RichText::new(TXT_PRODUCT_CLASS_SCOPE).weak());
3826 // 只读回带区(规划 U9):勾选是**意图**,网关回带才是**事实** ——
3827 // 旧口径 `ConfigureReply.product_classes` 既不回填也不显示,勾选是否生效无从判断。
3828 if let Some(r) = &editing {
3829 ui.horizontal(|ui| {
3830 ui.label("网关实际收录(只读回带):");
3831 ui.label(if r.effective_classes.is_empty() {
3832 "—(尚未装配或无回带)".to_string()
3833 } else {
3834 classes_label(&r.effective_classes)
3835 });
3836 ui.label("装配/登录状态(只读):");
3837 ui.label(format!(
3838 "{}{}",
3839 r.status_label(),
3840 r.fail_note
3841 .as_ref()
3842 .map(|n| format!(" —— {n}"))
3843 .unwrap_or_default()
3844 ));
3845 });
3846 }
3847 // 操作行(规划 §3.3 四态):『保存』只写清册;『保存并连接』= 保存 + 入列一条 Connect 令;
3848 // 『取消』= 放弃未保存(与窗 × 同口径,规划 Q24)。被拦 → 弹窗不关 + 原因上屏(规划 Q26)。
3849 if shared.account_edit_dirty() {
3850 ui.label(
3851 egui::RichText::new("有未保存修改:『保存』写入清册,『取消』或关闭 = 放弃")
3852 .color(crate::tokens::warn(ui.ctx())),
3853 );
3854 }
3855 ui.horizontal(|ui| {
3856 if ui.button("保存").clicked() {
3857 match save_account_draft(shared, &form, &alias, false) {
3858 Ok(()) => shared.end_account_edit(),
3859 Err(e) => {
3860 shared.log_line(format!("[账户] 保存被拦:{e}"));
3861 shared.set_edit_error(Some(e));
3862 }
3863 }
3864 }
3865 if ui.button("保存并连接").clicked() {
3866 match save_account_draft(shared, &form, &alias, true) {
3867 Ok(()) => shared.end_account_edit(),
3868 Err(e) => {
3869 shared.log_line(format!("[账户] 保存并连接被拦:{e}"));
3870 shared.set_edit_error(Some(e));
3871 }
3872 }
3873 }
3874 if ui.button("取消").clicked() {
3875 shared.end_account_edit();
3876 }
3877 ui.label("订阅不在本窗定死:查询合约窗勾选或下单面板代码回车(一律路由到行情源)");
3878 });
3879}
3880
3881/// 账户清册里的派生名集合(账本标注用,每表算一次,不在每格里克隆清册)。
3882fn account_gateways(shared: &UiShared) -> std::collections::BTreeSet<String> {
3883 shared
3884 .accounts()
3885 .iter()
3886 .map(|a| a.gateway.clone())
3887 .collect()
3888}
3889
3890/// 账本行的网关标注(0.2.18 Commit B,规划 U8):该网关已不在账户清册 = **已摘除账户的残留行**。
3891///
3892/// 摘除不清账本(柜台侧不受影响,重加该账户后由轮转查询重建视图 —— F5 实连复测:
3893/// 摘除后账本 81/29/44/2 原封不动),但界面必须说清这一行属于谁:旧口径零标注,
3894/// 用户会把已摘除账户的委托当成在场账户的。
3895/// 口径边界:**清册为空 = 不标注**(没有账户配置面时谈不上「摘除」,纯账本巡回钉 s27 即此形);
3896/// 资金格不标注(那里的网关位是账户来源标签,`ctp` 这类历史字面量不在清册口径内 —— 刻意划界)。
3897fn ledger_gw_label(gateway: &str, known: &std::collections::BTreeSet<String>) -> String {
3898 if known.is_empty() || gateway.is_empty() || known.contains(gateway) {
3899 gateway.to_string()
3900 } else {
3901 format!("{gateway}(已摘除)")
3902 }
3903}
3904
3905/// 产品类短标签(`"1"` → 期货,`"2"` → 期权):勾选意图与网关回带事实并排显示用。
3906fn classes_label(classes: &[String]) -> String {
3907 if classes.is_empty() {
3908 return "—".to_string();
3909 }
3910 classes
3911 .iter()
3912 .map(|c| match c.as_str() {
3913 "1" => "期货",
3914 "2" => "期权",
3915 other => other,
3916 })
3917 .collect::<Vec<_>>()
3918 .join("+")
3919}
3920
3921/// 『连接』入口的唯一出令处(四态分离:一条令做完 `svctl.start` + `{gw}.configure`)。
3922///
3923/// 入列同时就地置「装配中」:插件出队时也会置(幂等),但**入列到出队之间**若不置,
3924/// 行上的『连接/重试』钮还亮着 = 可重复入列(规划 Q7 防重入的界面侧一半)。
3925fn push_connect(shared: &UiShared, gateway: &str, form: &crate::state::CtpForm) {
3926 shared.push_cmd(UiCmd::Connect {
3927 gateway: gateway.to_string(),
3928 form: form.clone(),
3929 });
3930 shared.note_connect_sent(gateway);
3931 shared.log_line(format!(
3932 "[账户] {gateway} 连接已入列(svctl.start + {}.configure)",
3933 gateway
3934 ));
3935}
3936
3937/// 配置弹窗『保存』/『保存并连接』的共同路径:**校验 → 写清册 →(可选)入列一条 Connect 令**。
3938///
3939/// - 编辑模式:覆盖该账户留档 + 别名(broker/账号只读 → 派生名不变,规划 Q25)。
3940/// - 添加模式:派生建行(别名随行入册,唯一性在 `add_account` 守卫里)+ 单源定源(规划 §5.C / D3)。
3941///
3942/// 被拦返回原因字符串:调用方**不关弹窗**,把原因写进 `edit_error` 显形(规划 Q26)。
3943fn save_account_draft(
3944 shared: &UiShared,
3945 form: &crate::state::CtpForm,
3946 alias: &str,
3947 connect: bool,
3948) -> Result<(), String> {
3949 form.validate()?;
3950 if let Some(gw) = shared.editing_account() {
3951 // 编辑目标必须还在清册(弹窗非 modal:期间该行可能被摘除)。
3952 if shared.account(&gw).is_none() {
3953 return Err(format!(
3954 "编辑目标 {gw} 已不在清册(该行被摘除):关闭弹窗后重新『添加』"
3955 ));
3956 }
3957 shared.update_account_form(&gw, form.clone());
3958 if !shared.set_account_alias(&gw, alias) {
3959 return Err(format!(
3960 "别名 {alias:?} 不可用(已被其他账户占用;别名须唯一)"
3961 ));
3962 }
3963 shared.log_line(format!(
3964 "[账户] 保存 {gw}(留档已更新;未重连:点行内『连接/重试』才下发到网关)"
3965 ));
3966 if connect {
3967 push_connect(shared, &gw, form);
3968 }
3969 return Ok(());
3970 }
3971 let mut row = crate::state::AccountRow::derive(form)?;
3972 row.alias = alias.trim().to_string();
3973 let gateway = row.gateway.clone();
3974 let account = row.account.clone();
3975 shared.add_account(row.clone())?;
3976 // 单源纪律在「保存」这一刻定源(规划 §5.C / D3):无源且无账户在场 → 新账户就是元账号
3977 // (md 前置保留 —— 清掉它等于这个账户自己也永远收不到 tick);
3978 // 已有源或已有账户在场 → 按纯 TD 装配(md 位清空,**留档与下发同一份**,消 U4)。
3979 let md = shared.md_source();
3980 let mut f = row.form.clone();
3981 if md.is_empty() && !shared.accounts_locked() {
3982 match shared.set_md_source(&gateway) {
3983 Ok(()) => {
3984 if f.md_addr.trim().is_empty() {
3985 shared.log_line(format!(
3986 "[账户] {gateway} 已设为行情源但 md 前置为空:点『编辑 {account}』补填 md 前置才出行情"
3987 ));
3988 } else {
3989 shared.log_line(format!("[账户] {gateway} = 行情源(首个账户自动指定,§5.C)"));
3990 }
3991 }
3992 Err(e) => {
3993 shared.log_line(format!("[账户] {e}"));
3994 f.md_addr.clear();
3995 f.md_user.clear();
3996 f.md_password.clear();
3997 }
3998 }
3999 } else {
4000 f.md_addr.clear();
4001 f.md_user.clear();
4002 f.md_password.clear();
4003 if md.is_empty() {
4004 shared.log_line("[账户] 已有账户在场:新账户按纯 TD 装配,换源需先移除在场账户");
4005 }
4006 }
4007 shared.update_account_form(&gateway, f.clone());
4008 // **四态分离:『保存』到此为止** —— 不 start、不 configure(规划裁定)。
4009 shared.log_line(format!(
4010 "[账户] 添加 {gateway}(未装配:点行内『连接 {account}』上线)"
4011 ));
4012 if connect {
4013 push_connect(shared, &gateway, &f);
4014 }
4015 Ok(())
4016}
4017
4018/// 查询合约窗(Python ContractManager 等价):查询串(代码/交易所/名称模糊,
4019/// 留空 = 全部)+ 勾选表 + 订阅钮(勾选集 → UiCmd::CtpSubscribe → ask
4020/// ctp.subscribe)。合约数据 = `eContract.` 自动回流,窗不催查询。
4021fn render_contracts_window(ui: &mut egui::Ui, shared: &UiShared) {
4022 let mut q = shared.contract_query();
4023 ui.horizontal(|ui| {
4024 ui.label("代码或交易所(留空 = 全部):");
4025 if ui
4026 .add(
4027 egui::TextEdit::singleline(&mut q)
4028 .hint_text("cu 或 SHFE")
4029 .desired_width(200.0),
4030 )
4031 .changed()
4032 {
4033 shared.set_contract_query(q.clone());
4034 }
4035 });
4036 let rows = shared.contracts(&q);
4037 // 表头单源(0.2.6 审计修:空态分支曾误写另一套表头「代码/…/最后价」,
4038 // 与非空分支「选(代码)/…/最小变动」不一致——列语义两处必须同源)。
4039 const CONTRACT_HEADERS: [&str; 5] = ["选(代码)", "交易所", "名称", "乘数", "最小变动"];
4040 // 空态不再分支、不再画提示行(0.4.1 六期 BD-UI-59,同未成交口径)。
4041 // 0.2.29 那条审计修仍然成立:空态与非空态必须走同一条路(同一 id_salt、同一列语义),
4042 // 原来空态分支走无列线的入口、非空走有列线的入口,同一张表在空/非空之间切换时形制会变。
4043 let selected = shared.selected_contracts();
4044 // 动作行在前、表格吃满剩余窗高(BD-UI-33,用户实看指出):旧
4045 // max_height(260) 是内嵌弹窗时代残留——OS 窗里表格定高 260px,
4046 // 放大窗口表格不跟着长,放大就没了意义。现在放大窗口 = 表格变高,
4047 // 行溢出才出滚动条。
4048 ui.horizontal(|ui| {
4049 ui.label(format!("已选 {} 项 / 共 {} 项", selected.len(), rows.len()));
4050 if ui.button(BTN_SUBSCRIBE_SELECTED).clicked() {
4051 if selected.is_empty() {
4052 shared.log_line("[查询合约] 未勾选任何合约,订阅未发");
4053 } else {
4054 // en_symbol 勾选集 → CTP 裸代码订阅(ask {gw}.subscribe 收裸代码)
4055 let symbols: Vec<String> = selected
4056 .iter()
4057 .map(|k| {
4058 k.split_once('.')
4059 .map(|(_, s)| s.to_string())
4060 .unwrap_or_else(|| k.clone())
4061 })
4062 .collect();
4063 match subscribe_target(shared) {
4064 Ok(gw) => {
4065 shared.push_cmd(UiCmd::CtpSubscribe {
4066 gateway: gw.clone(),
4067 symbols,
4068 });
4069 shared.log_line(format!(
4070 "[ops] 查询合约窗订阅 {} 项已入列 → {gw}(等 eTimer 请辞 → {}.subscribe)",
4071 selected.len(),
4072 gw
4073 ));
4074 }
4075 Err(e) => shared.log_line(format!("[订阅] {e}")),
4076 }
4077 }
4078 }
4079 });
4080 // 网格线:这张表曾经是「全仓唯一开网格线的表」(Python 侧只有合约表没调
4081 // `setShowGrid(False)`:widget.py:2423 / 2621 建表时没关,交易表在 367 关了)。
4082 // 0.4.1 五期 BD-UI-58 按用户裁定反过来:网格线是**全部表**的固定形制,这条 Python
4083 // 差异从此不再成立(记死在 CHANGELOG / DESIGN / README)。
4084 pinned_table(ui, "contract_grid", &CONTRACT_HEADERS, |body, row_h| {
4085 for c in &rows {
4086 let key = format!("{}.{}", c.exchange.as_str(), c.symbol);
4087 let on = selected.contains(&key);
4088 // 勾选钮标签 = en_symbol(唯一可定位;订阅钮按勾选集发)。
4089 // BD-UI-31 扩展:勾选 = 订阅选择 + 行选中;其余格单击 =
4090 // 行选中(动作归行,不归某一列)。
4091 let row_sel = shared.row_selected("contracts", &key);
4092 // key/on 都是行内局部:格延迟画笔要活到 show,必须自带所有权 ——
4093 // 在 rep_row 闭包外准备 key 克隆与 on 拷贝,各格自己再取。
4094 let key_owned = key.clone();
4095 let on_owned = on;
4096 body.row(row_h, row_sel, |r| {
4097 macro_rules! cell {
4098 ($make:expr, $col:expr) => {{
4099 let key = key_owned.clone();
4100 r.cell(move |ui, ctx| {
4101 let (cell_r, inner_r) = pin_cell(ui, ctx, $make);
4102 let hit =
4103 cell_r.clicked() || inner_r.as_ref().is_some_and(|r| r.clicked());
4104 if hit {
4105 shared.select_row("contracts", &key.clone());
4106 }
4107 });
4108 }};
4109 }
4110 // 勾选框(首格):`changed()` 在勾选框自己的 Response 上,动作就地取。
4111 {
4112 let key = key_owned.clone();
4113 let mut on = on_owned;
4114 r.cell(move |ui, _ctx| {
4115 if ui.checkbox(&mut on, key.clone()).changed() {
4116 shared.toggle_contract_selection(&key);
4117 shared.select_row("contracts", &key);
4118 }
4119 });
4120 }
4121 cell!(|ui| ui.label(c.exchange.as_str().to_string()), 1);
4122 cell!(|ui| ui.label(c.name.clone()), 2);
4123 cell!(
4124 |ui| ui.label(crate::tokens::num_text(crate::format::volume(c.size))),
4125 3
4126 );
4127 cell!(
4128 |ui| ui.label(crate::tokens::num_text(crate::format::price_tick(
4129 c.price_tick
4130 ))),
4131 4
4132 );
4133 });
4134 }
4135 });
4136}
4137
4138/// CTP 表单字段枚举(ctp_edit 回写定位;订阅标的字段已撤出网关窗)。
4139enum CtpField {
4140 Broker,
4141 TdAddr,
4142 TdUser,
4143 TdPassword,
4144 AppId,
4145 AuthCode,
4146 MdAddr,
4147}
4148
4149/// 单行 TextEdit + changed 回写 CTP 表单(密码位掩码)。
4150fn ctp_edit(ui: &mut egui::Ui, shared: &UiShared, val: &mut String, hint: &str, field: CtpField) {
4151 let is_secret = matches!(field, CtpField::TdPassword | CtpField::AuthCode);
4152 let mut w = egui::TextEdit::singleline(val)
4153 .hint_text(hint)
4154 // 0.2.17:输入位加宽(旧 110 装不下一根 CTP 前置 `tcp://182.254.242.81:30001`
4155 // = 30 字符,用户看不见自己填的前置,也无法核对端口;快照钉 s39 前后对照)。
4156 .desired_width(210.0);
4157 if is_secret {
4158 w = w.password(true);
4159 }
4160 if ui.add(w).changed() {
4161 let mut f = shared.ctp_form();
4162 match field {
4163 CtpField::Broker => f.broker_id = val.clone(),
4164 CtpField::TdAddr => f.td_addr = val.clone(),
4165 CtpField::TdUser => f.td_user = val.clone(),
4166 CtpField::TdPassword => f.td_password = val.clone(),
4167 CtpField::AppId => f.td_app_id = val.clone(),
4168 CtpField::AuthCode => f.td_auth_code = val.clone(),
4169 CtpField::MdAddr => f.md_addr = val.clone(),
4170 }
4171 shared.set_ctp_form(f);
4172 }
4173}
4174
4175/// K线窗内容(dm bar 合成序列;格定点 = 该合约格;无格占位)。
4176///
4177/// 图实例每帧重建(BD-UI-20 口径:数据在 store 不丢,交互状态不跨帧)。
4178fn render_kline_cell(ui: &mut egui::Ui, cell: Option<&CellView>) {
4179 let Some(c) = cell else {
4180 ui.label("(K线无格:等 dm 合成)");
4181 return;
4182 };
4183 if c.bars.is_empty() {
4184 ui.label(format!("(K线:{}@{} 批空)", c.symbol, c.interval));
4185 return;
4186 }
4187 // 柱时间按北京钟面给图:egui_charts 0.2 的 Bar 只吃 DateTime<Utc> 且按
4188 // UTC 钟面画刻度 —— 用「换到 +08 再标回 UTC」的重标定,让横轴刻度显示
4189 // 北京钟面(数据面存 UTC 纳秒;重标定只挪刻度,不挪序)。
4190 let mut data = egui_charts::model::bar::BarData::new();
4191 for b in &c.bars {
4192 let dt = chrono::DateTime::<chrono::Utc>::from_timestamp_nanos(b.datetime)
4193 .with_timezone(&beijing_tz())
4194 .with_timezone(&chrono::Utc);
4195 data.push(egui_charts::model::bar::Bar::new(
4196 dt,
4197 b.open_price,
4198 b.high_price,
4199 b.low_price,
4200 b.close_price,
4201 b.volume,
4202 ));
4203 }
4204 ui.label(format!(
4205 "K线 {}@{}s({} 根)",
4206 c.symbol,
4207 c.interval,
4208 c.bars.len()
4209 ));
4210 // 0.2.30(BD-UI-46):图表色板不再自带它那套 TradingView 令牌。
4211 // egui_charts 0.2 的 `ChartConfig::default()` 读的是它自己的 RON `DESIGN_TOKENS`
4212 // (bullish `#26a69a` 青 / bearish `#F23645` 红)——**涨跌方向正好和我们的
4213 // 红涨绿跌相反**,而且它**不读 egui `Visuals`**,界面换什么档都影响不到它。
4214 // 所以这里显式覆盖五支:涨 = RISE(红)、跌 = FALL(绿)、底 = 当前档 `bg1`、
4215 // 网格 = 当前档 `border`、文字 = 当前档 `text1`。
4216 // 0.8.0 双档补的正是这后三支(判据 `s93`):旧口径直写 `shadcn::BG1/BORDER/TEXT1`
4217 // = 深档常量,浅色档下 K 线会是界面里唯一一块黑底 —— 这一处必须跟着档走。
4218 let pal = crate::tokens::palette(ui.ctx());
4219 let cfg = egui_charts::config::ChartConfig {
4220 bullish_color: crate::tokens::rise(ui.ctx()),
4221 bearish_color: crate::tokens::fall(ui.ctx()),
4222 background_color: pal.bg1,
4223 grid_color: pal.border,
4224 text_color: pal.text1,
4225 ..egui_charts::config::ChartConfig::default()
4226 };
4227 let mut chart = egui_charts::widget::Chart::with_config(data, cfg).visible_bars(60);
4228 chart.set_symbol(&c.symbol);
4229 chart.set_timeframe_label(&format!("{}s", c.interval));
4230 chart.enable_tracking_mode();
4231 let _ = chart.show(ui);
4232}
4233
4234#[cfg(test)]
4235mod tests {
4236 use super::*;
4237
4238 // 表头带**派生规则**钉(BD-UI-41,0.2.30 收缩成一套主题):
4239 // Chrome 的每个角色必须取到令牌里那一档,不许自己挑。
4240 // (色板原值本身由 `tests/ui_kittest.rs` 的 `u1_palette_matches_source` 钉 ——
4241 // 色值字面量只留在测试侧,src 侧不写 `from_rgb`。)
4242 // 原来这里还有一条「不得与金融深色那一列混同」:金融深色已随主题面删除,
4243 // 判据对象不存在,删掉,不留一条空转的断言。
4244 // 0.4.0:tab 那三档派生判据随 `tab_label` 一起撤除 —— tab 形态归 dock,
4245 // 其样式来自同一份 `visuals`(v5 钉住 `Style::from_egui` 这条派生路径)。
4246 #[test]
4247 fn chrome_derives_from_token_palette() {
4248 // 0.8.0 双档:派生规则对**两档各钉一遍**(浅档漏一支 = u9 钉的事,这里钉的是
4249 // 「表头文字必须走次级色」这条新口径在两档都成立)。
4250 for theme in [crate::tokens::Theme::Dark, crate::tokens::Theme::Light] {
4251 let v = crate::tokens::visuals_for(theme);
4252 let ch = Chrome::of(&v, theme);
4253 let p = theme.palette();
4254 // 0.4.1 四期(BD-UI-57):旧口径 `line` 一支兼做「带底 + 描边」(qss:1959-1970
4255 // `QHeaderView::section { background #455364 }` 与描边同色)。Nova 把两者拆开 →
4256 // 两条断言各钉一支,谁也不许兼谁的活。
4257 assert_eq!(ch.line, p.border, "{theme:?} 档的描边必须取 border 那支");
4258 assert_eq!(ch.band_fill, p.bg4, "{theme:?} 档的表头带底必须取 BG4 那支");
4259 // 0.8.0 裁定 C:表头文字走次级色(参考站 `th{color:ink-muted}`),
4260 // 与表体(`text2`)/ 标题(`text1`)是三层,不许塌回一层。
4261 assert_eq!(
4262 ch.header_text, p.text3,
4263 "{theme:?} 档的表头文字必须走次级色"
4264 );
4265 assert_ne!(
4266 ch.header_text, p.text1,
4267 "{theme:?} 档的表头文字与正文同色 = 层级塌一档"
4268 );
4269 }
4270 }
4271
4272 // 日志入环打戳钉(BD-UI-41):日志表格化后「时间」列的事实源是 `LogRing`,
4273 // 打戳必须与表内时间列(`fmt_dt`)同一个口径 = 北京 +08,不能跟本机时区走
4274 // (本机不是 +08 时,口径错 = 日志与成交表差几小时,交易员对不上账)。
4275 #[test]
4276 fn log_entries_stamp_beijing_wall_clock() {
4277 let mut ring = crate::state::LogRing::new(4);
4278 ring.push("[ops] 一行");
4279 let e = &ring.entries()[0];
4280 assert_eq!(e.text, "[ops] 一行", "正文不得被时间戳污染");
4281 assert_eq!(e.at.len(), 8, "时间戳必须是 HH:MM:SS(8 字符),实测 {}", e.at);
4282 for seg in e.at.split(':') {
4283 assert!(seg.parse::<u32>().is_ok(), "时间戳有非数字段:{seg}");
4284 }
4285 let want = chrono::Utc::now()
4286 .with_timezone(&beijing_tz())
4287 .format("%H:%M:%S")
4288 .to_string();
4289 let secs = |s: &str| -> i64 {
4290 s.split(':')
4291 .map(|x| x.parse::<i64>().unwrap())
4292 .fold(0, |acc, v| acc * 60 + v)
4293 };
4294 let (a, b) = (secs(&e.at), secs(&want));
4295 let d = (a - b).abs();
4296 // 允许跨秒抖动,并容忍跨午夜(差值接近 86400 即同一口径的另一侧)。
4297 assert!(
4298 d <= 2 || d > 86_398,
4299 "日志时间戳必须走北京 +08:实测 {a} vs 期望 {b}"
4300 );
4301 // 旧门面不变:`snapshot()` 仍只给正文(测试与巡回取证靠它)。
4302 assert_eq!(ring.snapshot(), vec!["[ops] 一行".to_string()]);
4303 }
4304
4305 // 表内时间列北京钟面钉(0.2.13):数据面存 UTC 纳秒,展示换回 +08 ——
4306 // 北京 09:30:01 入账后是 UTC 01:30:01,fmt_dt 必须显示 09:30:01,
4307 // 不是 01:30:01(旧实现的 UTC 直显,交易员看差 8 小时)。
4308 #[test]
4309 fn fmt_dt_shows_beijing_wall_clock() {
4310 let expect = chrono::DateTime::<chrono::Utc>::from_timestamp_nanos(
4311 ek_data::time::civil_to_nanos(ek_data::time::Civil {
4312 year: 2026,
4313 month: 4,
4314 day: 16,
4315 hour: 1,
4316 minute: 30,
4317 second: 1,
4318 nanos: 0,
4319 }),
4320 );
4321 // 真值自洽:UTC 01:30:01 ↔ 北京 09:30:01(双向换算回原钟面)
4322 let beijing = expect.with_timezone(&beijing_tz());
4323 assert_eq!(beijing.format("%H:%M:%S").to_string(), "09:30:01");
4324 // 再来一个跨日钉:北京 00:00:30 = UTC 前日 16:00:30(同 UTC 日,
4325 // 不同北京日 —— 旧实现会把这根显示成 16:00:30)
4326 let ns = ek_data::time::civil_to_nanos(ek_data::time::Civil {
4327 year: 2026,
4328 month: 4,
4329 day: 15,
4330 hour: 16,
4331 minute: 0,
4332 second: 30,
4333 nanos: 0,
4334 });
4335 // 0.3.1(Wave D):格式从 `HH:MM:SS` 收成 `HH:MM:SS.mmm`(照 Python `TimeCell`),
4336 // 时区口径没动 —— 这条钉的仍是「北京墙钟」这件事,不是小数位。
4337 assert_eq!(crate::format::time_hms_millis(Some(ns)), "00:00:30.000");
4338 // None → 占位
4339 assert_eq!(crate::format::time_hms_millis(None), "-");
4340 }
4341}