微信小程序连接阿里云物联网 源码

import mqtt from '../../utils/mqtt.js'; const aliyunOpt = require('../../utils/aliyun/aliyun_connect.js'); let that = null; var app = getApp(); Page({ data: { imagled:'../../images/LED_on.png', imagTV:'../../images/TV_on.png', imagKT:'../../images/KT_on.png', wendu:"0", shidu:"0", CO2:"0", TVOC:"0", light: "", currentTemperature:"", a0: "A0读取值", pwm:"PWM", servo:"Servo", backgroundimage: true, client: null,//记录重连的次数 reconnectCounts: 0,//MQTT连接的配置 options: { protocolVersion: 4, //MQTT连接协议版本 clean: false, reconnectPeriod: 1000, //1000毫秒，两次重新连接之间的间隔 connectTimeout: 1 * 1000, //1000毫秒，两次重新连接之间的间隔 resubscribe: true, //如果连接断开并重新连接，则会再次自动订阅已订阅的主题（默认true） /* clientId: 'WeChat|securemode=3,signmethod=hmacsha1|', password: 'F1E152EA5FF9582705500403FC3E17295E78603F', username: 'WeChat&a1VRADir8DT',*/ clientId: '', password: '', username: '', }, aliyunInfo: { //------------------------------ productKey: wx.getStorageSync("productKey"), //阿里云连接的三元组 ，请自己替代为自己的产品信息!! productKey deviceName: wx.getStorageSync("deviceName"), //阿里云连接的三元组 ，请自己替代为自己的产品信息!! deviceName deviceSecret: wx.getStorageSync("deviceSecret"), //阿里云连接的三元组 ，请自己替代为自己的产品信息!! deviceSecret regionId: 'cn-shanghai', //阿里云连接的三元组 ，请自己替代为自己的产品信息!! pubTopic: wx.getStorageSync("pubTopic"), //发布消息的主题 pubTopic subTopic: wx.getStorageSync("subTopic"), //订阅消息的主题 subTopic }, }, onLoad: function (){ if(app.globalData.DL_flag===1){ app.connect(); }else{ wx.showToast({ title: "请填写三元组信", }) } }, onPullDownRefresh: function () { if(app.globalData.DL_flag===1){ this.connect(); wx.stopPullDownRefresh() }else{ wx.showToast({ title: "请填写三元组信", }) } }, ///======================室灯oN/OFF switch1Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { this.setData({ imagled:'../../images/LED_on.png', }) console.log('switch1 change开 发送值为31'); app.sendCommond(1); //改括号里的数字，就改变了发送的值 }else { this.setData({ imagled:'../../images/LED_off.png', }) console.log('switch change关 发送值为30'); app.sendCommond(2); //改括号里的数字，就改变了发送的值 } }, ///======================电视on/OFF switch2Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { this.setData({ imagTV:'../../images/TV_on.png', }) console.log('switch2 change开 发送值为41'); app.sendCommond(3); //改括号里的数字，就改变了发送的值 }else { this.setData({ imagTV:'../../images/TV_off.png', }) console.log('switch2 change关 发送值为40'); app.sendCommond(4); //改括号里的数字，就改变了发送的值 } }, ///======================空调on/OFF switch3Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { this.setData({ imagKT:'../../images/KT_on.png', }) console.log('switch3 change开 发送值为51'); app.sendCommond(5); //改括号里的数字，就改变了发送的值 }else { this.setData({ imagKT:'../../images/KT_off.png', }) console.log('switch3 change关 发送值为50'); app.sendCommond(6); //改括号里的数字，就改变了发送的值 } }, ///======================蓝灯on/OFF switch4Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { console.log('switch4 change开 发送值为61'); app.sendCommond(61); //改括号里的数字，就改变了发送的值 }else { console.log('switch4 change关 发送值为60'); app.sendCommond(60); //改括号里的数字，就改变了发送的值 } }, ///======================黄灯on/OFF switch5Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { console.log('switch5 change开 发送值为71'); app.sendCommond(71); //改括号里的数字，就改变了发送的值 }else { console.log('switch5 change关 发送值为70'); app.sendCommond(70); //改括号里的数字，就改变了发送的值 } }, ///======================书灯on/OFF switch6Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { console.log('switch6 change开 发送值为81'); app.sendCommond(81); //改括号里的数字，就改变了发送的值 }else { console.log('switch6 change关 发送值为80 '); app.sendCommond(80); //改括号里的数字，就改变了发送的值 } }, ///======================吊灯on/OFF switch7Change: function (e) { // console.log('switch1 发生 change 事件，携带值为', e.detail.value); if (e.detail.value) { console.log('switch7 change开 发送值为91 '); app.sendCommond(91); //改括号里的数字，就改变了发送的值 }else { console.log('switch7 change关 发送值为90'); app.sendCommond(90); //改括号里的数字，就改变了发送的值 } }, sliderchange1(e){ //滑动按钮触发1 console.log(e) let data = e.detail.value data=data+100; // var propertyName = e.currentTarget.dataset.propertyName // if (propertyName == "NR") { that.sendCommond(data); // this.setData({ // numberD2: data * 28 // }) // } console.log('sliderchange1 值为'+ data); }, sliderchange2(e){ //滑动按钮触发2 console.log(e) let data = e.detail.value data=data+200; // var propertyName = e.currentTarget.dataset.propertyName // if (propertyName == "NR") { that.sendCommond(data); // this.setData({ // numberD2: data * 28 // }) // } console.log('sliderchange1 值为'+data); }, sliderchange3(e){ //滑动按钮触发3 console.log(e) let data = e.detail.value data=data+300; // var propertyName = e.currentTarget.dataset.propertyName // if (propertyName == "NR") { that.sendCommond(data); // this.setData({ // numberD2: data * 28 // }) // } console.log('sliderchange1 值为'+data); }, a0: function (e){ let value = e.detail.value wx.setStorageSync("a0", value) }, wendu: function (e) { let value = e.detail.value wx.setStorageSync("wendu", value) }, pwm: function (e){ let value = e.detail.value wx.setStorageSync("pwm", value) }, servo:function(e) { let value = e.detail.value wx.setStorageSync("servo", value) }, connect: function () { var that = this; let temp1=''; let temp2=''; let temp3=''; let temp4=''; let temp5=''; temp1=app.globalData.buffproductKey; temp2=app.globalData.buffdeviceName; temp3=app.globalData.buffdeviceSecret; temp4=app.globalData.buffpubTopic; temp5=app.globalData.buffsubTopic; let clientOpt = aliyunOpt.getAliyunIotMqttClient({ /* productKey: 'a108eu8DHY0', //阿里云连接的三元组 ，请自己替代为自己的产品信息!! productKey deviceName: 'OHW6pwCSvghojSyebn79', //阿