取消worker ws重连

src/views/web/archive/index-worker.vue

@@ -500,10 +500,8 @@ const initWorker = () => {
           if (json.type === 'session') {
             sessionId = json.sessionId
             // 左侧
-            if (data.init) {
-              state.ws.getMain()
-              state.activeTab = '首页'
-            }
+            state.ws.getMain()
+            state.activeTab = '首页'
           } else {
             switch (json.type) {
               case 'list-fix': {
@@ -582,14 +580,10 @@ const initWorker = () => {
       case 'onclose': {
         state.ws.loading = ElLoading.service({
           lock: true,
-          text: '智搜服务重新连接中……',
+          text: '智搜服务已断开，请刷新页面……',
           background: ThemeStore.loadingBg,
         })
       } break
-      case 'onconnect': {
-        state.ws.loading.close()
-        state.ws.loading = null
-      } break
     }
   }
 }

src/worker/worker-websocket.js

@@ -22,7 +22,7 @@ self.onconnect = (event) => {
           port.sessionRes = ports[0].sessionRes
           port.postMessage(JSON.stringify({type: 'onmessage', init: true, data: port.sessionRes}))
         } else {
-          initWS(port, true, data)
+          initWS(port, data)
         }
       } break
       case 'send': {
@@ -32,11 +32,11 @@ self.onconnect = (event) => {
   }
 };
 
-const initWS = (port, init, data) => {
+const initWS = (port, data) => {
   port.sessionRes = ''
   port.ws = new WebSocket(`ws://${location.host}/ws-api/smart-ws?userId=${data.userId}`)
   port.ws.onopen = (e) => {
-    port.postMessage(JSON.stringify({type: init ? 'onopen' : 'onconnect'}))
+    port.postMessage(JSON.stringify({type: 'onopen'}))
   }
   port.ws.onmessage = (e) => {
     const json = JSON.parse(e.data)
@@ -44,19 +44,17 @@ const initWS = (port, init, data) => {
       port.sessionRes = e.data
     }
     ports.forEach((p) => {
-      p.postMessage(JSON.stringify({type: 'onmessage', init: init, data: e.data}))
+      p.postMessage(JSON.stringify({type: 'onmessage', data: e.data}))
     })
   }
   port.ws.onclose = () => {
     ports.forEach((p) => {
       p.postMessage(JSON.stringify({type: 'onclose'}))
     })
-    setTimeout(initWS(port, false, data), 5000);
   }
   port.ws.onerror = () => {
     ports.forEach((p) => {
       p.postMessage(JSON.stringify({type: 'onclose'}))
     })
-    setTimeout(initWS(port, false, data), 5000);
   }
 }