wxmini/app.js

// app.ts
import mqtt from './utils/mqtt';
const eventBus = require('./utils/eventBus')

//连接的服务器域名
// const host = 'wxs://mqtt.test.radio1964.com';
// 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,
    newDeviceId: null, 
    is_debug: 2, // 1 测试环境 // 2正式环境
    client: null,
    oneInitBluetooth: true,
        systemInfo:null,
    //MQTT连接的配置
    options: {
      clientId: "wx_" + parseInt(Math.random() * 100 + 800, 10),
      reconnectPeriod: 1000, //1000毫秒，两次重新连接之间的间隔
      connectTimeout: 30 * 1000, //1000毫秒，两次重新连接之间的间隔
      resubscribe: true, //如果连接断开并重新连接，则会再次自动订阅已订阅的主题（默认true
      keepalive: 3,//每3秒发送一次心跳
    },
  },
  eventBus: eventBus,
  /**
   * 连接设备
   * mqttCallback：mqtt回调统一方法
   */
  connect() {
    this.globalData.client = mqtt.connect(host, this.globalData.options);
    // 连接成功
    this.globalData.client.on('connect', ()=> {
      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
      if(pageinfo.mqttCallback) {
        pageinfo.mqttCallback("connect")
      };
      
    });
    // 接收消息
    this.globalData.client.on("message", function(topic, payload) {
      wx.hideLoading();
      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
      const thisPageIsIndex = getCurrentPages().length === 1;
      if(pageinfo.mqttCallback) {
        if(topic.indexOf("status/onoffline") !== -1) {
          pageinfo.mqttCallback("message_onoffline", {topic, payload});
          if(!thisPageIsIndex) {
            getCurrentPages()[0].mqttCallback("message_onoffline", {topic, payload})
          }
        } else if(topic.indexOf("user/pub_response") !== -1) {
          pageinfo.mqttCallback("message", {topic, payload});
        }
      };
    });
    //服务器连接异常的回调
    this.globalData.client.on("error", function(error) {
      console.log(" 服务器 error 的回调" + error)
      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
      if(pageinfo.mqttCallback) {
        pageinfo.mqttCallback("error")
      };
    })

    // 服务器重连
    this.globalData.client.on("reconnect", function(errr) {
      console.log(" 服务器 reconnect的回调", errr);
      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
      if(pageinfo.mqttCallback) {
        pageinfo.mqttCallback("reconnect")
      };
    })
    //服务器断开连接
    this.globalData.client.on("offline", function(errr) {
      console.log(" 服务器 offline的回调", errr)
      const pageinfo = getCurrentPages()[getCurrentPages().length - 1];
      if(pageinfo.mqttCallback) {
        pageinfo.mqttCallback("offline")
      };
    })
  },

  changeUserRight() {
    const i = wx.getStorageSync('rightId') || 0
    const id = i === 0 ? 1 : 0
    wx.setStorageSync('rightId', id)
    getApp().eventBus.emit('rightChange', id)
  },


  // 订阅主题
  subscribe: function(topic, callback) {

    if (this.globalData.client && this.globalData.client.connected) {
      //订阅主题
      this.globalData.client.subscribe(topic, function(err, granted) {
        if (!err) {
          if(callback) {
            callback();
          }
          console.log("订阅成功");
        } else {
          console.log('订阅主题失败');
        }
      })
    } else {
      console.log("服务器已断开");
      // wx.showToast({
      //   title: '服务器已断开',
      //   icon: 'error',
      //   duration: 2000
      // })
    }
  },
  // 取消订阅
  unsubscribe: function(Topic) {
    if (this.globalData.client && this.globalData.client.connected) {
      this.globalData.client.unsubscribe(Topic);
    } else {
      console.log('请先连接服务器');
      // wx.showToast({
      //   title: '请先连接服务器',
      //   icon: 'none',
      //   duration: 2000
      // })
    }
  },

  /**
   * 发布信息
   * @param {*} data
   * DstDeviceName：目标设备
   * type: 指令
   * other：other
   * .......................
   * AIrSMArT_: 设备前缀
   */
  PubMsg(option, callback) {
    if (this.globalData.client && this.globalData.client.connected) {
      wx.showLoading({
        title: '请稍后',
      });
      const data = {"DstDeviceName": option.DstDeviceName,"SrcDeviceName": `ALY_${this.globalData.userInfo.userId}`,"type": option.type};
      if(option.other) {
        data.other = option.other;
      };
      this.globalData.client.publish(`/${option.DstDeviceName}/user/sub_control`, `${JSON.stringify(data)}`,(err) => {
        if (err) {
          console.log("发布消息失败");
        }
      });
    } else {
      console.log("服务器已断开");
      // wx.showToast({
      //   title: '服务器已断开',
      //   icon: 'error',
      //   duration: 2000
      // })
    }
  },
  onLaunch() {
    var _this = this;
    wx.onAppHide(()=> {
      if(_this.globalData.client && _this.globalData.client.connected){
        _this.globalData.client.end(true);
        _this.globalData.client.end(true);
        console.log("断开");
      };
    });

    wx.onAppShow(()=> {
      console.log("加载")
      if(_this.globalData.userInfo !== null){
        if(_this.globalData.client) {
          _this.globalData.client.end(true);
          _this.globalData.client.end(true);
        }
        console.log("重连");
        _this.connect();
      };
    });
    this.getBluetoothStatus();
    //自定义导航栏 获取设备顶部窗口的高度（不同设备窗口高度不一样，根据这个来设置自定义导航栏的高度）
    wx.getSystemInfo({
      success: (res) => {
        let custom = wx.getMenuButtonBoundingClientRect();
       _this.globalData.systemInfo = res;
        _this.globalData.navBarHeight = res.statusBarHeight + custom.height + (custom.top - res.statusBarHeight) * 2;
        _this.globalData.MenuButtonheight = custom.height;
        _this.globalData.MenuButtonTop = custom.top;
        
      }
      
    })
  },
  // 获取蓝牙权限
  getBluetoothStatus(){
    const _this = this;
    wx.getSetting({
      success (res) {
        if(res.authSetting["scope.bluetooth"]) {
          _this.globalData.scopeBluetooth = true;
        } else if(res.authSetting["scope.bluetooth"] === undefined) {
          _this.globalData.scopeBluetooth = false;
          wx.authorize({ 
            scope: "scope.bluetooth",
            complete () {
              _this.getBluetoothStatus();
            }
          });
        } else {
          _this.globalData.scopeBluetooth = false;
          wx.showModal({
            title: '请打开系统蓝牙进行配网',
            content: '如已打开蓝牙仍然弹框，请尝试重启小程序',
            success (res) {
              if (res.confirm) {
                console.log('用户点击确定')
                wx.openSetting({
                  complete () {
                    // _this.getBluetoothStatus();
                  }
                })
              } else if (res.cancel) {
                console.log('用户点击取消')
              }
            }
          })
        };
        if(getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck) {
          getCurrentPages()[getCurrentPages().length - 1].getBluetoothStatusCallck(_this.globalData.scopeBluetooth);
        }
        // res.authSetting = {
        //   "scope.userInfo": true,
        //   "scope.userLocation": true
        // }
      }
    })
  },
})