import {useUserStore} from "@/store/index.js";
|
import {getEnvObj} from "@/utils/index.js";
|
import {enterRoom} from "@/utils/voiceCallByTX/index.js";
|
|
let socketTask = null
|
|
export function useGlobalWS() {
|
const userStore = useUserStore();
|
const userId = computed(() => userStore?.userInfo?.user_id)
|
const access_token = computed(() => userStore?.userInfo?.access_token)
|
const {VITE_APP_WS_API_URL} = getEnvObj()
|
|
// 消息处理
|
function messageHandler(payload) {
|
switch (payload.biz_code) {
|
case 'JOB_ISREFRESH':
|
break
|
case 'DEVICE_ISREFRESH':
|
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:
|
break;
|
}
|
}
|
|
// 关闭ws
|
function closeWS() {
|
socketTask?.close({
|
success: () => {
|
console.log('ws关闭连接');
|
},
|
})
|
}
|
|
// 初始化ws
|
function initWS() {
|
// 关闭，再连接ws
|
closeWS()
|
if (!access_token.value) return
|
const url = VITE_APP_WS_API_URL
|
+ `?x-auth-token=${encodeURI(access_token?.value)}`
|
+ `&model_type=3&workspace-id=${userId.value}`
|
// 创建连接
|
socketTask = uni.connectSocket({
|
url: url,
|
success: () => {
|
console.log('ws连接成功');
|
},
|
fail: (err) => {
|
console.error('ws连接失败:', err);
|
}
|
});
|
// 消息监听
|
socketTask.onMessage((result) => {
|
messageHandler(JSON.parse(result.data))
|
})
|
}
|
|
watch(access_token, initWS, {immediate: true})
|
}
|
