fix: 关停进区摘要推送(噪音)+ per_stock结束也flush推荐摘要(688428式漏发根治)

This commit is contained in:
hmo
2026-07-22 10:39:20 +08:00
parent c91d4c33f0
commit b18e0d2164
2 changed files with 10 additions and 4 deletions
@@ -646,6 +646,13 @@ def main():
print(f"[DONE] {ok}成功 {skipped}跳过 {errors}失败")
# ── 推荐摘要发货(per_stock 路径产生的推荐也要出队列)──
try:
from mofin_db import flush_rec_digest
flush_rec_digest()
except Exception as _fe:
print(f" ⚠️ 推荐摘要发送失败: {_fe}", flush=True)
# ── 第二步:扫描自选股(watchlist),价格偏离买入区>20%触发重评 ──
scan_watchlist_stocks()
+3 -4
View File
@@ -608,11 +608,10 @@ def run_once(round_label=""):
state[code][key] = False
state_updated = True
# === 第二步收尾:进区事件聚合成一条摘要推送(INFO级,30min限1条+截断===
# === 第二步收尾:进区事件只记日志不推送(2026-07-22 老爸:进区提示=噪音,关停===
# 正式推荐由 12维→tag→摘要队列 通道负责;破止损/卖出/止盈(持仓)仍走 ACTION 直推。
if _zone_entries:
_digest = f"📋 {len(_zone_entries)}进入操作区:\n" + "\n".join(f"{e}" for e in _zone_entries)
_push_digest("盘中触发", _digest)
outputs.append(f"📨 进区摘要({len(_zone_entries)}只)→已按INFO策略推送")
outputs.append(f"📋 进区事件{len(_zone_entries)}(仅记日志不推送): {'; '.join(_zone_entries[:5])}")
# === 第三步:买入区偏离检测 + 自动重评 ===
reassesed_codes = []