95 lines
3.7 KiB
JavaScript
95 lines
3.7 KiB
JavaScript
|
import Vue from 'vue'
|
|||
|
|
import Vuex from 'vuex'
|
|||
|
|
import {loginUserId} from "../common/tool";
|
|||
|
|
Vue.use(Vuex)
|
|||
|
|
export default new Vuex.Store({
|
|||
|
|
state: {
|
|||
|
|
socketTask: null,
|
|||
|
|
isOpenSocket:false,
|
|||
|
|
eventlist: {},
|
|||
|
|
unread: []
|
|||
|
|
},
|
|||
|
|
mutations: {
|
|||
|
|
WEBSOCKET_INIT(state, url) {
|
|||
|
|
// 创建一个this.socketTask对象【发送、接收、关闭socket都由这个对象操作】
|
|||
|
|
state.socketTask = uni.connectSocket({
|
|||
|
|
url,
|
|||
|
|
// 【非常重要】必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099【特别容易犯的错误】
|
|||
|
|
success(data) {
|
|||
|
|
state.isOpenSocket = false;
|
|||
|
|
// console.log("websocket连接成功");
|
|||
|
|
},
|
|||
|
|
});
|
|||
|
|
// 消息的发送和接收必须在正常连接打开中,才能发送或接收【否则会失败】
|
|||
|
|
state.socketTask.onOpen((res) => {
|
|||
|
|
// console.log("WebSocket连接正常打开中...！");
|
|||
|
|
state.isOpenSocket = true;
|
|||
|
|
state.socketTask.send({
|
|||
|
|
data: '[join]' + 'mobile-'+loginUserId,
|
|||
|
|
async success() {
|
|||
|
|
// console.log("｛" + p + "｝==》消息发送成功");
|
|||
|
|
},
|
|||
|
|
});
|
|||
|
|
// 注：只有连接正常打开中 ，才能正常收到消息
|
|||
|
|
state.socketTask.onMessage((res) => {
|
|||
|
|
// console.log("收到服务器内容：" , JSON.parse(res.data));
|
|||
|
|
state.eventlist = JSON.parse(res.data)
|
|||
|
|
// state.unread.push(JSON.parse(res.data))
|
|||
|
|
if (state.eventlist.USER_ID === loginUserId) {
|
|||
|
|
var innerAudio = uni.createInnerAudioContext();
|
|||
|
|
innerAudio.autoplay = true;
|
|||
|
|
innerAudio.loop = true;
|
|||
|
|
innerAudio.src = '../../static/audio/alarm.mp3';
|
|||
|
|
innerAudio.onPlay(() => {
|
|||
|
|
// console.log('开始播放');
|
|||
|
|
});
|
|||
|
|
innerAudio.onError((e) => {
|
|||
|
|
console.log(e);
|
|||
|
|
// console.log(e.errMsg);
|
|||
|
|
// console.log(e.errCode);
|
|||
|
|
});
|
|||
|
|
if (state.eventlist.MESSAGE) {
|
|||
|
|
uni.showModal({
|
|||
|
|
title: '警告',
|
|||
|
|
content: state.eventlist.MESSAGE,
|
|||
|
|
showCancel: false,
|
|||
|
|
confirmText: '确定',
|
|||
|
|
success: res => {
|
|||
|
|
if (res.confirm) {
|
|||
|
|
innerAudio.stop()
|
|||
|
|
innerAudio = null
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
state.socketTask.onClose((res) => {
|
|||
|
|
state.isOpenSocket = false;
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
WEBSOCKET_SEND(state, p) {
|
|||
|
|
state.socketTask.send({
|
|||
|
|
data: p,
|
|||
|
|
async success() {
|
|||
|
|
// console.log("｛" + p + "｝==》消息发送成功");
|
|||
|
|
},
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
actions: {
|
|||
|
|
WEBSOCKET_INIT({
|
|||
|
|
commit
|
|||
|
|
}, url) {
|
|||
|
|
commit('WEBSOCKET_INIT', url)
|
|||
|
|
},
|
|||
|
|
WEBSOCKET_SEND({
|
|||
|
|
commit
|
|||
|
|
}, p) {
|
|||
|
|
commit('WEBSOCKET_SEND', p)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
})
|