思路同上一篇: 改為連接阿里云平臺, 增加了平臺對時功能和定位功能

思路同上一篇:

本例程實現(xiàn)了以下功能:

通過SIM800L連接網(wǎng)絡(luò)

連接阿里IOT平臺()

調(diào)用SHT20的庫采集溫濕度

將溫濕度信息以及LBS定位信息上傳至IOT

與阿里云IOT平臺進行對時

每5分鐘采集一次, 采集完成就休眠

#include

  pinMode(MODEM_POWER_ON, OUTPUT); //電源引腳

  pinMode(MODEM_PWRKEY, OUTPUT);   //開關(guān)機鍵引腳

  // 先打開SIM800L的電源

  digitalWrite(MODEM_POWER_ON, HIGH);

  //根據(jù)手冊要求拉下PWRKEY 1秒鐘以上 可以開機

  digitalWrite(MODEM_PWRKEY, HIGH);

  delay(100);

  digitalWrite(MODEM_PWRKEY, LOW);

  delay(1000);

  digitalWrite(MODEM_PWRKEY, HIGH);

  SerialMon.println('Initializing modem...');

  modem.init(); //開機后modem初始化一下}/*-------------------------------SIM800L連接GPRS-------------------------------------*/void modemToGPRS(){

  //連接網(wǎng)絡(luò)

  SerialMon.print('Waiting for network...');

  while (!modem.waitForNetwork(240000L))

  {

    SerialMon.print('.');

    delay(500);

  }

  SerialMon.println(' OK');

  //連接GPRS接入點

  SerialMon.print(F('Connecting to APN: '));

  SerialMon.print(apn);

  while (!modem.gprsConnect(apn, gprsUser, gprsPass))

  {

    SerialMon.print('.');

    delay(10000);

  }

  SerialMon.println(' OK');}/*-------------------------------獲取溫濕度-------------------------------------*/void getTempAndHumi(){

  float _currentTemp = sht20.temperature();

  float _currentHumi = sht20.humidity();

  if (_currentTemp > -50 && _currentTemp < 80)

  {

    currentTemp = _currentTemp;

    currentHumi = _currentHumi;

    tempAndHumi_Ready = true;

    /* code */

  }

  else

  {

    Serial.println('此處寫溫濕度采集失敗的處理函數(shù)');

  }}/*-------------------------------獲取位置信息-------------------------------------*/void getLBSLocation(){

  String locationStr, locationStrX, locationStrY;

  locationStr = modem.getGsmLocation();

  if (locationStr.length() > 15)

  {

    int finddou;

    finddou = locationStr.indexOf(',');

    locationStrX = locationStr.substring(0, finddou);

    locationStrY = locationStr.substring(finddou + 1, locationStr.length());

    Serial.println(locationStr);

    Serial.println(finddou);

    Serial.println(locationStrX);

    Serial.println(locationStrY);

    if (locationStrX.toFloat() > 1)

    {

      locationE = locationStrX.toFloat();

      locationN = locationStrY.toFloat();

    }

  }}/*-------------------------------獲取NTP信息-------------------------------------*/void mqttPublish_ntpTimeRequest(){

  if (mqttClient.connected())

  {

    //先拼接出json字符串

    char jsonBuf[178] = '{'deviceSendTime':'1571724098000'}';

    //再從mqtt客戶端中發(fā)布post消息

    if (mqttClient.publish(ALINK_TOPIC_NTP_REQ, jsonBuf))

    {

      Serial.print('NTP message to cloud: ');

      Serial.println(jsonBuf);

    }

    else

    {

      Serial.println('Publish NTP message to cloud failed!');

    }

  }}/*-------------------------------向云平臺斷線重連-------------------------------------*/void clientReconnect(){

  while (!mqttClient.connected()) //再重連客戶端

  {

    Serial.print('net connected :');

    Serial.println(modem.isGprsConnected());

    Serial.println('reconnect MQTT...');

    if (connectAliyunMQTT(mqttClient, PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET))

    {

      Serial.println('connected');

    }

    else

    {

      Serial.println('failed');

      Serial.println(mqttClient.state());

      Serial.println('try again in 5 sec');

      delay(5000);

    }

  }}/*-------------------------------向云平臺發(fā)送溫濕度數(shù)據(jù)-------------------------------*/void sendTempAndHumi(){

  if (mqttClient.connected())

  {

    if (!tempAndHumi_Ready)

      return; //如果沒有測好溫濕度, 就不用上傳了

    //先拼接出json字符串

    char param[182];

    char jsonBuf[278];

    sprintf(param, '{'CurrentHumidity':%.2f,'CurrentTemperature':%.2f,'GeoLocation':{'value':{'Longitude':%.2f,'Latitude':%.2f,'Altitude':150,'CoordinateSystem':2}}}',

            currentHumi,

            currentTemp,

            locationE,

            locationN); //我們把要上傳的數(shù)據(jù)寫在param里

    postMsgId += 1;

    sprintf(jsonBuf, ALINK_BODY_FORMAT, postMsgId, ALINK_METHOD_PROP_POST, param);

    //再從mqtt客戶端中發(fā)布post消息

    if (mqttClient.publish(ALINK_TOPIC_PROP_POST, jsonBuf))

    {

      Serial.print('Post message to cloud: ');

      Serial.println(jsonBuf);

    }

    else

    {

      Serial.println('Publish message to cloud failed!');

    }

    tempAndHumi_Ready = false;

  }}/*-------------------------------云平臺回調(diào)-------------------------------*/void callback(char *topic, byte *payload, unsigned int length){

  //如果收到的主題里包含字符串ALINK_TOPIC_PROP_SET(也就是收到'/sys/' PRODUCT_KEY '/' DEVICE_NAME '/thing/service/property/set'主題)

  if (strstr(topic, ALINK_TOPIC_PROP_SET))

  {

    Serial.println('rev a topic:');

    Serial.println(topic);

    Serial.println('the payload is:');

    payload[length] = '?'; //為payload添加一個結(jié)束附,防止Serial.println()讀過了

    Serial.println((char *)payload);

    //接下來是收到的json字符串的解析

    DynamicJsonDocument doc(100);

    DeserializationError error = deserializeJson(doc, payload);

    if (error)

    {

      Serial.println('parse json failed');

      return;

    }

    JsonObject setAlinkMsgObj = doc.as

    serializeJsonPretty(setAlinkMsgObj, Serial);

    Serial.println();

    //接下來就可以解析set里的命令了

  }

  //如果收到的主題里包含字符串ALINK_TOPIC_NTP_RSP(也就是收到'/ext/ntp/' PRODUCT_KEY '/' DEVICE_NAME '/response')

  if (strstr(topic, ALINK_TOPIC_NTP_RSP))

  {

    Serial.println('rev a topic:');

    Serial.println(topic);

    Serial.println('the payload is:');

    payload[length] = '?'; //為payload添加一個結(jié)束附,防止Serial.println()讀過了

    Serial.println((char *)payload);

    DynamicJsonDocument timDoc(100);

    DeserializationError error = deserializeJson(timDoc, payload);

    if (error)

    {

      Serial.println('parse timDoc json failed');

      return;

    }

    JsonObject setAlinkMsgObj = timDoc.as

    serializeJsonPretty(setAlinkMsgObj, Serial);

    String str = setAlinkMsgObj['serverRecvTime'];

    //這個時間字符串是以毫秒為單位的, 用toInt方法可能會溢出,所以需要裁減

    str = str.substring(0, 10);

    long stamp = str.toInt() + 8 * 60 * 60; //我們在東八區(qū),所以給時間戳加了八個小時的偏移

    time_t timesmap = stamp;

    timeNow = localtime(×map);

    Serial.printf('timeNow: %d-%d-%d %d:%d',

                  timeNow->tm_year + 1900, //由于格林威治時間從1900年開始,所以加1900

                  timeNow->tm_mon + 1,     //格林威治時間月份是0~11,所以＋1

                  timeNow->tm_mday,        //mday的意思是本月第幾天

                  timeNow->tm_hour,

                  timeNow->tm_min);

    timeNTPdone = true;

  }}void setup(){

  Wire.begin();

  sht20.begin();

  SerialMon.begin(115200);                                //初始化調(diào)試串口

  SerialAT.begin(115200, SERIAL_8N1, MODEM_RX, MODEM_TX); //初始化AT串口

  setupModem();  //SIM800L物理開機

  modemToGPRS(); //modem連接GPRS

  Serial.println('get LBS location:');

  getLBSLocation(); //采集位置信息

  //連接OneNet并上傳數(shù)據(jù)

  Serial.println('connecting to ALI IOT...');

  if (connectAliyunMQTT(mqttClient, PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET))

  {

    Serial.println('MQTT connected!');

  };

  mqttClient.setCallback(callback); //綁定收到set主題時的回調(diào)(命令下發(fā)回調(diào))

  getTempAndHumi();                 //采集溫濕度數(shù)據(jù)

  sendTempAndHumi();                //發(fā)布一次溫濕度位置消息

  Serial.println('now NTPing');

  timeNTPdone = false;

  mqttPublish_ntpTimeRequest();

  Serial.println('now looping');

  while (!timeNTPdone)

  {

    mqttClient.loop();

  }

  delay(500);

  //進入睡眠

  esp_sleep_enable_timer_wakeup(300000000);

  Serial.println('now sleep');

  esp_deep_sleep_start();}void loop(){}

/*-------------------------------獲取定位信息LSB-------------------------------------*/void getLSB(){

  String locationStr, locationStrX, locationStrY;

  int finddou;

  locationStr = modem.getGsmLocation();

  finddou = locationStr.indexOf(',');

  locationStrX = locationStr.substring(0, finddou);

  locationStrY = locationStr.substring(finddou+1, locationStr.length());

  Serial.println(locationStr);

  Serial.println(finddou);

  Serial.println(locationStrX);

  Serial.println(locationStrY);}

經(jīng)測試, 上傳正常

這是阿里云studio的畫面