选股计划入池逻辑

config.py

@@ -61,9 +61,9 @@ def price_mysql() -> Conn:
 
 
 def pms_mysql() -> Conn:
-    """读持仓（trading_position）与决策系统结论（strategy_daily_results），入池用。
-    这两张表都在 153 代理后面——与热度是同一台，默认直接复用 HEAT_MYSQL_*，
-    只有代理路由不通时才需要单独配 PMS_MYSQL_*。"""
+    """读持仓（首选 PMS 账本 pms_position，下游 trading_position 兜底）与决策系统
+    结论（strategy_daily_results），入池用。这几张表都在 153 代理后面——与热度是
+    同一台，默认直接复用 HEAT_MYSQL_*，只有代理路由不通时才需要单独配 PMS_MYSQL_*。"""
     return Conn(_opt("PMS_MYSQL_HOST", _req("HEAT_MYSQL_HOST")),
                 int(_opt("PMS_MYSQL_PORT", os.environ.get("HEAT_MYSQL_PORT", "3306"))),
                 _opt("PMS_MYSQL_USER", _req("HEAT_MYSQL_USER")),

docs/选股计划入池_对接说明.md

@@ -22,7 +22,7 @@ Mongo 侧记账（回收站），分析侧的清理是自动的。
 
 | 规则 | 内容 |
 |---|---|
-| 入池 | 当日计划（强传导主榜前 `POOL_TOP`，与 PMS 候选同口径）∪ 当前持仓（`trading_position` 数量>0） |
+| 入池 | 当日计划（强传导主榜前 `POOL_TOP`，与 PMS 候选同口径）∪ 当前持仓（首选 PMS 账本 `pms_position`——新架构下下游 `trading_position` 已无写入方，账本才是有人维护的持仓事实；账本读不到才退回下游表兜底） |
 | 留池 | 旧成员既不在计划也无持仓、但形态未恶化的，留下继续接受每晚分析——榜单是按条数截断过的，掉榜不等于变坏 |
 | 出池 | 无持仓、不在计划、且形态已恶化 → 移入回收站 `stock_recycle_bin`。恶化判据用决策系统自己的结论：`strategy_daily_results` 最新定性为 SELL / AVOID / DROPPED |
 | 上限 | 池子超过 `POOL_MAX`（默认 60）时，从「留池观察」里清最久没上过榜的；这类清退不进回收站（它们没有恶化记录），出池后由决策系统的 DROPPED 机制收尾 |

pool.py

@@ -141,8 +141,25 @@ def build_recycle_docs(d: dict, group_id: str, group_name: str, org_id: str,
 # 取数（每一路的失败语义见模块头「安全边界」）
 # ============================================================================
 def _read_holdings() -> set:
-    """当前持仓（trading_position，数量>0）。列名在下游换过多次，按候选名单挑；
-    读不到就抛——持仓是出池判断的底线输入，读不到宁可整轮不动池子。"""
+    """当前持仓。首选 PMS 账本 pms_position（新架构下它才是有人维护的持仓事实源：
+    下游 trading_position 表已没有写入方，2026-07-30 实测账户有仓时该表也是空的）；
+    账本表读不到再退回 trading_position 兜底。两条路都读不到就抛——持仓是出池判断
+    的底线输入，读不到宁可整轮不动池子。"""
+    try:
+        rows = db.read_mysql(
+            "pms", "SELECT ts_code, total_qty, status FROM pms_position")
+        out = set()
+        for r in rows.itertuples():
+            try:
+                qty = float(r.total_qty)
+            except (TypeError, ValueError):
+                qty = 0.0
+            if qty > 0 and str(r.status or "").upper() != "CLOSED":
+                out.add(common.to_prefix(str(r.ts_code).strip().upper()))
+        return out
+    except Exception as e:  # noqa: BLE001 —— 账本表读不到才走下游表兜底
+        print(f"  （PMS 账本 pms_position 读取失败，退回 trading_position 兜底: {e!r}）")
+
     rows = db.read_mysql("pms", "SELECT * FROM trading_position")
     if rows.empty:
         return set()