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";
|
|
export function useGlobalWS() {
|
const userStore = useUserStore();
|
const appStore = useAppStore();
|
|
// 设置默认用户ID为3
|
const defaultUserId = '3';
|
// WebSocket基础URL
|
const WS_BASE = 'wss://wrj.shuixiongit.com/ws/chat?userId=';
|
|
// 消息处理
|
function messageHandler(payload) {
|
console.log('🌐 全局WebSocket收到消息111111111111111111111:', payload)
|
// 先尝试直接处理消息（适用于mobile-web-view的voiceCallDetail页面的消息格式）
|
const t = (payload.type || '').toString()
|
const bizCode = payload.biz_code || ''
|
|
console.log('📋 消息分析：type=' + t + ', biz_code=' + bizCode)
|
|
// 处理语音通话请求
|
if (t === 'call') {
|
console.log('📞 全局收到来电 call，来自', payload.from)
|
// 构建来电参数
|
const callParams = {
|
peerUid: payload.from,
|
from: payload.from,
|
type: 'incoming'
|
};
|
|
// 转义参数以便在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环境）
|
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();
|
}
|
});
|
} 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;
|
}
|
}
|
|
// 初始化WebSocket连接
|
function initWS() {
|
try {
|
// 使用默认用户ID初始化WebSocket连接
|
websocketService.init(defaultUserId, WS_BASE);
|
console.log('🌐 全局WebSocket初始化成功，默认用户ID:', defaultUserId);
|
|
// 设置全局消息处理回调
|
websocketService.setOnMessageCallback(messageHandler);
|
|
console.log('✅ 全局WebSocket消息处理器已设置');
|
} catch (error) {
|
console.error('❌ 全局WebSocket初始化失败:', error);
|
}
|
}
|
|
// 监听用户信息变化，初始化WebSocket
|
watch(
|
() => userStore.userInfo,
|
(newUserInfo) => {
|
console.log('👤 用户信息变化，尝试初始化WebSocket');
|
initWS();
|
},
|
{ immediate: true }
|
)
|
}
|
