From 924fe9dfd503b3f91facb7e841088bf46d760c91 Mon Sep 17 00:00:00 2001
From: liuwei <liuwei@wdtrgf.com.cn>
Date: Tue, 10 Jun 2025 12:31:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=20=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E5=AE=9A=E6=97=B6=E6=8E=A8=E9=80=81=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 admin/dashboard/blueprints/message_push.py | 55 ++++++++++++----------
 1 file changed, 31 insertions(+), 24 deletions(-)

diff --git a/admin/dashboard/blueprints/message_push.py b/admin/dashboard/blueprints/message_push.py
index d4d628f..f1877ee 100644
--- a/admin/dashboard/blueprints/message_push.py
+++ b/admin/dashboard/blueprints/message_push.py
@@ -259,30 +259,37 @@ def api_preview_task(task_id):
         preview_user = session.get('username')
         if not preview_user:
             return jsonify({"success": False, "error": "未登录或会话已过期"}), 401
-
-        # 发送文本消息
-        if task.get('content_text'):
-            send_message_in_thread(server.client.send_text_message, preview_user, task['content_text'])
-
-        # 发送图片消息
-        if task.get('content_image'):
-            send_message_in_thread(server.client.send_image_message, preview_user, task['content_image'])
-
-        # 发送链接消息
-        if task.get('content_link'):
-            send_message_in_thread(server.client.send_link_message, preview_user, task['content_link'])
-
-        # # 发送小程序消息
-        # if task.get('content_miniprogram'):
-        #     miniprogram = task['content_miniprogram']
-        #     send_message_in_thread(
-        #         server.client.send_miniprogram_message,
-        #         preview_user,
-        #         miniprogram.get('title'),
-        #         miniprogram.get('appid'),
-        #         miniprogram.get('pagepath'),
-        #         miniprogram.get('thumb_url')
-        #     )
+            
+        # 获取预览接收者列表
+        preview_recipients = task.get("preview_recipients", [])
+        if not preview_recipients:
+            return jsonify({"success": False, "error": "未设置预览接收者"}), 400
+            
+        # 为每个接收者发送预览消息
+        for recipient in preview_recipients:
+            # 发送文本消息
+            if task.get('content_text'):
+                send_message_in_thread(server.client.send_text_message, recipient, task['content_text'])
+                
+            # 发送图片消息
+            if task.get('content_image'):
+                send_message_in_thread(server.client.send_image_message, recipient, task['content_image'])
+                
+            # 发送链接消息
+            if task.get('content_link'):
+                send_message_in_thread(server.client.send_link_message, recipient, task['content_link'])
+                
+            # # 发送小程序消息
+            # if task.get('content_miniprogram'):
+            #     miniprogram = task['content_miniprogram']
+            #     send_message_in_thread(
+            #         server.client.send_miniprogram_message,
+            #         recipient,
+            #         miniprogram.get('title'),
+            #         miniprogram.get('appid'),
+            #         miniprogram.get('pagepath'),
+            #         miniprogram.get('thumb_url')
+            #     )
 
         return jsonify({
             "success": True,