|
|
|
|
/*
|
|
|
|
|
* @Author: ch
|
|
|
|
|
* @Date: 2022-06-12 14:04:56
|
|
|
|
|
* @LastEditors: ch
|
|
|
|
|
* @LastEditTime: 2022-06-13 11:48:41
|
|
|
|
|
* @Description: file content
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
import MsbIm from '@/plugins/msbIm' ;
|
|
|
|
|
import { ToAsyncAwait, FormatJsonSearch } from './utils';
|
|
|
|
|
import { ApiGetSoketTicket } from '@/plugins/api/im';
|
|
|
|
|
import ENV from '@/plugins/config/env';
|
|
|
|
|
const Im = new MsbIm({
|
|
|
|
|
reconnect: true,
|
|
|
|
|
});
|
|
|
|
|
let ImInit = null;
|
|
|
|
|
export default ({store }) => {
|
|
|
|
|
ImInit = async () => {
|
|
|
|
|
const { error, result } = await ApiGetSoketTicket();
|
|
|
|
|
if (error) {
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
const par = FormatJsonSearch({
|
|
|
|
|
client: result.client,
|
|
|
|
|
ticket: result.ticket,
|
|
|
|
|
// 1普通用户 2客服链接
|
|
|
|
|
connect: 1,
|
|
|
|
|
user: store.state.userInfo.id,
|
|
|
|
|
nickname: store.state.userInfo.nickname,
|
|
|
|
|
avatar : store.state.userInfo.avatar
|
|
|
|
|
})
|
|
|
|
|
return await ToAsyncAwait(Im.init({
|
|
|
|
|
url: `${ENV.imUrl}/ws${par}`
|
|
|
|
|
}))
|
|
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Im.interceptors.dataChangeAfter = () => {
|
|
|
|
|
let data = Im.sessionData.find(i => {
|
|
|
|
|
return (i.type === 4 && (typeof i.payload === 'string' ? JSON.parse(i.payload).type === 'system' : false));
|
|
|
|
|
}) || {}
|
|
|
|
|
console.log(data,'---');
|
|
|
|
|
let msgCount = data.unreadCount || 0;
|
|
|
|
|
store.commit('setSocketMsgData', JSON.parse(JSON.stringify(data)));
|
|
|
|
|
store.commit('setUnreadCount', msgCount);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Im.interceptors.onClose = () => {
|
|
|
|
|
Im.setSessionData([]);
|
|
|
|
|
Im.setCurSessionId(null);
|
|
|
|
|
store.commit('setSocketMsgData', {});
|
|
|
|
|
store.commit('setUnreadCount', 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
export {
|
|
|
|
|
Im,
|
|
|
|
|
ImInit
|
|
|
|
|
}
|
