问题求解，无法处理来自贝壳物联的json信息

1. 首页
2. 讨论
3. ESP8266

根据网站中文档“基于Arduino + ESP8266控制LED灯并返回控制结果”改的代码，运行于arduino，目的是想通过贝壳物联网页端控制舵机运转，连接登录设备和维持设备在线都没问题，就是从网页端给设备发信息没有反应，已经查了几天了一直不知道是什么问题（╥﹏╥）

#include <aJSON.h>
#include <Servo.h> 
#include <SoftwareSerial.h>
//=============  此处必须修该============
String DEVICEID = "xxx"; // 设备ID       ==
String  APIKEY = "xxx"; //设备APIKEY ==
//=======================================

SoftwareSerial mySerial(10, 11); // RX, TX

unsigned long lastCheckStatusTime = 0; //记录上次报到时间
const unsigned long postingInterval = 30000; // 每隔40秒向服务器报到一次
unsigned long checkoutTime = 0;//登出时间
// DC hobby servo
Servo myservo;
int servospd=240;

void setup() {
  
  //舵机初始化
  myservo.attach(9);
  //串口初始化
  Serial.begin(115200);
  //esp8266串口初始化
  mySerial.begin(115200);
  
  //esp8266网络设置初始化
  //退出可能未退出的CIPSEND模式
  mySerial.write("+++");
  delay(1000);
  mySerial.write("\r\n");
  printmessage();
  delay(1000);
  //检验是否退出CIPSEND模式
  mySerial.write("AT\r\n");
  printmessage();
  delay(1000);
  mySerial.write("AT+CWMODE?\r\n");
  printmessage();
  delay(1000);
  mySerial.write("AT+CWMODE=3\r\n");
  printmessage();
  delay(1000);
  mySerial.write("AT+CWMODE?\r\n");
  printmessage();
  delay(1000);
  mySerial.write("AT+CWJAP=\"xxx\",\"xxx\"\r\n");
  printmessage();
  delay(10000);
  //检验透传模式
  mySerial.write("AT+CIPMODE?\r\n");
  printmessage();
  delay(1000);
  //刷新更改透传模式为1（开启）
  mySerial.write("AT+CIPMODE=1\r\n");
  printmessage();
  delay(1000);
  //检验透传模式是否更改成功
  mySerial.write("AT+CIPMODE?\r\n");
  printmessage();
  delay(1000);
  //连接贝壳物联
  mySerial.write("AT+CIPSTART=\"TCP\",\"www.bigiot.net\",8181\r\n");
  printmessage();
  delay(5000);
  //开始对话
  mySerial.write("AT+CIPSEND\r\n");
  printmessage();
  delay(1000);
  //设备登录
  mySerial.write("{\"M\":\"checkin\",\"ID\":\"xxx\",\"K\":\"xxx\"}\r\n");
  printmessage();
  delay(10000);
  //退出对话
  mySerial.write("+++");
  printmessage();
  delay(1000);
  mySerial.write("\r\n");
  printmessage();
  delay(1000);
  
}
void loop() {

  //每一定时间查询一次设备在线状态，同时替代心跳
  if (millis() - lastCheckStatusTime > postingInterval) {
    mySerial.write("AT+CIPSEND\r\n");
    delay(1000);
    mySerial.write("{\"M\":\"status\"}\r\n");
    lastCheckStatusTime = millis();
    delay(5000);
    mySerial.write("+++");
    delay(1000);
    mySerial.write("\r\n");
    delay(1000);
    
  }
  
#处理来自贝壳物联的信息
while(mySerial.available()){
    String inputmsg=mySerial.readStringUntil("\n");
    int jsonBeginAt=inputmsg.indexOf("{");
    int jsonEndAt=inputmsg.lastIndexOf("}");
    if(jsonBeginAt!=-1 && jsonEndAt!=-1){
      inputmsg=inputmsg.substring(jsonBeginAt,jsonEndAt+1);
      int len = inputmsg.length()+1;
      char jsonString[len];
      inputmsg.toCharArray(jsonString,len);
      aJsonObject *msg=aJson.parse(jsonString);

      aJsonObject* method=aJson.getObjectItem(msg, "M");
      if (!method){
        return;
      }
      String M = method->valuestring;
      if(M == "say"){
        aJsonObject* content=aJson.getObjectItem(msg, "C");
        aJsonObject* web_id= aJson.getObjectItem(msg, "ID");
        String C = content->valuestring;
        String ID = web_id->valuestring;
        if(C == "unlock"){
          myservo.write(servospd);
          mySerial.write("AT+CIPSEND\r\n");
          mySerial.write("{\"M\":\"say\",\"ID\":\"U17110\",\"C\":\"Servo forword!\",\"SIGN\":\"esp8266\"}\r\n");
          Serial.println("Unlock!");
          delay(1000);
          mySerial.write("+++");
          mySerial.write("\r\n");
        }
        if(C == "lock"){
          myservo.write(servospd*(-1));
          mySerial.write("AT+CIPSEND\r\n");
          mySerial.write("{\"M\":\"say\",\"ID\":\"U17110\",\"C\":\"Servo reverse!\",\"SIGN\":\"esp8266\"}\r\n");
          delay(1000);
          mySerial.write("+++");
          mySerial.write("\r\n");
        }
      }

      aJson.deleteItem(msg);
     
    }
  }

}

void printmessage(){
  if (mySerial.available())
    Serial.println(mySerial.readStringUntil("\n"));
  if (Serial.available())
    mySerial.write(Serial.read());
}

---

评论：共0条