From 0e43a7d4885006c4190924ebe1f774ded16ba383 Mon Sep 17 00:00:00 2001 From: liuwei Date: Tue, 10 Jun 2025 16:18:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E5=8A=9F=E8=83=BD=E6=B5=8B?= =?UTF-8?q?=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/task_db.py | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/db/task_db.py b/db/task_db.py index 5396e91..6509fee 100644 --- a/db/task_db.py +++ b/db/task_db.py @@ -183,8 +183,17 @@ class TaskDBOperator(BaseDBOperator): Returns: 是否删除成功 """ - sql = "DELETE FROM t_push_tasks WHERE task_id = %s" - return self.execute_update(sql, (task_id,)) + try: + # 先删除任务相关的日志 + delete_logs_sql = "DELETE FROM t_push_task_logs WHERE task_id = %s" + self.execute_update(delete_logs_sql, (task_id,)) + + # 然后删除任务 + delete_task_sql = "DELETE FROM t_push_tasks WHERE task_id = %s" + return self.execute_update(delete_task_sql, (task_id,)) + except Exception as e: + logger.error(f"删除任务失败: {e}") + return False def get_scheduled_tasks(self) -> List[Dict]: """获取待执行的任务