From e81c342acd1104e4de0c07c62ebb036628d4b016 Mon Sep 17 00:00:00 2001
From: wangxk <wangxk@sina.com>
Date: Mon, 16 Jun 2025 09:08:50 +0800
Subject: [PATCH] =?UTF-8?q?=E6=99=BA=E8=83=BD=E6=8E=A7=E5=88=B6=E9=A1=B5?=
 =?UTF-8?q?=E9=9D=A2=E6=B7=BB=E5=8A=A0WebSocket?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../intelligentcontrol/index.vue              | 40 +++++++++++++++++--
 riis-web/src/views/task/makeTask/index.vue    |  9 ++++-
 2 files changed, 43 insertions(+), 6 deletions(-)

diff --git a/riis-web/src/views/collectmonitor/intelligentcontrol/index.vue b/riis-web/src/views/collectmonitor/intelligentcontrol/index.vue
index 5265d81..57960fa 100644
--- a/riis-web/src/views/collectmonitor/intelligentcontrol/index.vue
+++ b/riis-web/src/views/collectmonitor/intelligentcontrol/index.vue
@@ -5,7 +5,7 @@ export default {
 </script>
 
 <script setup lang="ts">
-import { ref, onMounted, nextTick } from "vue";
+import { ref, onMounted, nextTick, onBeforeUnmount } from "vue";
 import { getTreeList } from "@/api/linksignal";
 import { countDeviceTypeStatus, queryYxData, sendCommand } from "@/api/intelligentcontrol";
 import { getDeviceByType } from '@/api/device'
@@ -133,12 +133,13 @@ function openchange(row: any) {
             let params = {
                 systemcode: row.systemcode,
                 signalId: row.signalId,
-                deviceType:row.deviceType,
-                type:'yk',
+                deviceType: row.deviceType,
+                type: 'yk',
                 value: row.yxValue,
             }
             sendCommand(params).then((res: any) => {
-                getdataone()
+                setupWebSocket(row.signalId)
+                // getdataone()
             })
         })
         .catch(() => {
@@ -190,7 +191,38 @@ function getDeviceImage1(deviceType: any, yxValue: any, status: any) {
         return ''; // 或者返回一个默认图片路径
     }
 }
+let indexarr: any = ref([])
+// = new WebSocket(userStore.wsApiBaseUrl + ''+'');
+function setupWebSocket(id: any) {
+    if (indexarr.value.length > 4) {
+        ElMessage.warning('当前设备打开过多，请稍后再试！')
+        return
+    }
+    let ws2 = new WebSocket(userStore.wsApiBaseUrl + '/websocket/auxcontrol_' + id);
+    indexarr.value.push(ws2)
+    ws2.onopen = () => {
+        console.log('WebSocket连接已打开');
+    };
+    ws2.onerror = (error: any) => {
+    };
+    ws2.onmessage = (e: any) => {
+        getdataone()
+        ws2.close()
+        indexarr.value = indexarr.value.filter((item: any) => item !== ws2);
+    }
+    ws2.onclose = () => {
+        console.log('WebSocket连接已关闭');
+    };
 
+}
+onBeforeUnmount(() => {
+    if (indexarr.value.length > 0) {
+        indexarr.value.forEach((item: any) => {
+            item.close()
+        });
+        indexarr.value.length = 0
+    }
+})
 onMounted(() => {
     getSelect();
     getType()
diff --git a/riis-web/src/views/task/makeTask/index.vue b/riis-web/src/views/task/makeTask/index.vue
index cfbce03..9c01c8b 100644
--- a/riis-web/src/views/task/makeTask/index.vue
+++ b/riis-web/src/views/task/makeTask/index.vue
@@ -96,11 +96,16 @@ const tableDataList: any = ref([])
 const tableTempDataList: any = ref([])
 // 搜索_时间赋值
 function dataChange() {
-  if (tableData.value.length == 2) {
+  if (tableData.value&&tableData.value.length == 2) {
     SearchBox.value.startDate = tableData.value[0]
     SearchBox.value.endDate = tableData.value[1]
+  }else{
+    SearchBox.value.startDate = ''
+    SearchBox.value.endDate = ''
   }
-}
+  getData()
+  }
+
 const treeloading = ref(false)
 //获取机器人-无人机
 const robotUAV: any = ref([])