From 99cc2c193a9ea3e262f4eaf036082d64a0abca86 Mon Sep 17 00:00:00 2001
From: tk <szdot@live.com>
Date: Wed, 14 Aug 2024 19:48:44 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E7=B1=BB=20=20=E5=9E=8B=E3=80=91?=
 =?UTF-8?q?=EF=BC=9Afix=20=E5=88=B7=E6=96=B0=E6=93=8D=E4=BD=9C=E6=97=B6=20?=
 =?UTF-8?q?=E8=A7=A6=E5=8F=91=E8=AE=A2=E5=A4=9A=E6=AC=A1=E8=AE=A2=E9=98=85?=
 =?UTF-8?q?=20=E3=80=90=E5=8E=9F=20=20=E5=9B=A0=E3=80=91=EF=BC=9Awatch?=
 =?UTF-8?q?=E6=97=B6=20=E9=A3=9E=E6=9C=BA=E5=88=97=E8=A1=A8=E6=AF=8F?=
 =?UTF-8?q?=E6=AC=A1=E9=83=BD=E9=87=8D=E6=96=B0=E8=BF=9E=20=E9=87=8D?=
 =?UTF-8?q?=E6=96=B0=E8=AE=A2=E9=98=85=20=E5=AF=BC=E8=87=B4=E8=AE=A2?=
 =?UTF-8?q?=E9=98=85=E5=A4=9A=E6=AC=A1=20=E3=80=90=E8=BF=87=20=20=E7=A8=8B?=
 =?UTF-8?q?=E3=80=91=EF=BC=9A=E6=96=AD=E5=BC=80=20=E9=87=8D=E8=BF=9Emqtt?=
 =?UTF-8?q?=20=E3=80=90=E5=BD=B1=20=20=E5=93=8D=E3=80=91=EF=BC=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/utils/mqtt/index.js    | 8 +-------
 src/views/layout/index.vue | 1 +
 2 files changed, 2 insertions(+), 7 deletions(-)

diff --git a/src/utils/mqtt/index.js b/src/utils/mqtt/index.js
index fbd1da7..59580fe 100644
--- a/src/utils/mqtt/index.js
+++ b/src/utils/mqtt/index.js
@@ -54,13 +54,7 @@ function doSubscribe (topic, callBack) {
     }
     store.state.app.mqttState = true // 标记mqtt链接成功 在线
     // 订阅一个主题
-    this.client.subscribe(topic, { qos: 2 }, err => {
-      if (!err) {
-        store.dispatch('fetchLog', { content: topic + '主题订阅成功' })
-      } else {
-        store.dispatch('fetchLog', { content: topic + '主题订阅失败' })
-      }
-    })
+    this.client.subscribe(topic, { qos: 2 })
   })
   // 获取订阅主题的消息
   this.client.on('message', (topic, message) => {
diff --git a/src/views/layout/index.vue b/src/views/layout/index.vue
index 53d4283..42dc851 100644
--- a/src/views/layout/index.vue
+++ b/src/views/layout/index.vue
@@ -76,6 +76,7 @@ export default {
      */
     airList (res) {
       /* mqtt */
+      mqtt.mqttDestroy()// 先断开mqtt
       mqtt.mqttConf()// 连接mqtt
       // 订阅飞机信息
       mqtt.doSubscribe('planeState/+', (mqttRes) => {