From 4d46c3cdac7d57d8998a1ea34dace0a1b1ddaad7 Mon Sep 17 00:00:00 2001
From: szdot <szdot@qq.com>
Date: Sat, 20 Jul 2024 18:42:47 +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=9Afeat=20=E5=90=91=E9=A3=9E=E6=9C=BA=E8=AF=B7=E6=B1=82?=
 =?UTF-8?q?=E8=BF=94=E5=9B=9E=20=E7=94=B5=E6=B1=A0=E5=AE=B9=E9=87=8F=20?=
 =?UTF-8?q?=E3=80=90=E5=8E=9F=20=20=E5=9B=A0=E3=80=91=EF=BC=9A=20=E3=80=90?=
 =?UTF-8?q?=E8=BF=87=20=20=E7=A8=8B=E3=80=91=EF=BC=9A=E7=9B=91=E6=B5=8B?=
 =?UTF-8?q?=E9=A3=9E=E6=9C=BA=E7=8A=B6=E6=80=81=20=E7=94=B5=E6=B1=A0?=
 =?UTF-8?q?=E5=AE=B9=E9=87=8Fnull=20=E6=97=B6=20=E5=90=91=E9=A3=9E?=
 =?UTF-8?q?=E6=9C=BA=E8=AF=B7=E6=B1=82=20=E8=BF=94=E5=9B=9E=E7=94=B5?=
 =?UTF-8?q?=E6=B1=A0=E5=AE=B9=E9=87=8F=20=E3=80=90=E5=BD=B1=20=20=E5=93=8D?=
 =?UTF-8?q?=E3=80=91=EF=BC=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

# 类型 包含:
# feat：新功能（feature）
# fix：修补bug
# docs：文档（documentation）
# style： 格式（不影响代码运行的变动）
# refactor：重构（即不是新增功能，也不是修改bug的代码变动）
# test：增加测试
# chore：构建过程或辅助工具的变动
---
 .../layout/components/main/planes/index.vue   |  5 +++
 src/views/layout/index.vue                    | 44 ++++++++++++-------
 2 files changed, 33 insertions(+), 16 deletions(-)

diff --git a/src/views/layout/components/main/planes/index.vue b/src/views/layout/components/main/planes/index.vue
index 5c36e81..9606cff 100644
--- a/src/views/layout/components/main/planes/index.vue
+++ b/src/views/layout/components/main/planes/index.vue
@@ -10,6 +10,7 @@
 </template>
 
 <script>
+import mqtt from '@/utils/mqtt'
 import MapBox from '@/components/MapBox'
 import ControllerTabs from '@/components/ControllerTabs'
 import PlaneStatus from '@/components/PlaneStatus'
@@ -100,6 +101,10 @@ export default {
     plane: {
       handler (val) {
         this.makePlane(val)// 有飞机数据之后 在地图上创建飞机
+        if (val.planeState.battCapacity === null) {
+          console.log(val.planeState.battCapacity)
+          mqtt.publishFun(`cmd/${this.plane.macadd}`, '{"getBattCapacity":1}')// 发送设置飞机状态主题 请求飞控返回 电池总容量
+        }
       },
       deep: true
     },
diff --git a/src/views/layout/index.vue b/src/views/layout/index.vue
index 2ca82bb..92ad57a 100644
--- a/src/views/layout/index.vue
+++ b/src/views/layout/index.vue
@@ -81,24 +81,36 @@ export default {
       mqtt.doSubscribe('planeState/+', (mqttRes) => {
         res.forEach(plane => {
           if (mqttRes.topic.indexOf(plane.macadd) > -1) {
-            // 反序列化 mqtt信息
-            const jsonData = JSON.parse(mqttRes.msg.trim())
-            // 更新mqtt信息 选择性更新状态
-            for (const key in jsonData) {
-              if (key === 'heartBeat') { // 每次接收到心跳 heartRandom属性 创建一个随机数 用于watch监听
-                plane.planeState.heartRandom = Math.random()
-              }
-              if (key === 'position') { // 如果是飞机位置信息 则不是直接刷新状态 而是累计 到数组 以便于画出飞机路径
-                let position = jsonData.position
-                position = position.replace(/([a-zA-Z0-9]+):/g, '"$1":')// mcu过来的json格式修正一下 键没有引号 改成"lng":
-                position = JSON.parse(position)
-                plane.planeState.position.push([position.lng / 10e6, position.lat / 10e6, Number(position.alt)])
-                if (plane.planeState.position.length > 1000) {
-                  plane.planeState.position.shift()// 删除最早的经纬度
+            try {
+              // 反序列化 mqtt信息
+              const jsonData = JSON.parse(mqttRes.msg.trim())
+
+              // 更新mqtt信息 选择性更新状态
+              for (const key in jsonData) {
+                if (key === 'heartBeat') {
+                  // 每次接收到心跳 heartRandom属性 创建一个随机数 用于watch监听
+                  plane.planeState.heartRandom = Math.random()
+                } else if (key === 'position') {
+                  // 如果是飞机位置信息 则不是直接刷新状态 而是累计 到数组 以便于画出飞机路径
+                  const position = JSON.parse(jsonData.position)
+                  plane.planeState.position.push([position.lng / 10e6, position.lat / 10e6, Number(position.alt)])
+                  if (plane.planeState.position.length > 1000) {
+                    plane.planeState.position.shift() // 删除最早的经纬度
+                  }
+                } else if (key === 'parameter') {
+                  // 如果是 get飞控参数 判断设置对应值
+                  const parameter = JSON.parse(jsonData.parameter.trim())
+                  for (const k in parameter) {
+                    if (k === 'BATT_CAPACITY') {
+                      plane.planeState.battCapacity = parameter.BATT_CAPACITY
+                    }
+                  }
+                } else {
+                  plane.planeState[key] = jsonData[key] // 按订阅信息 刷新飞机状态
                 }
-              } else {
-                plane.planeState[key] = jsonData[key]// 按订阅信息 刷新飞机状态
               }
+            } catch (error) {
+              console.error('Error parsing JSON or processing message:', error)
             }
           }
         })