From 8433d46ed7c95e1fb3f2aa90a210599c45e8037d Mon Sep 17 00:00:00 2001
From: xxm <xxm@mofin.local>
Date: Fri, 21 Aug 2026 20:36:57 +0800
Subject: [PATCH] =?UTF-8?q?feat(mofin=5Fdb):=20flush=5Frec=5Fdigest?=
 =?UTF-8?q?=E6=8E=A8=E8=8D=90=E8=BE=93=E5=87=BA=E6=8E=A5=E5=85=A5messenger?=
 =?UTF-8?q?(broadcast=E5=BD=92=E6=A1=A3+xmpp=E6=8E=A8=E9=80=81)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 deploy/profile-scripts/mofin_db.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/deploy/profile-scripts/mofin_db.py b/deploy/profile-scripts/mofin_db.py
index 6815133d..618bf4fa 100644
--- a/deploy/profile-scripts/mofin_db.py
+++ b/deploy/profile-scripts/mofin_db.py
@@ -1904,6 +1904,12 @@ def flush_rec_digest(max_items=5):
     try:
         import sys as _s, os as _o2
         _s.path.insert(0, '/home/hmo/MoFin/deploy/profile-scripts')
+        # 操作推荐：归档到 broadcast + 推 xmpp（统一消息处理者）
+        try:
+            from messenger import send_action_recommendation
+            send_action_recommendation(title="MoFin操作推荐", content="\n".join(lines), source="per_stock_reassess.py")
+        except Exception:
+            pass
         from alert_helper import notify, ACTION
         return notify("推荐操作", "\n".join(lines), ACTION)
     except Exception as e: