Struct StaticDataCache 

pub struct StaticDataCache {
    pub trade_dates: DashMap<String, Vec<CachedTradeDate>>,
    pub plates: DashMap<String, Vec<CachedPlateInfo>>,
    pub stale_mkt_ids: DashMap<String, ()>,
    pub mkt_id_refresh_marked_total: AtomicU64,
    pub mkt_id_refresh_done_total: AtomicU64,
    pub mkt_id_refresh_failed_total: AtomicU64,
    /* private fields */
}

静态数据缓存

Fields

trade_dates: DashMap<String, Vec<CachedTradeDate>>

交易日: “market:year-month” → Vec

plates: DashMap<String, Vec<CachedPlateInfo>>

板块: “market:plate_type” → Vec

stale_mkt_ids: DashMap<String, ()>

v1.4.89 P2-A: 需要 mkt_id refresh 的 cache key 集合.

Callers get_security_info_trigger_refresh 在返 info 前检查 info.needs_mkt_id_refresh(), 是则 mark key 到这里. 背景 worker (gateway bridge) 定期 drain_stale_mkt_ids() 批量 CMD 20106 refresh.

用 DashMap<String, ()> 替代 HashSet 免 lock 竞争.

mkt_id_refresh_marked_total: AtomicU64

v1.4.89 P2-A: mkt_id refresh 统计计数, 用于 metrics 观察.

• mkt_id_refresh_marked_total: 累积 mark stale 次数
• mkt_id_refresh_done_total: 累积 backend CMD 20106 成功 refresh 次数
• mkt_id_refresh_failed_total: 累积 refresh failure 次数

mkt_id_refresh_done_total: AtomicU64

mkt_id_refresh_failed_total: AtomicU64

Implementations

impl StaticDataCache

pub fn new() -> Self

pub fn get_security_info_trigger_refresh( &self, key: &str, ) -> Option<CachedSecurityInfo>

v1.4.89 P2-A: 取 cache info 同时机会性 mark stale (若 mkt_id=0).

返 Some(info) 如果 cache hit (无论是否 stale). 返 None 如果 miss.

调 info.needs_mkt_id_refresh() 判 stale → mark stale_mkt_ids, bump mkt_id_refresh_marked_total counter. 用 DashMap::insert 幂等 (同 key 重入不 double mark 但会 bump counter — 可接受).

替代 get_security_info 的推荐路径; 老 method 保留作 lookup-only 接口.

pub fn mark_stale_mkt_id(&self, key: &str)

v1.4.89 P2-A: 显式 mark key 需要 mkt_id refresh.

幂等: 同 key 可重入. Counter mkt_id_refresh_marked_total 每次都 bump (用作 metrics 观察 heuristic fallback 触发频率).

pub fn drain_stale_mkt_ids(&self) -> Vec<String>

v1.4.89 P2-A: drain 所有 stale keys, 清空集合, 返 Vec (给 backend worker 批量 CMD 20106 refresh).

背景 worker 用法 (伪码):

loop {
    sleep(Duration::from_secs(60)).await;
    let stale = cache.drain_stale_mkt_ids();
    if stale.is_empty() { continue; }
    for chunk in stale.chunks(50) {
        // CMD 20106 SecuritiesReq for chunk
        // on success: cache.update_mkt_id(key, new_mkt_id)
        //              + cache.record_mkt_id_refresh_done()
        // on failure: cache.record_mkt_id_refresh_failed()
    }
}

pub fn update_mkt_id(&self, key: &str, new_mkt_id: u32) -> bool

v1.4.89 P2-A: 更新已 cache row 的 mkt_id (refresh success 时调).

只改 mkt_id 字段, 其他字段保留 (info 可能有 SQLite 里更精准的 lot_size / list_time 等). 若 key 不在 cache (已被 evict), no-op.

pub fn record_mkt_id_refresh_failed(&self)

v1.4.89 P2-A: 记录 refresh failure (不改 cache row, 让下次 drain 重试).

pub fn stale_mkt_ids_count(&self) -> usize

v1.4.89 P2-A: 当前 stale keys 数 (给 observability / debug).

pub fn upsert_full_security_info(&self, key: &str, info: CachedSecurityInfo)

v1.4.106 codex 1148 F9 (P3): 统一写入口 — 完整静态行 (StockListFull / Bootstrap source)。同步维护 securities + id_to_key + 若有 owner 还更新 owner_to_warrants。自动 dedup: 已有同 key 但 warrnt_stock_owner 变化时, 旧 owner 下移除该 warrant id, 新 owner 下添加。

替代生产代码里手动调 securities.insert() + id_to_key.insert() + add_warrant_owner() 三步骤的 pattern。

不允许 caller 把不完整的 source 标 StockListFull(若 info.source == OnDemandBasic, 用 upsert_basic_security_info 而非本 fn)。

pub fn upsert_crypto_pair_info(&self, key: &str, pair: CryptoPairInfo)

写入 stock-list 下发的 crypto 货币对元数据。

pub fn set_option_contract_info(&self, stock_id: u64, info: OptionContractInfo)

Cache option contract metadata from CMD20106 OptionResultInfo.

pub fn get_option_contract_info_by_stock_id( &self, stock_id: u64, ) -> Option<OptionContractInfo>

Read option contract metadata by option stock_id.

pub fn get_crypto_pair_info(&self, key: &str) -> Option<CryptoPairInfo>

读取 crypto 货币对元数据。

pub fn set_crypto_trade_configs_for_broker( &self, broker_id: u32, configs: Vec<CryptoTradeConfig>, )

用 backend CMD20102 拉回的配置替换某个 broker 的 crypto trade config。

pub fn get_crypto_trade_config( &self, broker_id: u32, symbol: &str, exchange: &str, ) -> Option<CryptoTradeConfig>

查询某个 crypto symbol 的交易配置。

pub fn upsert_basic_security_info(&self, key: &str, info: CachedSecurityInfo)

v1.4.106 codex 1148 F9 (P3): 统一写入口 — 部分静态行 (OnDemandBasic source)。同步维护 securities + id_to_key, 不动 owner_to_warrants (因为 OnDemandBasic 不含 warrnt_stock_owner 字段, value 必为 0)。

info.source 必须是 OnDemandBasic (debug_assert)。

pub fn delete_security_info(&self, stock_id: u64) -> bool

v1.4.106 codex 1148 F9 (P3): 删除 cache row + 同步清三个索引 (securities, id_to_key, owner_to_warrants)。

用于 stock-list delete_flag = true 场景。 返 true 如果 row 存在并被删除, false 如果 stock_id 不在 id_to_key。

pub fn get_future_main_link_alias_keys(&self, stock_id: u64) -> Vec<String>

查询某个 backend push stock_id 对应的主连/连续合约 sec_key 别名。

只返回 stock-list 明确下发 origin_id / zhuli_id 关系的 key；不做 HSImain 等字符串启发式。调用方通常先按 id_to_key 处理真实合约， 再把这里返回的 main-link key 一并投递。

pub fn quote_push_targets_for_stock_id( &self, stock_id: u64, ) -> Vec<(String, Arc<CachedSecurityInfo>)>

查询 backend push stock_id 的所有 quote 投递目标。

顺序保持为：真实 stock_id 对应 key（如有）优先，然后是 stock-list origin_id / zhuli_id 下发的主连/连续合约别名 key。调用方不再直接 读取 id_to_key 和 future_main_link_aliases 两个索引，避免 alias 逻辑 分散在 push parser 里。

pub fn quote_push_targets_for_stock_key( &self, stock_id: u64, broker_id: Option<NonZeroU32>, ) -> Vec<(QotSecurityKey, Arc<CachedSecurityInfo>)>

v1.4.110 Phase 2 Slice 5: broker-aware 推送投递目标查询.

对应 push parser 从 SecurityQuote.broker_id 重建 broker-aware QotStockKey 的路径 (对齐 C++ NNBiz_Qot_PushQot.cpp:220-269).

语义:

• broker_id = None (C++ m_hasBroker=false): 只查 no-broker key, 返 QotSecurityKey::no_broker(public_sec_key, stock_id) 与 quote_push_targets_for_stock_id 等价
• broker_id = Some(N) (C++ m_hasBroker=true): 沿 stock_id 反向 找到 public_sec_key, 再用 QotSecurityKey::from_broker_id(...) 构造 broker-aware key. 该 broker 下 cache 写入独立桶 "market_code@b{N}", 不污染同 stock_id 其他 broker 的 cache.

Phase 2 默认: backend 当前对普通股 push 仍不下发 broker_id (=None), 与升级前行为完全等价. crypto multi-broker push 会带 broker_id, Phase 3 reader caller (handler GetBasicQot 等) 替换走 _broker 版本后, broker-aware cache 才被消费.

pub fn set_security_info(&self, key: &str, info: CachedSecurityInfo)

👎Deprecated since 1.4.106:

use upsert_full_security_info / upsert_basic_security_info / delete_security_info

deprecated: 改用 upsert_full_security_info / upsert_basic_security_info 显式表达数据完整度。

v1.4.111 codex legacy deep-dive follow-up: 保留此 public wrapper 兼容 既有 tests/bench/下游辅助代码，但不再直接写 securities 造成半索引行。 source.is_complete() 走 full upsert, 否则走 basic upsert, 始终维护 id_to_key / owner_to_warrants 与主表一致。

pub fn get_security_info(&self, key: &str) -> Option<CachedSecurityInfo>

pub fn get_security_info_arc( &self, key: &str, ) -> Option<Arc<CachedSecurityInfo>>

pub fn security_id_for_key(&self, key: &str) -> Option<u64>

pub fn security_info_snapshot(&self) -> Vec<CachedSecurityInfo>

pub fn security_info_snapshot_matching( &self, predicate: impl FnMut(&CachedSecurityInfo) -> bool, ) -> Vec<CachedSecurityInfo>

pub fn security_key_by_stock_id(&self, stock_id: u64) -> Option<String>

pub fn get_security_info_by_stock_id( &self, stock_id: u64, ) -> Option<CachedSecurityInfo>

通过 stock_id 查找股票信息 (使用 id_to_key 反向映射)

pub fn get_security_info_by_stock_id_trigger_refresh( &self, stock_id: u64, ) -> Option<CachedSecurityInfo>

pub fn add_warrant_owner(&self, warrant_stock_id: u64, owner_stock_id: u64)

添加窝轮→正股的映射关系

v1.4.106 codex 1148 F6: HashSet 自动去重, 重复 add 同 (warrant, owner) 是 idempotent — SQLite reload + stock-list sync 不会重复入。

pub fn search_warrants_by_owner(&self, owner_stock_id: u64) -> Vec<u64>

通过正股 ID 搜索该正股的所有窝轮

v1.4.106 codex 1148 F6: 内部 HashSet, 返 Vec (call site backward compatible)。返序非确定 (HashSet 不保留 insertion order); call site 若 需要稳定序应自己 sort。

v1.4.111 P2-1 Tier 3 audit comment: warrant lookup helper — empty Vec = “no warrants for this owner_stock_id” (legit “正股无窝轮”), 跟 C++ SearchWarrantsByOwner empty 行为对齐. caller decide 怎么用 (display 0 warrants 是合理). 非 silent-success risk (audit verified, essentials/ 2026-05-27).

Trait Implementations

impl Default for StaticDataCache

fn default() -> Self

Returns the “default value” for a type.