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