124 lines
3.1 KiB
Vue
124 lines
3.1 KiB
Vue
<script>
|
||
import indexUtil from "@/utils/indexUtil/index.js"
|
||
import {
|
||
deviceControl,
|
||
dcMsgType,
|
||
dcEventType
|
||
} from "@/utils/indexUtil/dc.js"
|
||
import mqttUtil from "@/utils/mqttUtil.js"
|
||
|
||
export default {
|
||
data() {
|
||
return {
|
||
ijs: new indexUtil(), //全局地块列表管理
|
||
dc: new deviceControl(2, this.dcEventHandler), // 设备控制类
|
||
mqtt: new mqttUtil(this.mqttMsgHandler), //Mqtt
|
||
}
|
||
},
|
||
globalData: {},
|
||
onLaunch: function() {
|
||
console.log('App Launch')
|
||
},
|
||
onShow: function() {
|
||
console.log('App Show')
|
||
const that = this;
|
||
|
||
uni.$off("notify-update-land");
|
||
uni.$on("notify-update-land", (data) => {
|
||
// console.error("index监听地块更新：", data)
|
||
// uni.$emit("index-showLoading", true);
|
||
uni.showLoading();
|
||
that.getWoList(data, null);
|
||
});
|
||
},
|
||
onHide: function() {
|
||
console.log('App Hide')
|
||
},
|
||
methods: {
|
||
getWoList(land, wo) {
|
||
const that = this;
|
||
if (land && wo) {
|
||
that.dc.setData(land, wo);
|
||
}
|
||
that.ijs.getWoList(land).then(res => {
|
||
that.dc.setData(land, res.data);
|
||
uni.$emit("update-land-index", res.data)
|
||
uni.$emit("update-land-indexMap", res.data)
|
||
uni.hideLoading();
|
||
}).catch(() => {
|
||
uni.hideLoading();
|
||
});
|
||
},
|
||
dcEventHandler(type, params, item) {
|
||
switch (type) {
|
||
case dcEventType.interface: // 界面操作
|
||
uni.$emit("open-angle-slider", params)
|
||
break;
|
||
case dcEventType.refresh: // 命令刷新设备
|
||
this.ijs.sendDeviceRefresh(item, params).then(res => {}).catch(error => {
|
||
this.dc.clearRefreshCountdown(params.deviceCode);
|
||
});
|
||
break;
|
||
case dcEventType.refreshApi: // 接口刷新阀门
|
||
break;
|
||
case dcEventType.send: // 命令控制设备
|
||
this.ijs.sendDeviceControl(params);
|
||
break;
|
||
default:
|
||
// 消息通知
|
||
if (params.success == dcMsgType.ok) {
|
||
this.$modal.msgSuccess(params.message);
|
||
} else if (params.success == dcMsgType.err) {
|
||
this.$modal.msgError(params.message);
|
||
} else {
|
||
this.$modal.msgWarning(params.message);
|
||
}
|
||
break;
|
||
}
|
||
},
|
||
//Mqtt连接
|
||
mqttLink(userId) {
|
||
this.mqtt.link(userId);
|
||
},
|
||
//Mqtt订阅
|
||
mqttSubscribes(topic) {
|
||
if (topic) {
|
||
this.mqtt.subscribes(topic);
|
||
} else {
|
||
const topic = this.dc.topic;
|
||
if (topic.newV.length) {
|
||
this.mqtt.subscribes(topic.newV);
|
||
}
|
||
if (topic.oldV.length) {
|
||
this.mqtt.subscribes(topic.oldV);
|
||
}
|
||
}
|
||
},
|
||
//Mqtt取消订阅
|
||
mqttUnsubscribes(topic) {
|
||
this.mqtt.unsubscribes(topic);
|
||
},
|
||
//Mqtt断开连接
|
||
mqttEnd() {
|
||
this.mqtt.over();
|
||
},
|
||
//Mqtt消息回调
|
||
mqttMsgHandler(topic, data) {
|
||
console.error("mqttMsgHandler:", {
|
||
topic: topic,
|
||
data: JSON.parse(data),
|
||
});
|
||
this.dc.handleMessage(topic, JSON.parse(data));
|
||
uni.$emit("mqttMsg-index", JSON.parse(data))
|
||
uni.$emit("mqttMsg-indexMap", JSON.parse(data))
|
||
},
|
||
}
|
||
}
|
||
</script>
|
||
|
||
<style lang="scss">
|
||
@import '@/uni_modules/uview-plus/index.scss';
|
||
@import '@/static/scss/index.scss';
|
||
@import '@/static/alifont/iconfont.css';
|
||
@import '@/static/scss/app.css';
|
||
</style> |