liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增 消息定时推送功能

Browse Source
This commit is contained in:
liuwei
2025-06-10 11:42:36 +08:00
parent 66cb374493
commit 05c3a271e0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
admin/dashboard/blueprints/message_push.py
View File

@@ -1,4 +1,4 @@
from flask import Blueprint, render_template, jsonify, request, current_app from flask import Blueprint, render_template, jsonify, request, current_app, session
from .auth import login_required from .auth import login_required
from loguru import logger from loguru import logger
import json import json
@@ -56,7 +56,7 @@ def api_create_task():
# 生成任务ID # 生成任务ID
data['task_id'] = str(uuid.uuid4()) data['task_id'] = str(uuid.uuid4())
data['creator_id'] = request.user.get('id') data['creator_id'] = session.get('user_id') # 从session中获取用户ID
# 创建任务 # 创建任务
db = current_app.dashboard_server.task_db db = current_app.dashboard_server.task_db
@@ -187,7 +187,7 @@ def api_preview_task(task_id):
# 发送预览 # 发送预览
message_push = current_app.dashboard_server.message_push_task.message_push message_push = current_app.dashboard_server.message_push_task.message_push
if not message_push.send_preview(task, [request.user.get('id')]): if not message_push.send_preview(task, [session.get('user_id')]): # 从session中获取用户ID
return jsonify({"success": False, "error": "发送预览失败"}), 500 return jsonify({"success": False, "error": "发送预览失败"}), 500
return jsonify({ return jsonify({