From 8adc469c71bf0af3882ca30a9effca6b678e0fd3 Mon Sep 17 00:00:00 2001
From: haotian <2421912570@qq.com>
Date: Wed, 22 Oct 2025 17:22:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=AF=B9=E6=9C=BA=E5=99=A8?=
 =?UTF-8?q?=E4=BA=BA=E6=B2=A1=E6=9C=89=E5=80=BC=E7=8F=AD=E5=AE=89=E6=8E=92?=
 =?UTF-8?q?=E6=97=B6=E7=9A=84=E9=BB=98=E8=AE=A4=E5=A4=84=E7=90=86,?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=85=B6=E5=9C=A8=E6=B2=A1=E6=9C=89=E5=80=BC?=
 =?UTF-8?q?=E7=8F=AD=E6=83=85=E5=86=B5=E4=B8=8B=E5=90=8C=E6=AD=A5=E6=9C=BA?=
 =?UTF-8?q?=E5=99=A8=E4=BA=BA=E4=BF=A1=E6=81=AF=E7=9A=84=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/services/robot_sync_service.py | 10 +++++++++-
 app/services/scheduler.py          |  7 ++++---
 run_sync.py                        |  4 ++--
 3 files changed, 15 insertions(+), 6 deletions(-)

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