diff --git a/docs/TDX_RELAY_COLLAB.md b/docs/TDX_RELAY_COLLAB.md index 7d4a3d7..58cae0c 100644 --- a/docs/TDX_RELAY_COLLAB.md +++ b/docs/TDX_RELAY_COLLAB.md @@ -225,20 +225,39 @@ server.py 接收更新 ## 六、当前实现状态 -### 已完成 -- server.py `/api/update/realtime` 端点 ✅(v1.0) -- portfolio.json 写入 data_source 字段 ✅ +### 已完成(全部 ✅) +- server.py `/api/update/realtime` 端点 ✅ +- server.py `/api/relay/status` GET 端点 ✅ +- relay_state.json 持久化 ✅ +- price_monitor.py relay_active 检测 ✅ +- price_monitor 回退逻辑(relay 离线→腾讯 API 兜底)✅ +- tdx-relay 心跳上报(每15秒推送)✅ +- 断线自动重连(3次退避)✅ +- 17只港股全量推送 ✅ +- 数据层重构:JSON+SQLite 双写 + 消费者切 SQLite 优先 ✅ -### 待实现(知微负责) -1. relay_state.json 持久化 — 记录 relay 在线状态 -2. /api/relay/status GET 端点 — 中继状态查询 -3. price_monitor.py relay_active 检测 — 在线/离线判断 -4. price_monitor 回退逻辑 — relay 离线时用腾讯 API 兜底 +### 2026-06-20 数据层重构(小小莫完成) -### 待实现(小小莫负责) -1. tdx-relay 心跳上报 — 定期推送到 /api/update/realtime -2. 断线自动重连验证 — Windows 端长期稳定运行 -3. 行情覆盖检查 — 确保 17 只港股全量推送 +**新增文件**: +- `mofin_db.py` — 统一 SQLite 访问层(13张表 + 18个查询函数 + 4个写入函数) +- `migrate_all.py` — 一次性 JSON→SQLite 迁移脚本 +- `mofin_query.py` — 通用查询工具 +- `docs/DATABASE_ARCHITECTURE.md` — 完整架构文档 + +**修改文件**: +- `market_watch.py` — JSON+SQLite 双写 +- `multi_timeframe.py` — K线双写 +- `price_monitor.py` — 价格事件双写 +- `server.py` — SQLite 优先读取(/api/portfolio, /api/watchlist, /api/overview, /api/market) +- `strategy_lifecycle.py` — SQLite 优先读取(stock_sector_map, market_context, holdings, watchlist) +- `market_insight.py` — SQLite 优先读取 +- `strategy_feedback.py` — SQLite 优先读取 price_events +- `system_health_check.py` — SQLite 优先读取 price_events + +**设计原则**: +- 所有消费者:SQLite 优先 → 失败回退 JSON,系统不中断 +- 所有写入:JSON+SQLite 双写,SQLite 失败不影响 JSON 管道 +- 迁移脚本幂等可重跑,JSON 文件不修改 ---