新增 消息定时推送功能

db/task_db.py

@@ -103,6 +103,11 @@ class TaskDBOperator(BaseDBOperator):
                     %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s
                 )
             """
+            # 将字典和列表类型转换为JSON字符串
+            content_miniprogram = json.dumps(task_data.get('content_miniprogram', {}))
+            groups = json.dumps(task_data.get('groups', []))
+            preview_recipients = json.dumps(task_data.get('preview_recipients', []))
+
             params = (
                 task_data['task_id'],
                 task_data['name'],
@@ -113,12 +118,12 @@ class TaskDBOperator(BaseDBOperator):
                 task_data.get('content_text'),
                 task_data.get('content_image'),
                 task_data.get('content_link'),
-                task_data.get('content_miniprogram'),
-                task_data.get('groups'),
+                content_miniprogram,
+                groups,
                 task_data.get('priority', 'medium'),
                 task_data.get('status', 'draft'),
                 task_data['creator_id'],
-                task_data.get('preview_recipients')
+                preview_recipients
             )
 
             if self.execute_update(sql, params):