接口调试

修改了mqtt客户端ID，防止冲突接收不到数据

jf_power_center.py

@@ -26,7 +26,7 @@ class jf_power_center():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_pump_1125m.py

@@ -25,7 +25,7 @@ class jf_pump_1125m():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_pump_18m.py

@@ -25,7 +25,7 @@ class jf_pump_18m():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_pump_18m_a.py

@@ -25,7 +25,7 @@ class jf_pump_18m():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_transport.py

@@ -26,7 +26,7 @@ class jf_transport():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_wind_center.py

@@ -26,7 +26,7 @@ class jf_wind_center():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_wind_north.py

@@ -26,7 +26,7 @@ class jf_wind_north():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(self.cf.ip)
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调