From cde87999f7fefda1213ce70da836bdeb0b33245c Mon Sep 17 00:00:00 2001
From: liujianjiang <liujianjiang@chongdaads.com>
Date: Thu, 27 Nov 2025 14:08:48 +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

---
 model/model.py                         | 2 ++
 task_management/all_task_management.py | 7 +++----
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/model/model.py b/model/model.py
index 074235e..4724962 100644
--- a/model/model.py
+++ b/model/model.py
@@ -35,3 +35,5 @@ class DataReceive(BaseModel):
 
 class DeviceResetData(BaseModel):
     device_id: str = Field(..., description="设备ID")
+    country: str = Field(..., description="国家")
+    app_name: str = Field(..., description="应用名称")
diff --git a/task_management/all_task_management.py b/task_management/all_task_management.py
index 656001b..0929f7f 100644
--- a/task_management/all_task_management.py
+++ b/task_management/all_task_management.py
@@ -23,7 +23,7 @@ class AllTask:
         # 任务结束后开始等待
         endtime = time.time() + 55
         while time.time() < endtime:
-            await time.sleep(1)
+            await time.sleep(5)
             result = self.redis_conn.read_data(key)
             if result:
                 return result
@@ -62,8 +62,7 @@ class AllTask:
             await self.db_pool.insert_many(table="crawler_task_record_info", data=param)
         except Exception as e:
             print("将任务记录到数据库失败，失败原因为：{}".format(e))
+        result = []
         if param["app_name"] == "Shopee":
             result = await self.deal_shopee_task(data)
-        if result:
-            return result
-        return None
+        return result