From 1ff3c1f51d1a3aab483412bd9e0025e329c9651d Mon Sep 17 00:00:00 2001
From: liujianjiang <liujianjiang@chongdaads.com>
Date: Fri, 28 Nov 2025 18:35:59 +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 | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/task_management/all_task_management.py b/task_management/all_task_management.py
index 5311151..0a1560d 100644
--- a/task_management/all_task_management.py
+++ b/task_management/all_task_management.py
@@ -28,16 +28,12 @@ class AllTask:
         处理Shopee任务的异步方法
         修复了NoneType对象无法await的问题
         """
-        # 查询redis数据库，redis数据库存在该数据直接返回
-        # key = f"{param['shop_id']}:{param['item_id']}"
         key = f"{param['app_name'].lower()}:{param['region'].lower()}"
         result = self.redis_conn.read_data(key)
-        # 关键修复：确保result不是None再进行处理
         if result is not None:
             print(f"{key} 从Redis缓存中获取到数据")
             return result
         print(f"{key}:{param['shop_id']}:{param['item_id']} 在redis中获取数据失败，将任务提交到队列")
-        # 确保add_task_to_set是异步方法或正确处理
         self.redis_conn.add_task_to_set(task_data=param)
         update_parms = {"task_id": param["task_id"], "status": 3}
         await self.update_task_record(update_parms)
@@ -45,7 +41,6 @@ class AllTask:
         endtime = time.time() + 55
         counter = 0
         while time.time() < endtime:
-            # 使用asyncio.sleep而不是time.sleep
             await asyncio.sleep(5)
             counter += 1
             result = self.redis_conn.read_data(key)