diff --git a/deploy/profile-scripts/fund_flow_alert.py b/deploy/profile-scripts/fund_flow_alert.py index af7696c5..08a1ed6b 100644 --- a/deploy/profile-scripts/fund_flow_alert.py +++ b/deploy/profile-scripts/fund_flow_alert.py @@ -72,12 +72,13 @@ def _is_watchlist(code): def _send_xmpp(text): - """XMPP 推送——2026-08-19 P1 统一网关:走 alert_helper(内容型 ACTION 级,30行容量+5min去重)""" + """消息出口——2026-08-24 老莫新规则:资金流异动属"无操作建议"信息,只进 broadcast + 归档不推 XMPP;若重评产出操作级结论,由 reconcile→tag→推荐通道自行推送,不重复。""" try: - from alert_helper import notify, ACTION - notify("资金流异动", text, level=ACTION) + from messenger import send as _msend + _msend(title="资金流异动", content=text, source="fund_flow_alert.py", channel="broadcast") except Exception as e: - print(f"[XMPP失败] {e}", file=sys.stderr) + print(f"[broadcast失败] {e}", file=sys.stderr) def process_flow_alerts(all_flows):