wxmini/utils/lexin/subscribe.js

module.exports = {
  subscribeSingleDevice: subscribeSingleDevice,
  subscribeAllDevice: subscribeAllDevice,
}

// 订阅在线单个设备
function subscribeSingleDevice(deviceId) {
  var topic = `/AIrSMArT_${deviceId.split("BLUFI_")[1]}/status/onoffline`;
  const app = getApp();
  app.unsubscribe(topic);
  app.subscribe(topic);
};

// 订阅在线设备
function subscribeAllDevice() {
  const strings = require('../strings');
  var deviceList = getCurrentPages()[0].getDeviceList();
  if (strings.isEmpty(deviceList)) {
    return;
  }

  const app = getApp();
  ///扫描所有在线Wifi设备
  for (var i = 0; i < deviceList.length; i++) {
    var device = deviceList[i];
    if (device.connectType == 3) {
      var deviceId = device.deviceId;
      var topic = `/AIrSMArT_${deviceId.split("BLUFI_")[1]}/status/onoffline`;
      app.subscribe(topic);
      // break;
    }
  }
};