实时获取

src/components/SealTest.vue

@@ -86,6 +86,7 @@ import StopTest from '@/assets/img/seal/stoptest.png'
 import {
   someAirSwitchJSON,
   airCompressor_setStateJSON,
+  airCompressorGetPressureDirectIntervalJSON,
   airCompressor_channelCtrlJSON,
   AirInletProportionalValve_setStateJSON,
   AirOutletProportionalValve_setStateJSON,
@@ -300,9 +301,9 @@ const newStartTest = async flag => {
 }
 
 const timer = ref(null)
+const timerData = ref(null)
 onBeforeUnmount(() => {
-  timer.value = null
-  timerStart.value = null
+  clearInterval(timerData.value)
   clearInterval(timer.value)
   clearInterval(timerStart.value)
 })
@@ -379,6 +380,9 @@ onMounted(() => {
   }, 1000)
   websocketStore.sendCommandMsg(airInletProportionalValve_getStateJSON)
   websocketStore.sendCommandMsg(AirOutletProportionalValve_getStateJSON)
+  timerData.value = setInterval(() => {
+    websocketStore.sendCommandMsg(airCompressorGetPressureDirectIntervalJSON)
+  }, 100)
 })
 </script>
 

src/mock/command.js

@@ -409,3 +409,8 @@ export const airCompressorGetPressureDirectJSON = {
   command: 'DeviceIOControlService.airCompressor_getPressureDirect',
   messageId: 'airCompressor_getPressureDirect',
 }
+
+export const airCompressorGetPressureDirectIntervalJSON = {
+  command: 'DeviceIOControlService.airCompressor_getPressureDirect',
+  messageId: 'airCompressor_getPressureDirect_interval',
+}

src/store/modules/websocket.js

@@ -108,7 +108,6 @@ export const useWebSocketStore = defineStore({
               operatorStore.updateStopReady(false)
             }
             sealStore.updateAllPressure(pressure)
-            sealStore.updateCurrentAirPressure(pressure[1])
             settingStore.updateSprinklerPumpGPM(sprinklerPumpGPM)
             settingStore.updateChargingPumpRPM(chargingPumpRPM)
             settingStore.updateSprinklerPumpRPM(sprinklerPumpRPM)
@@ -189,10 +188,20 @@ export const useWebSocketStore = defineStore({
             )
             if (getPressureCode == 0) {
               // 值初始化
-              console.log('pressureAck', pressureAck)
+              console.log('pressureAck[0]', pressureAck[0].toFixed(1))
               sealStore.updateOldAirPressure(pressureAck[0].toFixed(1) || 0)
             }
             break
+          case 'airCompressor_getPressureDirect_interval':
+            const { ackcode: getPressureInterCode, ack: pressureIntervalAck } =
+              JSON.parse(ev.data)
+            if (getPressureInterCode == 0) {
+              // 值初始化
+              sealStore.updateCurrentAirPressure(
+                pressureIntervalAck[0].toFixed(1) || 0,
+              )
+            }
+            break
           case 'chpasswd':
             const { ackcode: chpasswdCode } = JSON.parse(ev.data)
             if (chpasswdCode != 0) {