From 10e8d1d4e91467a4bb2a44d6093a3ca28ade1bf9 Mon Sep 17 00:00:00 2001 From: liujianjiang Date: Thu, 27 Nov 2025 11:39:28 +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 --- main.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/main.py b/main.py index 0b26fde..7f8a0e9 100644 --- a/main.py +++ b/main.py @@ -79,9 +79,9 @@ async def add_account(account_data: AccountCreate, account_manager: Any = Depend - **app_name**: 应用名称 """ try: - print(account_data.dict()) + print(account_data.model_dump()) # 这里应该调用实际的添加账号方法 - result = await account_manager.add_account([account_data.dict()]) + result = await account_manager.add_account([account_data.model_dump()]) if result: return {"code": 200, "message": "新增账号成功", "data": result} raise HTTPException(status_code=404, detail="新增账号失败") @@ -99,7 +99,7 @@ async def update_account(account_data: AccountUpdate, account_manager: Any = Dep - **app_name**: 应用名称 """ try: - data = account_data.dict() + 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"]) @@ -118,7 +118,7 @@ async def update_account(account_data: AccountUpdate, account_manager: Any = Dep async def receive_data(task_data: DataReceive, task_manager: Any = Depends(get_task_manager)): """数据接收接口""" try: - params = task_data.dict() + params = task_data.model_dump() print(params) result = await task_manager.deal_receive_data(params) if result: @@ -133,7 +133,7 @@ async def receive_data(task_data: DataReceive, task_manager: Any = Depends(get_t async def crawler_task(task_data: CrawlerTask, task_manager: Any = Depends(get_task_manager)): """爬虫任务接口""" try: - params = task_data.dict() + params = task_data.model_dump() params['task_id'] = uuid.uuid4().hex result = await task_manager.task_distribution(params) if result: @@ -148,7 +148,7 @@ async def crawler_task(task_data: CrawlerTask, task_manager: Any = Depends(get_t # async def device_reset(task_data: CrawlerTask, reset_manager: Any = Depends(get_reset_manager)): # """设备重置接口""" # try: -# params = task_data.dict() +# params = task_data.model_dump() # params['task_id'] = uuid.uuid4().hex # # 将任务记录到mysql # # result = await task_manager.task_distribution(params)