自选正反自动同步

clean_watchlist.py 双向：
  买入→持仓→移出自选 ✅ （已完成）
  清仓→自动加回自选 ✅ （新增）
每日09:05 cron自动执行

scripts/clean_watchlist.py

@@ -54,4 +54,47 @@ if dec_changed:
 else:
     print(f"\ndecisions.json: 无需更新")
 
+# ── 反过程：清仓股自动加回自选 ──
+# 找出曾持仓但现已不在 portfolio 的股票
+prev_held = {}  # code → last_execution info
+for d in dec.get("decisions", []):
+    code = d.get("code", "")
+    exec_info = d.get("execution", {})
+    if exec_info and exec_info.get("status") in ("executing", "partial_exit"):
+        # 当前仍持仓但不在 portfolio？说明 portfolio 数据落后，跳过
+        pass
+    elif exec_info and exec_info.get("status") in ("sold", "closed") and code not in holding_codes:
+        prev_held[code] = {
+            "name": d.get("name", code),
+            "entry_low": d.get("entry_low", 0),
+            "entry_high": d.get("entry_high", 0),
+        }
+
+if prev_held:
+    wl_stock_codes = set(s.get("code", "") for s in new_stocks)
+    added = 0
+    for code, info in sorted(prev_held.items()):
+        if code not in wl_stock_codes and code not in holding_codes:
+            # 确保买入区有值
+            entry_low = info.get("entry_low", 0) or 0
+            entry_high = info.get("entry_high", 0) or 0
+            new_stocks.append({
+                "code": code,
+                "name": info["name"],
+                "entry_low": entry_low,
+                "entry_high": entry_high,
+                "stop_loss": 0,
+                "tag": "recovered_from_sold",
+            })
+            added += 1
+            print(f"  ← 已清仓→加回自选: {code} {info['name']}")
+    if added:
+        wl["stocks"] = new_stocks
+        json.dump(wl, open(WL, "w"), indent=2, ensure_ascii=False)
+        print(f"\n反过程: {added} 只清仓股已加回自选")
+    else:
+        print("\n反过程: 无清仓股需加回")
+else:
+    print("\n反过程: 无已清仓记录")
+
 print("\nDONE")