397 lines
11 KiB
JavaScript
397 lines
11 KiB
JavaScript
|
|
import store from '@/store';
|
|
|
|
function handle(state, data) {
|
|
// console.log(data, 'socket订阅');
|
|
const msg = data.body;
|
|
const path = window.location.href;
|
|
switch (data.type) {
|
|
case 'Order_Pay_Result': // 订单支付结果消息
|
|
state.payOrder = msg;
|
|
break;
|
|
case 'JointTraining_Room': // 综合演练室-房间消息
|
|
if (!path.includes('/plan') || !path.includes('/dp/')) {
|
|
state.jointRoomInfo = msg; // 房间信息
|
|
}
|
|
break;
|
|
case 'JointTraining_User': // 综合演练室-用户消息
|
|
handleUserinfo(state, msg); // 分配角色权限消息
|
|
break;
|
|
case 'JointTraining_Chat': // 综合演练室-群聊消息
|
|
handleRecordList(state, msg);
|
|
break;
|
|
case 'Simulation_DeviceStatus': // 仿真-设备状态消息
|
|
state.equipmentStatus = msg;
|
|
break;
|
|
case 'Simulation_RunFact': // 仿真-列车实际到发车站消息
|
|
state.trainStationList = msg;
|
|
break;
|
|
case 'Simulation_Error': // 仿真-异常消息
|
|
state.simulationError = msg;
|
|
break;
|
|
case 'Simulation_RunAsPlan_Start': // 仿真-仿真开始按计划行车消息
|
|
state.simulationStart = msg;
|
|
break;
|
|
case 'Simulation_Reset': // 仿真-仿真重置消息 退出计划行车
|
|
state.simulationReset = msg;
|
|
break;
|
|
case 'Simulation_Conversation': // 仿真-用户交互消息（聊天/命令）
|
|
handleSimulationInfo(state, msg);
|
|
break;
|
|
case 'Simulation_PlayBack_Conversation': // 回放-用户交互消息
|
|
handleSimulationInfo(state, msg);
|
|
break;
|
|
case 'Simulation_ApplyHandle': // 请求处理消息
|
|
handlePushMsgQueue(state, msg);
|
|
break;
|
|
case 'JointTraining_User_Permit': // 综合演练室-用户获取权限消息
|
|
state.userPermit = msg;
|
|
break;
|
|
case 'JointTraining_User_RoomKickOut': // 综合演练室-用户被踢出房间消息
|
|
state.userRoomKickOut = msg; // 没有给被踢用户发送
|
|
handleMessageInfo(state, 'userRoomKickOut', msg);
|
|
break;
|
|
case 'JointTraining_User_InRoom': // 综合演练室-用户从外部进入房间消息
|
|
state.userInRoom = msg;
|
|
handleMessageInfo(state, 'userInRoom', msg);
|
|
break;
|
|
case 'JointTraining_User_OutRoom': // 综合演练室-用户退出房间消息
|
|
state.userOutRoom = msg;
|
|
handleMessageInfo(state, 'userOutRoom', msg);
|
|
break;
|
|
case 'JointTraining_User_InSimulation': // 综合演练室-用户进入仿真消息
|
|
state.userInSimulation = msg;
|
|
handleMessageInfoSimulation(state, 'userInSimulation', msg);
|
|
break;
|
|
case 'JointTraining_User_BackRoom': // 综合演练室-用户从仿真返回房间消息
|
|
state.userBackRoom = msg;
|
|
handleMessageInfoSimulation(state, 'userBackRoom', msg);
|
|
break;
|
|
case 'JointTraining_Room_Invite': // 综合演练室-房间邀请消息
|
|
state.roomInvite = msg;
|
|
break;
|
|
case 'Big_Screen_Simulation_DeviceStatus': // 大屏仿真状态数据
|
|
state.equipmentStatus = msg;
|
|
break;
|
|
case 'Big_Screen_Simulation_RunFact': // 大屏仿真运行图状态
|
|
state.trainStationList = msg;
|
|
break;
|
|
case 'Plan_Simulation_DeviceStatus': // 大屏仿真状态数据
|
|
state.equipmentStatus = msg;
|
|
break;
|
|
case 'Plan_Simulation_RunFact': // 大屏仿真运行图状态
|
|
state.trainStationList = msg;
|
|
break;
|
|
case 'Simulation_Permission_Over': // 权限结束
|
|
state.permissionOver = msg;
|
|
break;
|
|
case 'Simulation_Quest_Finish': // 任务结束标志
|
|
state.tipOperateCount++;
|
|
break;
|
|
case 'Simulation_Control_Pause': // 暂停中
|
|
store.dispatch('scriptRecord/updateSimulationPause', msg);
|
|
}
|
|
}
|
|
|
|
// 操作聊天信息
|
|
function handleRecordList(state, data) {
|
|
const userId = store.state.user.id;
|
|
let isSelf = false;
|
|
if (data.member.id == userId) {
|
|
isSelf = true;
|
|
}
|
|
const myDate = new Date();
|
|
const myDate1 = myDate.toLocaleDateString().replace(/\//g, '-');
|
|
const param = {
|
|
join: false,
|
|
value: data.message,
|
|
self: isSelf,
|
|
voice: data.isAudio,
|
|
src: data.isAudio ? `${process.env.process.env.VUE_VOICE_API}/jlcloud/audio/${data.audioPath}` : '',
|
|
other: !isSelf,
|
|
userName: data.member.nickName,
|
|
chatTime: data.chatTime,
|
|
chatInfo: true,
|
|
inSimulation: false,
|
|
inRoom: true,
|
|
date: +new Date(`${myDate1} ${data.chatTime}`)
|
|
};
|
|
state.chatContentList = param;
|
|
}
|
|
// 仿真内部聊天
|
|
function handleSimulationInfo(state, data) {
|
|
const userId = store.state.user.id;
|
|
let isSelf = false;
|
|
if (data.member.userId == userId) {
|
|
isSelf = true;
|
|
}
|
|
let role = '';
|
|
switch (data.member.role) {
|
|
case '01':
|
|
role = '管理员';
|
|
break;
|
|
case '02':
|
|
role = '教员';
|
|
break;
|
|
case '03':
|
|
role = `调度员`;
|
|
break;
|
|
case '04':
|
|
store.state.map.map.stationList.forEach(nor => {
|
|
if (nor.code == data.member.deviceCode) {
|
|
role = `${nor.name}`;
|
|
}
|
|
});
|
|
break;
|
|
}
|
|
if (!data.member.userId && data.member.deviceName) {
|
|
data.member.nickName = data.member.deviceName;
|
|
}
|
|
if (!data.targetMember.userId && data.targetMember.deviceName) {
|
|
data.targetMember.nickName = data.targetMember.deviceName;
|
|
}
|
|
const myDate = new Date();
|
|
const myDate1 = myDate.toLocaleDateString().replace(/\//g, '-');
|
|
const chatTime = /\d{2}:\d{2}:\d{2}/.exec(data.chatTime)[0] || data.chatTime;
|
|
const param = {
|
|
join: false,
|
|
value: data.message,
|
|
self: isSelf,
|
|
voice: data.isAudio,
|
|
src: data.isAudio ? `${process.env.process.env.VUE_VOICE_API}/jlcloud/audio/${data.audioPath}` : '',
|
|
other: !isSelf,
|
|
userName: '',
|
|
id: data.member.id,
|
|
chatTime: data.chatTime,
|
|
date: +new Date(`${myDate1} ${chatTime}`),
|
|
conversationId: data.conversationId,
|
|
changeVO: data.changeVO || {},
|
|
targetMember: data.targetMember,
|
|
member: data.member,
|
|
group: data.group
|
|
};
|
|
if (data.member.role) {
|
|
param.userName = `${role}【${data.member.nickName}】`;
|
|
} else {
|
|
param.userName = `${data.member.nickName}`;
|
|
}
|
|
state.simulationText = param;
|
|
}
|
|
function handleUserinfo(state, data) {
|
|
if (data.length) { // 分配角色信息
|
|
state.roleInfo = data;
|
|
}
|
|
}
|
|
function handleMessageInfo(state, type, data) {
|
|
const message = {
|
|
join: true,
|
|
id: data.id,
|
|
userName: data.nickName,
|
|
userRole: data.userRole,
|
|
name: data.name,
|
|
roomTip: '',
|
|
chatInfo: true,
|
|
inSimulation: data.inSimulation,
|
|
inRoom: data.inRoom,
|
|
session: 'session',
|
|
type: type,
|
|
oneself: data.id === store.state.user.id
|
|
};
|
|
switch (type) {
|
|
case 'userInRoom':
|
|
message.roomTip = `${data.nickName}进入房间`;
|
|
break;
|
|
case 'userRoomKickOut':
|
|
message.roomTip = `${data.nickName}被踢出房间`;
|
|
break;
|
|
case 'userOutRoom':
|
|
message.roomTip = `${data.nickName}退出房间`;
|
|
break;
|
|
}
|
|
state.chatContentList = message;
|
|
}
|
|
function handleMessageInfoSimulation(state, type, data) {
|
|
const message = {
|
|
join: true,
|
|
id: data.id,
|
|
userName: data.nickName,
|
|
userRole: data.userRole,
|
|
name: data.name,
|
|
simulationTip: '',
|
|
chatInfo: true,
|
|
inSimulation: data.inSimulation,
|
|
inRoom: data.inRoom,
|
|
session: 'session'
|
|
};
|
|
switch (type) {
|
|
case 'userInSimulation':
|
|
message.simulationTip = `${data.nickName}进入仿真`;
|
|
break;
|
|
case 'userBackRoom':
|
|
message.simulationTip = `${data.nickName}退出仿真`;
|
|
break;
|
|
}
|
|
state.chatContentSimuList = message;
|
|
}
|
|
function handlePushMsgQueue(state, msg) {
|
|
if (msg instanceof Array) {
|
|
state.msgQueue.concat(msg);
|
|
} else {
|
|
state.msgQueue.push(msg);
|
|
}
|
|
|
|
if (!state.msgHead) {
|
|
state.msgHead = state.msgQueue[0];
|
|
}
|
|
}
|
|
|
|
const socket = {
|
|
namespaced: true,
|
|
|
|
state: {
|
|
payOrder: {}, // 支付消息
|
|
jointRoomInfo: {}, // 受邀请房间信息
|
|
chatContentList: {}, // 聊天室聊天内容
|
|
roleInfo: [], // 设置角色信息
|
|
jointRoomPrepare: false, // 演练房间准备状态
|
|
equipmentStatus: [], // 仿真-设备状态消息
|
|
trainStationList: [], // 仿真-列车实际到发车站消息
|
|
simulationError: '', // 仿真-异常消息
|
|
simulationStart: '', // 仿真-开始消息
|
|
simulationReset: '', // 仿真-异常消息
|
|
simulationText: {}, // 仿真-用户交互消息（聊天/命令）
|
|
message: {}, // 仿真聊天
|
|
msgQueue: [], // 命令请求列表
|
|
msgHead: null, // 消息头
|
|
|
|
userPermit: {}, // 用户获取权限消息
|
|
userRoomKickOut: {}, // 用户被踢出房间消息
|
|
userInRoom: {}, // 用户从外部进入房间消息
|
|
userOutRoom: {}, // 用户退出房间消息
|
|
userInSimulation: {}, // 用户进入仿真消息
|
|
userBackRoom: {}, // 用户从仿真返回房间消息
|
|
roomInvite: {}, // 用户扫码信息
|
|
chatContentSimuList: {}, // 进入仿真，离开仿真信息
|
|
|
|
permissionOver: {}, // 权限结束
|
|
|
|
tipOperateCount: 0 // 任务结束提示消息
|
|
},
|
|
|
|
getters: {
|
|
},
|
|
mutations: {
|
|
setJointRoomInfo: (state, jointRoomInfo) => {
|
|
state.jointRoomInfo = jointRoomInfo;
|
|
},
|
|
|
|
setChatContentList: (state, chatContentList) => {
|
|
state.chatContentList = chatContentList;
|
|
},
|
|
|
|
setEquipmentStatus: (state, equipmentStatus) => {
|
|
state.equipmentStatus = equipmentStatus;
|
|
},
|
|
|
|
setTrainStationList: (state, trainStationList) => {
|
|
state.trainStationList = trainStationList;
|
|
},
|
|
|
|
setSimulationError: (state, simulationError) => {
|
|
state.simulationError = simulationError;
|
|
},
|
|
|
|
setSimulationStart: (state, simulationStart) => {
|
|
state.simulationStart = simulationStart;
|
|
},
|
|
|
|
setSimulationReset: (state, simulationReset) => {
|
|
state.simulationReset = simulationReset;
|
|
},
|
|
|
|
setSimulationTextList: (state, simulationText) => {
|
|
state.simulationText = simulationText;
|
|
},
|
|
|
|
setPayOrder: (state, payOrder) => {
|
|
state.payOrder = payOrder;
|
|
},
|
|
|
|
shiftMsgQueue: (state) => {
|
|
state.msgHead = null;
|
|
state.msgQueue.shift();
|
|
state.msgHead = state.msgQueue[0];
|
|
},
|
|
pushMsgQueue: (state, msg) => {
|
|
handlePushMsgQueue(state, msg);
|
|
},
|
|
|
|
setRoomInvite: (state, roomInvite) => {
|
|
state.roomInvite = roomInvite;
|
|
}
|
|
},
|
|
|
|
actions: {
|
|
setStomp: ({ state }, res) => {
|
|
handle(state, res);
|
|
},
|
|
|
|
setChatContentList: ({ commit }, chatContentList) => {
|
|
commit('setChatContentList', chatContentList);
|
|
},
|
|
|
|
setJointRoomInfo: ({ commit }) => {
|
|
commit('setJointRoomInfo', {});
|
|
},
|
|
|
|
setEquipmentStatus: ({ commit }) => {
|
|
commit('setEquipmentStatus', []);
|
|
},
|
|
|
|
setTrainStationList: ({ commit }) => {
|
|
commit('setTrainStationList', []);
|
|
},
|
|
|
|
setSimulationError: ({ commit }) => {
|
|
commit('setSimulationError', '');
|
|
},
|
|
|
|
setSimulationStart: ({ commit }) => {
|
|
commit('setSimulationStart', '');
|
|
},
|
|
|
|
setSimulationReset: ({ commit }) => {
|
|
commit('setSimulationReset', '');
|
|
},
|
|
|
|
setSimulationTextList: ({ commit }) => {
|
|
commit('setSimulationTextList', {});
|
|
},
|
|
|
|
setRoomInvite: ({ commit }) => {
|
|
commit('setRoomInvite', {});
|
|
},
|
|
|
|
setMessage: ({ state }, data) => {
|
|
if (!state.message[data.key]) {
|
|
state.message[data.key] = [];
|
|
}
|
|
state.message[data.key].push(data.value);
|
|
},
|
|
|
|
setPayOrder: ({ commit }) => {
|
|
commit('setPayOrder', {});
|
|
},
|
|
|
|
shiftMsgQueue: ({ commit }) => {
|
|
commit('shiftMsgQueue');
|
|
},
|
|
|
|
pushMsgQueue: ({ commit }, msg) => {
|
|
commit('pushMsgQueue', msg);
|
|
}
|
|
}
|
|
};
|
|
|
|
export default socket;
|