import mqtt from './utils/mqtt'; import update from './utils/update'; import strings from './utils/strings'; //连接的服务器域名 // const host = 'wxs://mqtt.test.radio1964.com'; const host = 'wxs://mqtt.ssl.keepradioon.net:8884' // const host = 'wxs://mqtt.test.radio1964.com:8884'; // const host = 'wxs://mqtt.ssl.keepradioon.net:8884' App({ globalData: { statusBarHeight: 0, navBarHeight: 0, MenuButtonheight: 0, MenuButtonTop: 0, scopeBluetooth: true, ssid: "", pwdData: "", userData: null, userInfo: null, is_debug: 2, // 1 测试环境 // 2正式环境 client: null, oneInitBluetooth: true, mDeviceList: [], // 当前设备 // device: {}, // 设备列表,跟app同步字段 classifyProducts: [], //MQTT连接的配置 options: { clientId: "wx_" + parseInt(Math.random() * 100 + 800, 10), reconnectPeriod: 1000, //1000毫秒,两次重新连接之间的间隔 connectTimeout: 30 * 1000, //1000毫秒,两次重新连接之间的间隔 resubscribe: true, //如果连接断开并重新连接,则会再次自动订阅已订阅的主题(默认true) keepalive: 3, //每3秒发送一次心跳 }, }, ///全局初始化 onLaunch() { var that = this; var userInfo = wx.getStorageSync("userInfo") || ""; if (!strings.isEmpty(userInfo)) { that.globalData.userInfo = userInfo; } ///显示界面 wx.onAppShow(() => { if (that.globalData.userInfo !== null) { if (that.globalData.client) { that.globalData.client.end(true); } console.log("重连"); that.connect(); }; }); ///界面后台化 wx.onAppHide(() => { if (that.globalData.client && that.globalData.client.connected) { that.globalData.client.end(true); }; }); // that.getBluetoothStatus(); //自定义导航栏 获取设备顶部窗口的高度(不同设备窗口高度不一样,根据这个来设置自定义导航栏的高度) wx.getSystemInfo({ success: (res) => { let custom = wx.getMenuButtonBoundingClientRect(); that.globalData.navBarHeight = res.statusBarHeight + custom.height + (custom.top - res.statusBarHeight) * 2; that.globalData.MenuButtonheight = custom.height; that.globalData.MenuButtonTop = custom.top; // var platform = res.platform; // that.globalData.isIOS = platform == "ios"; // that.globalData.isAndroid = platform == "android"; } }); }, onShow: function () { update.update(); }, onHide: function () {}, ///连接设备 connect() { var that = this; that.globalData.client = mqtt.connect(host, that.globalData.options); // 设备连接 that.globalData.client.on('connect', () => { var page = getCurrentPages()[getCurrentPages().length - 1]; if (page.mqttCallback) { page.mqttCallback("connect") }; }); // 消息回调 wx.hideLoading(); that.globalData.client.on("message", function (topic, payload) { var page = getCurrentPages()[getCurrentPages().length - 1]; if (topic.indexOf("status/onoffline") !== -1) { ///当前界面回调 if (page.mqttCallback) { page.mqttCallback("message_onoffline", { topic, payload }); } ///多个界面回调首页 if (getCurrentPages().length != 1) { getCurrentPages()[0].mqttCallback("message_onoffline", { topic, payload }); } } else if (topic.indexOf("user/pub_response") !== -1) { page.mqttCallback("message", { topic, payload }); } }); // 重连 that.globalData.client.on("reconnect", function (errr) { console.log(" 服务器 reconnect的回调", errr); var page = getCurrentPages()[getCurrentPages().length - 1]; if (page.mqttCallback) { page.mqttCallback("reconnect") }; }); // 离线回调 that.globalData.client.on("offline", function (errr) { console.log(" 服务器 offline的回调", errr) var page = getCurrentPages()[getCurrentPages().length - 1]; if (page.mqttCallback) { page.mqttCallback("offline") }; }); // 错误回调 that.globalData.client.on("error", function (error) { console.log(" 服务器 error 的回调" + error) var page = getCurrentPages()[getCurrentPages().length - 1]; if (page.mqttCallback) { page.mqttCallback("error", {}) }; }); }, // 订阅主题 subscribe: function (topic, callback) { var that = this; console.log("gasdfqwerqweqr===00==" + topic); if (that.globalData.client && that.globalData.client.connected) { //订阅主题 that.globalData.client.subscribe(topic, function (err, granted) { if (!err) { if (callback) { callback(); } console.log("订阅成功"); } else { console.log('订阅主题失败'); } }) } else { console.log("服务器已断开"); } }, // 取消订阅 unsubscribe: function (topic) { var that = this; if (that.globalData.client && that.globalData.client.connected) { that.globalData.client.unsubscribe(topic); } else { console.log('请先连接服务器'); } }, /** * 发布信息 * @param {*} data * DstDeviceName:目标设备 * type: 指令 * other:other * ....................... * AIrSMArT_: 设备前缀 */ PubMsg(option, callback) { var that = this; if (strings.isEmpty(that.globalData.userInfo)) { return; } console.log("gasdfqwerqweqr===11==" + JSON.stringify(option)); console.log("gasdfqwerqweqr===22==" + option.type); console.log("gasdfqwerqweqr===33==" + option.DstDeviceName); console.log("gasdfqwerqweqr===44==" + `ALY_${that.globalData.userInfo.userId}`); if (that.globalData.client && that.globalData.client.connected) { const data = { "type": option.type, "DstDeviceName": option.DstDeviceName, "SrcDeviceName": `ALY_${that.globalData.userInfo.userId}`, }; if (option.other) { data.other = option.other; }; that.globalData.client.publish(`/${option.DstDeviceName}/user/sub_control`, `${JSON.stringify(data)}`, (err) => { if (err) { console.log("发布消息失败"); } }); } else { console.log("服务器已断开"); } }, // 获取蓝牙权限 getBluetoothStatus() { var that = this; wx.getSetting({ success(res) { if (res.authSetting["scope.bluetooth"]) { that.globalData.scopeBluetooth = true; } else if (res.authSetting["scope.bluetooth"] === undefined) { that.globalData.scopeBluetooth = false; wx.authorize({ scope: "scope.bluetooth", complete() { that.getBluetoothStatus(); } }); } else { that.globalData.scopeBluetooth = false; wx.showModal({ title: '请打开系统蓝牙进行配网', content: '如已打开蓝牙仍然弹框,请尝试重启小程序', success(res) { if (res.confirm) { console.log('用户点击确定') wx.openSetting({ complete() { // that.getBluetoothStatus(); } }) } else if (res.cancel) { console.log('用户点击取消') } } }) }; if (getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck) { getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck(that.globalData.scopeBluetooth); } // res.authSetting = { // "scope.userInfo": true, // "scope.userLocation": true // } } }) }, }) // "tabBar": { // "borderStyle": "black", // "list": [{ // "pagePath": "pages/index/index", // "text": "首页", // "iconPath": "./img/index_unaction.png", // "selectedIconPath": "./img/index_action.png" // }, // { // "pagePath": "pages/me/me", // "text": "我的", // "iconPath": "./img/me_unaction.png", // "selectedIconPath": "./img/me_action.png" // } // ] // },