#include <Arduino.h>
#include <ESP8266WiFi.h>
#include <Arduino_JSON.h>


#ifndef STASSID
  #define STASSID "1"
  #define STAPSK  "16888qwe"  
#endif

const char* ssid = STASSID;
const char* password = STAPSK;

const char* host = "www.bigiot.net";
const int tcpPort = 8181;

String line = "";
String cmd="";

WiFiClient client;

const int LedPin = D2;//在本demo中是控制的ESP8266的D4 口，可根据自己需求更改。
const String DevConnectStr = "{\"M\":\"checkin\",\"ID\":\"31051\",\"K\":\"5f0c618aa\"}\n";
//软件调试
void setup() 
{

  Serial.begin(115200);

  pinMode(LedPin, OUTPUT);
  
  for(int i=0;i<2;i++) //端口测试
  {
    digitalWrite(LedPin, HIGH);
    Serial.println("Turn Off");
    delay(2000);
    digitalWrite(LedPin, LOW);
    Serial.println("Turn Off");
    delay(2000);
    
  }

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  int i = 0;
  while (WiFi.status() != WL_CONNECTED) 
  {
    delay(500); 
    Serial.println("connecting AP...");
    i++;   
  }
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());

   while (!client.connected())//若未连接到服务端，则客户端进行连接。
    {
        if (!client.connect(host, tcpPort))//实际上这一步就在连接服务端，如果连接上，该函数返回true
        {
            Serial.println("connecting....");
            delay(500);
        }
    }
    client.print(DevConnectStr);//发送http连接Json数据包
}
int connSecond=0;
unsigned long lastTimeMs=0;
unsigned long nowTimeMs=0;
void loop() 
{
         
     nowTimeMs=millis();
      if(nowTimeMs-lastTimeMs>10000)//发送心跳周期:10秒
      {
        lastTimeMs= nowTimeMs;   
        if(client.connected()) //已经连接到云服务器
        {
           client.print(DevConnectStr);
           //Serial.print("send heartbeat.");
        }
      }
            
      if (client.connected()) //接收处理
      {
        line = client.readStringUntil('\n');   
        if(line.length()>0)
        {
           JSONVar myObject = JSON.parse(line); 
           //Serial.print(line);
           if (myObject.hasOwnProperty("C")) 
           {
              cmd = (const char*) myObject["C"]; 
              //Serial.println(cmd);
             if(cmd.indexOf("play")!=-1)
             {
              //增加指令处理函数              
              //digitalWrite(LedPin, HIGH); // (第一阶段)
              //增加串口输出，控制zigbee节点的LED  (第二阶段)  
              Serial.println("A:0");  
             }
             else if(cmd.indexOf("stop")!=-1)
             {
              //增加指令处理函数
              
              //digitalWrite(LedPin, LOW); // (第一阶段)
              //增加串口输出，控制zigbee节点的LED  (第二阶段)          
              Serial.println("A:1");  
             }
           }
        }
      
      }
      else //已经断开连接
      {
        while (!client.connected())//若未连接到服务端，则客户端进行连接。
        {
            if (!client.connect(host, tcpPort))//实际上这一步就在连接服务端，如果连接上，该函数返回true
            {
                Serial.println("connection....");
                delay(500);
            }
        }
      }
}