ESP8266 wifi 获取天气数据情况心知天气API 中国气象局开放平台 arduino - YFROBOT创客社区

[C] 纯文本查看 复制代码
/**

    Get the Weather from intenet with esp8266



    get data from 心知天气：http://www.thinkpage.cn/

    api 文档说明：http://www.thinkpage.cn/doc

    city id list download ：http://www.thinkpage.cn/data/thinkpage_cities.zip



    Created by yfrobot, 2016.8.23

    This example is in public domain.

*/



#include <ESP8266WiFi.h>

#include <ArduinoJson.h>



WiFiClient client;



const char* ssid     = "YFROBOT";         // XXXXXX -- 使用时请修改为当前你的 wifi ssid

const char* password = "yfrobot2016";         // XXXXXX -- 使用时请修改为当前你的 wifi 密码





const char* host = "api.thinkpage.cn";

const char* APIKEY = "24qbvr1mjsnukavo";        //API KEY

const char* city = "huaian";

const char* language = "en";

//心知天气获取连接：https://api.thinkpage.cn/v3/weather/daily.json?key=KEY&location=城市&language=zh-Hans&unit=c&start=-1&days=5



const unsigned long BAUD_RATE = 115200;                   // serial connection speed

const unsigned long HTTP_TIMEOUT = 2100;               // max respone time from server

const size_t MAX_CONTENT_SIZE = 2048;                   // max size of the HTTP response



// Skip HTTP headers so that we are at the beginning of the response's body

//  -- 跳过 HTTP 头，使我们在响应正文的开头

bool skipResponseHeaders() {

  // HTTP headers end with an empty line

  char endOfHeaders[] = "\r\n\r\n";



  client.setTimeout(HTTP_TIMEOUT);

  bool ok = client.find(endOfHeaders);



  if (!ok) {

    Serial.println("No response or invalid response!");

  }



  return ok;

}



// 发送请求指令

bool sendRequest(const char* host, const char* cityid, const char* apiKey) {

  // We now create a URI for the request

  //心知天气

  String GetUrl = "/v3/weather/now.json?key=";

  GetUrl += apiKey;

  GetUrl += "&location=";

  GetUrl += city;

  GetUrl += "&language=";

  GetUrl += language;



  // This will send the request to the server

  client.print(String("GET ") + GetUrl + " HTTP/1.1\r\n" +

               "Host: " + host + "\r\n" +

               "Connection: close\r\n\r\n");

  return true;

}



// Read the body of the response from the HTTP server -- 从HTTP服务器响应中读取正文

void readReponseContent(char* content, size_t maxSize) {

  size_t length = client.peekBytes(content, maxSize);

  delay(100);

  Serial.println("Get the data from Internet!");

  content[length] = 0;

  Serial.println(content);

  Serial.println("Read Over!");

}



// The type of data that we want to extract from the page -- 我们要从此网页中提取的数据的类型

struct UserData {

  char city[16];

  char cnty[16];

  char weather[32];

  char temp[16];

  char feel[16];

  char hum[16];

  char visi[16];

  char udate[32];

};



// 解析数据

bool parseUserData(char* content, struct UserData* userData) {

  // Compute optimal size of the JSON buffer according to what we need to parse.

  //  -- 根据我们需要解析的数据来计算JSON缓冲区最佳大小

  // This is only required if you use StaticJsonBuffer. -- 如果你使用StaticJsonBuffer时才需要

  //  const size_t BUFFER_SIZE = 1024;



  // Allocate a temporary memory pool on the stack -- 在堆栈上分配一个临时内存池

  //  StaticJsonBuffer<BUFFER_SIZE> jsonBuffer;

  //  -- 如果堆栈的内存池太大，使用 DynamicJsonBuffer jsonBuffer 代替

  // If the memory pool is too big for the stack, use this instead:

  DynamicJsonBuffer jsonBuffer;



  JsonObject& root = jsonBuffer.parseObject(content);



  if (!root.success()) {

    Serial.println("JSON parsing failed!");

    return false;

  }

  //  const char* x = root["results"][0]["location"]["name"];//

  //  Serial.println(x);

  // Here were copy the strings we're interested in -- 复制我们感兴趣的字符串

  strcpy(userData->city, root["results"][0]["location"]["name"]);

  strcpy(userData->cnty, root["results"][0]["location"]["country"]);

  strcpy(userData->weather, root["results"][0]["now"]["text"]);

  strcpy(userData->temp, root["results"][0]["now"]["temperature"]);

  strcpy(userData->feel, root["results"][0]["now"]["feels_like"]);

  strcpy(userData->hum, root["results"][0]["now"]["humidity"]);

  strcpy(userData->visi, root["results"][0]["now"]["visibility"]);

  strcpy(userData->udate, root["results"][0]["last_update"]);

  // It's not mandatory to make a copy, you could just use the pointers

  // Since, they are pointing inside the "content" buffer, so you need to make

  // sure it's still in memory when you read the string

  //  -- 这不是强制复制，你可以使用指针，因为他们是指向“内容”缓冲区内，所以你需要确保

  //   当你读取字符串时它仍在内存中



  return true;

}



// Print the data extracted from the JSON -- 打印从JSON中提取的数据

void printUserData(const struct UserData* userData) {

  Serial.println("Print parsed data :");

  Serial.print("City : ");

  Serial.print(userData->city);

  Serial.print(", \t");

  Serial.print("Country : ");

  Serial.println(userData->cnty);

  

  Serial.print("Weather : ");

  Serial.print(userData->weather);

  Serial.print(",\t");

  Serial.print("Temp : ");

  Serial.print(userData->temp);

  Serial.print(" C");

  Serial.print(",\t");

  Serial.print("Feel : ");

  Serial.print(userData->feel);

  Serial.print(" C");

  Serial.print(",\t");

  Serial.print("Humidity : ");

  Serial.print(userData->hum);

  Serial.print(" %");

  Serial.print(",\t");

  Serial.print("visibility : ");

  Serial.print(userData->visi);

  Serial.println(" km");

  

  Serial.print("Last Updata : ");

  Serial.print(userData->udate);

  Serial.println("");

}



// Close the connection with the HTTP server -- 关闭与HTTP服务器连接

void stopConnect() {

  Serial.println("Disconnect");

  client.stop();

}



void setup(){

  WiFi.mode(WIFI_STA);     //设置esp8266 工作模式



  Serial.begin(BAUD_RATE );      //设置波特率

  Serial.println();

  Serial.print("connecting to ");

  Serial.println(ssid);



  WiFi.begin(ssid, password);   //连接wifi

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }

  Serial.println("");

  Serial.println("WiFi connected");

  delay(500);

  // Check if a client has connected

  if (!client.connect(host, 80)) {

    Serial.println("connection failed");

    return;

  }



  if (sendRequest(host, city, APIKEY) && skipResponseHeaders()) {

    char response[MAX_CONTENT_SIZE];

    readReponseContent(response, sizeof(response));

    UserData userData;

    if (parseUserData(response, &userData)) {

      printUserData(&userData);

    }

  }

  stopConnect();

}

void loop(){

  delay(3000);

}