新增 消息定时推送功能

admin/dashboard/blueprints/message_push.py

@@ -260,36 +260,45 @@ def api_preview_task(task_id):
         if not preview_user:
             return jsonify({"success": False, "error": "未登录或会话已过期"}), 401
             
-        # 获取预览接收者列表
-        preview_recipients = task.get("preview_recipients", [])
+        # 获取预览接收者并解析JSON
+        preview_recipients_str = task.get("preview_recipients", "[]")
+        try:
+            preview_recipients = json.loads(preview_recipients_str)
+        except json.JSONDecodeError:
+            return jsonify({"success": False, "error": "预览接收者格式错误"}), 400
+            
         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')
-            #     )
+            try:
+                # 发送文本消息
+                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')
+                #     )
+            except Exception as e:
+                logger.error(f"发送预览消息到 {recipient} 失败: {e}")
+                continue
 
         return jsonify({
             "success": True,