新版ONENET的物联网环境调节系统（esp32+onenet+微信小程序）

好久没用onenet突然发现它大更新了，现在都是使用新版的物联网开放平台，只有老用户还有老版的多协议接入，新用户是没有的，所以我顺便更新一下新的开发组件吧.温湿度、Oled、风扇这些基本不变，这里就不再赘叙。

1、ONENET平台

1.1创建产品

在这里插入图片描述

这里你任意设置就行

在这里插入图片描述

我这里选择的是设备接入
在这里插入图片描述

这里我选择用MQTT协议接入，数据协议选择的数据流，这里最好还是跟我一样。

在这里插入图片描述

这样就创建完成了

在这里插入图片描述

1.2创建设备

在这里插入图片描述

1.3创建数据流

这里就可以看到我创建设备完成了，然后进入详情页面，创建数据流

在这里插入图片描述

2、下位机代码编写

2.1接入地址

查看文档可以发现新版的接口是1883

在这里插入图片描述

const int port = 1883;                     //端口号

2.2token秘钥生成

查看文档发现现在只能使用安全鉴权才可以访问了，以前的是可以直接使用api-key

在这里插入图片描述

这里使用token生成秘钥，token工具自行去onenet官方下载

只需要产品id和access_key就可以生成token秘钥

在这里插入图片描述

#define mqtt_password "********" //鉴权信息换成你自己的

2.3 主题订阅

因为我前面选择的是数据流，而不是物模型，所以查看onenet的文档时要注意，主题命名的方式是有所不同的，这前面的物模型的主题，

在这里插入图片描述

这下面的才是我们所要注意到的格式

在这里插入图片描述

然后我们去参考Onenet提供的实践可以看到是这样的

在这里插入图片描述

所以我在这里可以简化一下设置主题


#define mqtt_devid "******" //设备ID
#define mqtt_pubid "*******"        //产品ID
//接收设备属性获取命令主题
#define ONENET_TOPIC_GET "$sys/" mqtt_pubid "/" mqtt_devid "/cmd/request/+" 
//设备上发数据主题
#define ONENET_TOPIC_POST  "$sys/" mqtt_pubid "/" mqtt_devid "/dp/post/json"

2.4订阅主题

在setup函数里面对mqtt进行相关配置，client.subscribe是订阅应用程序下发命令的主题，而sendtempAndHumi函数是我发布主题的函数

 client.setServer(mqtt_server, port);                   //设置客户端连接的服务器,连接Onenet服务器, 使用1883端口
  client.connect(mqtt_devid, mqtt_pubid, mqtt_password); //客户端连接到指定的产品的指定设备.同时输入鉴权信息
  //client.setCallback(callback);                                //设置好客户端收到信息是的回调
  client.subscribe(ONENET_TOPIC_GET);
  client.setCallback(callback); //订阅命令下发主题
  tim1.attach(5, sendTempAndHumi);                            //定时每5秒调用一次发送数据函数sendTempAndHumi

2.5发布主题

//信息模板
//这是post上传数据使用的模板
#define ONENET_POST_BODY_FORMAT "{\"id\":%d,\"dp\":%s}"
void sendTempAndHumi()
{
  if (client.connected())
  {

 //先拼接出json字符串
    char param[82];
    char jsonBuf[178];
     sprintf(param, "{\"feng\":[{\"v\":%d}], \"temp\":[{\"v\":%.2f}],\"humi\":[{\"v\":%.2f}] , \"threshold\":[{\"v\":%d}]}",shan, dht.readTemperature(),dht.readHumidity(),threshold); //我们把要上传的数据写在param里
   
    postMsgId += 1;
    sprintf(jsonBuf, ONENET_POST_BODY_FORMAT, postMsgId, param);

    Serial.print("public the data:");
    //client.publish("$dp", (uint8_t *)msg_buf, 3+strlen(msgJson));
     client.publish(ONENET_TOPIC_POST, jsonBuf);
    //发送数据到主题
    delay(500);
    
  }
}

2.6callback函数

使用了JSON数据，利用键值对来实现操作

//收到主题下发的回调, 注意这个回调要实现三个形参 1:topic 主题, 2: payload: 传递过来的信息 3: length: 长度
void callback(char *topic, byte *payload, unsigned int length)
{
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
   // Handle incoming message here
  String message = "";
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
  }

  Serial.println("Received message: " + message);
   // Parse message as JSON
  DynamicJsonDocument doc(1024);
  DeserializationError error = deserializeJson(doc, payload, length);
  if (error) {
    Serial.print(F("deserializeJson() failed: "));
    Serial.println(error.c_str());
    return;
  }
  // Check which command was received
  if (doc.containsKey("修改温度阈值")) {
    threshold = doc["修改温度阈值"];



    Serial.println("Executing temperature threshold update operation.");
    Serial.print(threshold);
  } else if (doc.containsKey("风扇")) {
    newshan  =doc["风扇"];
    Serial.print(F("\n"));
    Serial.print(newshan);
   
  } else {
    // Unknown command
    Serial.println("Unknown command received.");
  }
    // Get the new threshold value

}