feat(sector-capital-radar): 实现板块资金雷达模块，包括技术设计、执行计划和数据采集规范，支持独立指标计算与版本化发布

2026-08-29 16:31:27 +08:00
parent ad9545ef55
commit 5e4fe7220b
9 changed files with 376 additions and 0 deletions
@@ -0,0 +1,32 @@
+# 板块资金雷达实现依据
+
+## 已选择的产品边界
+
+用户选择 Tushare 独立生产 MVP，并确认具备 Tushare 权限。生产运行时不依赖 OneChartLab；公开 payload 只用于验证公开契约、构造固定样本和对账。未公开公式必须使用知行系统自己的策略名称与版本。
+
+## 仓库复用点
+
+- 后端采用 `modules/<bounded_context>/{domain,application,infrastructure,presentation}`，依据 `docs/adr/0001-bounded-context-first-modular-monolith.md` 和 `.trellis/spec/backend/directory-structure.md`。雷达应创建独立 bounded context。
+- `market_data.infrastructure.tushare.RequestCoordinator` 已实现供应商请求冷却、退避和有限重试；`TushareAdapter` 已使用注入的 `pro_api(token)` client。相关实现位于 `zhixing-server/src/zhixing_server/modules/market_data/infrastructure/tushare.py:40-126,235-377`。
+- `SyncMarketData` 已实现 advisory lock、批次审计、部分成功和定向重试，位于 `zhixing-server/src/zhixing_server/modules/market_data/application/sync.py:150-165,255-261,408-532`。
+- PostgreSQL 适配器已有连接池、事务、staging + COPY 和幂等 upsert 模式，位于 `zhixing-server/src/zhixing_server/modules/market_data/infrastructure/postgres.py:26-57,296-401,769-925`。
+- FastAPI 业务路由由 `zhixing-server/src/zhixing_server/interfaces/http/router.py:10-18` 统一挂载；浏览器固定使用同源 `/api/v1`。
+- 前端垂直切片、路由和页面状态模式分别见 `zhixing-web/src/routes/route-tree.tsx:17-70`、`zhixing-web/src/features/home/api/`、`zhixing-web/src/features/home/pages/home-page.tsx`。当前没有图表依赖，因此首个 MVP 不加入轨迹图。
+- `.codegraph/` 不存在，跨文件影响分析只能使用源码、测试和 `rg`。
+
+## 当前 Tushare 客户端核验
+
+项目声明 `tushare>=1.4.24`，见 `zhixing-server/pyproject.toml:7-16`。2026-08-28 通过 Context7 解析 `/waditu/tushare` 与 `/websites/tushare_pro`，确认：
+
+- `ts.pro_api(token)` 创建 `DataApi`；客户端 `query(api_name, fields, **kwargs)` 把接口名、token、参数和字段列表发送到服务端。
+- 客户端本身不执行积分、权限、频率或行数限制；这些限制由 Tushare 服务端返回。因此采集 Job 必须记录安全错误类别、响应行数和覆盖率，并在返回数接近单次上限时分片重拉。
+- 不采用 `set_token()` 的用户目录持久化方式；项目继续通过 `Settings` 注入 token，避免凭据落盘或进入任务文档。
+
+Context7 对具体板块接口的字段覆盖有限，接口字段、单位、历史边界和 2026-08-28 权限快照继续以 `docs/research/onechartlab-tushare-data-requirements.md` 所列 Tushare 第一方页面为实现依据。上线前由目标账号执行能力探测，不能把文档积分视为账号实测结果。
+
+## 独立指标契约
+
+- `zhixing_amount_net_bn_v1`：对当日有效成员的 `moneyflow_dc.net_amount` 求和，由万元除以 10,000 转为亿元；它是待公开样本对账的独立聚合，不宣称原站等价。
+- `zhixing_ratio_turnover_v1`：先统一为元，再计算板块 `sum(net_amount) / sum(daily.amount)`；分母为零或输入缺失时返回 NULL。
+- `zhixing_swing_equal_3_10_v1`：对窗口 3—10 个交易日分别计算 `sum(net_amount) / sum(turnover)`，再对八个完整窗口等权平均。任何窗口不完整时该指标不可用。该公式是透明、可替换的知行独立实现，不是 OneChartLab 的 3—10 日权重或 `Swing_Score`。
+- 横截面排名按指标值降序、板块代码升序稳定打破并列；概念与行业独立成池。`RankPct`、TOP/BOTTOM 阈值和 `PastRank - CurrentRank` 复用公开确认算法。
@@ -0,0 +1,35 @@
+# Tushare 板块雷达最小契约
+
+本文件从 `docs/research/onechartlab-tushare-data-requirements.md` 提炼首个 Radar MVP 实际需要的接口，避免实现上下文被宏观择时和后续增强接口稀释。上线前仍以目标账号的只读 capability probe 为准。
+
+## 最小接口
+
+| 接口 | 作用 | 调用与必要字段 | 业务键与边界 |
+| --- | --- | --- | --- |
+| `trade_cal` | 确认开市日和窗口 | `exchange,start_date,end_date`；`exchange,cal_date,is_open,pretrade_date` | `(exchange,cal_date)`；初始化后按年刷新 |
+| `dc_index` | 当日概念/行业 universe | `trade_date,idx_type`；`ts_code,trade_date,name,idx_type,level,pct_change,leading_code` | `(trade_date,ts_code)`；概念与行业分别拉取，单次上限公开页为 5,000 |
+| `dc_member` | 当日 point-in-time 成员 | 优先 `trade_date`，必要时按 `ts_code` 分片；`trade_date,ts_code,con_code,name` | `(trade_date,ts_code,con_code)`；单次上限 5,000，命中上限或覆盖不足必须分片，不得用当前成员补历史 |
+| `stock_basic` | 生命周期与市场过滤 | 分别拉 `list_status=L,D,P,G,UN`；`ts_code,symbol,name,market,exchange,list_status,list_date,delist_date` | `ts_code + observed_at`；默认只返回 L，不能漏掉其他状态 |
+| `suspend_d` | 区分停牌与缺数 | `trade_date`；`ts_code,trade_date,suspend_timing,suspend_type` | `(ts_code,trade_date,suspend_type,suspend_timing)`；官方称不定期修订，需重叠回拉 |
+| `daily` | 成交额、涨跌幅和行情可用性 | `trade_date`；`ts_code,trade_date,close,pre_close,pct_chg,vol,amount` | `(ts_code,trade_date)`；单次上限 6,000，停牌期间不返回；`amount` 单位千元 |
+| `moneyflow_dc` | 个股东财口径主力净额 | `trade_date`；`trade_date,ts_code,name,net_amount,net_amount_rate,pct_change,close` | `(ts_code,trade_date)`；单次上限 6,000，历史始于 2023-09-11；`net_amount` 单位万元 |
+
+## 单位与规范化
+
+- `moneyflow_dc.net_amount` 万元转元时乘 `10_000`，转亿元时除 `10_000`。
+- `daily.amount` 千元转元时乘 `1_000`，转亿元时除 `100_000`。
+- `daily.pct_chg=1.5` 表示 1.5%；不与 OneChartLab 小数比例字段直接混算。
+- 空字符串、`None` 和 `NaN` 规范为 NULL；`inf`、`-inf`、重复业务键和错误交易日属于硬错误。
+- 缺失资金流不是 0。只有生命周期有效、非停牌且源接口应有记录的股票进入缺失率分母。
+
+## Universe 与质量
+
+- 只纳入沪深 A 股，排除北交所与沪深 B 股；OneChartLab Radar 契约未声明排除 ST，因此不能复用现有选股股票池的 ST 过滤。
+- `dc_member` 某日缺失时标记 `membership_unknown`，不能向前或向后填充。
+- 全局分别计算成员、`daily` 和 `moneyflow_dc` 覆盖率；publication 只有在全部必需接口通过、成员完整且事实覆盖率达到配置门槛时才为 success。
+- 板块结果输出成员数、有效样本数、成交额、成员覆盖率与资金覆盖率；有效样本少于 5 时标记 `available_limited_sample`。
+- 初始回填必须按交易日顺序完成至少 10 日，才能生成完整 3—10 日独立波段指标；`moneyflow_dc` 的最早日期是硬边界。
+
+## 客户端与安全
+
+项目使用 `ts.pro_api(token)` 返回的 `DataApi`，动态调用最终进入 `query(api_name, fields, **params)`。客户端不执行权限、积分、频率或行数保护，采集 adapter 必须处理服务端错误、退避、返回行数和覆盖率。token 只从 `Settings` 注入，不调用 `set_token()` 写用户目录，不写入日志、原始请求清单或错误摘要。