1. 修复导入错误；2. 为mqtt客户端命名

LAS.py

@@ -14,7 +14,7 @@ from common.sys_comm import (
     get_utc_time_ms
 )
 
-from mqtt import mqtt_process as mp
+import mqtt.mqtt_process as mp
 from mqtt.mqtt_process import (
     MQTTClientThread, RobustMQTTClient, MQTTConsumerThread, g_mqtt_client, g_mqtt_consumer
 )

mqtt/mqtt_process.py

@@ -209,7 +209,8 @@ class MQTTClientThread(threading.Thread):
 class RobustMQTTClient(threading.Thread):
     def __init__(self, max_workers=4):
         super().__init__(name="RobustMQTTClient")
-        self.client: mqtt.Client = mqtt.Client()
+        client_id: str = "LAS_" + str(sys_comm.g_sys_conf["sp_id"])
+        self.client: mqtt.Client = mqtt.Client(client_id= client_id)
         self.client.username_pw_set(MQTT_USERNAME, MQTT_PASSWD)
         self.client.on_connect = self.on_connect
         self.client.on_disconnect = self.on_disconnect