rt-sim-training-client/src/store/modules/socket.js

import store from '@/store';
import { Notification } from 'element-ui';

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 'Be_Logged_Out': // 重复登录被登出
        state.beLogout = 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_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 'JointTraining_Device':
        state.realDeviceInfo++;
        break;
    case 'Simulation_Control_Pause': // 暂停中
        store.dispatch('scriptRecord/updateSimulationPause', msg);
        break;
    case 'BROADCAST': // 升级通知消息
        Notification.warning({
            title: msg.title,
            center: true,
            message: msg.message,
            position: 'bottom-right',
            showClose: msg.showClose,
            duration: 0
        });
        break;
    }
}

// 操作聊天信息
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.chatContent = 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) {
    state.roleList = (data instanceof Array) ? data : [data];
}

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: {}, // 支付消息
        beLogout: {},	// 被登出
        jointRoomInfo: {}, // 受邀请房间信息
        chatContent: {}, // 聊天室聊天内容
        roleList: [], // 设置角色信息
        jointRoomPrepare: false, // 演练房间准备状态
        equipmentStatus: [], // 仿真-设备状态消息
        trainStationList: [], //  仿真-列车实际到发车站消息
        simulationError: '', // 仿真-异常消息
        simulationStart: '',	// 仿真-开始消息
        simulationReset: '', // 仿真-异常消息
        simulationText: {}, // 仿真-用户交互消息（聊天/命令）

        message: {}, // 仿真聊天
        msgQueue: [],	// 命令请求列表
        msgHead: null,	// 消息头

        userPermit: {}, // 用户获取权限消息
        userRoomKickOut: {}, // 用户被踢出房间消息
        userInRoom: {}, // 用户从外部进入房间消息
        userOutRoom: {}, // 用户退出房间消息
        userInSimulation: {}, //  用户进入仿真消息
        userBackRoom: {}, // 用户从仿真返回房间消息
        roomInvite: {}, // 用户扫码信息

        permissionOver: {}, // 权限结束

        tipOperateCount: 0, // 任务结束提示消息
        realDeviceInfo: 0 // 真实设备信息
    },

    getters: {
    },
    mutations: {
        setJointRoomInfo: (state, jointRoomInfo) => {
            state.jointRoomInfo = jointRoomInfo;
        },

        setChatContent: (state, chatContent) => {
            state.chatContent = chatContent;
        },

        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);
        },

        setChatContent: ({ commit }, chatContent) => {
            commit('setChatContent', chatContent);
        },

        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;