diff --git a/deploy/profile-scripts/per_stock_reassess.py b/deploy/profile-scripts/per_stock_reassess.py index 49e0a123..d842f92f 100644 --- a/deploy/profile-scripts/per_stock_reassess.py +++ b/deploy/profile-scripts/per_stock_reassess.py @@ -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() diff --git a/deploy/profile-scripts/price_monitor.py b/deploy/profile-scripts/price_monitor.py index 0ca7ed6e..9d3ea89c 100644 --- a/deploy/profile-scripts/price_monitor.py +++ b/deploy/profile-scripts/price_monitor.py @@ -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 = []