行情系统

子工程

coinex-contract-market 包含 contract-market-api、contract-market-core、contract-market-provider，除深度、Ticker 和 K 线，还包含指数价、标记价和相关周期数据处理。

深度与成交消费

CONTRACT_DEPTH_MSG → EntrustConsumerV1
    → 交易对 → 深度初始化或更新 → 深度缓存与盘口摘要

CONTRACT_TRADE_MSG → CompleteOrderConsumerV2
    → 交易对 → K 线、Ticker、成交记录缓存更新
    → 行情更新时间或价格消息相关处理

当前两类上可见有效的 RocketMQ 监听注解，生产主题、消费实例和数据时效仍需运行验证。

指数与标记价流程

provider/market3rd/service/IndexPriceService 定义 generateIndexAndMarkPriceData、generateFundRateBasisData、createIndexPriceKline、updateHoldAmounts；代码可见查询三方 symbol、使用行情缓存、保存价格数据及调用 IndexMarkPriceSendHelper。

外部价格及本地行情上下文
    → 指数 / 标记价计算相关逻辑
    → 价格与基差数据缓存
    → 对应消息 / 周期记录 / 消费方

没有逐项核对计算公式、权重和所有兜底规则，不将最新成交价、指数价、标记价视为同一种价格，也不把图当成已经验证的风险定价链路。

源码入口

路径相对于 coinex-contract-market：

• contract-market-provider/src/main/java/com/exch/contract/market/provider/mq/EntrustConsumerV1.java
• contract-market-provider/src/main/java/com/exch/contract/market/provider/mq/CompleteOrderConsumerV2.java
• contract-market-provider/src/main/java/com/exch/contract/market/provider/market3rd/service/IndexPriceService.java
• contract-market-provider/src/main/java/com/exch/contract/market/provider/mq/IndexMarkPriceSendHelper.java

验证场景

深度快照与增量错序、重复成交、指数来源中断、标记价延迟、价格极值及周期恢复。资金费率和强平使用何种价格需追踪各自消费方，不能仅凭行情字段存在就下结论。