针对切换时异常

src/views/dashboard/overview/hooks/useWS.ts

@@ -12,7 +12,7 @@ import {
   upfFlowParse,
   upfTotalFlowReset,
 } from './useUPFTotalFlow';
-import { topologyReset, neStateParse } from './useTopology';
+import { topologyReset, neStateParse, neStateRequestMap } from './useTopology';
 import PQueue from 'p-queue';
 
 /**UPF-的Id */
@@ -35,7 +35,6 @@ export default function useWS() {
   function wsError(ev: any) {
     // 接收数据后回调
     console.error(ev);
-    
   }
 
   /**接收数据后回调 */
@@ -198,7 +197,14 @@ export default function useWS() {
   /**重新发送至UPF 12_rmUid */
   function reSendUPF(rmUid: string) {
     upfWhoRmUid.value = rmUid;
-    ws.close();
+    //初始时时无需还原全部属性以及关闭
+    if (ws.state() === WebSocket.OPEN) {
+      ws.close();
+      userActivityReset();
+      upfTotalFlowReset();
+      neStateRequestMap.value = new Map();
+      //topologyReset();
+    }
     const options: OptionsType = {
       url: '/ws',
       params: {
@@ -214,37 +220,15 @@ export default function useWS() {
       onmessage: wsMessage,
       onerror: wsError,
     };
-    setTimeout(() => {
-      // 在这里进行重新连接WebSocket的操作
-      ws.connect(options);
-    }, 1000); //延迟1秒
-  }
-
-  onMounted(() => {
-    const options: OptionsType = {
-      url: '/ws',
-      params: {
-        /**订阅通道组
-         *
-         * 指标UPF (GroupID:12)
-         * AMF_UE会话事件(GroupID:1010)
-         * MME_UE会话事件(GroupID:1011)
-         * IMS_CDR会话事件(GroupID:1005)
-         */
-        subGroupID: '12_' + upfWhoRmUid.value + ',1010,1011,1005',
-      },
-      onmessage: wsMessage,
-      onerror: wsError,
-    };
     ws.connect(options);
-  });
+  }
 
   onBeforeUnmount(() => {
     ws.close();
     userActivityReset();
     upfTotalFlowReset();
     topologyReset();
-    upfWhoRmUid.value='';
+    upfWhoRmUid.value = '';
   });
 
   return {