| | |
| | | import { useUserStore } from "@/store/index.js"; |
| | | 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 |
| | |
| | | // const WS_BASE = 'wss://wrj.shuixiongit.com/ws/chat?userId='; |
| | | const WS_BASE = 'ws://218.202.104.82:38201/ws/chat'; |
| | | |
| | | // 消息处理 |
| | | function messageHandler(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() |
| | |
| | | // 处理语音通话请求 |
| | | 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(payload.from || '未知来电') |
| | | showIncomingCallNotification(callerName || '未知来电') |
| | | // 拉起应用到前台 |
| | | openDialog() |
| | | // #endif |
| | |
| | | return |
| | | } |
| | | } |
| | | |
| | | // 播放来电铃声 - 定义在 messageHandler 外部 |
| | | // function playRingtone() { |
| | | // try { |
| | | // if (typeof uni !== 'undefined' && uni.createInnerAudioContext) { |
| | | // const ringtone = uni.createInnerAudioContext(); |
| | | // // 使用默认铃声,注意路径写法 |
| | | // ringtone.src = '/static/audio/ringtone.mp3'; |
| | | // ringtone.loop = true; |
| | | // ringtone.volume = 0.8; |
| | | // ringtone.play(); |
| | | // // 存储铃声实例 |
| | | // ringtoneInstance = ringtone; // 使用局部变量而不是window |
| | | // } |
| | | // } catch (error) { |
| | | // } |
| | | // } |
| | | |
| | | // 触发震动 |
| | | function triggerVibration() { |
| | |
| | | } |
| | | } |
| | | |
| | | // 停止铃声 |
| | | // function stopRingtone() { |
| | | // try { |
| | | // if (ringtoneInstance) { |
| | | // ringtoneInstance.stop(); |
| | | // ringtoneInstance.destroy(); |
| | | // ringtoneInstance = null; |
| | | // } |
| | | // } catch (error) { |
| | | // // 即使出错也重置实例 |
| | | // ringtoneInstance = null; |
| | | // } |
| | | // } |
| | | // |
| | | // // 监听停止铃声事件 |
| | | // if (typeof uni !== 'undefined' && uni.$on) { |
| | | // uni.$on('stopRingtone', stopRingtone); |
| | | // // 监听WebView消息事件 |
| | | // uni.$on('webViewMessage', (data) => { |
| | | // // 检查是否是停止铃声消息 |
| | | // if (data?.type === 'stopVoice') { |
| | | // stopRingtone(); |
| | | // console.log('📳 收到WebView停止铃声消息,已停止铃声'); |
| | | // |
| | | // } |
| | | // }); |
| | | // } |
| | | |
| | | // 初始化WebSocket连接 |
| | | function isVoiceCallDetailActive() { |
| | |
| | | return |
| | | } |
| | | recoverTimer = setInterval(() => { |
| | | // console.log('shouldRecoverWS()',shouldRecoverWS(),'----------',websocketService.getConnected()) |
| | | if (shouldRecoverWS() && !websocketService.getConnected()) { |
| | | initWS() |
| | | } |
| | |
| | | |
| | | // 获取当前用户ID,优先使用store中的用户信息 |
| | | const userId = userStore.userInfo?.new_userInfo.userId || defaultUserId; |
| | | console.log('🌐 全局WebSocket初始化开始,用户ID:', userId) |
| | | // console.log('🌐 全局WebSocket初始化开始,用户ID:', userId) |
| | | |
| | | // 检查是否已经有活跃的WebSocket连接 |
| | | if (!websocketService.getConnected() || websocketService.userId !== userId) { |