From 871f4c478c14a4d8c38f7ff486a4d4350d6001c7 Mon Sep 17 00:00:00 2001 From: liuwei Date: Thu, 20 Mar 2025 15:45:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E8=A3=85=E9=A5=B0=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- game_task/game_task_encyclopedia.py | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/game_task/game_task_encyclopedia.py b/game_task/game_task_encyclopedia.py index 1a9a337..76ac0b8 100644 --- a/game_task/game_task_encyclopedia.py +++ b/game_task/game_task_encyclopedia.py @@ -5,6 +5,7 @@ from typing import Dict, List, Optional from game_task.game_chatgpt_qa import game_question_json, game_answer_json from db.connection import DBConnectionManager from db.encyclopedia import EncyclopediaDB +from job_decorators import scheduled_job # 获取数据库连接管理器的单例 db_manager = DBConnectionManager.get_instance() @@ -420,6 +421,14 @@ def setup_schedule(): run_random_task_assignment(group_id=gid) +@scheduled_job("*/1 * * * *", name="game_task_encyclopedia.py -test_job") +def send_message(self): + try: + print(f"定时任务执行！game_task_encyclopedia.py") + self.wcf.send_text("定时任务执行！game_task_encyclopedia.py", "filehelper") + except Exception as e: + print(f"send_message error：{e}") + # 主程序 if __name__ == "__main__": # 测试用例