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

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

function handle(state, data) {
    // console.log(data, 'socket订阅');
    const msg = data.body;
    const path = window.location.href;
    if (path.includes('/practiceDisplay') && !state.isFirst) { state.isFirst = true; }
    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_User': // 仿真-进出仿真消息
        handleSimulationUserinfo(state, msg); // 用户进出仿真消息
        break;
    case 'Simulation_Script_Action_Tip': // 剧本提示消息
        handleSimulationScriptTipInfo(state, msg); // 剧本提示消息
        break;
    case 'Simulation_Script_Action_Finish':
        state.simulationScriptTipFinish++; // 剧本某一部操作完成提示
        break;
    case 'Simulation_Script_Action_Error':
        state.simulationScriptTipError++; // 剧本某一部操作执行错误
        break;
    case 'Simulation_PlayBack_Finish': // 竞赛裁判系统裁判员回放结束推送
        state.playBackFinish++; // 竞赛裁判系统裁判员回放结束推送
        break;
    case 'Simulation_Over': // 用户退出仿真推送消息
        state.simulationOver++; // 用户退出仿真推送消息
        break;
    case 'Simulation_Script_Finish': // 剧本执行完成推送消息
        state.scriptFinish++; // 剧本执行完成推送消息
        break;
    case 'Simulation_Script_Action':// 剧本编制添加指令的推送消息
        state.scriptAction = msg;
        break;
    case 'Simulation_AutoFault_Trigger': // 自动故障触发操作推送消息
        state.autoFaultTrigger++;
        break;
    case 'Simulation_RunFact': // 仿真-列车实际到发车站消息
        if (!Array.isArray(msg)) {
            state.trainStationList = [msg];
        } else {
            state.trainStationList = msg;
        }
        break;
    case 'Simulation_Error': // 仿真-异常消息
        state.simulationError += 1;
        break;
    case 'Simulation_RunAsPlan_Start': // 仿真-仿真开始按计划行车消息
        state.simulationStart = msg;
        break;
    case 'Simulation_Reset': // 仿真-仿真重置消息 退出计划行车
        state.simulationReset += 1;
        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 'Simulation_Invite': // 综合演练-仿真邀请消息
        state.simulationInvite = 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 'Be_Logged_Out': // 重复登录被登出
        state.beLogoutCount++;
        break;
    case 'Simulation_Run_Plan_Reload': // 运行图变更
        state.runPlanReloadCount++;
        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;
    case 'Simulation_Member':
        state.memberChangeCount++;
        break;
    case 'Simulation_Time_Sync':
        state.simulationTimeSync = msg;
        break;
    case 'Simulation_IbpStatus':
        state.simulationIbpStatus = msg;
        break;
    case 'Simulation_Competition_Practice_Finish':
        state.competitionPracticeFinish++;
        break;
    case 'Simulation_Alarm':
        state.simulationAlarmInfo = msg;
        break;
    case 'STATION_PFI_NUM':
        state.stationPfiNum = msg;
        break;
    case 'STAND_PFI':
        state.standPfiNum = msg;
        break;
    case 'TRAIN_PFI_NUM':
        state.trainPfiNum = msg;
        break;
    case 'TRAIN_PFI_BL':
        state.trainPfiBL = msg;
        break;
    case 'Simulation_Scenes_Reload':
        if (msg) {
            store.dispatch('training/start');
        } else {
            store.dispatch('training/over');
        }
        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 ? `${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) {
    switch (data.messageType) {
    case 'INVITE':
        state.inviteSimulationConversition = data;
        break;
    case 'CONNECT':
        state.acceptConversionInvite = data;
        break;
    case 'OVER':
        state.overConversition = data;
        break;
    case 'MESSAGE':
        state.conversationInfo = data;
        break;
    case 'CREATE':
        state.createConversition = data;
        break;
    case 'EXIT':
        state.exitConversition = data;
        break;
    }
}

// 剧本提示
function handleSimulationScriptTipInfo(state, data) {
    state.simulationScriptTip = data;
}

function handleUserinfo(state, data) {
    state.roleList = (data instanceof Array) ? data : [data];
}

function handleSimulationUserinfo(state, data) {
    state.simulationRoleList = (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: {}, // 支付消息
        jointRoomInfo: {}, // 受邀请房间信息
        chatContent: {}, // 聊天室聊天内容
        roleList: [], // 设置角色信息
        simulationRoleList:[], // 设置仿真的聊天角色信息
        simulationScriptTip:{}, // 剧本推送提示信息
        simulationScriptTipFinish:0, // 剧本某一步完成的消息
        simulationScriptTipError: 0, // 剧本某一步执行错误
        scriptFinish:0, // 剧本执行完成提示信息
        autoFaultTrigger:0, // 自动故障触发操作推送消息
        scriptAction:{}, // 剧本编制添加指令的推送消息
        playBackFinish:0, // 竞赛裁判系统裁判回放结束推送
        jointRoomPrepare: false, // 演练房间准备状态
        equipmentStatus: [], // 仿真-设备状态消息
        trainStationList: [], //  仿真-列车实际到发车站消息
        simulationError: 0, // 仿真-异常消息
        simulationStart: '',	// 仿真-开始消息
        simulationOver:0, // 退出仿真推送消息
        simulationReset: 0, // 仿真-异常消息
        inviteSimulationConversition: {}, // 仿真会话邀请消息
        acceptConversionInvite:{}, // 仿真会话成员接收邀请
        createConversition:{}, // 仿真创建会话
        overConversition: {}, // 仿真会话结束
        exitConversition: {}, // 仿真成员退出会话
        conversationInfo: {}, // 仿真会话消息

        message: {}, // 仿真聊天
        msgQueue: [],	// 命令请求列表（旧版控制权转移可能在用，新版不用这个）
        msgHead: null,	// 消息头（旧版控制权转移可能在用，新版不用这个）

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

        permissionOver: {}, // 权限结束

        roomIsSubscribe:false, // 房间是否订阅
        assistantIsSubscribe:false, // 综合演练仿真聊天是否订阅

        tipOperateCount: 0, // 任务结束提示消息
        realDeviceInfo: 0, // 真实设备信息
        beLogoutCount: 0, // 被登出
        runPlanReloadCount: 0, // 仿真运行图变更
        memberChangeCount: 0, // 仿真成员变更
        roomInvite: {},
        simulationTimeSync: '', // 仿真时间
        simulationIbpStatus: null,
        stationPfiNum: null, // 客流消息列表
        standPfiNum:null, // 站台客流人数信息
        trainPfiNum:null, // 列车客流当前人数信息
        trainPfiBL:null, // 列车客流乘降人数信息
        isFirst:false, // 第一次是否已经订阅
        competitionPracticeFinish:0, //  竞赛场景结束标识
        simulationAlarmInfo:  []// 仿真报警信息
    },
    getters: {
    },
    mutations: {
        setJointRoomInfo: (state, jointRoomInfo) => {
            state.jointRoomInfo = jointRoomInfo;
        },

        setStationPfiNum: (state, stationPfiNum) => {
            state.stationPfiNum = stationPfiNum;
        },

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

        setEquipmentStatus: (state, equipmentStatus) => {
            state.equipmentStatus = equipmentStatus;
        },

        setTrainStationList: (state, trainStationList) => {
            state.trainStationList = trainStationList;
        },

        setSimulationStart: (state, simulationStart) => {
            state.simulationStart = simulationStart;
        },

        setSimulationReset: (state, simulationReset) => {
            state.simulationReset = simulationReset;
        },

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

        setSimulationInvite: (state, simulationInvite) => {
            state.simulationInvite = simulationInvite;
        },
        setRoomInvite: (state, roomInvite) => {
            state.roomInvite = roomInvite;
        },
        setRoomSubscribe:(state, roomIsSubscribe)=>{
            state.roomIsSubscribe = roomIsSubscribe;
        },
        setAssistantSubscribe:(state, assistantIsSubscribe)=>{
            state.assistantIsSubscribe = assistantIsSubscribe;
        },
        resetTrainPassagerNum:(state, assistantIsSubscribe)=>{
            state.standPfiNum = null;
            state.trainPfiNum = null;
            state.trainPfiBL = null;
        },
        setIsFirst:(state, isFirst)=>{
            state.isFirst = isFirst;
        }
    },

    actions: {
        setStomp: ({ state }, res) => {
            handle(state, res);
        },

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

        setJointRoomInfo: ({ commit }) => {
            commit('setJointRoomInfo', {});
        },

        setStationPfiNum: ({ commit }) => {
            commit('setStationPfiNum', null);
        },

        setEquipmentStatus: ({ commit }) => {
            commit('setEquipmentStatus', []);
        },

        setTrainStationList: ({ commit }) => {
            commit('setTrainStationList', []);
        },

        setSimulationStart: ({ commit }) => {
            commit('setSimulationStart', '');
        },

        setSimulationReset: ({ commit }) => {
            commit('setSimulationReset', 0);
        },

        setSimulationInvite: ({ commit }) => {
            commit('setSimulationInvite', {});
        },
        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);
        // },
        setRoomSubscribe:({ commit }, msg) => {
            commit('setRoomSubscribe', msg);
        },
        setAssistantSubscribe:({ commit }, msg) => {
            commit('setAssistantSubscribe', msg);
        },
        resetTrainPassagerNum:({ commit }) => {
            commit('resetTrainPassagerNum');
        },
        setIsFirst:({ commit }, isFirst) => {
            commit('setIsFirst', isFirst);
        }
    }
};

export default socket;