提交优化代码

src/App.vue

@@ -78,21 +78,6 @@ export default {
     },
     onShow() {
         console.log("onShow", "页面又进来了");
-        const userId = uni.getStorageSync("userId");
-        if (!userId) return console.error("MQTT 初始化失败：缺少 userId");
-        if (!MqttService.dataConnected) {
-            // 未连接，先 connect
-            MqttService.connectData(userId)
-                .then((client) => {
-                    // 页面订阅逻辑，等 connect 成功再执行
-                    const handler = () => {
-                        MqttService.resubscribeAll("DATA");
-                        uni.$off("mqttData-ready", handler);
-                    };
-                    uni.$on("mqttData-ready", handler);
-                })
-                .catch((err) => console.error("DATA MQTT 初始化失败", err));
-        }
     },
     onHide() {
         // MqttService.disconnectAll();

src/pagesA/deviceDetail/deviceDetail.vue

@@ -1071,6 +1071,21 @@ export default {
     onShow() {
         this.showModle = true;
         // MQTT 初始化
+        const userId = uni.getStorageSync("userId");
+        if (!userId) return console.error("MQTT 初始化失败：缺少 userId");
+        if (!MqttService.dataConnected) {
+            // 未连接，先 connect
+            MqttService.connectData(userId)
+                .then((client) => {
+                    // 页面订阅逻辑，等 connect 成功再执行
+                    const handler = () => {
+                        MqttService.resubscribeAll("DATA");
+                        uni.$off("mqttData-ready", handler);
+                    };
+                    uni.$on("mqttData-ready", handler);
+                })
+                .catch((err) => console.error("DATA MQTT 初始化失败", err));
+        }
     },
 
     onUnload() {

src/utils/globalMqtt.js

@@ -200,7 +200,7 @@ class MqttService {
 
     // ---------------- 手动恢复订阅 ----------------
     resubscribeAll(brokerName) {
-        const connection = this.connections.get(brokerName); ``
+        const connection = this.connections.get(brokerName);
         if (!connection || !connection.connected) return;
 
         connection.subscriptions.forEach((callbacks, topic) => {