(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0daf21"],{"6e84":function(t,e,n){"use strict";n.r(e);var s=function(){var t=this,e=t.$createElement,n=t._self._c||e;return n("div",[t._v(t._s(t.title))])},i=[],c=n("e7fc"),r=n("0fea"),o={name:"MqttIot",data:function(){return{client:"",clientCount:0,topic:[],title:"",receivedMessage:null,mqttOpts:{keepalive:60,clientId:"clientId-"+Math.random().toString(16).substr(2,8),username:"",password:"",connectTimeout:1e4,path:"/mqtt"},mqttUrl:{head:"ws",host:"",port:8083,tailPath:"mqtt"},url:{subscribe:"/equipment/subscribe",queryById:"/serve/deploy/mqtt/queryById"}}},props:["serverId"],methods:{initMqtt:function(){var t=this;Object(r["c"])(this.url.queryById,{id:this.serverId}).then((function(e){if(e.success&&null!=e.result){t.mqttUrl.host=e.result.address,t.mqttOpts.username=e.result.userName,t.mqttOpts.password=e.result.userPassword;var n=JSON.parse(JSON.stringify(t.mqttOpts));t.client=c["connect"]("".concat(t.mqttUrl.head,"://").concat(t.mqttUrl.host,":").concat(t.mqttUrl.port,"/").concat(t.mqttUrl.tailPath),n),t.client.on("connect",t.handleConnect),t.client.on("message",t.handleMessage),t.client.on("reconnect",t.handleReconnect),t.client.on("error",t.handleError)}}))},disconnectMqtt:function(){this.client.end()},handleConnect:function(){var t=this;Object(r["c"])(this.url.subscribe,{id:this.serverId}).then((function(e){e.success&&t.client.subscribe(e.result)}))},handleMessage:function(t,e){this.receivedMessage=JSON.parse(e.toString()),"ActualDevices"===t.split("/")[2]?this.$bus.$emit("solid-iot-topic",e.toString()):this.$bus.$emit("empty-iot-topic",e.toString()),this.title=this.receivedMessage.msg},handleReconnect:function(t){this.clientCount++,this.clientCount>=10&&this.client.end()},handleError:function(t){},mqttPublish:function(t,e){this.client.publish(t,JSON.stringify(e))}}},l=o,u=n("2877"),a=Object(u["a"])(l,s,i,!1,null,null,null);e["default"]=a.exports}}]);
|
