下面贴上代码：
#include <aJSON.h> #include <SPI.h> #include <Wire.h> #include <dht11.h> #include <DS3231.h> //============= 此处必须修改============ String DEVICEID="1494"; // 你的设备编号 == String APIKEY="d6easd772"; // 设备密码== String INPUTID1="1583";//接口ID============== String INPUTID2="1588";//接口ID============== String INPUTID3="1589";//接口ID============== String INPUTID4="1590";//接口ID============== //======================================= unsigned long lastCheckInTime = 0; //记录上次报到时间 unsigned long lastUpdateTime = 0;//记录上次上传数据时间 const unsigned long postingInterval = 40000; // 每隔40秒向服务器报到一次 const unsigned long updateInterval = 10000; // 数据上传间隔时间10秒 String inputString = "";//串口读取到的内容 boolean stringComplete = false;//串口是否读取完毕 boolean CONNECT = true; //连接状态 boolean isCheckIn = false; //是否已经登录服务器 char* parseJson(char *jsonString);//定义aJson字符串 ///**************************************************** dht11 DHT11; #define DHT11PIN 2 /////////////PM2.5 int measurePin = 1; //Connect dust sensor to Arduino A1 pin int ledPower = 3; //Connect 3 led driver pins of dust sensor to Arduino D3 float voMeasured = 0; float calcVoltage = 0; float dustDensity = 0; int samplingTime = 280; int deltaTime = 40; int sleepTime = 9680; ///////////////////PM2.5 /////****************************************************** int val;//MQ_2 float valTemperature;//定义变量 float valHumidity;//定义变量 void update1(String did, String inputid, float value); void setup() { Serial.begin(115200);//ESP 8266 工作波特率 Wire.begin(); int chk = DHT11.read(DHT11PIN); pinMode(ledPower,OUTPUT); delay(5000); } void loop() { if(millis() - lastCheckInTime > postingInterval || lastCheckInTime==0) { checkIn(); } val=analogRead(0); valTemperature = (float)DHT11.temperature; valHumidity = (float)DHT11.humidity; digitalWrite(ledPower,LOW); delayMicroseconds(samplingTime); voMeasured = analogRead(measurePin); // read the dust value delayMicroseconds(deltaTime); digitalWrite(ledPower,HIGH); // turn the LED off delayMicroseconds(sleepTime); calcVoltage = voMeasured * (5.0 / 1024.0); dustDensity = 0.17 * calcVoltage - 0.1; if((millis() - lastUpdateTime >= updateInterval) && isCheckIn) { update1(DEVICEID,INPUTID1,val);//MQ_2 update1(DEVICEID,INPUTID2,valTemperature); update1(DEVICEID,INPUTID3,valHumidity); update1(DEVICEID,INPUTID4,dustDensity); ///************************ } serialEvent(); if (stringComplete) { inputString.trim(); //Serial.println(inputString); if(inputString=="CLOSED"){ Serial.println("connect closed!"); CONNECT=false; }else{ int len = inputString.length()+1; if(inputString.startsWith("{") && inputString.endsWith("}")){ char jsonString[len]; inputString.toCharArray(jsonString,len); aJsonObject *msg = aJson.parse(jsonString); processMessage(msg); aJson.deleteItem(msg); } } // clear the string: inputString = ""; stringComplete = false; } } void checkIn() {//定时签到，防止离线 if (!CONNECT) { isCheckIn = false; Serial.print("+++"); delay(500); Serial.print(" "); delay(1000); Serial.print("AT+RST "); delay(6000); CONNECT=true; lastCheckInTime=0; } else{ Serial.print("{"M":"checkin","ID":""); Serial.print(DEVICEID); Serial.print("","K":""); Serial.print(APIKEY); Serial.print(""} "); lastCheckInTime = millis(); isCheckIn = true; } } void processMessage(aJsonObject *msg){ aJsonObject* method = aJson.getObjectItem(msg, "M"); aJsonObject* content = aJson.getObjectItem(msg, "C"); aJsonObject* client_id = aJson.getObjectItem(msg, "ID"); //char* st = aJson.print(msg); if (!method) { return; } //Serial.println(st); //free(st); String M=method->valuestring; String C=content->valuestring; String F_C_ID=client_id->valuestring; if(M=="say"){ if(C=="play"){ // digitalWrite(LED, HIGH); sayToClient(F_C_ID,"LED on!"); } if(C=="stop"){ // digitalWrite(LED, LOW); sayToClient(F_C_ID,"LED off!"); } if(C=="wendu"){ sayToClient(F_C_ID,String(valTemperature)); } if(C=="shidu"){ sayToClient(F_C_ID,String(valHumidity)); } if(C=="mq2"){ sayToClient(F_C_ID,String(val)); } if(C=="pm"){ sayToClient(F_C_ID,String(dustDensity)); } } } void sayToClient(String client_id, String content){//命令回复 Serial.print("{"M":"say","ID":""); Serial.print(client_id); Serial.print("","C":""); Serial.print(content); Serial.print(""} "); lastCheckInTime = millis(); } void serialEvent() { while (Serial.available()) { char inChar = (char)Serial.read(); inputString += inChar; if (inChar == ' ') { stringComplete = true; } } } //上报数据 拼接json void update1(String did, String inputid, float value){ Serial.print("{"M":"update","ID":""); Serial.print(did); Serial.print("","V":{""); Serial.print(inputid); Serial.print("":""); Serial.print(value); Serial.println(""}}"); lastCheckInTime = millis(); lastUpdateTime= millis(); } //同时上传两个接口数据调用此函数 void update2(String did, String inputid1, float value1, String inputid2, float value2){ Serial.print("{"M":"update","ID":""); Serial.print(did); Serial.print("","V":{""); Serial.print(inputid1); Serial.print("":""); Serial.print(value1); Serial.print("",""); Serial.print(inputid2); Serial.print("":""); Serial.print(value2); Serial.println(""}}"); lastCheckInTime = millis(); lastUpdateTime= millis(); }