From 353ac4ed3a3e2a7f3526e3bceeea7b74a87bb834 Mon Sep 17 00:00:00 2001
From: shuishen <1109946754@qq.com>
Date: Thu, 26 Feb 2026 16:12:22 +0800
Subject: [PATCH] feat:语音通话及工单样式调整

---
 uniapps/work-app/src/hooks/useGlobalWS.js |   57 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 54 insertions(+), 3 deletions(-)

diff --git a/uniapps/work-app/src/hooks/useGlobalWS.js b/uniapps/work-app/src/hooks/useGlobalWS.js
index 36086d1..052312a 100644
--- a/uniapps/work-app/src/hooks/useGlobalWS.js
+++ b/uniapps/work-app/src/hooks/useGlobalWS.js
@@ -10,6 +10,8 @@
   const callStatus = ref(null)
   // token 存储
   const accessToken = ref('')
+  // 断线恢复定时器
+  let recoverTimer = null
   // 存储铃声实例
   let ringtoneInstance = null
 
@@ -143,11 +145,61 @@
   // }
 
   // 初始化WebSocket连接
+  function isVoiceCallDetailActive() {
+    try {
+      const pages = getCurrentPages()
+      const currentPage = pages[pages.length - 1]
+      const route = currentPage?.route || currentPage?.$page?.fullPath || ''
+      return String(route).includes('subPackages/voiceCallDetail/index')
+    } catch (error) {
+      return false
+    }
+  }
+
+  function shouldRecoverWS() {
+    return !isVoiceCallDetailActive() && !!useUserStore()?.userInfo?.access_token
+  }
+
+  function ensureRecoverTimer() {
+    if (recoverTimer) {
+      return
+    }
+    recoverTimer = setInterval(() => {
+      if (websocketService.getConnected()) {
+        clearInterval(recoverTimer)
+        recoverTimer = null
+        return
+      }
+      if (shouldRecoverWS()) {
+        initWS()
+      }
+    }, 3000)
+  }
+
   function initWS() {
     const userStore = useUserStore()
     accessToken.value =userStore?.userInfo.access_token
+    if (!accessToken.value || isVoiceCallDetailActive()) {
+      return
+    }
     try {
       websocketService.setOnMessageCallback(messageHandler);
+      websocketService.setOnOpenCallback(() => {
+        if (recoverTimer) {
+          clearInterval(recoverTimer)
+          recoverTimer = null
+        }
+      })
+      websocketService.setOnCloseCallback(() => {
+        if (shouldRecoverWS()) {
+          ensureRecoverTimer()
+        }
+      })
+      websocketService.setOnErrorCallback(() => {
+        if (shouldRecoverWS()) {
+          ensureRecoverTimer()
+        }
+      })
 
       // 获取当前用户ID,优先使用store中的用户信息
       const userId = userStore.userInfo?.new_userInfo.userId || defaultUserId;
@@ -158,9 +210,6 @@
         // 使用用户ID初始化WebSocket连接
         websocketService.init(userId, WS_BASE, accessToken.value);
         // console.log('🌐 全局WebSocket初始化成功,用户ID:', userId);
-      } else {
-        websocketService.connect();
-
       }
     } catch (error) {
     }
@@ -176,6 +225,8 @@
     },
     { immediate: true, deep: true }
   )
+
+  ensureRecoverTimer()
 }
 
 

--
Gitblit v1.9.3