增加对机器人没有值班安排时的默认处理,修改其在没有值班情况下同步机器人信息的错误

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:

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

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"))
+    # asyncio.run(run_sync_event("435ee8779e0d4e1980b2ad40cb361c75"))