|
|
@@ -1,12 +1,12 @@
|
|
|
import mqtt from '../../common/mqtt.js'
|
|
|
import Vue from 'vue'
|
|
|
-import {messageParse,indexOfUuid} from './mqttParse.js'
|
|
|
+import { messageParse, indexOfUuid } from './mqttParse.js'
|
|
|
//import mqtt from 'mqtt/dist/mqtt.js'
|
|
|
|
|
|
const options = {
|
|
|
- clientId: "wx_" + parseInt(Math.random() * 100 + 800, 10),
|
|
|
- keepalive: 28,//每28秒发送一次心跳
|
|
|
- connectTimeout: 15 * 1000,//连接超时的时间
|
|
|
+ clientId: "wx_" + parseInt(Math.random() * 100 + 800, 10),
|
|
|
+ keepalive: 28, //每28秒发送一次心跳
|
|
|
+ connectTimeout: 15 * 1000, //连接超时的时间
|
|
|
};
|
|
|
|
|
|
|
|
|
@@ -14,16 +14,16 @@ let url = 'wss://mqtt.test.radio1964.com'
|
|
|
|
|
|
// #ifdef MP-WEIXIN
|
|
|
url = 'wxs://mqtt.test.radio1964.com'
|
|
|
-// #endif
|
|
|
+ // #endif
|
|
|
|
|
|
|
|
|
|
|
|
//订阅设备在线状态
|
|
|
function subscribeDevicesStatus(dispatch, deviceList) {
|
|
|
- deviceList.forEach((value) => {
|
|
|
- let topic = `/${value.uuid}/status/onoffline`
|
|
|
- dispatch('subscribe', topic)
|
|
|
- })
|
|
|
+ deviceList.forEach((value) => {
|
|
|
+ let topic = `/${value.uuid}/status/onoffline`
|
|
|
+ dispatch('subscribe', topic)
|
|
|
+ })
|
|
|
}
|
|
|
|
|
|
//订阅消息
|
|
|
@@ -35,340 +35,352 @@ function subscribeDevicesStatus(dispatch, deviceList) {
|
|
|
// }
|
|
|
|
|
|
export default {
|
|
|
- namespaced: true,
|
|
|
- state: {
|
|
|
- //当前选择的设备
|
|
|
- currentDevice: null,
|
|
|
- //用户设备列表
|
|
|
- deviceList: [],
|
|
|
- //mqtt客户端
|
|
|
- mqttClient: null,
|
|
|
- //收到的消息的历史记录
|
|
|
- msgList: [],
|
|
|
- //设备的播放信息
|
|
|
- playInfo: {
|
|
|
- title: "",
|
|
|
- artist: "",
|
|
|
- albumURI: "",
|
|
|
- songInfoID: "",
|
|
|
- songAlbumID: "",
|
|
|
- Duration: 0,
|
|
|
- channel: 1,
|
|
|
- audioType: 1,
|
|
|
- PlayState: 3,
|
|
|
- PlayMode: 0
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- },
|
|
|
- getters: {
|
|
|
- //mqtt连接状态
|
|
|
- connected: state => {
|
|
|
- return state.mqttClient && state.mqttClient.connected
|
|
|
- },
|
|
|
-
|
|
|
- },
|
|
|
- mutations: {
|
|
|
- //添加设备
|
|
|
- addDevice(state, device) {
|
|
|
- state.deviceList.push(device)
|
|
|
- },
|
|
|
- //设置当前选择的设备
|
|
|
- setCurrentDevice(state, device) {
|
|
|
- //state.currentDevice = device
|
|
|
- Vue.set(state, 'currentDevice', device)
|
|
|
- },
|
|
|
- //移除设备
|
|
|
- removeDevice(state, device) {
|
|
|
- let index = state.deviceList.indexOf(device)
|
|
|
- state.deviceList.slice(index, 1)
|
|
|
- },
|
|
|
- //连接mqtt服务器 clientId为wx_加上用户的uid
|
|
|
- connect(state, clientId) {
|
|
|
- console.log(`connect clientId = ${clientId}`);
|
|
|
- options.clientId = clientId
|
|
|
- state.mqttClient = mqtt.connect(url, options)
|
|
|
- },
|
|
|
- //token失效，退出登录，需要清除数据
|
|
|
- release(state) {
|
|
|
- state.deviceList = []
|
|
|
- state.currentDevice = null
|
|
|
- state.mqttClient = null
|
|
|
- },
|
|
|
- //更新设备信息
|
|
|
- updateDevice(state, data) {
|
|
|
- Vue.set(state.deviceList, data.index, data.device)
|
|
|
- },
|
|
|
- //更新播放信息
|
|
|
- updatePlayInfo(state, playinfo) {
|
|
|
- state.playInfo = playinfo
|
|
|
- }
|
|
|
-
|
|
|
- },
|
|
|
- actions: {
|
|
|
- //添加设备
|
|
|
- addDevice({ state, dispatch, commit, getters }, data) {
|
|
|
- let clientId = (data.clientId) ? data.clientId : options.clientId
|
|
|
- let device = data.device
|
|
|
-
|
|
|
- console.log(`deviceList = ${state.deviceList} device = ${device}`);
|
|
|
- //判断设备是否存在deviceList中
|
|
|
- let findDevice = state.deviceList.find((item) => {
|
|
|
- return item.uuid === device.uuid
|
|
|
- })
|
|
|
- if (findDevice == null) {
|
|
|
- if (state.deviceList.length === 0) {
|
|
|
- //设置当前的设备为添加的设备
|
|
|
- commit('setCurrentDevice', device)
|
|
|
- }
|
|
|
- //添加设备
|
|
|
- state.deviceList.push(device)
|
|
|
- //如果已经连接
|
|
|
- if (getters.connected) {
|
|
|
- //订阅设备是否在线
|
|
|
- subscribeDevicesStatus(dispatch, [device])
|
|
|
- //if (state.currentDevice && state.currentDevice.uuid === device.uuid) {
|
|
|
- //订阅当前设备的消息
|
|
|
- //subscribeCurrDevice(dispatch, state.currentDevice)
|
|
|
- //}
|
|
|
-
|
|
|
- } else {//如果没有连接
|
|
|
- //连接服务器
|
|
|
- dispatch('connect', clientId)
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- },
|
|
|
- //删除设备
|
|
|
- removeDevice({ state, dispatch, commit, getters }, device) {
|
|
|
- //判断设备是否存在deviceList中
|
|
|
- let findDevice = state.deviceList.find((item) => {
|
|
|
- return item.uuid === device.uuid
|
|
|
- })
|
|
|
- if (findDevice) {
|
|
|
- //取消此设备的订阅
|
|
|
- let topic = `/${device.uuid}/status/onoffline`
|
|
|
- dispatch('unsubscribe', topic)
|
|
|
- topic = `/${device.uuid}/status/pub_response`
|
|
|
- dispatch('unsubscribe', topic)
|
|
|
- //在设备列表中删除此设备
|
|
|
- commit('removeDevice', findDevice)
|
|
|
- //如果删除的是选中的设备
|
|
|
- if (currentDevice && state.currentDevice.uuid == device.uuid) {
|
|
|
- //清除当前选中的设备 todo 还是自动选中在线的设备
|
|
|
- commit('setCurrentDevice', null)
|
|
|
- }
|
|
|
-
|
|
|
- if (state.deviceList.length === 0) {//所有的设备都已经删除,关闭连接
|
|
|
- dispatch('disconnect')
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
-
|
|
|
- //连接设备
|
|
|
- connect({ state, dispatch, commit, getters }, clientId) {
|
|
|
- if (state.mqttClient == null) {
|
|
|
- //连接服务器
|
|
|
- commit('connect', clientId)
|
|
|
- //连接成功回调
|
|
|
- state.mqttClient.on("connect", function () {
|
|
|
- console.log("connect success!");
|
|
|
- //订阅设备是否在线
|
|
|
- subscribeDevicesStatus(dispatch, state.deviceList)
|
|
|
- //订阅当前设备的消息
|
|
|
- //subscribeCurrDevice(dispatch, state.currentDevice)
|
|
|
- });
|
|
|
-
|
|
|
- //异常回调
|
|
|
- state.mqttClient.on("error", function (err) {
|
|
|
- console.log(err);
|
|
|
- });
|
|
|
-
|
|
|
- state.mqttClient.on('offline', function () {
|
|
|
-
|
|
|
- console.log(`offline callback`);
|
|
|
- })
|
|
|
-
|
|
|
- state.mqttClient.on('end', function () {
|
|
|
-
|
|
|
- console.log(`end callback`);
|
|
|
- })
|
|
|
- //网络断开的回调
|
|
|
- state.mqttClient.on('close', function () {
|
|
|
- console.log(`close callback`);
|
|
|
- })
|
|
|
- //收到消息的回调
|
|
|
- state.mqttClient.on('message', function (topic, message) {
|
|
|
- console.log(`message = ${message.toString()}`);
|
|
|
- //解析收到的消息
|
|
|
- messageParse({ state, dispatch, commit, getters }, topic, message)
|
|
|
-
|
|
|
- //这是测试的
|
|
|
- state.msgList.push({
|
|
|
- topic: topic.toString(),
|
|
|
- msg: message.toString(),
|
|
|
- });
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- })
|
|
|
- } else {
|
|
|
- if (!state.mqttClient.connected) {
|
|
|
- console.log("reconnect");
|
|
|
- state.mqttClient.reconnect()
|
|
|
- //重连成功的回调
|
|
|
- state.mqttClient.on("reconnect", function () {
|
|
|
- console.log("reconnect success!");
|
|
|
-
|
|
|
- });
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- //断开mqtt的连接
|
|
|
- disconnect({ state, commit }, isRelease) {
|
|
|
- console.log('disconnect')
|
|
|
- if (state.mqttClient) {
|
|
|
- state.mqttClient.end(false, () => {
|
|
|
- console.log(`state.mqttClient.connected = ${state.mqttClient.connected}`);
|
|
|
- })
|
|
|
- }
|
|
|
- if (isRelease) {
|
|
|
- //清除数据
|
|
|
- commit('release')
|
|
|
- }
|
|
|
- },
|
|
|
- //发布消息
|
|
|
- publishMsg({ state, dispatch, getters }, msg) {
|
|
|
- let uuid = msg.uuid
|
|
|
- let type = msg.mqttType;
|
|
|
- let other = msg.other;
|
|
|
- if (!getters.connected) {
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- reject('连接已断开')
|
|
|
- });
|
|
|
- } else {
|
|
|
- let index = indexOfUuid(state.deviceList,uuid)
|
|
|
- if (index >= 0) {
|
|
|
- let device = state.deviceList[index];
|
|
|
- if(device.online){
|
|
|
- let topic = `/${uuid}/user/sub_control`;
|
|
|
- let json = {
|
|
|
- 'DstDeviceName': uuid,
|
|
|
- 'SrcDeviceName': options.clientId,
|
|
|
- 'type': type,
|
|
|
- }
|
|
|
- if (other) {
|
|
|
- json.other = other
|
|
|
- }
|
|
|
- let payload = JSON.stringify(json)
|
|
|
- console.log(`publishWithType topic = ${topic} payload = ${payload}`);
|
|
|
- return dispatch('publish', { topic, payload })
|
|
|
- }else{
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- reject('设备已经离线')
|
|
|
- });
|
|
|
- }
|
|
|
- }else{
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- reject('没有此设备')
|
|
|
- });
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
-
|
|
|
- //发布消息
|
|
|
- publishWithType({ state, dispatch, getters }, payload) {
|
|
|
- //console.log(payload);
|
|
|
- //console.log(options);
|
|
|
- let type = payload.mqttType;
|
|
|
- let other = payload.other;
|
|
|
- if (!getters.connected) {
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- reject('连接已断开')
|
|
|
- });
|
|
|
- } else if (!(state.currentDevice && state.currentDevice.online)) {
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- reject('设备已经离线')
|
|
|
- });
|
|
|
- } else {
|
|
|
- let topic = `/${state.currentDevice.uuid}/user/sub_control`;
|
|
|
- //console.log(payload);
|
|
|
- //console.log(payload.mqttType);
|
|
|
- let json = {
|
|
|
- 'DstDeviceName': state.currentDevice.uuid,
|
|
|
- 'SrcDeviceName': options.clientId,
|
|
|
- 'type': type,
|
|
|
- }
|
|
|
- if (other) {
|
|
|
- json.other = other
|
|
|
- }
|
|
|
- let payload = JSON.stringify(json)
|
|
|
- console.log(`publishWithType topic = ${topic} payload = ${payload}`);
|
|
|
- return dispatch('publish', { topic, payload })
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- },
|
|
|
-
|
|
|
- //发布消息
|
|
|
- publish({ state, commit, getters }, message) {
|
|
|
- console.log('publish');
|
|
|
- console.log(message);
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- if (getters.connected) {
|
|
|
- //发布消息
|
|
|
- state.mqttClient.publish(message.topic, message.payload, (err) => {
|
|
|
- if (err) {
|
|
|
- console.warn(err);
|
|
|
- reject(err)
|
|
|
- } else {
|
|
|
- resolve()
|
|
|
- }
|
|
|
- })
|
|
|
- } else {
|
|
|
- reject("mqttClient is not connected")
|
|
|
- }
|
|
|
- })
|
|
|
- },
|
|
|
- //订阅消息
|
|
|
- subscribe({ state, commit, getters }, topic) {
|
|
|
- console.log(`subscribe topic = ${topic}`);
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- if (getters.connected) {
|
|
|
- //发布消息
|
|
|
- state.mqttClient.subscribe(topic, (err) => {
|
|
|
- if (err) {
|
|
|
- console.log(err);
|
|
|
- reject(err)
|
|
|
- } else {
|
|
|
- resolve()
|
|
|
- }
|
|
|
- })
|
|
|
- } else {
|
|
|
- reject("mqttClient is not connected")
|
|
|
- }
|
|
|
- })
|
|
|
- },
|
|
|
- //解除订阅消息
|
|
|
- unsubscribe({ state, commit, getters }, topic) {
|
|
|
- console.log(`unsubscribe topic = ${topic}`);
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- if (getters.connected) {
|
|
|
- //发布消息
|
|
|
- state.mqttClient.unsubscribe(topic, (err) => {
|
|
|
- if (err) {
|
|
|
- console.log(err);
|
|
|
- reject(err)
|
|
|
- } else {
|
|
|
- resolve()
|
|
|
- }
|
|
|
- })
|
|
|
- } else {
|
|
|
- reject("mqttClient is not connected")
|
|
|
- }
|
|
|
- })
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
+ namespaced: true,
|
|
|
+ state: {
|
|
|
+ //当前选择的设备
|
|
|
+ currentDevice: null,
|
|
|
+ //用户设备列表
|
|
|
+ deviceList: [],
|
|
|
+ //mqtt客户端
|
|
|
+ mqttClient: null,
|
|
|
+ //收到的消息的历史记录
|
|
|
+ msgList: [],
|
|
|
+ //设备的播放信息
|
|
|
+ playInfo: {
|
|
|
+ title: "",
|
|
|
+ artist: "",
|
|
|
+ albumURI: "",
|
|
|
+ songInfoID: "",
|
|
|
+ songAlbumID: "",
|
|
|
+ Duration: 0,
|
|
|
+ channel: 1,
|
|
|
+ audioType: 1,
|
|
|
+ PlayState: 3,
|
|
|
+ PlayMode: 0
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ },
|
|
|
+ getters: {
|
|
|
+ //mqtt连接状态
|
|
|
+ connected: state => {
|
|
|
+ return state.mqttClient && state.mqttClient.connected
|
|
|
+ },
|
|
|
+ //更具index找到对应的设备
|
|
|
+ getDeviceByIndex: (state) => (index) => {
|
|
|
+ if (index < 0 || index >= state.deviceList.length) {
|
|
|
+ return null
|
|
|
+ } else {
|
|
|
+ return state.deviceList[index]
|
|
|
+ }
|
|
|
+ },
|
|
|
+ //根据uuid找到对应的设备
|
|
|
+ getDeviceById: (state) => (uuid) => {
|
|
|
+ return state.deviceList.find(todo => todo.uuid === uuid)
|
|
|
+ }
|
|
|
+
|
|
|
+ },
|
|
|
+ mutations: {
|
|
|
+ //添加设备
|
|
|
+ addDevice(state, device) {
|
|
|
+ state.deviceList.push(device)
|
|
|
+ },
|
|
|
+ //设置当前选择的设备
|
|
|
+ setCurrentDevice(state, device) {
|
|
|
+ //state.currentDevice = device
|
|
|
+ Vue.set(state, 'currentDevice', device)
|
|
|
+ },
|
|
|
+ //移除设备
|
|
|
+ removeDevice(state, device) {
|
|
|
+ let index = state.deviceList.indexOf(device)
|
|
|
+ state.deviceList.slice(index, 1)
|
|
|
+ },
|
|
|
+ //连接mqtt服务器 clientId为wx_加上用户的uid
|
|
|
+ connect(state, clientId) {
|
|
|
+ console.log(`connect clientId = ${clientId}`);
|
|
|
+ options.clientId = clientId
|
|
|
+ state.mqttClient = mqtt.connect(url, options)
|
|
|
+ },
|
|
|
+ //token失效，退出登录，需要清除数据
|
|
|
+ release(state) {
|
|
|
+ state.deviceList = []
|
|
|
+ state.currentDevice = null
|
|
|
+ state.mqttClient = null
|
|
|
+ },
|
|
|
+ //更新设备信息
|
|
|
+ updateDevice(state, data) {
|
|
|
+ Vue.set(state.deviceList, data.index, data.device)
|
|
|
+ },
|
|
|
+ //更新播放信息
|
|
|
+ updatePlayInfo(state, playinfo) {
|
|
|
+ state.playInfo = playinfo
|
|
|
+ }
|
|
|
+
|
|
|
+ },
|
|
|
+ actions: {
|
|
|
+ //添加设备
|
|
|
+ addDevice({ state, dispatch, commit, getters }, data) {
|
|
|
+ let clientId = (data.clientId) ? data.clientId : options.clientId
|
|
|
+ let device = data.device
|
|
|
+
|
|
|
+ console.log(`deviceList = ${state.deviceList} device = ${device}`);
|
|
|
+ //判断设备是否存在deviceList中
|
|
|
+ let findDevice = state.deviceList.find((item) => {
|
|
|
+ return item.uuid === device.uuid
|
|
|
+ })
|
|
|
+ if (findDevice == null) {
|
|
|
+ if (state.deviceList.length === 0) {
|
|
|
+ //设置当前的设备为添加的设备
|
|
|
+ commit('setCurrentDevice', device)
|
|
|
+ }
|
|
|
+ //添加设备
|
|
|
+ state.deviceList.push(device)
|
|
|
+ //如果已经连接
|
|
|
+ if (getters.connected) {
|
|
|
+ //订阅设备是否在线
|
|
|
+ subscribeDevicesStatus(dispatch, [device])
|
|
|
+ //if (state.currentDevice && state.currentDevice.uuid === device.uuid) {
|
|
|
+ //订阅当前设备的消息
|
|
|
+ //subscribeCurrDevice(dispatch, state.currentDevice)
|
|
|
+ //}
|
|
|
+
|
|
|
+ } else { //如果没有连接
|
|
|
+ //连接服务器
|
|
|
+ dispatch('connect', clientId)
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ },
|
|
|
+ //删除设备
|
|
|
+ removeDevice({ state, dispatch, commit, getters }, device) {
|
|
|
+ //判断设备是否存在deviceList中
|
|
|
+ let findDevice = state.deviceList.find((item) => {
|
|
|
+ return item.uuid === device.uuid
|
|
|
+ })
|
|
|
+ if (findDevice) {
|
|
|
+ //取消此设备的订阅
|
|
|
+ let topic = `/${device.uuid}/status/onoffline`
|
|
|
+ dispatch('unsubscribe', topic)
|
|
|
+ topic = `/${device.uuid}/status/pub_response`
|
|
|
+ dispatch('unsubscribe', topic)
|
|
|
+ //在设备列表中删除此设备
|
|
|
+ commit('removeDevice', findDevice)
|
|
|
+ //如果删除的是选中的设备
|
|
|
+ if (currentDevice && state.currentDevice.uuid == device.uuid) {
|
|
|
+ //清除当前选中的设备 todo 还是自动选中在线的设备
|
|
|
+ commit('setCurrentDevice', null)
|
|
|
+ }
|
|
|
+
|
|
|
+ if (state.deviceList.length === 0) { //所有的设备都已经删除,关闭连接
|
|
|
+ dispatch('disconnect')
|
|
|
+ }
|
|
|
+ }
|
|
|
+ },
|
|
|
+
|
|
|
+ //连接设备
|
|
|
+ connect({ state, dispatch, commit, getters }, clientId) {
|
|
|
+ if (state.mqttClient == null) {
|
|
|
+ //连接服务器
|
|
|
+ commit('connect', clientId)
|
|
|
+ //连接成功回调
|
|
|
+ state.mqttClient.on("connect", function() {
|
|
|
+ console.log("connect success!");
|
|
|
+ //订阅设备是否在线
|
|
|
+ subscribeDevicesStatus(dispatch, state.deviceList)
|
|
|
+ //订阅当前设备的消息
|
|
|
+ //subscribeCurrDevice(dispatch, state.currentDevice)
|
|
|
+ });
|
|
|
+
|
|
|
+ //异常回调
|
|
|
+ state.mqttClient.on("error", function(err) {
|
|
|
+ console.log(err);
|
|
|
+ });
|
|
|
+
|
|
|
+ state.mqttClient.on('offline', function() {
|
|
|
+
|
|
|
+ console.log(`offline callback`);
|
|
|
+ })
|
|
|
+
|
|
|
+ state.mqttClient.on('end', function() {
|
|
|
+
|
|
|
+ console.log(`end callback`);
|
|
|
+ })
|
|
|
+ //网络断开的回调
|
|
|
+ state.mqttClient.on('close', function() {
|
|
|
+ console.log(`close callback`);
|
|
|
+ })
|
|
|
+ //收到消息的回调
|
|
|
+ state.mqttClient.on('message', function(topic, message) {
|
|
|
+ console.log(`message = ${message.toString()}`);
|
|
|
+ //解析收到的消息
|
|
|
+ messageParse({ state, dispatch, commit, getters }, topic, message)
|
|
|
+
|
|
|
+ //这是测试的
|
|
|
+ state.msgList.push({
|
|
|
+ topic: topic.toString(),
|
|
|
+ msg: message.toString(),
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ if (!state.mqttClient.connected) {
|
|
|
+ console.log("reconnect");
|
|
|
+ state.mqttClient.reconnect()
|
|
|
+ //重连成功的回调
|
|
|
+ state.mqttClient.on("reconnect", function() {
|
|
|
+ console.log("reconnect success!");
|
|
|
+
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ },
|
|
|
+ //断开mqtt的连接
|
|
|
+ disconnect({ state, commit }, isRelease) {
|
|
|
+ console.log('disconnect')
|
|
|
+ if (state.mqttClient) {
|
|
|
+ state.mqttClient.end(false, () => {
|
|
|
+ console.log(`state.mqttClient.connected = ${state.mqttClient.connected}`);
|
|
|
+ })
|
|
|
+ }
|
|
|
+ if (isRelease) {
|
|
|
+ //清除数据
|
|
|
+ commit('release')
|
|
|
+ }
|
|
|
+ },
|
|
|
+ //发布消息
|
|
|
+ publishMsg({ state, dispatch, getters }, msg) {
|
|
|
+ let uuid = msg.uuid
|
|
|
+ let type = msg.mqttType;
|
|
|
+ let other = msg.other;
|
|
|
+ if (!getters.connected) {
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ reject('连接已断开')
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ let index = indexOfUuid(state.deviceList, uuid)
|
|
|
+ if (index >= 0) {
|
|
|
+ let device = state.deviceList[index];
|
|
|
+ if (device.online) {
|
|
|
+ let topic = `/${uuid}/user/sub_control`;
|
|
|
+ let json = {
|
|
|
+ 'DstDeviceName': uuid,
|
|
|
+ 'SrcDeviceName': options.clientId,
|
|
|
+ 'type': type,
|
|
|
+ }
|
|
|
+ if (other) {
|
|
|
+ json.other = other
|
|
|
+ }
|
|
|
+ let payload = JSON.stringify(json)
|
|
|
+ console.log(`publishWithType topic = ${topic} payload = ${payload}`);
|
|
|
+ return dispatch('publish', { topic, payload })
|
|
|
+ } else {
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ reject('设备已经离线')
|
|
|
+ });
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ reject('没有此设备')
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ },
|
|
|
+
|
|
|
+ //发布消息
|
|
|
+ publishWithType({ state, dispatch, getters }, payload) {
|
|
|
+ //console.log(payload);
|
|
|
+ //console.log(options);
|
|
|
+ let type = payload.mqttType;
|
|
|
+ let other = payload.other;
|
|
|
+ if (!getters.connected) {
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ reject('连接已断开')
|
|
|
+ });
|
|
|
+ } else if (!(state.currentDevice && state.currentDevice.online)) {
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ reject('设备已经离线')
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ let topic = `/${state.currentDevice.uuid}/user/sub_control`;
|
|
|
+ //console.log(payload);
|
|
|
+ //console.log(payload.mqttType);
|
|
|
+ let json = {
|
|
|
+ 'DstDeviceName': state.currentDevice.uuid,
|
|
|
+ 'SrcDeviceName': options.clientId,
|
|
|
+ 'type': type,
|
|
|
+ }
|
|
|
+ if (other) {
|
|
|
+ json.other = other
|
|
|
+ }
|
|
|
+ let payload = JSON.stringify(json)
|
|
|
+ console.log(`publishWithType topic = ${topic} payload = ${payload}`);
|
|
|
+ return dispatch('publish', { topic, payload })
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ },
|
|
|
+
|
|
|
+ //发布消息
|
|
|
+ publish({ state, commit, getters }, message) {
|
|
|
+ console.log('publish');
|
|
|
+ console.log(message);
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ if (getters.connected) {
|
|
|
+ //发布消息
|
|
|
+ state.mqttClient.publish(message.topic, message.payload, (err) => {
|
|
|
+ if (err) {
|
|
|
+ console.warn(err);
|
|
|
+ reject(err)
|
|
|
+ } else {
|
|
|
+ resolve()
|
|
|
+ }
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ reject("mqttClient is not connected")
|
|
|
+ }
|
|
|
+ })
|
|
|
+ },
|
|
|
+ //订阅消息
|
|
|
+ subscribe({ state, commit, getters }, topic) {
|
|
|
+ console.log(`subscribe topic = ${topic}`);
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ if (getters.connected) {
|
|
|
+ //发布消息
|
|
|
+ state.mqttClient.subscribe(topic, (err) => {
|
|
|
+ if (err) {
|
|
|
+ console.log(err);
|
|
|
+ reject(err)
|
|
|
+ } else {
|
|
|
+ resolve()
|
|
|
+ }
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ reject("mqttClient is not connected")
|
|
|
+ }
|
|
|
+ })
|
|
|
+ },
|
|
|
+ //解除订阅消息
|
|
|
+ unsubscribe({ state, commit, getters }, topic) {
|
|
|
+ console.log(`unsubscribe topic = ${topic}`);
|
|
|
+ return new Promise((resolve, reject) => {
|
|
|
+ if (getters.connected) {
|
|
|
+ //发布消息
|
|
|
+ state.mqttClient.unsubscribe(topic, (err) => {
|
|
|
+ if (err) {
|
|
|
+ console.log(err);
|
|
|
+ reject(err)
|
|
|
+ } else {
|
|
|
+ resolve()
|
|
|
+ }
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ reject("mqttClient is not connected")
|
|
|
+ }
|
|
|
+ })
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
|
|
|
}
|
houjie