diff --git a/app/services/robot_sync_service.py b/app/services/robot_sync_service.py index 7fd64f0..dd854d4 100644 --- a/app/services/robot_sync_service.py +++ b/app/services/robot_sync_service.py @@ -71,7 +71,15 @@ class RobotSyncService: # 2. 获取分组信息 duty_list = self.kangda._get_robot_group(login_info["tenantInfoId"], login_info["token"]) if not duty_list: - raise Exception("获取分组信息失败") + # raise Exception("获取分组信息失败") + duty_list = [ + { + "quantity": 1, + "groupingId": "0dc1ad7fdb394246981b8576465240ce", + "name": "室外巡检", + "tenantInfoId": "4fff5d4bcc4b4239941ff077a0da8958" + } + ] # 3. 更新分组信息 for duty in duty_list: diff --git a/app/services/scheduler.py b/app/services/scheduler.py index 25f68ad..65f1f57 100644 --- a/app/services/scheduler.py +++ b/app/services/scheduler.py @@ -41,13 +41,14 @@ class Scheduler: async with async_session() as session: try: # 同步分组信息 - logger.info("开始同步机器人数据...") + now = datetime.now() + logger.info(f"{now} 开始同步机器人数据...") success = await robot_sync_service.sync_robot_data(session) if not success: - raise Exception("同步机器人数据失败") + raise Exception(f"{now} 同步机器人数据失败") # 同步机器人任务信息 - logger.info("开始同步机器人任务...") + logger.info(f"{now} 开始同步机器人任务...") await robot_sync_service.sync_robot_task(session) self.last_sync_time = current_time diff --git a/run_sync.py b/run_sync.py index 56ac348..29951d2 100644 --- a/run_sync.py +++ b/run_sync.py @@ -8,7 +8,7 @@ from app.services.event_sync_service import run_sync, run_sync_event if __name__ == "__main__": print("启动事件同步服务...") # 同步所有未同步事件 - # asyncio.run(run_sync()) + asyncio.run(run_sync()) # 同步单个事件 - asyncio.run(run_sync_event("435ee8779e0d4e1980b2ad40cb361c75")) \ No newline at end of file + # asyncio.run(run_sync_event("435ee8779e0d4e1980b2ad40cb361c75")) \ No newline at end of file