Merge branch 'master' of http://xiaohaodianzi.cn:3000/xhdz/TEST into master

TEST_Prj/esp32_mqtt/esp32_mqtt.ino

@@ -0,0 +1,171 @@
+#include <Arduino.h>
+#include "WiFi.h"
+#include "PubSubClient.h"
+#include "Ticker.h"
+
+const char *ssid = "LH_TEST";                 //wifi名
+const char *password = "lh326802247";         //wifi密码
+const char *mqtt_server = "183.230.40.39"; //onenet 的 IP地址
+
+#define mqtt_devid "914788329"  //设备ID
+#define mqtt_pubid "499051"     //产品ID
+#define mqtt_password "espdemo1" //鉴权信息
+
+/*
+Master-APIkey
+yOALPHrBqGL8Xr0xxosXpZB0q5I=
+
+access_key：
+yd+CP8y4H45pZjGj9NOh5Yp3JmiNKk7UEcSKhnDGL2I=
+*/
+WiFiClient espClient;           //创建一个WIFI连接客户端
+PubSubClient client(espClient); // 创建一个PubSub客户端, 传入创建的WIFI客户端
+
+char msg_buf[256]={0};                                //发送信息缓冲区
+char dataTemplate[] = "{\"temp\":%d,\"hum\":%.2f}"; //信息模板
+char msgJson[75]={0};                                 //要发送的json格式的数据
+unsigned short json_len = 0;                      //json长度
+Ticker tim1;                                      //定时器,用来循环上传数据
+
+//连接WIFI相关函数
+void setupWifi()
+{
+  delay(10);
+  Serial.println("连接WIFI");
+  WiFi.begin(ssid, password);
+  while (!WiFi.isConnected())
+  {
+    Serial.print(".");
+    delay(500);
+  }
+  Serial.println("OK");
+  Serial.println("Wifi连接成功");
+}
+
+//收到主题下发的回调, 注意这个回调要实现三个形参 1:topic 主题, 2: payload: 传递过来的信息 3: length: 长度
+void callback(char *topic, byte *payload, unsigned int length)
+{
+  Serial.println("message rev:");
+  Serial.println(topic);
+  for (size_t i = 0; i < length; i++)
+  {
+    Serial.print((char)payload[i]);
+  }
+  Serial.println();
+}
+int temp=0;
+//向主题发送模拟的温湿度数据
+void sendTempAndHumi()
+{
+  if (client.connected())
+  {
+    temp = (rand()%100);
+    snprintf(msgJson, 40, dataTemplate, temp, 25.92); //将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJson
+    json_len = strlen(msgJson);                   //msgJson的长度
+    msg_buf[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
+    msg_buf[1] = char(json_len >> 8);              //数据第二位是要发送的数据长度的高八位
+    msg_buf[2] = char(json_len & 0xff);            //数据第三位是要发送数据的长度的低八位
+    memcpy(msg_buf + 3, msgJson, strlen(msgJson)); //从msg_buf的第四位开始,放入要传的数据msgJson
+    msg_buf[3 + strlen(msgJson)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了
+    Serial.print("public message:");
+    Serial.println(msgJson);
+    client.publish("$dp", (uint8_t *)msg_buf, 3 + strlen(msgJson)); //发送数据到主题$dp
+  }
+}
+void send_mqtt_msgToOnenet(char *pdat,uint16_t len)
+{
+    json_len = len;                   //msgJson的长度
+    msg_buf[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
+    msg_buf[1] = char(json_len >> 8);              //数据第二位是要发送的数据长度的高八位
+    msg_buf[2] = char(json_len & 0xff);            //数据第三位是要发送数据的长度的低八位
+    memcpy(msg_buf + 3, pdat, len); //从msg_buf的第四位开始,放入要传的数据msgJson
+    msg_buf[3 + len] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了
+    Serial.print("public message:");
+    Serial.println(pdat);
+    client.publish("$dp", (uint8_t *)msg_buf, 3 + len); //发送数据到主题$dp
+}
+//重连函数, 如果客户端断线,可以通过此函数重连
+void clientReconnect()
+{
+  while (!client.connected()) //再重连客户端
+  {
+    Serial.println("reconnect MQTT...");
+    if (client.connect(mqtt_devid, mqtt_pubid, mqtt_password))
+    {
+      Serial.println("connected");
+    }
+    else
+    {
+      Serial.println("failed");
+      Serial.println(client.state());
+      Serial.println("try again in 5 sec");
+      delay(5000);
+    }
+  }
+}
+#define Serial_RX_MAXSIZE  100
+unsigned char Serial_Buffer[Serial_RX_MAXSIZE]={0};//串口缓存区
+uint32_t timeTick = 0;
+unsigned int  buffUartIndex = 0;
+unsigned long preUartTick = 0;
+char UsendFlag=0;
+//{"temp":84,"hum":25.92}
+void Usart_RxTask(void)//串口接收处理 空闲时表示接收完毕了 
+{
+  unsigned char i =0;
+  if (Serial.available() > 0)//读取串口数据
+  {
+    uint8_t t = Serial.read();
+    Serial_Buffer[buffUartIndex++] = t;
+    preUartTick = millis();
+    if (buffUartIndex >= Serial_RX_MAXSIZE - 1) {
+      buffUartIndex = Serial_RX_MAXSIZE - 2;
+      preUartTick = preUartTick - 10;
+    }
+  }
+  if (buffUartIndex > 0 && (millis() - preUartTick >= 10))
+  { 
+    Serial_Buffer[buffUartIndex] = 0x00;
+    send_mqtt_msgToOnenet((char*)Serial_Buffer,buffUartIndex);
+//     if(strstr((char*)&Serial_Buffer[0],"kg")!=NULL)
+//     {
+//        String tem;
+//        for(int i=0;i<buffUartIndex;i++)
+//        {
+//           tem +=(char)Serial_Buffer[i];
+//        }
+//        data_str=tem;
+//     }
+     memset(Serial_Buffer,0,Serial_RX_MAXSIZE);
+     buffUartIndex = 0;  
+  }
+   
+  
+}
+
+void setup()
+{
+  Serial.begin(115200);                                  //初始化串口
+  delay(3000);                                           //这个延时是为了让我打开串口助手
+  setupWifi();                                           //调用函数连接WIFI
+  client.setServer(mqtt_server, 6002);                   //设置客户端连接的服务器,连接Onenet服务器, 使用6002端口
+  client.connect(mqtt_devid, mqtt_pubid, mqtt_password); //客户端连接到指定的产品的指定设备.同时输入鉴权信息
+  client.setCallback(callback);                          //设置好客户端收到信息是的回调
+  //tim1.attach(5, sendTempAndHumi);                      //定时每20秒调用一次发送数据函数sendTempAndHumi
+}
+
+void loop()
+{
+  if (!WiFi.isConnected()) //先看WIFI是否还在连接
+  {
+    setupWifi();
+  }
+  if (!client.connected()) //如果客户端没连接ONENET, 重新连接
+  {
+    clientReconnect();
+  }else
+  {
+    Usart_RxTask();  //解析串口数据 进行发送 
+  }
+  client.loop(); //客户端循环检测
+}