import { jsCode2Session } from './services/index'

App({
  onLaunch() {
    // 异步请求获取数据，添加全局Promise，其他页面方便获取用户信息和opneId
    this.userInfoReadyCallback = new Promise(resovle => {
      let openid; 
      let userInfo; 

      // 获取用户信息
      wx.getSetting().then(res => {
        if (!res.authSetting['scope.userInfo']) return (userInfo = {})
        // 已经授权，可以直接调用 getUserInfo 获取头像昵称，不会弹框
        wx.getUserInfo().then(res => {
          userInfo = res.userInfo
          this.globalData.userInfo = userInfo
          if (!openid || openid === undefined) return
          resovle({ openid, userInfo })
        })
      })

      // 获取用户的openid
      wx.login().then(res => {
        // 调用后端接口获取openId、unionid（如果有）
        jsCode2Session({ jsCode: res.code }).then(rs => {
          openid = rs.data.openid
          this.globalData.openId = openid
          if (!userInfo) return
          resovle({ openid, userInfo })
        }).catch(e => {
          console.log('获取openid失败！')
          openid = ''
          if (!userInfo) return
          resovle({ openid, userInfo })
        })
      })
    })
  }
})

// 未授权，弹窗授权按钮，引导用户授权
<view wx:if="{{!userInfo.nickName}}">
  <view class="mask-dialog">
    <text>获取头像昵称</text>
    <button open-type="getUserInfo" bindgetuserinfo="getUserInfo">确定</button>
  </view>
</view>

// 授权后的回调
getUserInfo(e) {
  const userInfo = e.detail.userInfo
  app.globalData.userInfo = userInfo
  this.setData({ userInfo })
}

import mqtt from './my_mqtt.js';

// 连接选项
const options = {
  clean: true, // 保留回话
  connectTimeout: 15000, // 超时时间
  keepalive: 20,
  username: 'admin',
  password: 'public',
}

let mqttClient
const getMqttClient = () => {
  if (mqttClient) return mqttClient
  mqttClient = mqtt.connect('wxs://ybstest.com:443/ws/mqtt', options);

  mqttClient.on('connect', () => {
    console.log('connect:', mqttClient.options.href);
  });
  
  mqttClient.on('close', () => {
    console.log('close..........')
  });
  
  mqttClient.on('reconnect', () => { 
    console.log('reconnect..........')
  });
  
  mqttClient.on('disconnect', () => {
    console.log('disconnect..........')
  });
  
  mqttClient.on('error', () => {
    console.log('error..........')
  });

  return mqttClient
};

export default getMqttClient;

// // 订阅消息
// mqttClient.subscribe(`/device/upload/${deviceSn}`, { qos: 0 }, err => {
//   if (err) console.log(err);
// });

// 订阅消息后，才能接收消息
// mqttClient.on('message', (topic, message) => {
//   try {
//     const obj = JSON.parse(message.toString());
//     console.log('收到信息：', obj);
//   } catch (error) {
//     console.error(error);
//   }
// });

// 无需订阅消息，链接成功即可发送消息
// mqttClient.publish('/device/push/${deviceSn}', JSON.stringify({
//   deviceSn: '设备SN',
//   mqttActionEnum: 'BASE_DIRECTION_CONTROL',
//   DIRECTION: 'LEFT', // RIGHT UP DOWN
//   timestamp: +new Date()
// }));

handleDownload(e) {
  let fileName = new Date().valueOf();
　　 // 单次下载允许的最大文件为 200MB
  wx.downloadFile({
    url: '下载地址：xxxx',
    filePath: wx.env.USER_DATA_PATH + '/' + fileName + '.mp4', // 指定文件下载后存储的路径 (本地路径)
    success: res => {
      let filePath = res.filePath; // 传入 filePath 时会返回，跟传入的 filePath 一致
      
      // 保存视频到系统相册
      wx.saveVideoToPhotosAlbum({ 
        filePath,
        success: file => {
          wx.showToast({
            title: '下载成功',
            icon: 'success',
            duration: 2000
          })
        },
        fail: err => {
          if (err.errMsg === 'saveVideoToPhotosAlbum:fail auth deny') {
      　　  wx.authorize({
              scope: 'scope.writePhotosAlbum', // 保存到相册 授权
              success () {
                // 再次保存
              }
            })
          }
        }
      })
    }
  })
}