1

python/mcu/DeviceControl.py

@@ -105,14 +105,14 @@ class DeviceControl(BaseClass, metaclass=SingletonType):
             100: self.print_mcu_error_data,  # 打印下位机的错误内容
         }
 
-    async def initDevice(self):
+    async def initDevice(self,is_force=False):
         if not self.is_running:
             self.sendSocketMessage(
                 code=1, msg="mcu设备未连接,请先连接设备", device_status=0
             )
             return False
         self.serial_ins.clearn_flush()
-        self.to_init_device_origin_point(device_name="mcu")
+        self.to_init_device_origin_point(device_name="mcu",is_force=is_force)
         print("MCU 开始循环~")
         while 1:
             await asyncio.sleep(0.01)
@@ -740,9 +740,9 @@ class DeviceControl(BaseClass, metaclass=SingletonType):
             self.sendSocketMessage(
                 msg="MCU连接成功", data=message_data, device_status=2
             )
-            time.sleep(2)
-            loop = asyncio.get_event_loop()
-            loop.create_task(self.initDevice(), name="init_mcu")
+            # time.sleep(2)
+            # loop = asyncio.get_event_loop()
+            # loop.create_task(self.initDevice(), name="init_mcu")
             # async def getBaseInfo():
             #     while True:
             #         await asyncio.sleep(1)

python/sockets/message_handler.py

@@ -45,7 +45,7 @@ async def handlerSend(
             # loop.close()
         case "init_mcu":
             device_ctrl = DeviceControl(websocket_manager=manager)
-            loop.create_task(device_ctrl.initDevice(), name="init_mcu")
+            loop.create_task(device_ctrl.initDevice(True), name="init_mcu")
         case "control_mcu":
             device_name = data.get("device_name")
             value = data.get("value")