From 45edcdea6bcf634498eacebac8222777719aef9c Mon Sep 17 00:00:00 2001
From: liujianjiang <liujianjiang@chongdaads.com>
Date: Fri, 28 Nov 2025 17:29:21 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 task_management/all_task_management.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/task_management/all_task_management.py b/task_management/all_task_management.py
index ef1dd7c..f56f091 100644
--- a/task_management/all_task_management.py
+++ b/task_management/all_task_management.py
@@ -29,7 +29,7 @@ class AllTask:
         if result is not None:
             print(f"{key} 从Redis缓存中获取到数据")
             return result
-        print(f"{key} 在redis中获取数据失败，将任务提交到队列")
+        print(f"{key}:{param['shop_id']}:{param['item_id']} 在redis中获取数据失败，将任务提交到队列")
         # 确保add_task_to_set是异步方法或正确处理
         self.redis_conn.add_task_to_set(task_data=param)
         # 任务结束后开始等待
@@ -62,13 +62,15 @@ class AllTask:
             print(f"{params['task_id']} 数据存入mysql失败，失败原因为{e}")
 
     async def update_task_record(self, data: Dict[str, Any]):
+        print(f"开始修改任务：{data['task_id']} 状态")
         await self.db_pool.initialize()
         # 对任务状态进行修改
         try:
-            params = {"task_id": data["task_id"]}
+            params = (data["task_id"],)
             where_conditions = "task_id = %s"
             affected_rows = await self.db_pool.update(table='crawler_task_record_info', set_columns={"status": data["status"]},
                                                       where_conditions=where_conditions, params=params)
+
             if affected_rows:
                 print(f"task_id{data['task_id']} 任务完成，任务状态已修改成功")
                 return True