| | |
| | | import { useUserStore } from "@/store/index.js"; |
| | | import { ref, computed, watch } from "vue"; |
| | | import useAppStore from "../store/modules/app/index.js"; |
| | | import websocketService from "@/utils/websocket.js"; |
| | | |
| | | import { getPhoneBookListApi } from '@/api/voiceCall/index.js' |
| | | // #ifdef APP-PLUS |
| | | import { openDialog, allowFloat, getBatteryCapacity, showIncomingCallNotification, cancelIncomingCallNotification } from '@/uni_modules/lgh-dialog' |
| | | // #endif |
| | | export function useGlobalWS() { |
| | | const userStore = useUserStore(); |
| | | const appStore = useAppStore(); |
| | | const callStatus = ref(null) |
| | | // token 存储 |
| | | const accessToken = ref('') |
| | | // 断线恢复定时器 |
| | | let recoverTimer = null |
| | | // 存储铃声实例 |
| | | let ringtoneInstance = null |
| | | |
| | | // 监听WebView消息事件 |
| | | if (typeof uni !== 'undefined' && uni.$on) { |
| | | uni.$on('webViewMessage', (data) => { |
| | | console.log('📨 useGlobalWS 收到 WebView 消息:', data) |
| | | // 处理挂断消息 |
| | | if (data?.type === 'hangupVoice') { |
| | | initWS() |
| | | } |
| | | }); |
| | | } |
| | | |
| | | // 设置默认用户ID为3 |
| | | const defaultUserId = '3'; |
| | | const defaultUserId = '2021474815063486465'; |
| | | // WebSocket基础URL |
| | | const WS_BASE = 'wss://wrj.shuixiongit.com/ws/chat?userId='; |
| | | // const WS_BASE = 'wss://wrj.shuixiongit.com/ws/chat?userId='; |
| | | // const WS_BASE = 'ws://218.202.104.82:38201/ws/chat'; |
| | | const WS_BASE = 'ws://220.177.172.27:8100/webrtc/ws/chat'; |
| | | |
| | | // 消息处理 |
| | | function messageHandler(payload) { |
| | | console.log('🌐 全局WebSocket收到消息111111111111111111111:', payload) |
| | | // 获取通讯录数据 |
| | | async function fetchContactList() { |
| | | try { |
| | | const params = { |
| | | current: 1, |
| | | size: 1000, // 一次性获取更多数据 |
| | | nickName: '' |
| | | }; |
| | | const res = await getPhoneBookListApi(params); |
| | | const response = res.data.data; |
| | | // 过滤掉与当前登录用户userId一致的联系人 |
| | | const filteredRecords = response.records.filter(contact => { |
| | | return contact.userId && String(contact.userId) !== String(userStore.userInfo.new_userInfo.userId); |
| | | }); |
| | | // 更新通讯录到全局状态管理 |
| | | appStore.updateContactList(filteredRecords); |
| | | return filteredRecords; |
| | | } catch (error) { |
| | | console.error('📞 获取通讯录失败:', error); |
| | | return []; |
| | | } |
| | | } |
| | | |
| | | // 消息处理 |
| | | async function messageHandler(payload) { |
| | | |
| | | // 先尝试直接处理消息(适用于mobile-web-view的voiceCallDetail页面的消息格式) |
| | | const t = (payload.type || '').toString() |
| | | const bizCode = payload.biz_code || '' |
| | | |
| | | console.log('📋 消息分析:type=' + t + ', biz_code=' + bizCode) |
| | | |
| | | callStatus.value = t |
| | | // 处理语音通话请求 |
| | | if (t === 'call') { |
| | | console.log('📞 全局收到来电 call,来自', payload.from) |
| | | // 如果通讯录为空,尝试获取一次 |
| | | if (appStore.contactList.length === 0) { |
| | | await fetchContactList(); |
| | | } |
| | | |
| | | // 从全局状态管理中获取联系人信息 |
| | | const contact = appStore.getContactByUserId(payload.from) |
| | | const callerName = contact?.nickName || '未知联系人' |
| | | // 触发震动 |
| | | // triggerVibration(); |
| | | // 构建来电参数 |
| | | const callParams = { |
| | | peerUid: payload.from, |
| | | from: payload.from, |
| | | type: 'incoming' |
| | | type: 'incoming', |
| | | callerName: callerName |
| | | }; |
| | | |
| | | // #ifdef APP-PLUS |
| | | // 发送来电通知(锁屏/后台都会弹出 + 亮屏) |
| | | showIncomingCallNotification(callerName || '未知来电') |
| | | // 拉起应用到前台 |
| | | openDialog() |
| | | // #endif |
| | | // 转义参数以便在URL中传递 |
| | | const encodedParams = encodeURIComponent(JSON.stringify(callParams)); |
| | | |
| | | // 跳转到mobile-web-view应用中的语音通话页面 |
| | | const voiceCallUrl = `http://localhost:9527/work-app/#/subPackages/voiceCallDetail/index?voiceparams=${encodedParams}`; |
| | | |
| | | console.log('🔗 准备导航到:', voiceCallUrl) |
| | | |
| | | try { |
| | | // 优先使用uni-app的导航API(适用于uni-app环境) |
| | | // 优先使用uni-app的导航API(适用于同应用内跳转) |
| | | if (typeof uni !== 'undefined' && uni.navigateTo) { |
| | | console.log('使用uni-app导航API跳转到语音通话页面'); |
| | | |
| | | // 检查是否是跳转到应用内页面 |
| | | if (voiceCallUrl.includes('/subPackages/voiceCallDetail/')) { |
| | | // 应用内页面跳转 |
| | | uni.navigateTo({ |
| | | url: voiceCallUrl.replace('http://localhost:9527/work-app/#', ''), |
| | | success: () => { |
| | | console.log('✅ 应用内导航成功!'); |
| | | }, |
| | | fail: (err) => { |
| | | console.error('❌ 应用内导航失败:', err); |
| | | // 如果应用内导航失败,尝试使用外部跳转 |
| | | fallbackToExternalNavigation(); |
| | | } |
| | | url: `/subPackages/voiceCallDetail/index?voiceparams=${encodedParams}`, |
| | | }); |
| | | } else { |
| | | // 外部页面跳转 |
| | | fallbackToExternalNavigation(); |
| | | } |
| | | } |
| | | // 否则尝试使用window.location跳转(适用于Web环境) |
| | | else if (typeof window !== 'undefined' && window.location) { |
| | | console.log('使用window.location跳转到语音通话页面'); |
| | | window.location.href = voiceCallUrl; |
| | | } else { |
| | | console.error('无法跳转到语音通话页面:当前环境不支持导航'); |
| | | } |
| | | } catch (error) { |
| | | console.error('跳转到语音通话页面失败:', error); |
| | | // 尝试使用外部跳转作为最后的补救措施 |
| | | fallbackToExternalNavigation(); |
| | | } |
| | | |
| | | // 外部页面跳转的回调函数 |
| | | function fallbackToExternalNavigation() { |
| | | console.log('尝试使用外部导航跳转到语音通话页面'); |
| | | try { |
| | | // 使用uni-app的外部链接跳转API |
| | | if (typeof uni !== 'undefined' && uni.navigateToWebview) { |
| | | // 这是一个示例,具体API可能需要根据uni-app版本和配置调整 |
| | | uni.navigateToWebview({ |
| | | url: voiceCallUrl, |
| | | success: () => { |
| | | console.log('✅ 外部Webview导航成功!'); |
| | | }, |
| | | fail: (err) => { |
| | | console.error('❌ 外部Webview导航失败:', err); |
| | | // 如果还是失败,尝试使用浏览器打开 |
| | | if (typeof plus !== 'undefined' && plus.runtime) { |
| | | plus.runtime.openURL(voiceCallUrl); |
| | | } else { |
| | | console.error('❌ 所有导航方式都失败了'); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | // 或者使用plus.runtime.openURL(适用于App环境) |
| | | else if (typeof plus !== 'undefined' && plus.runtime) { |
| | | plus.runtime.openURL(voiceCallUrl); |
| | | console.log('尝试使用plus.runtime.openURL打开外部链接'); |
| | | } else { |
| | | console.error('无法跳转到外部页面:当前环境不支持外部导航'); |
| | | } |
| | | } catch (fallbackError) { |
| | | console.error('外部导航尝试失败:', fallbackError); |
| | | } |
| | | } |
| | | return |
| | | } |
| | | } |
| | | |
| | | // 然后处理biz_code格式的消息 |
| | | switch (bizCode) { |
| | | case 'JOB_ISREFRESH': |
| | | appStore.setJobUpdateKeyAdd() |
| | | break |
| | | case 'DEVICE_ISREFRESH': |
| | | appStore.setDeviceUpdateKeyAdd() |
| | | break |
| | | case 'DOWNLOAD_PROGRESS': |
| | | break |
| | | case 'LOGOUT_USER': |
| | | userStore.setUserInfo(null) |
| | | uni.reLaunch({ |
| | | url: '/pages/login/index' |
| | | }) |
| | | break |
| | | case 'VoiceCall': |
| | | // enterRoom(payload, userId.value) |
| | | break |
| | | default: |
| | | // 记录未处理的消息 |
| | | console.log('未处理的WebSocket消息:', payload) |
| | | break; |
| | | // 触发震动 |
| | | function triggerVibration() { |
| | | try { |
| | | if (typeof uni !== 'undefined') { |
| | | // 方法1:使用uni.vibrate(现代API) |
| | | if (uni.vibrate) { |
| | | // 震动400ms |
| | | uni.vibrate({ |
| | | duration: 400, |
| | | success: () => { |
| | | console.log('📳 震动已触发'); |
| | | }, |
| | | fail: (error) => { |
| | | // 方法2:使用uni.vibrateLong(兼容旧设备) |
| | | if (uni.vibrateLong) { |
| | | uni.vibrateLong({ |
| | | success: () => { |
| | | console.log('📳 兼容模式震动已触发'); |
| | | }, |
| | | fail: (err) => { |
| | | console.error('兼容模式震动失败:', err); |
| | | } |
| | | }); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | // 方法3:使用plus API(H5+) |
| | | if (typeof plus !== 'undefined' && plus.device && plus.device.vibrate) { |
| | | plus.device.vibrate(400); |
| | | console.log('📳 H5+ 震动已触发'); |
| | | } |
| | | } |
| | | } catch (error) { |
| | | console.error('触发震动失败:', error); |
| | | } |
| | | } |
| | | |
| | | |
| | | // 初始化WebSocket连接 |
| | | function initWS() { |
| | | function isVoiceCallDetailActive() { |
| | | try { |
| | | // 使用默认用户ID初始化WebSocket连接 |
| | | websocketService.init(defaultUserId, WS_BASE); |
| | | console.log('🌐 全局WebSocket初始化成功,默认用户ID:', defaultUserId); |
| | | |
| | | // 设置全局消息处理回调 |
| | | websocketService.setOnMessageCallback(messageHandler); |
| | | |
| | | console.log('✅ 全局WebSocket消息处理器已设置'); |
| | | 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) { |
| | | console.error('❌ 全局WebSocket初始化失败:', error); |
| | | return false |
| | | } |
| | | } |
| | | |
| | | // 监听用户信息变化,初始化WebSocket |
| | | function shouldRecoverWS() { |
| | | return !isVoiceCallDetailActive() && !!useUserStore()?.userInfo?.access_token |
| | | } |
| | | |
| | | function ensureRecoverTimer() { |
| | | if (recoverTimer) { |
| | | return |
| | | } |
| | | recoverTimer = setInterval(() => { |
| | | if (shouldRecoverWS() && !websocketService.getConnected()) { |
| | | initWS() |
| | | } |
| | | }, 3000) |
| | | } |
| | | |
| | | function initWS() { |
| | | websocketService.close() |
| | | const userStore = useUserStore() |
| | | accessToken.value =userStore?.userInfo.access_token |
| | | if (!accessToken.value || isVoiceCallDetailActive()) { |
| | | return |
| | | } |
| | | try { |
| | | websocketService.setOnMessageCallback(messageHandler); |
| | | websocketService.setOnOpenCallback(() => {}) |
| | | websocketService.setOnCloseCallback(() => { |
| | | if (shouldRecoverWS()) { |
| | | ensureRecoverTimer() |
| | | } |
| | | }) |
| | | websocketService.setOnErrorCallback(() => { |
| | | if (shouldRecoverWS()) { |
| | | ensureRecoverTimer() |
| | | } |
| | | }) |
| | | |
| | | // 获取当前用户ID,优先使用store中的用户信息 |
| | | const userId = userStore.userInfo?.new_userInfo.userId || defaultUserId; |
| | | // console.log('🌐 全局WebSocket初始化开始,用户ID:', userId) |
| | | |
| | | // 检查是否已经有活跃的WebSocket连接 |
| | | if (!websocketService.getConnected() || websocketService.userId !== userId) { |
| | | // 使用用户ID初始化WebSocket连接 |
| | | websocketService.init(userId, WS_BASE, accessToken.value); |
| | | // console.log('🌐 全局WebSocket初始化成功,用户ID:', userId); |
| | | } |
| | | } catch (error) { |
| | | } |
| | | } |
| | | watch( |
| | | () => userStore.userInfo, |
| | | (newUserInfo) => { |
| | | console.log('👤 用户信息变化,尝试初始化WebSocket'); |
| | | () => callStatus.value, |
| | | (newValue) => { |
| | | if (newValue === 'accept') { |
| | | console.log('📞 通话中,跳过WebSocket初始化'); |
| | | return; |
| | | } |
| | | initWS(); |
| | | }, |
| | | { immediate: true } |
| | | { immediate: true, deep: true } |
| | | ) |
| | | |
| | | ensureRecoverTimer() |
| | | } |
| | | |
| | | |