107 lines
3.7 KiB
JavaScript
107 lines
3.7 KiB
JavaScript
import config from "@/config";
|
||
import storage from "@/utils/storage";
|
||
import constant from "@/utils/constant";
|
||
import { login, logout, getInfo } from "@/api/login";
|
||
import { getToken, setToken, removeToken } from "@/utils/auth";
|
||
import { GetListid } from "@/api/signln/SignTa/SignTa";
|
||
const baseUrl = config.baseUrl;
|
||
const qnDomain = config.qnDomain;
|
||
const chat = {
|
||
state: {
|
||
token: getToken(),
|
||
socket: storage.get(constant.socket),
|
||
sysMessageInfo:storage.get(constant.sysMessageInfo),
|
||
activiInfo:storage.get(constant.activiInfo),
|
||
sysAuditInfo:storage.get(constant.sysAuditInfo),
|
||
userMessageinfo:storage.get(constant.userMessageinfo),
|
||
interactMessage:storage.get(constant.interactMessage),
|
||
},
|
||
|
||
mutations: {
|
||
SET_socket: (state, socket) => {
|
||
state.socket = socket;
|
||
storage.set(constant.socket, socket);
|
||
},
|
||
|
||
// SET_sysMessageInfo: (state, sysMessageInfo) => {
|
||
// state.sysMessageInfo = sysMessageInfo;
|
||
// storage.set(constant.sysMessageInfo, sysMessageInfo);
|
||
// },
|
||
// SET_sysActiviInfo: (state, activiInfo) => {
|
||
|
||
// state.activiInfo = activiInfo;
|
||
// storage.set(constant.activiInfo, activiInfo);
|
||
// },
|
||
// SET_sysAuditInfo: (state, sysAuditInfo) => {
|
||
// state.sysAuditInfo = sysAuditInfo;
|
||
// storage.set(constant.sysAuditInfo, sysAuditInfo);
|
||
// },
|
||
SET_userMessageinfo: (state, userMessageinfo) => {
|
||
state.userMessageinfo = userMessageinfo;
|
||
storage.set(constant.userMessageinfo, userMessageinfo);
|
||
},
|
||
// SET_interactMessage: (state, interactMessage) => {
|
||
// state.interactMessage = interactMessage;
|
||
// storage.set(constant.interactMessage, interactMessage);
|
||
// }
|
||
},
|
||
|
||
actions: {
|
||
// 进行webSocker链接
|
||
webSockerInfo({ commit }) {
|
||
GetListid().then((res) => {
|
||
let socket = null;
|
||
return new Promise((resolve, reject) => {
|
||
const fileWithoutProtocol = baseUrl.replace(
|
||
/^https?:\/\//,
|
||
""
|
||
);
|
||
const url = "ws://" + fileWithoutProtocol + "/text/text?" + res;
|
||
socket = new WebSocket(url);
|
||
|
||
socket.onopen = () => {
|
||
commit("SET_socket",socket)
|
||
resolve();
|
||
console.log("WebSocket连接已打开");
|
||
};
|
||
|
||
socket.onmessage = (event) => {
|
||
console.log("收到WebSocket消息：", event.data);
|
||
const jsonObject = JSON.parse(event.data);
|
||
// if (jsonObject.messageType == 1){
|
||
// console.log("系统通知:",jsonObject);
|
||
// commit("SET_sysMessageInfo",jsonObject.messageText)
|
||
// }
|
||
// else if (jsonObject.messageType == 2){
|
||
// console.log("审核通知111:",jsonObject);
|
||
// commit("SET_sysAuditInfo",jsonObject.messageText)
|
||
// }
|
||
// else if (jsonObject.messageType == 51 || (jsonObject.messageType == 52)) {
|
||
|
||
// commit("SET_userMessageinfo",jsonObject)
|
||
// }else if (jsonObject.messageType == 61 || (jsonObject.messageType == 62)) {
|
||
// commit("SET_interactMessage",jsonObject)
|
||
// }
|
||
if (jsonObject.messageType == 51 || (jsonObject.messageType == 52)) {
|
||
|
||
commit("SET_userMessageinfo",jsonObject)
|
||
}
|
||
};
|
||
|
||
socket.onerror = (error) => {
|
||
console.error("WebSocket发生错误：", error);
|
||
};
|
||
|
||
socket.onclose = () => {
|
||
console.log("WebSocket连接已关闭");
|
||
reject("WebSocket连接已关闭");
|
||
};
|
||
|
||
});
|
||
});
|
||
},
|
||
},
|
||
};
|
||
|
||
export default chat;
|