docs: 更新协作文档 — 记录数据层重构完成状态

docs/TDX_RELAY_COLLAB.md

@@ -225,20 +225,39 @@ server.py 接收更新
 
 ## 六、当前实现状态
 
-### 已完成
+### 已完成（全部 ✅）
-- server.py `/api/update/realtime` 端点 ✅（v1.0）
+- server.py `/api/update/realtime` 端点 ✅
-- portfolio.json 写入 data_source 字段 ✅
+- 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 优先 ✅
 
-### 待实现（知微负责）
+### 2026-06-20 数据层重构（小小莫完成）
-1. relay_state.json 持久化 — 记录 relay 在线状态
-2. /api/relay/status GET 端点 — 中继状态查询
-3. price_monitor.py relay_active 检测 — 在线/离线判断
-4. price_monitor 回退逻辑 — relay 离线时用腾讯 API 兜底
 
-### 待实现（小小莫负责）
+**新增文件**：
-1. tdx-relay 心跳上报 — 定期推送到 /api/update/realtime
+- `mofin_db.py` — 统一 SQLite 访问层（13张表 + 18个查询函数 + 4个写入函数）
-2. 断线自动重连验证 — Windows 端长期稳定运行
+- `migrate_all.py` — 一次性 JSON→SQLite 迁移脚本
-3. 行情覆盖检查 — 确保 17 只港股全量推送
+- `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 文件不修改
 
 ---