|
|
@@ -40,7 +40,7 @@ class MqttService {
|
|
|
this.cmdClient.on("connect", () => {
|
|
|
this.cmdConnected = true
|
|
|
console.log("CMD MQTT 连接成功")
|
|
|
- uni.$emit("mqtt-ready", mqttClient)
|
|
|
+ uni.$emit("mqtt-ready", this.cmdClient)
|
|
|
this.cmdClient.subscribe(`/mps/wx_${userId}/notice`, (err) => {
|
|
|
if (err) {
|
|
|
console.error("CMD 订阅失败", err)
|
|
|
@@ -73,7 +73,7 @@ class MqttService {
|
|
|
console.log("DATA MQTT 已连接，复用现有实例")
|
|
|
return this.dataClient
|
|
|
}
|
|
|
-
|
|
|
+ console.log("DATA MQTT 连接中...")
|
|
|
const params = {
|
|
|
clientId: "xcx_mqtt_data1_" + userId + "_" + Date.now(),
|
|
|
username: "lnradar",
|
|
|
@@ -91,7 +91,7 @@ class MqttService {
|
|
|
|
|
|
this.dataClient.on("connect", () => {
|
|
|
this.dataConnected = true
|
|
|
- uni.$emit("mqttData-ready", mqttClientData)
|
|
|
+ uni.$emit("mqttData-ready", this.dataClient)
|
|
|
console.log("DATA MQTT 连接成功")
|
|
|
})
|
|
|
|
