ek_ui/

render.rs

//! 唯一渲染入口(L2):真实 eframe App 与 kittest 建构走同一个 `render_body`。
//!
//! 布局 v5(BD-UI-29 面板化,官方面板组合;蓝本 = Python 主窗 mainwindow.py):
//! **TopBottomPanel(菜单) → TopBottomPanel(行情带) → SidePanel(下单侧) →
//! CentralPanel(2×2 监控格) → Window 弹窗**,两带物理分离。
//! - 行情带(TopBottomPanel::resizable = Python 分带 splitter 语义,缺省 240):
//!   交易所二级 tab(只列有 tick 的所)+ tick 表(唯一源 = `eTick.`
//!   订阅流,不从 bar 回);行内任意格单击 = 带入下单面板(ek 增值,方案钉;
//!   盘口四列带方向:买1 价/量 → 卖,卖1 价/量 → 买,价格列顺带填价,其余列
//!   方向保持默认——0.2.1 `import_tick`),行内任意格双击 = 弹 K线窗。
//! - 下单侧(SidePanel::resizable,缺省 250):下单面板常驻(Python
//!   TradingWidget 等价:9 字段 + 委托 + 全撤;表单 = 网格,按钮/提示语都是
//!   网格行;网格后置 err label 由 ScrollArea 吸收 sizing 退让,BD-UI-27)+
//!   盘口(买5卖5,Python TradingWidget 内序:字段钮 → 盘口)。
//! - 2×2 监控格(CentralPanel 内,响应式分配,无定宽定高,BD-UI-29)
//!   「委托|未成交」「成交」「持仓」「资金|日志」(撤单钮仅活动行,既有 s11
//!   钉口径;委托行双击 = 撤单,Python OrderMonitor 等价;格内宽表走横向滚动,
//!   D7 口径)。
//! - 弹窗两式(BD-UI-32):运维窗(菜单「运维」:插件/服务/依赖/流控查询)、
//!   CTP 配置窗(菜单「网关」,CTP 插件自己的界面)= egui::Window 依附主窗;
//!   查询合约窗(菜单「查询合约」:查询 + 勾选 + 订阅钮,Python ContractManager
//!   等价)、K线窗(双击弹出,按合约多开)= 独立 OS 窗(show_viewport_immediate,
//!   原生最小化/最大化/关闭,可拖出主窗;后端不支持多窗自动回退 egui::Window,
//!   kittest 走回退面断言)。
//! - 订阅两入口(用户裁定,网关窗不定死订阅):下单面板代码框**回车**订阅
//!   (Python returnPressed 等价);查询合约窗**勾选订阅**。合约数据 =
//!   `eContract.` 自动回流(ek-ctp 登录后自动查询,UI 只收不催)。
//! - 回灌表单与票据文本框已退役(界面面);总线口(`UiCmd::Reload` 等)保留。
//!
//! kittest 断言面:各单元格独立 Label(`get_by_label` 直查);操作走
//! `push_cmd` 入队(ui 插件 eTimer 辞行出队),确认状态就地翻位,零自制通道。
//! 隔离红标:行状态含 Quarantin(快照扫描,BD-UI-17)。

use ek_data::constant::{Direction, Offset, OrderType};
use ek_station::wire::PlugRow;

use crate::state::{
    BottomRightTab, CellView, ConfirmStep, TopLeftTab, UiCmd, UiShared, is_quarantined,
};

/// 清空日志按钮的唯一可访问性标签(测试与 UI 同源)。
pub const BTN_CLEAR_LOGS: &str = "清空日志";
/// 取消待确认按钮标签。
pub const BTN_CANCEL_CONFIRM: &str = "取消确认";
/// 下单提交按钮标签(v4 = Python「委托」钮)。
pub const BTN_SEND_ORDER: &str = "委托";
/// 全撤按钮标签(v4;活动委托逐个走既有撤单 ask)。
pub const BTN_CANCEL_ALL: &str = "全撤";
/// 流控查询按钮标签(S5;v4 收纳进运维窗)。
pub const BTN_QUERY_RATE: &str = "流控查询";
/// 撤单按钮前缀(S5;行级标签 = `撤单 {orderid}`)。
pub const BTN_CANCEL_ORDER: &str = "撤单";
/// CTP 连接按钮标签(S6;手工配置 → ask ctp.configure)。
pub const BTN_CTP_CONNECT: &str = "连接 CTP";
/// 菜单项:运维(弹运维窗)。
pub const MENU_OPS: &str = "运维";
/// 菜单项:网关(弹 CTP 配置窗)。
pub const MENU_CTP: &str = "网关";
/// 菜单项:帮助。
pub const MENU_HELP: &str = "帮助";
/// 菜单项:查询合约(弹查询合约窗;Python ContractManager 等价)。
pub const MENU_CONTRACTS: &str = "查询合约";
/// 菜单项 → 弹窗入口钮(BD-UI-31 一键直达:菜单钮即入口,一步弹窗,
/// 不再挂下拉层;入口钮标签 = 菜单名本身)。
/// 查询合约窗订阅钮(勾选集 → ask ctp.subscribe)。
pub const BTN_SUBSCRIBE_SELECTED: &str = "订阅选中";

fn remove_button_label(name: &str, armed_on: Option<&str>) -> String {
    if armed_on == Some(name) {
        format!("确认移除 {name} ?")
    } else {
        format!("移除 {name}")
    }
}

fn state_text(r: &PlugRow) -> String {
    r.state.clone()
}

/// DtNs → HH:MM:SS(UTC;表内时间列统一口径)。
fn fmt_dt(dt: Option<i64>) -> String {
    dt.map(|ns| {
        chrono::DateTime::<chrono::Utc>::from_timestamp_nanos(ns)
            .format("%H:%M:%S")
            .to_string()
    })
    .unwrap_or_else(|| "-".to_string())
}

// ---- BD-UI-31(R3)行高亮:悬停淡底 / 选中跳底 ----

/// 行底色绘制:行内各格响应矩形并集 → 选中 = 跳底(蓝调);否则悬停 = 淡灰底。
/// 半透明叠底(行文字先画,叠后仍可读);行交互钮单击选中与双击动作并存
/// (egui 双击先经 clicked,选中顺带发生,无冲突)。
fn paint_row_bg(ui: &egui::Ui, cell_rects: &[egui::Rect], selected: bool) {
    let Some(union) = cell_rects.iter().copied().reduce(|a, b| a.union(b)) else {
        return;
    };
    let hovered = ui
        .input(|i| i.pointer.interact_pos())
        .is_some_and(|p| union.expand(3.0).contains(p));
    if selected {
        ui.painter().rect_filled(
            union.expand(3.0),
            3.0,
            egui::Color32::from_rgba_unmultiplied(64, 108, 180, 82),
        );
    } else if hovered {
        ui.painter().rect_filled(
            union.expand(3.0),
            3.0,
            egui::Color32::from_rgba_unmultiplied(128, 128, 128, 38),
        );
    }
}

/// 委托是否可撤(与 ek-data ACTIVE_STATUSES 同口径)。
fn order_active(status: ek_data::constant::Status) -> bool {
    ek_data::constant::ACTIVE_STATUSES.contains(&status)
}

/// 格可点化(BD-UI-31 扩展):标签外观不变,在标签矩形上叠一层点击感应 ——
/// 行内任何一格都可单击/双击(用户裁定:动作归行,不归某一列)。
fn click_cell(ui: &egui::Ui, rect: egui::Rect, id_salt: impl std::hash::Hash) -> egui::Response {
    ui.interact(rect, ui.id().with(id_salt), egui::Sense::click())
}

/// 行情带入(0.2.1 扩展):任意列单击 = 带入合约+交易所;盘口四列带方向
/// (买1价/买1量 → 卖,卖1价/卖1量 → 买 —— 吃对手挂价口径),两个价格列
/// 顺带把该价填进价格格;其余列方向/价格保持表单默认(用户裁定)。
pub fn import_tick(shared: &UiShared, t: &ek_data::tick::TickData, exchange: &str, col: usize) {
    let mut f = shared.order_form();
    f.symbol = t.symbol.clone();
    f.exchange = exchange.to_string();
    match col {
        8 => {
            f.direction = Direction::SHORT;
            f.price = format!("{:.1}", t.bid_price_1);
        }
        9 => f.direction = Direction::SHORT,
        10 => {
            f.direction = Direction::LONG;
            f.price = format!("{:.1}", t.ask_price_1);
        }
        11 => f.direction = Direction::LONG,
        _ => {}
    }
    shared.set_order_form(f);
}

/// 按合约找最新 tick(下单面板名称/盘口/随价共用)。
/// 交易所非空 = 精确 EX.symbol 匹配(跨所同码不串);空 = 仅按代码找。
fn tick_of(shared: &UiShared, exchange: &str, symbol: &str) -> Option<ek_data::tick::TickData> {
    if symbol.is_empty() {
        return None;
    }
    shared.tick_rows().into_iter().find(|t| {
        t.symbol == symbol
            && (exchange.is_empty() || t.exchange.as_str().eq_ignore_ascii_case(exchange))
    })
}

/// 全局字号(BD-UI-32 R1,用户实看裁定「整体字偏小」,对照 Python 版):
/// body/button/strong 16px、small 14px、heading 22px、monospace 15px
/// (egui 缺省 13/12/18/12)。render_body 顶部统一施加,真实 App 与 kittest 同源。
pub fn apply_ui_style(ctx: &egui::Context) {
    ctx.style_mut(|style| {
        style
            .text_styles
            .insert(egui::TextStyle::Body, egui::FontId::proportional(16.0));
        style
            .text_styles
            .insert(egui::TextStyle::Button, egui::FontId::proportional(16.0));
        style
            .text_styles
            .insert(egui::TextStyle::Small, egui::FontId::proportional(14.0));
        style
            .text_styles
            .insert(egui::TextStyle::Heading, egui::FontId::proportional(22.0));
        style
            .text_styles
            .insert(egui::TextStyle::Monospace, egui::FontId::monospace(15.0));
    });
}

/// 画一窗(官方面板组合:render_body 直接开顶层面板,不自嵌 CentralPanel)。
///
/// v5 框架(BD-UI-29 面板化):TopBottomPanel(菜单) → TopBottomPanel(行情带,
/// resizable = Python 分带 splitter 语义) → SidePanel(下单面板 + 盘口,
/// resizable) → CentralPanel(2×2 监控格,响应式分配,必须最后) → 弹窗。
/// 官方纪律(panel.rs 模块文档):顶层面板不得互相嵌套、CentralPanel 最后加、
/// Window 挂在所有面板之后。
pub fn render_body(ctx: &egui::Context, shared: &UiShared) {
    apply_ui_style(ctx);
    // ---- 菜单栏(顶层面板,最先 = 最外) ----
    egui::TopBottomPanel::top("menu_bar").show(ctx, |ui| {
        render_menu_bar(ui, shared);
    });

    // ---- 上带:行情带(全宽独占;可拖分隔条,缺省 240 ≈ Python 30:70 分带) ----
    egui::TopBottomPanel::top("market_band")
        .resizable(true)
        .default_height(240.0)
        .show(ctx, |ui| {
            // ScrollArea auto_shrink(false) 吃满面板可用空间(resizable 面板的官方前提)
            egui::ScrollArea::both()
                .id_salt("market_band_scroll")
                .auto_shrink([false, false])
                .show(ui, |ui| {
                    render_market_band(ui, shared);
                });
        });

    // ---- 下带左侧:下单面板 + 盘口(Python TradingWidget 内序:字段钮 → 盘口) ----
    egui::SidePanel::left("order_side")
        .resizable(true)
        .default_width(250.0)
        .show(ctx, |ui| {
            // ScrollArea 吸收 sizing 退让(BD-UI-27):网格后置 err label 不再叠回网格
            egui::ScrollArea::vertical()
                .id_salt("order_side_scroll")
                .auto_shrink([false, false])
                .show(ui, |ui| {
                    render_order_panel(ui, shared);
                    ui.separator();
                    render_book_frame(ui, shared);
                });
        });

    // ---- 下带右侧:2×2 监控格(CentralPanel 最后;响应式分配,无定宽定高) ----
    egui::CentralPanel::default().show(ctx, |ui| {
        let avail = ui.available_size();
        let sp = ui.spacing().item_spacing;
        // 机制钉(dbg 实锤):horizontal 行成员的可用高度初始只有一行高
        // (interact_size),高度分配不沿横向向下传播 → 定高 max_height 失效、
        // 行按内容收缩(v4 死区根因)。官方解法 = 先精确预留矩形(group_frame:
        // allocate_exact_size + new_child;add_sized 收 impl Widget 不适用),
        // Frame+ScrollArea 在预留矩形内才吃满。
        let gw = ((avail.x - sp.x) / 2.0).max(220.0);
        let gh = ((avail.y - sp.y) / 2.0).max(120.0);
        ui.horizontal(|ui| {
            group_frame(ui, "grp_topleft", gw, gh, |ui| {
                render_topleft_group(ui, shared);
            });
            group_frame(ui, "grp_trades", gw, gh, |ui| {
                render_trades_group(ui, shared);
            });
        });
        ui.horizontal(|ui| {
            group_frame(ui, "grp_positions", gw, gh, |ui| {
                render_positions_group(ui, shared);
            });
            group_frame(ui, "grp_bottomright", gw, gh, |ui| {
                render_bottomright_group(ui, shared);
            });
        });
    });

    // ---- 弹窗面(官方口径:Window 在顶层面板之后) ----
    render_windows(ctx, shared);
}

/// 2×2 格统一容器(响应式尺寸 + 双向滚动,BD-UI-27 可达性口径延续)。
/// 尺寸钉(BD-UI-29):`allocate_exact_size` 精确预留 w×h 矩形 + `new_child`
/// 在预留矩形内开 Frame+ScrollArea(dbg 实锤:horizontal 行成员的可用高度
/// 初始只有一行高,高度分配不沿横向向下传播 → 定高 max_height 失效、行按
/// 内容收缩 = v4 死区根因;先预留矩形,可用空间才吃满)。
/// 布局泄漏钉(第五轮审计):Frame::show 继承父级布局 → 格内内容强制
/// `ui.vertical`(短行成行,宽网格末位溢出走横向滚动)。
fn group_frame(ui: &mut egui::Ui, id: &str, w: f32, h: f32, content: impl FnOnce(&mut egui::Ui)) {
    let (rect, _resp) = ui.allocate_exact_size(egui::vec2(w, h), egui::Sense::hover());
    let mut child = ui.new_child(egui::UiBuilder::new().max_rect(rect));
    egui::Frame::group(ui.style()).show(&mut child, |ui| {
        egui::ScrollArea::both()
            .id_salt(id)
            .auto_shrink([false, false])
            .show(ui, |ui| {
                ui.vertical(content);
            });
    });
}

// ================= 菜单栏 =================

fn render_menu_bar(ui: &mut egui::Ui, shared: &UiShared) {
    ui.horizontal(|ui| {
        // BD-UI-31(R1):一键直达 —— 菜单钮即入口,单击直接弹窗(去下拉层)。
        if ui.button(MENU_OPS).clicked() {
            shared.set_ops_window_open(true);
        }
        if ui.button(MENU_CTP).clicked() {
            shared.set_ctp_window_open(true);
        }
        if ui.button(MENU_CONTRACTS).clicked() {
            shared.set_contracts_window_open(true);
        }
        ui.menu_button(MENU_HELP, |ui| {
            ui.label(format!("ek-station 观测台 v{}", env!("CARGO_PKG_VERSION")));
            ui.label("布局 = Python 主窗框架等价(行情带/交易带/弹窗)");
        });
    });
}

// ================= 行情带 =================

fn render_market_band(ui: &mut egui::Ui, shared: &UiShared) {
    // BD-UI-31(R4):表题文字撤除(带位即身份,Python TickMonitor 无题同口径)。
    let groups = shared.tick_groups();
    if groups.is_empty() {
        ui.label("(等待 eTick 订阅)");
        return;
    }
    // 二级 tab:只列有 tick 的所
    let sel = shared.selected_exchange();
    let active = if groups.iter().any(|(e, _)| *e == sel) {
        sel.clone()
    } else {
        groups[0].0.clone()
    };
    ui.horizontal(|ui| {
        for (ex, _) in &groups {
            if ui.selectable_label(*ex == active, ex.clone()).clicked() {
                shared.set_selected_exchange(ex.clone());
            }
        }
    });
    let ticks = groups
        .iter()
        .find(|(e, _)| *e == active)
        .map(|(_, v)| v.clone())
        .unwrap_or_default();
    let last_time = ticks
        .iter()
        .map(|t| {
            if t.update_time.is_empty() {
                fmt_dt(Some(t.datetime))
            } else {
                t.update_time.clone()
            }
        })
        .max()
        .unwrap_or_else(|| "-".to_string());
    ui.label(format!(
        "tick {} 格 / 最后更新 {last_time}",
        shared.tick_count()
    ));
    egui::Grid::new("tick_grid")
        .striped(true)
        .num_columns(14)
        .show(ui, |ui| {
            for h in [
                "代码",
                "名称",
                "最新价",
                "涨跌幅",
                "成交量",
                "今开",
                "最高",
                "最低",
                "买1价",
                "买1量",
                "卖1价",
                "卖1量",
                "时间",
                "接口",
            ] {
                ui.strong(h);
            }
            ui.end_row();
            for t in &ticks {
                // 行交互(BD-UI-31 扩展):行内任何一格单击 = 带入下单面板
                // (盘口四列带方向:买1价/买1量 → 卖,卖1价/卖1量 → 买,价格列
                // 顺带填价;其余列方向/价格保持默认——用户裁定);任何一格双击
                // = 弹 K线窗。选中行 = 下单面板当前合约(带入即跳色)。
                let row_sel = shared.order_form().symbol == t.symbol;
                let mut cells = Vec::with_capacity(14);
                let mut dbl = false;
                let resp = ui.button(t.symbol.clone());
                if resp.clicked() {
                    shared.set_selected_exchange(active.clone());
                    import_tick(shared, t, &active, 0);
                }
                dbl |= resp.double_clicked();
                cells.push(resp.rect);
                macro_rules! cell {
                    ($base:expr, $col:expr) => {{
                        let base = $base;
                        let r = click_cell(ui, base.rect, ("tick", &t.symbol, $col));
                        if r.clicked() {
                            shared.set_selected_exchange(active.clone());
                            import_tick(shared, t, &active, $col);
                        }
                        dbl |= r.double_clicked();
                        cells.push(base.rect);
                    }};
                }
                cell!(
                    ui.label(if t.name.is_empty() {
                        "-".to_string()
                    } else {
                        t.name.clone()
                    }),
                    1
                );
                cell!(ui.label(format!("{:.1}", t.last_price)), 2);
                cell!(
                    ui.label(egui::RichText::new(format!("{:+.2}", t.pct_change)).color(
                        if t.pct_change < 0.0 {
                            egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                        } else {
                            egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                        },
                    )),
                    3
                );
                cell!(ui.label(format!("{:.0}", t.volume)), 4);
                cell!(ui.label(format!("{:.1}", t.open_price)), 5);
                cell!(ui.label(format!("{:.1}", t.high_price)), 6);
                cell!(ui.label(format!("{:.1}", t.low_price)), 7);
                cell!(
                    ui.label(
                        egui::RichText::new(format!("{:.1}", t.bid_price_1))
                            .color(egui::Color32::from_rgb(0xE0, 0x50, 0x50)),
                    ),
                    8
                );
                cell!(
                    ui.label(
                        egui::RichText::new(format!("{:.0}", t.bid_volume_1))
                            .color(egui::Color32::from_rgb(0xE0, 0x50, 0x50)),
                    ),
                    9
                );
                cell!(
                    ui.label(
                        egui::RichText::new(format!("{:.1}", t.ask_price_1))
                            .color(egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)),
                    ),
                    10
                );
                cell!(
                    ui.label(
                        egui::RichText::new(format!("{:.0}", t.ask_volume_1))
                            .color(egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)),
                    ),
                    11
                );
                cell!(
                    ui.label(if t.update_time.is_empty() {
                        fmt_dt(Some(t.datetime))
                    } else {
                        t.update_time.clone()
                    }),
                    12
                );
                cell!(ui.label(t.gateway_name.clone()), 13);
                if dbl {
                    shared.open_kline(t.symbol.clone());
                }
                paint_row_bg(ui, &cells, row_sel);
                ui.end_row();
            }
        });
}

// ================= 下单面板(常驻) =================

fn render_order_panel(ui: &mut egui::Ui, shared: &UiShared) {
    // BD-UI-31(R4):面板题字撤除(下单侧栏即身份)。
    let mut f = shared.order_form();
    let before = f.clone();
    let mut err: Option<String> = None;

    // 随价勾选:价格框随该合约最新 tick(勾选态)
    if f.follow_price {
        if let Some(t) = tick_of(shared, &f.exchange, &f.symbol) {
            if t.last_price > 0.0 {
                f.price = format!("{:.1}", t.last_price);
            }
        }
    }

    // 交易所下拉:有 tick 的所 ∪ 六家常用所(操作面默认,不是配置面)
    let mut ex_opts: Vec<String> = shared
        .tick_groups()
        .iter()
        .map(|(e, _)| e.clone())
        .collect();
    for e in ["SHFE", "DCE", "CZCE", "CFFEX", "INE", "GFEX"] {
        if !ex_opts.iter().any(|x| x == e) {
            ex_opts.push(e.to_string());
        }
    }
    if !ex_opts.contains(&f.exchange) {
        ex_opts.insert(0, f.exchange.clone());
    }
    // 接口下拉:trade_snap 网关去重集 ∪ {sim, ctp}(审计钉:不新增总线口)
    let ts = shared.trade_snap();
    let mut gw_opts: Vec<String> = Vec::new();
    for g in ts
        .orders
        .iter()
        .map(|o| o.gateway_name.clone())
        .chain(ts.trades.iter().map(|t| t.gateway_name.clone()))
        .chain(ts.accounts.iter().map(|a| a.gateway_name.clone()))
    {
        if !g.is_empty() && !gw_opts.contains(&g) {
            gw_opts.push(g);
        }
    }
    for g in ["sim", "ctp"] {
        if !gw_opts.iter().any(|x| x == g) {
            gw_opts.push(g.to_string());
        }
    }
    if !gw_opts.contains(&f.gateway) {
        gw_opts.insert(0, f.gateway.clone());
    }

    // 表单网格(Python TradingWidget 字段排;委托/全撤 = 网格行;
    // 网格后不挂面板内容 —— 帧内 sizing 退让会把后置行叠回网格,盘口独立帧)。
    egui::Grid::new("order_form_grid")
        .num_columns(2)
        .show(ui, |ui| {
            ui.label("交易所");
            egui::ComboBox::from_id_salt("of_exchange")
                .selected_text(f.exchange.clone())
                .show_ui(ui, |ui| {
                    for e in &ex_opts {
                        ui.selectable_value(&mut f.exchange, e.clone(), e.clone());
                    }
                });
            ui.end_row();
            ui.label("代码");
            let sym_resp = ui.add(
                egui::TextEdit::singleline(&mut f.symbol)
                    .hint_text("cu2709")
                    .desired_width(150.0),
            );
            // 代码回车 = 订阅(Python TradingWidget returnPressed → set_en_symbol 等价)。
            // egui 单行 TextEdit 遇 Enter 即 surrender_focus,has_focus 在检查时已
            // false —— 规范口径 lost_focus + key_pressed(第五轮审计钉:s20 实测
            // has_focus 口径回车订阅从不触发)。
            if sym_resp.lost_focus() && ui.input(|i| i.key_pressed(egui::Key::Enter)) {
                let s = f.symbol.trim().to_string();
                // 与查询合约窗同口径:输入带 EX. 前缀则剥成裸代码(ctp.subscribe
                // 收裸码);剥后回写表单,名称/盘口/随价的 tick 查找同步可用。
                let bare = match s.split_once('.') {
                    Some((_, b)) => b.trim().to_string(),
                    None => s,
                };
                if !bare.is_empty() {
                    f.symbol = bare.clone();
                    shared.push_cmd(UiCmd::CtpSubscribe {
                        symbols: vec![bare.clone()],
                    });
                    shared.log_line(format!("[ops] 订阅已入列 {bare}(代码回车订阅)"));
                }
            }
            ui.end_row();
            ui.label("名称");
            ui.label(
                tick_of(shared, &f.exchange, &f.symbol)
                    .map(|t| {
                        if t.name.is_empty() {
                            "-".to_string()
                        } else {
                            t.name
                        }
                    })
                    .unwrap_or_else(|| "-".to_string()),
            );
            ui.end_row();
            ui.label("方向");
            egui::ComboBox::from_id_salt("of_direction")
                .selected_text(f.direction.as_str())
                .show_ui(ui, |ui| {
                    for d in [Direction::LONG, Direction::SHORT] {
                        ui.selectable_value(&mut f.direction, d, d.as_str());
                    }
                });
            ui.end_row();
            ui.label("开平");
            ui.horizontal(|ui| {
                egui::ComboBox::from_id_salt("of_offset")
                    .selected_text(f.offset.as_str())
                    .show_ui(ui, |ui| {
                        for o in [
                            Offset::OPEN,
                            Offset::CLOSE,
                            Offset::CLOSETODAY,
                            Offset::CLOSEYESTERDAY,
                        ] {
                            ui.selectable_value(&mut f.offset, o, o.as_str());
                        }
                    });
                // 0.1.1 BD-UI-30:自动开平勾选(开 = Auto 走拆单器;关 = None 原样)。
                ui.checkbox(&mut f.auto_split, "自动开平");
            });
            ui.end_row();
            ui.label("类型");
            egui::ComboBox::from_id_salt("of_order_type")
                .selected_text(f.order_type.as_str())
                .show_ui(ui, |ui| {
                    for ot in [OrderType::LIMIT, OrderType::MARKET] {
                        ui.selectable_value(&mut f.order_type, ot, ot.as_str());
                    }
                });
            ui.end_row();
            ui.label("价格");
            ui.horizontal(|ui| {
                ui.add(
                    egui::TextEdit::singleline(&mut f.price)
                        .hint_text("107660")
                        .desired_width(90.0),
                );
                ui.checkbox(&mut f.follow_price, "随价");
            });
            ui.end_row();
            ui.label("数量");
            ui.add(
                egui::TextEdit::singleline(&mut f.volume)
                    .hint_text("1")
                    .desired_width(90.0),
            );
            ui.end_row();
            ui.label("接口");
            egui::ComboBox::from_id_salt("of_gateway")
                .selected_text(if f.gateway.is_empty() {
                    "sim".to_string()
                } else {
                    f.gateway.clone()
                })
                .show_ui(ui, |ui| {
                    for g in &gw_opts {
                        ui.selectable_value(&mut f.gateway, g.clone(), g.clone());
                    }
                });
            ui.end_row();
            ui.label("操作");
            ui.horizontal(|ui| {
                if ui.button(BTN_SEND_ORDER).clicked() {
                    match f.to_request() {
                        Ok(req) => match crate::state::parse_gateway(&f.gateway) {
                            Ok(gateway) => {
                                shared.push_cmd(UiCmd::SendOrder {
                                    req,
                                    gateway,
                                    mode: if f.auto_split {
                                        ek_oms::LockMode::Auto
                                    } else {
                                        ek_oms::LockMode::None
                                    },
                                });
                                shared.log_line("[ops] 下单请求已入列(等 eTimer 请辞)");
                            }
                            Err(e) => {
                                shared.log_line(format!("[下单] {e}"));
                                err = Some(e);
                            }
                        },
                        Err(e) => {
                            shared.log_line(format!("[下单] {e}"));
                            err = Some(e);
                        }
                    }
                }
                if ui.button(BTN_CANCEL_ALL).clicked() {
                    // 全撤 = 活动委托逐个走 oms.cancel_order(界面侧扇出;
                    // 守卫逐单计数在 oms,不可绕过——0.1.1 BD-UI-30)
                    let mut n = 0usize;
                    for o in ts.orders.iter().filter(|o| order_active(o.status)) {
                        let gw = if o.gateway_name.is_empty() {
                            "sim".to_string()
                        } else {
                            o.gateway_name.clone()
                        };
                        shared.push_cmd(UiCmd::CancelOrder {
                            orderid: o.orderid.clone(),
                            gateway: gw,
                        });
                        n += 1;
                    }
                    shared.log_line(format!("[ops] 全撤入列 {n} 笔(等 eTimer 请辞)"));
                }
            });
            ui.end_row();
            ui.label("代码回车 = 订阅");
            ui.label("");
            ui.end_row();
        });
    if let Some(e) = err {
        ui.label(egui::RichText::new(e).color(egui::Color32::RED));
    }
    if f != before {
        shared.set_order_form(f.clone());
    }
}

/// 盘口帧(选中合约 tick 五档;Python 买5卖5 等价;独立帧避网格叠行)。
/// BD-UI-31(R4):题字撤除(含括号合约代码——选中合约已由下单面板代码格与
/// 行情带跳色行指认,盘口帧不重复报幕)。
fn render_book_frame(ui: &mut egui::Ui, shared: &UiShared) {
    let f = shared.order_form();
    match tick_of(shared, &f.exchange, &f.symbol) {
        Some(t) => {
            for i in (1..=5).rev() {
                let (p, v) = match i {
                    1 => (t.ask_price_1, t.ask_volume_1),
                    2 => (t.ask_price_2, t.ask_volume_2),
                    3 => (t.ask_price_3, t.ask_volume_3),
                    4 => (t.ask_price_4, t.ask_volume_4),
                    _ => (t.ask_price_5, t.ask_volume_5),
                };
                ui.label(
                    egui::RichText::new(format!("卖{i}  {:.1}  {:.0}", p, v))
                        .color(egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)),
                );
            }
            for i in 1..=5 {
                let (p, v) = match i {
                    1 => (t.bid_price_1, t.bid_volume_1),
                    2 => (t.bid_price_2, t.bid_volume_2),
                    3 => (t.bid_price_3, t.bid_volume_3),
                    4 => (t.bid_price_4, t.bid_volume_4),
                    _ => (t.bid_price_5, t.bid_volume_5),
                };
                ui.label(
                    egui::RichText::new(format!("买{i}  {:.1}  {:.0}", p, v))
                        .color(egui::Color32::from_rgb(0xE0, 0x50, 0x50)),
                );
            }
        }
        None => {
            ui.label("(无 tick)");
        }
    }
}

// ================= 2×2 监控格 =================

fn render_topleft_group(ui: &mut egui::Ui, shared: &UiShared) {
    let tab = shared.topleft_tab();
    ui.horizontal(|ui| {
        if ui
            .selectable_label(tab == TopLeftTab::Orders, TopLeftTab::Orders.label())
            .clicked()
        {
            shared.set_topleft_tab(TopLeftTab::Orders);
        }
        if ui
            .selectable_label(tab == TopLeftTab::Active, TopLeftTab::Active.label())
            .clicked()
        {
            shared.set_topleft_tab(TopLeftTab::Active);
        }
    });
    render_orders_table(ui, shared, tab == TopLeftTab::Active);
}

/// 委托表(17 列逐值 = Python OrderMonitor 蓝图:代码/名称/交易所/类型/方向/
/// 开平/价格/总量/已成/成交均价/状态/状态描述/时间/委托号/来源/接口 + 操作;
/// 活动行撤单钮 + 双击撤单,终态行只读)。
fn render_orders_table(ui: &mut egui::Ui, shared: &UiShared, active_only: bool) {
    let ts = shared.trade_snap();
    // 表题撤除(第五轮审计):tab「委托|未成交」即 Python 口径的表身份,
    // 再挂同名 label = 三重撞名(下单钮/tab/表题),纯冗余。
    let rows: Vec<_> = ts
        .orders
        .iter()
        .filter(|o| !active_only || order_active(o.status))
        .collect();
    if rows.is_empty() {
        ui.label(if active_only {
            "(无未成交)"
        } else {
            "(无委托:等网关 send_order)"
        });
        return;
    }
    egui::Grid::new(if active_only {
        "active_grid"
    } else {
        "order_grid"
    })
    .striped(true)
    .num_columns(17)
    .show(ui, |ui| {
        for h in [
            "代码",
            "名称",
            "交易所",
            "类型",
            "方向",
            "开平",
            "价格",
            "总量",
            "已成",
            "成交均价",
            "状态",
            "状态描述",
            "时间",
            "委托号",
            "来源",
            "接口",
            "操作",
        ] {
            ui.strong(h);
        }
        ui.end_row();
        for o in &rows {
            // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
            // 任何一格双击 = 撤单(Python OrderMonitor itemDoubleClicked→
            // cancel_order 等价,活动行限定;显式撤单钮同令并存)。
            let key = format!("{}.{}", o.gateway_name, o.orderid);
            let row_sel = shared.row_selected("orders", &key);
            let mut cells = Vec::with_capacity(17);
            let mut dbl = false;
            let sel = ui.selectable_label(row_sel, o.symbol.clone());
            if sel.clicked() {
                shared.select_row("orders", &key);
            }
            dbl |= sel.double_clicked();
            cells.push(sel.rect);
            macro_rules! cell {
                ($base:expr, $col:expr) => {{
                    let base = $base;
                    let r = click_cell(ui, base.rect, ("ord", &key, $col));
                    if r.clicked() {
                        shared.select_row("orders", &key);
                    }
                    dbl |= r.double_clicked();
                    cells.push(base.rect);
                }};
            }
            cell!(
                ui.label(if o.name.is_empty() {
                    "-".to_string()
                } else {
                    o.name.clone()
                }),
                1
            );
            cell!(ui.label(o.exchange.as_str().to_string()), 2);
            cell!(ui.label(o.order_type.as_str().to_string()), 3);
            cell!(
                ui.label(
                    egui::RichText::new(o.direction.map(|d| d.as_str()).unwrap_or("-")).color(
                        if o.direction == Some(Direction::SHORT) {
                            egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                        } else {
                            egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                        },
                    ),
                ),
                4
            );
            cell!(ui.label(o.offset.as_str().to_string()), 5);
            cell!(ui.label(format!("{:.1}", o.price)), 6);
            cell!(ui.label(format!("{:.0}", o.volume)), 7);
            cell!(ui.label(format!("{:.0}", o.traded)), 8);
            cell!(ui.label(format!("{:.1}", o.traded_price)), 9);
            cell!(
                ui.label(egui::RichText::new(o.status.as_str()).color(
                    if o.status == ek_data::constant::Status::REJECTED {
                        egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                    } else if o.status == ek_data::constant::Status::ALLTRADED {
                        egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                    } else {
                        egui::Color32::from_rgb(0xE0, 0x88, 0x10)
                    },
                )),
                10
            );
            cell!(ui.label(o.status_msg.clone()), 11);
            cell!(ui.label(fmt_dt(o.datetime)), 12);
            cell!(ui.label(o.orderid.clone()), 13);
            cell!(
                ui.label(if o.reference.is_empty() {
                    "-".to_string()
                } else {
                    o.reference.clone()
                }),
                14
            );
            cell!(ui.label(o.gateway_name.clone()), 15);
            if dbl && order_active(o.status) {
                let gw = if o.gateway_name.is_empty() {
                    "sim".to_string()
                } else {
                    o.gateway_name.clone()
                };
                shared.push_cmd(UiCmd::CancelOrder {
                    orderid: o.orderid.clone(),
                    gateway: gw,
                });
            }
            let hr = ui.horizontal(|ui| {
                if order_active(o.status)
                    && ui
                        .small_button(format!("{BTN_CANCEL_ORDER} {}", o.orderid))
                        .clicked()
                {
                    // 撤单跟随委托的来路网关(行级 gateway_name;空串兜底 sim)
                    let gw = if o.gateway_name.is_empty() {
                        "sim".to_string()
                    } else {
                        o.gateway_name.clone()
                    };
                    shared.push_cmd(UiCmd::CancelOrder {
                        orderid: o.orderid.clone(),
                        gateway: gw,
                    });
                }
            });
            cells.push(hr.response.rect);
            paint_row_bg(ui, &cells, row_sel);
            ui.end_row();
        }
    });
}

/// 成交组(12 列逐值 = Python TradeMonitor 蓝图)。
fn render_trades_group(ui: &mut egui::Ui, shared: &UiShared) {
    ui.label("成交");
    let ts = shared.trade_snap();
    if ts.trades.is_empty() {
        ui.label("(无成交)");
        return;
    }
    egui::Grid::new("trade_grid")
        .striped(true)
        .num_columns(12)
        .show(ui, |ui| {
            for h in [
                "成交号",
                "代码",
                "名称",
                "交易所",
                "方向",
                "开平",
                "价格",
                "数量",
                "成交额",
                "时间",
                "委托号",
                "接口",
            ] {
                ui.strong(h);
            }
            ui.end_row();
            for t in &ts.trades {
                // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
                // 方向列上色(R2,与委托/持仓表同口径:空绿/多红)。
                let key = format!("{}.{}", t.gateway_name, t.tradeid);
                let row_sel = shared.row_selected("trades", &key);
                let mut cells = Vec::with_capacity(12);
                let sel = ui.selectable_label(row_sel, t.tradeid.clone());
                if sel.clicked() {
                    shared.select_row("trades", &key);
                }
                cells.push(sel.rect);
                macro_rules! cell {
                    ($base:expr, $col:expr) => {{
                        let base = $base;
                        let r = click_cell(ui, base.rect, ("trd", &key, $col));
                        if r.clicked() {
                            shared.select_row("trades", &key);
                        }
                        cells.push(base.rect);
                    }};
                }
                cell!(ui.label(t.symbol.clone()), 1);
                cell!(
                    ui.label(if t.name.is_empty() {
                        "-".to_string()
                    } else {
                        t.name.clone()
                    }),
                    2
                );
                cell!(ui.label(t.exchange.as_str().to_string()), 3);
                cell!(
                    ui.label(
                        egui::RichText::new(t.direction.map(|d| d.as_str()).unwrap_or("-")).color(
                            if t.direction == Some(Direction::SHORT) {
                                egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                            } else {
                                egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                            },
                        ),
                    ),
                    4
                );
                cell!(ui.label(t.offset.as_str().to_string()), 5);
                cell!(ui.label(format!("{:.1}", t.price)), 6);
                cell!(ui.label(format!("{:.0}", t.volume)), 7);
                cell!(ui.label(format!("{:.1}", t.traded_amount)), 8);
                cell!(ui.label(fmt_dt(t.datetime)), 9);
                cell!(ui.label(t.orderid.clone()), 10);
                cell!(ui.label(t.gateway_name.clone()), 11);
                paint_row_bg(ui, &cells, row_sel);
                ui.end_row();
            }
        });
}

/// 持仓组(16 列逐值 = Python PositionMonitor 蓝图;双击行带入下单面板,
/// Python mainwindow.py:276 等价,不开 K线)。
fn render_positions_group(ui: &mut egui::Ui, shared: &UiShared) {
    ui.label("持仓");
    let ts = shared.trade_snap();
    if ts.positions.is_empty() {
        ui.label("(无持仓)");
        return;
    }
    egui::Grid::new("pos_grid")
        .striped(true)
        .num_columns(16)
        .show(ui, |ui| {
            for h in [
                "代码",
                "名称",
                "交易所",
                "方向",
                "数量",
                "昨仓",
                "可用",
                "冻结",
                "在途",
                "市值",
                "成本",
                "均价",
                "最新价",
                "盈亏",
                "盈亏比",
                "接口",
            ] {
                ui.strong(h);
            }
            ui.end_row();
            for p in &ts.positions {
                // 行交互(BD-UI-31 扩展):行内任何一格单击 = 选中行(跳色);
                // 任何一格双击 = 带入下单面板(Python mainwindow.py:276 等价,
                // 不开 K线;方向随持仓方向,Python 同口径)。
                let key = format!("{}.{}.{}", p.gateway_name, p.symbol, p.direction.as_str());
                let row_sel = shared.row_selected("positions", &key);
                let mut cells = Vec::with_capacity(16);
                let mut dbl = false;
                let sel = ui.selectable_label(row_sel, p.symbol.clone());
                if sel.clicked() {
                    shared.select_row("positions", &key);
                }
                dbl |= sel.double_clicked();
                cells.push(sel.rect);
                macro_rules! cell {
                    ($base:expr, $col:expr) => {{
                        let base = $base;
                        let r = click_cell(ui, base.rect, ("pos", &key, $col));
                        if r.clicked() {
                            shared.select_row("positions", &key);
                        }
                        dbl |= r.double_clicked();
                        cells.push(base.rect);
                    }};
                }
                cell!(
                    ui.label(if p.name.is_empty() {
                        "-".to_string()
                    } else {
                        p.name.clone()
                    }),
                    1
                );
                cell!(ui.label(p.exchange.as_str().to_string()), 2);
                cell!(
                    ui.label(egui::RichText::new(p.direction.as_str()).color(
                        if p.direction == ek_data::constant::Direction::SHORT {
                            egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                        } else {
                            egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                        },
                    )),
                    3
                );
                cell!(ui.label(format!("{:.0}", p.volume)), 4);
                cell!(ui.label(format!("{:.0}", p.yd_volume)), 5);
                cell!(ui.label(format!("{:.0}", p.can_use_volume)), 6);
                cell!(ui.label(format!("{:.0}", p.frozen)), 7);
                cell!(ui.label(format!("{:.0}", p.on_road_volume)), 8);
                cell!(ui.label(format!("{:.1}", p.market_value)), 9);
                cell!(ui.label(format!("{:.2}", p.price)), 10);
                cell!(ui.label(format!("{:.2}", p.avg_price)), 11);
                cell!(ui.label(format!("{:.2}", p.last_price)), 12);
                cell!(
                    ui.label(
                        egui::RichText::new(format!("{:+.1}", p.pnl)).color(if p.pnl < 0.0 {
                            egui::Color32::from_rgb(0x2E, 0x9E, 0x2E)
                        } else {
                            egui::Color32::from_rgb(0xE0, 0x50, 0x50)
                        }),
                    ),
                    13
                );
                cell!(ui.label(format!("{:+.4}", p.profit_rate)), 14);
                cell!(ui.label(p.gateway_name.clone()), 15);
                if dbl {
                    let mut f = shared.order_form();
                    f.symbol = p.symbol.clone();
                    f.exchange = p.exchange.as_str().to_string();
                    f.direction = p.direction;
                    shared.set_order_form(f);
                    shared.log_line(format!("[ops] 持仓带入下单面板 {}", p.symbol));
                }
                paint_row_bg(ui, &cells, row_sel);
                ui.end_row();
            }
        });
}

fn render_bottomright_group(ui: &mut egui::Ui, shared: &UiShared) {
    let tab = shared.bottomright_tab();
    ui.horizontal(|ui| {
        if ui
            .selectable_label(
                tab == BottomRightTab::Account,
                BottomRightTab::Account.label(),
            )
            .clicked()
        {
            shared.set_bottomright_tab(BottomRightTab::Account);
        }
        if ui
            .selectable_label(tab == BottomRightTab::Logs, BottomRightTab::Logs.label())
            .clicked()
        {
            shared.set_bottomright_tab(BottomRightTab::Logs);
        }
    });
    match tab {
        BottomRightTab::Account => {
            let ts = shared.trade_snap();
            if ts.accounts.is_empty() {
                ui.label("(无资金:等网关 eAccount.)");
                return;
            }
            egui::Grid::new("acct_grid")
                .striped(true)
                .num_columns(5)
                .show(ui, |ui| {
                    for h in ["账号", "接口", "余额", "可用", "冻结"] {
                        ui.strong(h);
                    }
                    ui.end_row();
                    for a in &ts.accounts {
                        ui.label(a.accountid.clone());
                        ui.label(a.gateway_name.clone());
                        ui.label(format!("{:.2}", a.balance));
                        ui.label(format!("{:.2}", a.available()));
                        ui.label(format!("{:.2}", a.frozen));
                        ui.end_row();
                    }
                });
        }
        BottomRightTab::Logs => {
            render_logs(ui, shared);
        }
    }
}

fn render_logs(ui: &mut egui::Ui, shared: &UiShared) {
    ui.horizontal(|ui| {
        if ui.button(BTN_CLEAR_LOGS).clicked() {
            shared.clear_logs(); // LOCAL-FIRST:就地清,零往返
        }
        let (_, spilled) = shared.logs_snapshot();
        if spilled > 0 {
            ui.label(format!(
                "已丢弃 {spilled} 条(环形 {})",
                crate::state::RING_CAP
            ));
        }
    });
    let lines = shared.logs_snapshot().0;
    egui::ScrollArea::vertical()
        .id_salt("log_scroll")
        .max_height(180.0)
        .stick_to_bottom(true)
        .show(ui, |ui| {
            for line in lines {
                ui.monospace(line);
            }
        });
}

// ================= 弹窗面 =================

fn render_windows(ctx: &egui::Context, shared: &UiShared) {
    // 运维窗(菜单「运维」)
    let mut ops_open = shared.ops_window_open();
    egui::Window::new("运维窗")
        .id(egui::Id::new("ops_win"))
        .default_pos([80.0, 320.0])
        .default_size([640.0, 380.0])
        .open(&mut ops_open)
        .show(ctx, |ui| {
            render_ops_window(ui, shared);
        });
    shared.set_ops_window_open(ops_open);

    // CTP 配置窗(菜单「网关」;CTP 插件自己的界面,主窗只当弹窗宿主)
    let mut ctp_open = shared.ctp_window_open();
    egui::Window::new("CTP 网关配置窗")
        .id(egui::Id::new("ctp_win"))
        .default_pos([640.0, 320.0])
        .default_size([560.0, 330.0])
        .open(&mut ctp_open)
        .show(ctx, |ui| {
            render_ctp_window(ui, shared);
        });
    shared.set_ctp_window_open(ctp_open);

    // 查询合约窗(菜单「查询合约」;Python ContractManager 等价:查询 + 勾选 + 订阅)。
    // BD-UI-32 R2/R3(用户裁定):独立 OS 窗(eframe immediate viewport)——原生
    // 最小化/最大化/关闭钮、可拖出主窗放屏幕任意处(Python 独立窗形态)。
    // 后端不支持多窗(kittest/WEB)时 egui 自动回退 Embedded = 主窗内弹窗,
    // 同一本体(kittest 断言面零改动)。
    // **0.2.3 守卫(关不掉根因修复):** egui 销毁判据 = 子 viewport 本拍未
    // used(context.rs「never used this pass」)。show_viewport_immediate 每拍
    // 调用 = 每拍 used = 永不销毁(X 点了被重新用起来)。必须按状态位辞行:
    // 位关 → 整段不 show → GC 销毁 OS 窗。Embedded 分支靠 .open 旗标幸免,
    // 测试面被回退掩盖——Immediate 路径守卫由 s24 钉(注入 recording renderer)。
    if shared.contracts_window_open() {
        let contracts_closed = std::cell::Cell::new(false);
        ctx.show_viewport_immediate(
            egui::ViewportId::from_hash_of("contracts_win"),
            egui::ViewportBuilder::default()
                .with_title("查询合约窗")
                .with_inner_size([620.0, 460.0])
                .with_min_inner_size([420.0, 260.0])
                .with_minimize_button(true)
                .with_maximize_button(true)
                .with_close_button(true),
            |ctx2, class| {
                if class == egui::ViewportClass::Embedded {
                    let mut open = shared.contracts_window_open();
                    egui::Window::new("查询合约窗")
                        .id(egui::Id::new("contracts_win"))
                        .default_pos([420.0, 300.0])
                        .default_size([560.0, 420.0])
                        .open(&mut open)
                        .show(ctx2, |ui| {
                            render_contracts_window(ui, shared);
                        });
                    shared.set_contracts_window_open(open);
                    return;
                }
                if ctx2.input(|i| i.viewport().close_requested()) {
                    contracts_closed.set(true);
                    return;
                }
                egui::CentralPanel::default().show(ctx2, |ui| {
                    render_contracts_window(ui, shared);
                });
            },
        );
        if contracts_closed.get() {
            shared.set_contracts_window_open(false);
        }
    }

    // K线窗(双击弹出,按合约多开;BD-UI-32 同口径独立 OS 窗,Embedded 回退同本体)。
    let mut closed: Vec<String> = Vec::new();
    for sym in shared.kline_symbols() {
        let closed_flag = std::cell::Cell::new(false);
        ctx.show_viewport_immediate(
            egui::ViewportId::from_hash_of(("kline_win", sym.clone())),
            egui::ViewportBuilder::default()
                .with_title(format!("K线 — {sym}"))
                .with_inner_size([560.0, 360.0])
                .with_min_inner_size([360.0, 220.0])
                .with_minimize_button(true)
                .with_maximize_button(true)
                .with_close_button(true),
            |ctx2, class| {
                if class == egui::ViewportClass::Embedded {
                    let resp = egui::Window::new(format!("K线 — {sym}"))
                        .id(egui::Id::new(("kline_win", sym.clone())))
                        .default_pos([300.0, 340.0])
                        .default_size([540.0, 330.0])
                        .show(ctx2, |ui| {
                            let cell = shared
                                .market()
                                .cells()
                                .into_iter()
                                .find(|c| c.symbol == sym);
                            render_kline_cell(ui, cell.as_ref());
                        });
                    if resp.is_none() {
                        closed_flag.set(true);
                    }
                    return;
                }
                if ctx2.input(|i| i.viewport().close_requested()) {
                    closed_flag.set(true);
                    return;
                }
                egui::CentralPanel::default().show(ctx2, |ui| {
                    let cell = shared
                        .market()
                        .cells()
                        .into_iter()
                        .find(|c| c.symbol == sym);
                    render_kline_cell(ui, cell.as_ref());
                });
            },
        );
        if closed_flag.get() {
            closed.push(sym);
        }
    }
    for s in closed {
        shared.close_kline(&s);
    }
}

/// 运维窗:插件表(svctl 操作 + 二次确认)+ 待确认横幅 + 服务目录(三列)
/// + 依赖图 + 流控查询钮。回灌界面面已退役(总线口保留)。
fn render_ops_window(ui: &mut egui::Ui, shared: &UiShared) {
    ui.label("插件");
    let snap = shared.snapshot();
    egui::Grid::new("plug_grid")
        .striped(true)
        .num_columns(6)
        .show(ui, |ui| {
            ui.strong("名称");
            ui.strong("状态");
            ui.strong("版本");
            ui.strong("依赖");
            ui.strong("统计");
            ui.strong("操作");
            ui.end_row();
            if snap.rows.is_empty() {
                ui.label("(快照空:等 eTimer 首拉)");
                ui.end_row();
            }
            for r in &snap.rows {
                if is_quarantined(&r.state) {
                    ui.label(egui::RichText::new(r.name.clone()).color(egui::Color32::RED));
                    ui.label(
                        egui::RichText::new(state_text(r))
                            .color(egui::Color32::RED)
                            .strong(),
                    );
                } else {
                    ui.label(r.name.clone());
                    ui.label(state_text(r));
                }
                ui.label(r.version.clone());
                ui.label(format!("deps:[{}]", r.deps.join(",")));
                ui.label(format!("spilled:{} panics:{}", r.spilled, r.panics));
                ui.horizontal(|ui| {
                    if ui.small_button(format!("重注入 {}", r.name)).clicked() {
                        shared.push_cmd(UiCmd::Start {
                            factory: r.name.clone(),
                        });
                    }
                    let armed = shared.pending_confirm();
                    let armed_here = ui
                        .small_button(remove_button_label(&r.name, armed.as_deref()))
                        .clicked()
                        && shared.confirm_step(&r.name) == ConfirmStep::Fired;
                    if armed_here {
                        shared.push_cmd(UiCmd::Remove {
                            name: r.name.clone(),
                        });
                    }
                });
                ui.end_row();
            }
        });

    if let Some(name) = shared.pending_confirm() {
        ui.horizontal(|ui| {
            ui.label(
                egui::RichText::new(format!("待二次确认:再次点击『移除 {name}』完成"))
                    .color(egui::Color32::from_rgb(0xE0, 0x88, 0x10)),
            );
            if ui.small_button(BTN_CANCEL_CONFIRM).clicked() {
                shared.confirm_cancel();
            }
        });
    }

    ui.label("服务");
    let flat: Vec<String> = snap
        .services
        .iter()
        .flat_map(|(n, ids)| {
            if ids.is_empty() {
                vec![format!("{n} 服务"), "-".to_string()]
            } else {
                ids.iter()
                    .flat_map(|id| [format!("{n} 服务"), id.clone()])
                    .collect()
            }
        })
        .collect();
    if flat.is_empty() {
        ui.label("(无服务目录)");
    } else {
        let rows = flat.len().div_ceil(6); // 每列 2 字段 × 3 列
        egui::Grid::new("svc_grid")
            .striped(true)
            .num_columns(6)
            .show(ui, |ui| {
                for r in 0..rows {
                    for c in 0..3 {
                        let i = c * rows * 2 + r * 2;
                        if i < flat.len() {
                            ui.label(flat[i].clone());
                            ui.label(flat[i + 1].clone());
                        } else {
                            ui.label("");
                            ui.label("");
                        }
                    }
                    ui.end_row();
                }
            });
    }

    ui.label("依赖");
    if !snap.rows.iter().any(|r| !r.deps.is_empty()) {
        ui.label("(全部无依赖)");
    }
    for r in &snap.rows {
        if !r.deps.is_empty() {
            ui.label(format!("{} → {}", r.name, r.deps.join(" + ")));
        }
    }

    ui.horizontal(|ui| {
        if ui.small_button(BTN_QUERY_RATE).clicked() {
            shared.push_cmd(UiCmd::QueryRate);
        }
    });
}

/// CTP 配置窗渲染(S6 定盘口径:账号/前置全部界面手工输入,插件不读文件;
/// `连接 CTP` → ask ctp.configure;密码位掩码。**无订阅字段**(用户裁定:
/// 订阅不在网关窗定死,走下单面板代码回车或查询合约窗勾选))。
fn render_ctp_window(ui: &mut egui::Ui, shared: &UiShared) {
    ui.label("账号与前置手工输入(插件自带配置面;密码不回显)");
    let mut form: crate::state::CtpForm = shared.ctp_form();
    egui::Grid::new("ctp_grid").num_columns(6).show(ui, |ui| {
        ui.label("broker");
        ctp_edit(ui, shared, &mut form.broker_id, "9999", CtpField::Broker);
        ui.label("td 前置");
        ctp_edit(
            ui,
            shared,
            &mut form.td_addr,
            "tcp://host:40001",
            CtpField::TdAddr,
        );
        ui.label("td 用户");
        ctp_edit(ui, shared, &mut form.td_user, "用户号", CtpField::TdUser);
        ui.end_row();
        ui.label("td 密码");
        ctp_edit(
            ui,
            shared,
            &mut form.td_password,
            "密码",
            CtpField::TdPassword,
        );
        ui.label("AppID");
        ctp_edit(ui, shared, &mut form.td_app_id, "app", CtpField::AppId);
        ui.label("AuthCode");
        ctp_edit(
            ui,
            shared,
            &mut form.td_auth_code,
            "授权码",
            CtpField::AuthCode,
        );
        ui.end_row();
        ui.label("md 前置");
        ctp_edit(
            ui,
            shared,
            &mut form.md_addr,
            "tcp://host:40011",
            CtpField::MdAddr,
        );
        ui.label("md 用户");
        ctp_edit(
            ui,
            shared,
            &mut form.md_user,
            "空=td 回落",
            CtpField::MdUser,
        );
        ui.label("md 密码");
        ctp_edit(
            ui,
            shared,
            &mut form.md_password,
            "空=td 回落",
            CtpField::MdPassword,
        );
        ui.end_row();
    });
    ui.horizontal(|ui| {
        if ui.small_button(BTN_CTP_CONNECT).clicked() {
            shared.push_cmd(UiCmd::CtpConfigure(form.clone()));
            shared.log_line("[ops] CTP 配置已入列(等 eTimer 请辞 → ctp.configure)");
        }
        ui.label("订阅不在本网关窗定死:查询合约窗勾选订阅,或下单面板代码回车订阅(用户裁定)");
    });
}

/// 查询合约窗(Python ContractManager 等价):查询串(代码/交易所/名称模糊,
/// 留空 = 全部)+ 勾选表 + 订阅钮(勾选集 → UiCmd::CtpSubscribe → ask
/// ctp.subscribe)。合约数据 = `eContract.` 自动回流,窗不催查询。
fn render_contracts_window(ui: &mut egui::Ui, shared: &UiShared) {
    let mut q = shared.contract_query();
    ui.horizontal(|ui| {
        ui.label("代码或交易所(留空 = 全部):");
        if ui
            .add(
                egui::TextEdit::singleline(&mut q)
                    .hint_text("cu 或 SHFE")
                    .desired_width(200.0),
            )
            .changed()
        {
            shared.set_contract_query(q.clone());
        }
    });
    let rows = shared.contracts(&q);
    if rows.is_empty() {
        ui.label("(无合约:先连接 CTP,合约随 eContract. 自动回流)");
        return;
    }
    let selected = shared.selected_contracts();
    egui::ScrollArea::vertical()
        .id_salt("contract_scroll")
        .max_height(260.0)
        .auto_shrink([false, false])
        .show(ui, |ui| {
            egui::Grid::new("contract_grid")
                .striped(true)
                .num_columns(5)
                .show(ui, |ui| {
                    for h in ["选(代码)", "交易所", "名称", "乘数", "最小变动"] {
                        ui.strong(h);
                    }
                    ui.end_row();
                    for c in &rows {
                        let key = format!("{}.{}", c.exchange.as_str(), c.symbol);
                        let mut on = selected.contains(&key);
                        // 勾选钮标签 = en_symbol(唯一可定位;订阅钮按勾选集发)。
                        // BD-UI-31 扩展:勾选 = 订阅选择 + 行选中;其余格单击 =
                        // 行选中(动作归行,不归某一列)。
                        let row_sel = shared.row_selected("contracts", &key);
                        let mut cells = Vec::with_capacity(5);
                        let ck = ui.checkbox(&mut on, key.clone());
                        if ck.changed() {
                            shared.toggle_contract_selection(&key);
                            shared.select_row("contracts", &key);
                        }
                        cells.push(ck.rect);
                        macro_rules! cell {
                            ($base:expr, $col:expr) => {{
                                let base = $base;
                                let r = click_cell(ui, base.rect, ("crt", &key, $col));
                                if r.clicked() {
                                    shared.select_row("contracts", &key);
                                }
                                cells.push(base.rect);
                            }};
                        }
                        cell!(ui.label(c.exchange.as_str().to_string()), 1);
                        cell!(ui.label(c.name.clone()), 2);
                        cell!(ui.label(format!("{:.0}", c.size)), 3);
                        cell!(ui.label(format!("{:.4}", c.price_tick)), 4);
                        paint_row_bg(ui, &cells, row_sel);
                        ui.end_row();
                    }
                });
        });
    ui.horizontal(|ui| {
        ui.label(format!("已选 {} 项 / 共 {} 项", selected.len(), rows.len()));
        if ui.button(BTN_SUBSCRIBE_SELECTED).clicked() {
            if selected.is_empty() {
                shared.log_line("[查询合约] 未勾选任何合约,订阅未发");
            } else {
                // en_symbol 勾选集 → CTP 裸代码订阅(ask ctp.subscribe 收裸代码)
                let symbols: Vec<String> = selected
                    .iter()
                    .map(|k| {
                        k.split_once('.')
                            .map(|(_, s)| s.to_string())
                            .unwrap_or_else(|| k.clone())
                    })
                    .collect();
                shared.push_cmd(UiCmd::CtpSubscribe { symbols });
                shared.log_line(format!(
                    "[ops] 查询合约窗订阅 {} 项已入列(等 eTimer 请辞 → ctp.subscribe)",
                    selected.len()
                ));
            }
        }
    });
}

/// CTP 表单字段枚举(ctp_edit 回写定位;订阅标的字段已撤出网关窗)。
enum CtpField {
    Broker,
    TdAddr,
    TdUser,
    TdPassword,
    AppId,
    AuthCode,
    MdAddr,
    MdUser,
    MdPassword,
}

/// 单行 TextEdit + changed 回写 CTP 表单(密码位掩码)。
fn ctp_edit(ui: &mut egui::Ui, shared: &UiShared, val: &mut String, hint: &str, field: CtpField) {
    let is_secret = matches!(
        field,
        CtpField::TdPassword | CtpField::MdPassword | CtpField::AuthCode
    );
    let mut w = egui::TextEdit::singleline(val)
        .hint_text(hint)
        .desired_width(110.0);
    if is_secret {
        w = w.password(true);
    }
    if ui.add(w).changed() {
        let mut f = shared.ctp_form();
        match field {
            CtpField::Broker => f.broker_id = val.clone(),
            CtpField::TdAddr => f.td_addr = val.clone(),
            CtpField::TdUser => f.td_user = val.clone(),
            CtpField::TdPassword => f.td_password = val.clone(),
            CtpField::AppId => f.td_app_id = val.clone(),
            CtpField::AuthCode => f.td_auth_code = val.clone(),
            CtpField::MdAddr => f.md_addr = val.clone(),
            CtpField::MdUser => f.md_user = val.clone(),
            CtpField::MdPassword => f.md_password = val.clone(),
        }
        shared.set_ctp_form(f);
    }
}

/// K线窗内容(dm bar 合成序列;格定点 = 该合约格;无格占位)。
///
/// 图实例每帧重建(BD-UI-20 口径:数据在 store 不丢,交互状态不跨帧)。
fn render_kline_cell(ui: &mut egui::Ui, cell: Option<&CellView>) {
    let Some(c) = cell else {
        ui.label("(K线无格:等 dm 合成)");
        return;
    };
    if c.bars.is_empty() {
        ui.label(format!("(K线:{}@{} 批空)", c.symbol, c.interval));
        return;
    }
    let mut data = egui_charts::model::bar::BarData::new();
    for b in &c.bars {
        let dt = chrono::DateTime::<chrono::Utc>::from_timestamp_nanos(b.datetime);
        data.push(egui_charts::model::bar::Bar::new(
            dt,
            b.open_price,
            b.high_price,
            b.low_price,
            b.close_price,
            b.volume,
        ));
    }
    ui.label(format!(
        "K线 {}@{}s({} 根)",
        c.symbol,
        c.interval,
        c.bars.len()
    ));
    let mut chart = egui_charts::widget::Chart::new(data).visible_bars(60);
    chart.set_symbol(&c.symbol);
    chart.set_timeframe_label(&format!("{}s", c.interval));
    chart.enable_tracking_mode();
    let _ = chart.show(ui);
}