fix: stale_push_wlin去重+清理34只重复watchlist_stocks

2026-07-09 10:03:17 +08:00
parent ea750f2cb3
commit 96d9071b8f
1 changed files with 10 additions and 0 deletions
@@ -437,6 +437,16 @@ def main():
            pass

    # 重新过滤：重评后可能有策略变化（止盈/止损/信号变动）
+    # 去重：同一股票只推送一次（防止两个源重复）
+    seen_codes = set()
+    deduped = []
+    for item in all_candidates:
+        code = item[1]
+        if code not in seen_codes:
+            seen_codes.add(code)
+            deduped.append(item)
+    all_candidates = deduped
+
    # 重建 stocks 列表，用新数据判断（不再用旧 is_stale 标记，因为已全部重评）
    stocks = []
    for (name, code, price, buy_low, buy_high, cur, is_stale) in all_candidates: