diff --git a/README.md b/README.md index 4bf8406..f6a4bf7 100644 --- a/README.md +++ b/README.md @@ -58,7 +58,7 @@ app/ industry.py 行业划分可插拔适配器 (gp_hybk / custom_table / 停用; 带实探不靠参数) ws/runner.py **常驻连接进程 (pms-ws)**: 握手/心跳/重连/补发 + 出口出栈 + 上行落库确认 web/ FastAPI + 单页 (Vue3 + ElementPlus),页面四块 + 运维/日报抽屉 - scheduler.py Celery beat 调度总表 (九个调度位 + 三条守卫) + scheduler.py Celery beat 调度总表 (十三个调度位 + 三条守卫) scripts/ run_tests.py 一次跑完全部单测 (见下方「Docker 部署」) test_core_units.py 仓位与安全垫核心逻辑 14 例 @@ -150,17 +150,23 @@ docker compose logs -f pms-ws ## 调度总表(`--profile sched` 生效,设计 §10) +共十三个调度位,按一天的时间顺序列出。任务名是 `pms.*`(`app/scheduler.py` 的 `beat_schedule`)。 + | 调度 | 时间 | 任务 | 本批状态 | |---|---|---|---| -| 拉上游计划 | 交易日 08:40 | `/plan` 拉当日选股计划 → 刷候选池缓存 + `theme` 灌 `pms_industry_map` | ✅ | -| 盘前准备 | 交易日 08:50 | T+1 可卖重置 / 参考位取数 / 刹车结算 | ✅ | -| 命令轮询 | 每 1 分钟(全天) | 新命令解析 → 方案生成 → 状态机推进 | ✅ | -| 成交回放 | 交易时段每 1 分钟 | ws 逐笔入账 + `trading_order` 增量回放 + 盘中轻对账 | ✅ | -| 盘中执行 | 交易时段每 1 分钟 | 方案转指令 → 自主提议扫描 → 择时出手(规则闸终检 → 下发 → 记子单) | ✅ | -| 信号消化 | 交易时段每 1 分钟 | 订阅 db2 盘中广播 + db3 风控卖出 → 卖出指令或提议 | ✅ | -| T 仓平回 | 14:50 | 做T强制平回 | 🔜 二期(现只自证 T 仓为 0) | -| 日终结算 | 15:10 | 除权检测 / 全量对账 / 安全垫 / 命令进度日结 | ✅ | -| 运营日报 | 15:30 | 关注区 + 全量统计(页面「日报」按钮可查) | ✅ | +| 拉技术面读数 | 交易日 06:30 | `pms.tech_pull`:分页拉全市场技术面读数落表 → 重建技术面映射 | ✅ | +| 拉上游计划 | 交易日 08:40 | `pms.plan_pull`:`/plan` 拉当日选股计划 → 刷候选池缓存 + `theme` 灌 `pms_industry_map` + 补拉技术面重建映射 | ✅ | +| 盘前准备 | 交易日 08:50 | `pms.premarket`:T+1 可卖重置 / 参考位取数 / 刹车结算 | ✅ | +| 宏观扫描 | 交易日 09:35 | `pms.macro_scan`:股汇对冲指数算区制 → 写宏观偏热闸状态 | ✅ | +| 策略自动挂载 | 交易日 09:40 | `pms.strategy_attach`:个股打法状态机(吸筹挂网格 / 高热挂跟踪止盈 / 接力切换) | ✅ | +| 命令轮询 | 每 1 分钟(全天) | `pms.command_poll`:新命令解析 → 方案生成 → 状态机推进 | ✅ | +| 成交回放 | 交易时段每 1 分钟 | `pms.replay_fills`:ws 逐笔入账 + `trading_order` 增量回放 + 盘中轻对账 | ✅ | +| 盘中执行 | 交易时段每 1 分钟 | `pms.intraday_exec`:方案转指令 → 自主提议扫描(含三源合议分流与技术面转空离场)→ 择时出手(规则闸终检 → 下发 → 记子单) | ✅ | +| 信号消化 | 交易时段每 1 分钟 | `pms.signal_digest`:订阅 db2 盘中广播 + db3 风控卖出 → 卖出指令或提议 | ✅ | +| T 仓平回 | 14:50 | `pms.t0_close`:做T强制平回 | 🔜 二期(现只自证 T 仓为 0) | +| 日终结算 | 15:10 | `pms.daily_settle`:除权检测 / 全量对账 / 安全垫 / 命令进度日结 | ✅ | +| 净值快照 | 15:20 | `pms.nav_snapshot`:当日净值落 `pms_nav_daily`(公示导出用) | ✅ | +| 运营日报 | 15:30 | `pms.daily_report`:关注区 + 全量统计(页面「日报」按钮可查) | ✅ | 调度器三条守卫:交易日守卫、故障即守成(任务内异常吞掉记 ERROR,绝不因调度异常产生新指令)、全局暂停执行(休假模式下除对账与日报外全部跳过)。