diff --git a/main.py b/main.py index d8c576b..ca3b10a 100644 --- a/main.py +++ b/main.py @@ -90,7 +90,6 @@ async def add_account(account_data: AccountCreate, account_manager: Any = Depend - **app_name**: 应用名称 """ try: - # 这里应该调用实际的添加账号方法 result = await account_manager.add_account([account_data.model_dump()]) if result: return {"code": 200, "message": "新增账号成功", "data": result} @@ -111,10 +110,8 @@ async def update_account(account_data: AccountUpdate, account_manager: Any = Dep try: data = account_data.model_dump() set_param = {"status": data["status"]} - # params = {"account_id": data["account_id"], "app_name": data["app_name"]} params = (data["account_id"], data["app_name"]) where_conditions = "account_id = %s and app_name = %s " - # # 这里应该调用实际的添加账号方法 result = await account_manager.update_account_info(set_param=set_param, where_conditions=where_conditions, params=params) if result: return {"code": 200, "message": "删除账号状态修改成功", "data": result} @@ -158,8 +155,6 @@ async def device_reset(task_data: DeviceResetData, reset_manager: Any = Depends( """设备重置接口""" try: params = task_data.model_dump() - params['task_id'] = uuid.uuid4().hex - # 将任务记录到mysql result = await reset_manager.task_distribution(params) if result: return {"code": 200, "message": "", "data": result} diff --git a/task_management/all_task_management.py b/task_management/all_task_management.py index 88dfb59..b70cbb5 100644 --- a/task_management/all_task_management.py +++ b/task_management/all_task_management.py @@ -42,7 +42,7 @@ class AllTask: try: result = await self.deal_shopee_task(data) except Exception as e: - print(f"{data['task_id']} 获取商品数据失败,失败原因为:{e}") + print(f"{data['goods_id']}:{data['store_id']}获取商品数据失败,失败原因为:{e}") return result async def deal_receive_data(self, data: Dict[str, Any]):