吉安感知网项目-前端
shuishen
2026-02-26 353ac4ed3a3e2a7f3526e3bceeea7b74a87bb834
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()
}