From b18e0d21648b4bee6e97ab14c3d9b2eb42a552a5 Mon Sep 17 00:00:00 2001 From: hmo Date: Wed, 22 Jul 2026 10:39:20 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=85=B3=E5=81=9C=E8=BF=9B=E5=8C=BA?= =?UTF-8?q?=E6=91=98=E8=A6=81=E6=8E=A8=E9=80=81=EF=BC=88=E5=99=AA=E9=9F=B3?= =?UTF-8?q?=EF=BC=89+=20per=5Fstock=E7=BB=93=E6=9D=9F=E4=B9=9Fflush?= =?UTF-8?q?=E6=8E=A8=E8=8D=90=E6=91=98=E8=A6=81=EF=BC=88688428=E5=BC=8F?= =?UTF-8?q?=E6=BC=8F=E5=8F=91=E6=A0=B9=E6=B2=BB=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- deploy/profile-scripts/per_stock_reassess.py | 7 +++++++ deploy/profile-scripts/price_monitor.py | 7 +++---- 2 files changed, 10 insertions(+), 4 deletions(-) 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 = []