一、簡(jiǎn)介



1.這期視頻向大家介紹如何使用CW32單片機(jī)通過ESP8266連接OneNET物聯(lián)網(wǎng)平臺(tái)，發(fā)送溫濕度數(shù)據(jù)到平臺(tái)，并接受平臺(tái)的云控制。

二、所需物料


2.本實(shí)驗(yàn)使用到了CW32-48F大學(xué)計(jì)劃開發(fā)板、DHT11溫濕度傳感器模塊、ESP8266WIFI模塊及Keil5開發(fā)環(huán)境。

3.接線：根據(jù)原理圖，把模塊連接到開發(fā)板上

（1）ESP8266WIFI模塊：

開發(fā)板上預(yù)留了該模塊接口，通過串口向ESP8266寫入指令。

（2）DHT11模塊：開發(fā)板上預(yù)留了該模塊接口

4.（1）MQTT協(xié)議介紹：

MQTT是一種輕量級(jí)的發(fā)布/訂閱消息傳輸協(xié)議，常用于物聯(lián)網(wǎng)領(lǐng)域。它的特點(diǎn)是簡(jiǎn)化和減少了網(wǎng)絡(luò)流量，可以高效地進(jìn)行數(shù)據(jù)傳輸。在本次應(yīng)用中，我們將使用MQTT協(xié)議進(jìn)行數(shù)據(jù)上傳。

（2）OneNET代碼介紹：

在使用OneNet平臺(tái)時(shí)，我們需要使用TCP協(xié)議進(jìn)行連接。首先需要設(shè)置好TCP協(xié)議的相關(guān)參數(shù)，然后通過POST方法將溫濕度數(shù)據(jù)上傳到OneNet平臺(tái)中。在上傳數(shù)據(jù)時(shí)需要使用OneNet平臺(tái)提供的API接口進(jìn)行數(shù)據(jù)傳輸。

注：#define PROID"XXX" //xxx為產(chǎn)品ID

#define ACCESS_KEY "XXX" //xxx為acess_key訪問密鑰

#define DEVICE_NAME"XXX" //xxx為設(shè)備名稱

三、核心代碼

main.c

int main(void)
{ 
 unsigned short timeCount = 0; //發(fā)送間隔變量 
 unsigned char *dataPtr = NULL;
 
 Hardware_Init();    //初始化外圍硬件
  while(DHT11_Init())  //檢測(cè)DHT11
  Delay_ms(200);
 ESP8266_Init();     //初始化ESP8266
 UsartPrintf(USART_DEBUG, "Connect MQTTs Server...
");
 while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT")) //ESP8266聯(lián)網(wǎng)
  Delay_ms(500);
 UsartPrintf(USART_DEBUG, "NET_OK
"); 
 while(OneNet_DevLink())   //接入OneNET
  Delay_ms(500);
 OneNET_Subscribe();   //訂閱消息傳輸，允許接受下發(fā)指令
 TFTShowString(0,0,"   OneNET   "); //界面
 TFTShowString(1,0," 智能物聯(lián)平臺(tái) ");
 TFTShowString(3,0,"humidity:  %");
 TFTShowString(4,0,"temperature: C");
 while(1)
 {
  if(++timeCount >= 50)         
  {
   DHT11_Read_Data(&temperature,&humidity); //讀取溫濕度值 
   TFTShowNumber(3,10,humidity);
   TFTShowNumber(4,12,temperature);
   UsartPrintf(USART_DEBUG,"TEMP:%d HUMI:%d
",temperature,humidity);
   UsartPrintf(USART_DEBUG, "OneNet_SendData
");
   OneNet_SendData();    //數(shù)據(jù)上傳
   timeCount = 0;
   ESP8266_Clear();  //清除緩存
  } 
 
  dataPtr = ESP8266_GetIPD(0); //接收OneNET平臺(tái)返回的數(shù)據(jù)
  if(dataPtr != NULL)
   OneNet_RevPro(dataPtr); //確認(rèn)返回?cái)?shù)據(jù)，執(zhí)行下發(fā)命令
 
  Delay_ms(10);
 }
}

#define PROID   "3OB4R7cKCw"    //產(chǎn)品ID（名稱）
#define ACCESS_KEY  "n7GptYNpf9U97zHTz2ltc1Pvy4GB+0MXsU1nKel9ixc=" //產(chǎn)品訪問密鑰
#define DEVICE_NAME  "111"   //設(shè)備ID（名稱）
void OneNet_RevPro(unsigned char *cmd)
{
 char *req_payload = NULL;
 char *cmdid_topic = NULL;
 unsigned short topic_len = 0;
 unsigned short req_len = 0;
 unsigned char qos = 0;
 static unsigned short pkt_id = 0;
 unsigned char type = 0;
 short result = 0;
 char *dataPtr = NULL;
 char numBuf[10];
 int num = 0;
 
 type = MQTT_UnPacketRecv(cmd);
 switch(type)
 {
  case MQTT_PKT_PUBLISH:                //接收的Publish消息
 
   result = MQTT_UnPacketPublish(cmd, &cmdid_topic, &topic_len, &req_payload, &req_len, &qos, &pkt_id);
   if(result == 0)
   {
    char *data_ptr = NULL;
    UsartPrintf(USART_DEBUG, "topic: %s, topic_len: %d, payload: %s, payload_len: %d
", cmdid_topic, topic_len, req_payload, req_len);
    data_ptr = strstr(cmdid_topic, "request/");         //查找cmdid
    if(data_ptr)
    {
     char topic_buf[80], cmdid[40];
 
     data_ptr = strchr(data_ptr, '/');
     data_ptr++;
 
     memcpy(cmdid, data_ptr, 36);           //復(fù)制cmdid
     cmdid[36] = 0;
     snprintf(topic_buf, sizeof(topic_buf), "$sys/%s/%s/cmd/response/%s",
               PROID, DEVICE_NAME, cmdid);
     OneNET_Publish(topic_buf, "ojbk");          //回復(fù)命令
    }
   }
   case MQTT_PKT_PUBACK:              //發(fā)送Publish消息，平臺(tái)回復(fù)的Ack
     if(MQTT_UnPacketPublishAck(cmd) == 0)
    UsartPrintf(USART_DEBUG, "Tips: MQTT Publish Send OK
");
  break;
  case MQTT_PKT_SUBACK:                //發(fā)送Subscribe消息的Ack
 
   if(MQTT_UnPacketSubscribe(cmd) == 0)
    UsartPrintf(USART_DEBUG, "Tips: MQTT Subscribe OK
");
   else
    UsartPrintf(USART_DEBUG, "Tips: MQTT Subscribe Err
");
  break;
  default:
   result = -1;
  break;
 }
 
 ESP8266_Clear();         //清空緩存
 
 if(result == -1)
  return;
 
 dataPtr = strchr(req_payload, ':');     //搜索':'
 if(dataPtr != NULL)     //如果找到了
 {
  dataPtr++;
  while(*dataPtr >= '0' && *dataPtr <= '9') ? ?//判斷是否是下發(fā)的命令控制數(shù)據(jù)
 ? ?{
 ? ? ?numBuf[num++] = *dataPtr++;
 ? ?}
 ? ?numBuf[num] = 0;
 ? ?num = atoi((const char *)numBuf); ? ? ? ?//轉(zhuǎn)為數(shù)值形式
 ? ?if(strstr((char *)req_payload, "light")) ? ?//搜索"light",判斷":"后面的數(shù)值進(jìn)行控制
 ? ?{
 ? ? ?if(num == 1) ? ? ? ? ? ? ? ?//控制數(shù)據(jù)如果為1，代表開
 ? ? ?{
 ? ? ? ?UsartPrintf(USART_DEBUG, "接收到1
");
 ? ? ? ?//開燈
 ? ? ? ?PA07_SETLOW();
 ? ? ? ?TFTShowString(5,0,"light: ON ");
 ? ? ?}
 ? ? ?else if(num == 0) ? ? ? ? ? ? ?//控制數(shù)據(jù)如果為0，代表關(guān)
 ? ? ?{
 ? ? ? ?UsartPrintf(USART_DEBUG, "接收到0
");
 ? ? ? ?//關(guān)燈
 ? ? ? ?PA07_SETHIGH();
 ? ? ? ?TFTShowString(5,0,"light: OFF");
 ? ? ?}
 ? ?}
 ?}
 ?if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
 ?{
 ? ?MQTT_FreeBuffer(cmdid_topic);
 ? ?MQTT_FreeBuffer(req_payload);
 ?}
}