【7天入门RTOS网络编程】Nautilus day6-7 作业

发布于 2018-10-23 16:05:42 浏览：1622 订阅该版

* 本帖最后由 yukelab 于 2018-10-23 16:08 编辑 *

**题目要求**运用所学的知识，获取实时的日期、时间、天气，并把获取的数据通过在 OneNet 云平台创建应用展示出来。**完成思路**[list=1]
(*)按照题目要求，获取实时的日期，时间，天气，需要用到package中的webclient获取天气信息，通过cJSON解析天气信息中的数据；NTP获取实时的时间数据；
(*)OneNet云平台当然要使用OneNet工具包和paho mqtt工具包（因为OneNET的设备接入方式是MQTT）。
(*)完成思路很简单
[/list]![day6_1.png](/uploads/201810/23/160822ybwb93f9z1h51wsj.png)
中间部分没有先后顺序。本来打算获取时间后，采用本地时间作为一个时间戳，与天气信息同时上传。可是，示例里的天气WebAPI已经弃用，获取到的天气信息是2013年左右的。于是，在网上找了好多API，大多收费，找到一个测试接口，勉强可以用，不过获取时间间隔和1h内获取的数目有限制，因此在实现的过程中将天气信息的上传改为单次。时间同步后，可以直接使用本地数据，因此，对时间的上传使用了连续上传，进行试验；**具体步骤**过程叙述较多，具体可见文档附件，这里只贴代码部分了
```/* 获取天气信息相关头文件 */
#include <webclient.h> /* 使用 HTTP 协议与服务器通信需要包含此头文件 */
#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */
#include <netdb.h>
#include <cJSON.h>
#define GET_HEADER_BUFSZ 1024 //头部大小
#define GET_RESP_BUFSZ 2048 //响应缓冲区大小
#define GET_URL_LEN_MAX 256 //网址最大长度
/* 实时天气信息，数据来自国家气象局天气网,每小时更新一次 */
#define GET_URI "http://api.k780.com:88/?app=weather.today&weaid=%s&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4&format=json" //获取天气的 API
#define AREA_ID "101290101" //昆明地区 ID

static void weather_hw(void);
static int onenet_publish_string(int argc, char **argv);
/* 与OneNET连接相关头文件 */
#include <stdlib.h>
#include <onenet.h>

/* 与ntp获取相关头文件 */
#include <ntp.h>
#include <sys/time.h>

#ifdef FINSH_USING_MSH
#include <finsh.h>

typedef struct __weather_msg
{
 char cityNo[20];
 char cityNm[20];
 char wind[20];
 int winp;
 int temperature;
 int humidity;
 char date[20];
} WEATHER_MSG;
static WEATHER_MSG weather_msg;
static void onenet_upload_weather(void)
{
 weather_hw();
 rt_kprintf("date: %s ", weather_msg.date);
 if (onenet_mqtt_upload_string("date", weather_msg.date) < 0)
 {
 log_e("upload string has an error! ");
 }
 if (onenet_mqtt_upload_string("cityNm", weather_msg.cityNm) < 0)
 {
 log_e("upload has an error, stop uploading");
 }
 if (onenet_mqtt_upload_string("wind", weather_msg.wind) < 0)
 {
 log_e("upload has an error, stop uploading");
 }
 
 if (onenet_mqtt_upload_digit("temperature", weather_msg.temperature) < 0)
 {
 log_e("upload has an error, stop uploading");
 }
 if (onenet_mqtt_upload_digit("winp", weather_msg.winp) < 0)
 {
 log_e("upload has an error, stop uploading");
 }
 if (onenet_mqtt_upload_digit("humidity", weather_msg.humidity) < 0)
 {
 log_e("upload has an error, stop uploading");
 }
 else
 {
 log_i("buffer : {\"humidity\":%d}", (int)weather_msg.humidity);
 }
}
MSH_CMD_EXPORT(onenet_upload_weather, send weather data to OneNET cloud cycle);

/* upload random value to temperature*/
static void onenet_upload_ntp_entry(void *parameter)
{
        char *host_name = NULL;
        /* 同步时间 */
    time_t cur_time = ntp_sync_to_rtc(host_name);

if (cur_time)
    {
        rt_kprintf("Get local time from NTP server: %s", ctime((const time_t*) &cur_time));

#ifdef RT_USING_RTC
 rt_kprintf("The system time is updated. ");
#else
 rt_kprintf("The system time update failed. Please enable RT_USING_RTC. ");
#endif /* RT_USING_RTC */

}
    while (1)
    {
                /* 获取本地时间并将其上传到OneNET云 */
                cur_time = ntp_get_local_time(host_name);

if (onenet_mqtt_upload_string("datetime", ctime((const time_t*) &cur_time)) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_i("buffer : {\"Get local time\": %s}", ctime((const time_t*) &cur_time));
 }
 rt_thread_delay(rt_tick_from_millisecond(5 * 1000));
 }
}

static int onenet_upload_cycle_hw(void)
{
    rt_thread_t tid;

tid = rt_thread_create("onenet_upload",
                           onenet_upload_ntp_entry,
                           RT_NULL,
                           2 * 1024,
                           RT_THREAD_PRIORITY_MAX / 3 - 1,
                           5);
    if (tid)
    {
        rt_thread_startup(tid);
    }

return 0;
}
MSH_CMD_EXPORT(onenet_upload_cycle_hw, send data to OneNET cloud cycle);

/* onenet mqtt command response callback function */
static void onenet_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)
{
 char res_buf[] = { "cmd is received! " };

log_d("recv data is %.*s ", recv_size, recv_data);

/* user have to malloc memory for response data */
    *resp_data = (uint8_t *) ONENET_MALLOC(strlen(res_buf));

strncpy(*resp_data, res_buf, strlen(res_buf));

*resp_size = strlen(res_buf);
}

/* set the onenet mqtt command response callback function */
static int onenet_set_cmd_rsp(int argc, char **argv)
{
    onenet_set_cmd_rsp_cb(onenet_cmd_rsp_cb);
}
MSH_CMD_EXPORT(onenet_set_cmd_rsp, set cmd response function);

#endif /* FINSH_USING_MSH */

static void weather_data_parse(rt_uint8_t *data, WEATHER_MSG *p_msg)
{
    cJSON *root = RT_NULL, *object = RT_NULL, *item = RT_NULL;

root = cJSON_Parse((const char *)data);
 if (!root)
 {
 /* rt_kprintf("%s", data); */
 rt_kprintf("No memory for cJSON root! ");
 return;
 }
 object = cJSON_GetObjectItem(root, "result");

item = cJSON_GetObjectItem(object, "cityno");
 strncpy(p_msg->cityNo, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" cityNo:%s ", p_msg->cityNo);

item = cJSON_GetObjectItem(object, "citynm");
 strncpy(p_msg->cityNm, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" cityName:%s ", p_msg->cityNm);

item = cJSON_GetObjectItem(object, "temperature");
 p_msg->temperature = atoi(item->valuestring);
 rt_kprintf(" temp :%d ", p_msg->temperature);

item = cJSON_GetObjectItem(object, "wind");
 strncpy(p_msg->wind, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" wd :%s ", p_msg->wind);

item = cJSON_GetObjectItem(object, "winp");
 p_msg->winp = atoi(item->valuestring);
 rt_kprintf(" ws :%d ", p_msg->winp);

item = cJSON_GetObjectItem(object, "humidity");
 p_msg->humidity = atoi(item->valuestring);
 rt_kprintf(" humidity:%d ", p_msg->humidity);

item = cJSON_GetObjectItem(object, "days");
 strncpy(p_msg->date, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" days :%s ", p_msg->date);

if (root != RT_NULL)
        cJSON_Delete(root);
}
static void weather_hw(void)
{
    rt_uint8_t *buffer = RT_NULL;
    int resp_status;
    struct webclient_session *session = RT_NULL;
    char *weather_url = RT_NULL;
    int content_length = -1, bytes_read = 0;
    int content_pos = 0;

/* 为 weather_url 分配空间 */
 weather_url = rt_calloc(1, GET_URL_LEN_MAX);
 if (weather_url == RT_NULL)
 {
 rt_kprintf("No memory for weather_url! ");
 goto __exit;
 }
 /* 拼接 GET 网址 */
 rt_snprintf(weather_url, GET_URL_LEN_MAX, GET_URI, AREA_ID);

/* 创建会话并且设置响应的大小 */
 session = webclient_session_create(GET_HEADER_BUFSZ);
 if (session == RT_NULL)
 {
 rt_kprintf("No memory for get header! ");
 goto __exit;
 }
 else
 {
 rt_kprintf("create session successed! ");
 }

/* 发送 GET 请求使用默认的头部 */
 if ((resp_status = webclient_get(session, weather_url)) != 200)
 {
 rt_kprintf("webclient GET request failed, response(%d) error. ", resp_status);
 goto __exit;
 }

/* 分配用于存放接收数据的缓冲 */
 buffer = rt_calloc(1, GET_RESP_BUFSZ);
 if(buffer == RT_NULL)
 {
 rt_kprintf("No memory for data receive buffer! ");
 goto __exit;
 }

content_length = webclient_content_length_get(session);
 if (content_length < 0)
 {
 /* 返回的数据是分块传输的. */
 do
 {
 bytes_read = webclient_read(session, buffer, GET_RESP_BUFSZ);
 if (bytes_read <= 0)
 {
 break;
 }
 } while (1);
 }
 else
 {
 do
 {
 bytes_read = webclient_read(session, buffer, 
 content_length - content_pos > GET_RESP_BUFSZ ?
 GET_RESP_BUFSZ : content_length - content_pos);
 if (bytes_read <= 0)
 {
 break;
 }
 content_pos += bytes_read;
 } while (content_pos < content_length);
 }

/* 天气数据解析 */
    weather_data_parse(buffer, &weather_msg);

__exit:
    /* 释放网址空间 */
    if (weather_url != RT_NULL)
        rt_free(weather_url);
    /* 关闭会话 */
    if (session != RT_NULL)
        webclient_close(session);
    /* 释放缓冲区空间 */
    if (buffer != RT_NULL)
        rt_free(buffer);
}```**输出结果**
![day6.png](/uploads/201810/23/160509kug2by5yb9foo5fr.png)

下载附件 [day6.pdf](https://oss-club.rt-thread.org/uploads/201810/23/160534ksrrxcevkvqerbeo.attach)