RT-Thread-【7天入门RTOS网络编程】Young day6-7 作业RT-Thread问答社区

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

发布于 2018-10-27 09:59:30 浏览：1269 订阅该版

* 本帖最后由 爱喝柠檬水 于 2018-10-27 10:01 编辑 *

题目要求：观看视频及文档，能够正常获取并运行示例程序，运用所学的知识，获取实时的日期、时间、天气，并把获取的数据通过在 OneNet 云平台创建应用展示出来。
设计思路：1、初始化onenet

2、HTTP获取数据并保存，NTP获取网络时间信息并保存

3、上传数据到onenet平台，通过应用显示出来

图了个方便，应用RT-Threadt提供的例程修改，调用http、cJSon和NTP头文件在onenet_sample中完成项目，其中部分函数自己修改了
此处只贴出修改后的函数其他代码均未变。项目中我使用了两个线程，一个发送时间数据，一个发送天气数据。

cJson解析出天气数据再发送
```void weather_data_parse(rt_uint8_t *data)
{
    cJSON *root = RT_NULL, *object = RT_NULL, *item = RT_NULL;

root = cJSON_Parse((const char *)data);
 if (!root)
 {
 rt_kprintf("No memory for cJSON root! ");
 return;
 }
 object = cJSON_GetObjectItem(root, "result");
 //城市
 item = cJSON_GetObjectItem(object, "citynm");
 if (onenet_mqtt_upload_string("CityName", item->valuestring) < 0)
 {
 log_e("CityName error!");
 return;
 }
 else
 {
 log_d("buffer : {\"CityName\":%s}", item->valuestring);
 }
 rt_thread_delay(100);
 //rt_kprintf(" cityName :%s ", item->valuestring);
 //温度
 item = cJSON_GetObjectItem(object, "temp_curr"); 
 int temp = atoi(item->valuestring); //发现只能得到字符串才能正确显示数值，所以我将其转换为int型
 //rt_kprintf(" temperature :%s ", item->valuestring);
 if (onenet_mqtt_upload_digit("temperature", temp) < 0)
 {
 log_e("temperature error!");
 return;
 }
 else
 {
 log_d("buffer : {\"temperature\":%d}", temp);
 }
 rt_thread_delay(100);
 //风向
 item = cJSON_GetObjectItem(object, "wind");
 //rt_kprintf(" temperature :%s ", item->valuestring);
 if (onenet_mqtt_upload_string("windD", item->valuestring) < 0)
 {
 log_e("windD error!");
 return;
 }
 else
 {
 log_d("buffer : {\"windD\":%s}", item->valuestring);
 }
 rt_thread_delay(100);
 //风速
 item = cJSON_GetObjectItem(object, "winp");
 //rt_kprintf(" winp :%s ", item->valuestring);
 if (onenet_mqtt_upload_string("winP", item->valuestring) < 0)
 {
 log_e("winP error!");
 return;
 }
 else
 {
 log_d("buffer : {\"winP\":%s}", item->valuestring);
 }
 rt_thread_delay(100);
 //湿度
 item = cJSON_GetObjectItem(object, "humidity");
 int humidity = atoi(item->valuestring);
 //rt_kprintf(" humidity :%s ", item->valuestring);
 if (onenet_mqtt_upload_digit("Humidity", humidity) < 0)
 {
 log_e("Humidity error!");
 return;
 }
 else
 {
 log_d("buffer : {\"Humidity\":%s}", item->valuestring);
 }
 rt_thread_delay(100);
 //天气
 item = cJSON_GetObjectItem(object, "weather");
 //rt_kprintf(" weather :%s ", item->valuestring);
 if (onenet_mqtt_upload_string("Weather", item->valuestring) < 0)
 {
 log_e("Weather error!");
 return;
 }
 else
 {
 log_d("buffer : {\"Weather\":%s}", item->valuestring);
 }
 
 if (root != RT_NULL)
 cJSON_Delete(root);
}```发送时间数据函数
```static void onenet_upload_http(void *parameter)
{
 char *time;

while (1)
 {
 time_t cur_time = ntp_sync_to_rtc(NULL);
 time = ctime((const time_t*) &cur_time);
 //上传时间数据
 if (onenet_mqtt_upload_string("timedata", time) < 0)
 {
 log_e("timedata error!");
 break;
 }
 else
 {
 log_d("buffer : {\"timedata\":%s}", time);
 }
 rt_thread_delay(rt_tick_from_millisecond(5 * 1000));
 }
}```线程初始化```int onenet_upload_cycle(void)
{
 rt_thread_t tid,tid1;
 //时间线程 
 tid = rt_thread_create("onenet_send_timedata",
 onenet_upload_http,
 RT_NULL,
 1024,
 RT_THREAD_PRIORITY_MAX / 3 ,
 5);
 if (tid != RT_NULL)
 rt_thread_startup(tid);
 else
 return -1;
 //天气线程
 tid1 = rt_thread_create("onenet_send_ntp",
 onenet_upload_ntp,
 RT_NULL,
 2 * 1024,
 RT_THREAD_PRIORITY_MAX / 3 - 1,
 10);
 if (tid1 != RT_NULL)
 rt_thread_startup(tid1);
 else
 return -1;
}```
运行结果：

![3.png](/uploads/201810/27/095912whggzt16y6tgy3d6.png)![4.png](/uploads/201810/27/095915cmsoee6ukmoiyy0o.png)