• NL6621 实现获取天气情况

    一、主要完成的工作

    1、建立TASK

    1. INT32 main(VOID)
    2. {
    3.     /* system Init */
    4.     SystemInit();
    5.    
    6.     OSTaskCreate(TestAppMain, NULL, &sAppStartTaskStack[NST_APP_START_TASK_STK_SIZE -1],  NST_APP_TASK_START_PRIO); 
    7.  
    8.     OSStart();
    9.     
    10.     return 1;
    11. }

    2、application test task

    1. VOID TestAppMain(VOID * pParam)
    2. {
    3.  
    4.   demo_gpio_init();     //初始化LCD GPIO
    5. 	
    6.   InitLCD();            //初始化屏幕
    7.   clrScr(VGA_BLACK);    //清屏
    8.   GUI_Write16CnCharMatrix(0,160,"初始化......     ",VGA_BLUE,VGA_BLACK);
    9.  
    10.  
    11.   pLinkUpSem = OSSemCreate(0);
    12.  
    13.   InfSysEvtCBSet(AppEvtCallBack);
    14.   InfLoadDefaultParam();
    15.  
    16.   sys_thread_new("weatherThread", weatherThread, NULL, NST_TEST_APP_TASK_STK_SIZE, TCPIP_THREAD_PRIO + 4);
    17.  
    18.     while (1) 
    19.     {                                          /* Task body, always written as an infinite loop.       */
    20.         OSTimeDly(20);
    21.         DBGPRINT_LWIP(DEBUG_INFO, "TestApp RxDataCnt=%d, SendDataCnt=%d.\n", RxDataCnt, SendDataCnt);
    22.     }
    23.  
    24. }

    3、void weatherThread(void *arg)

    1. void weatherThread(void *arg)
    2. {
    3. 	char* buff,*http_data;
    4. 	
    5. 	DBGPRINT(DEBUG_TRACE, " ********************** weatherThread ********************* \n\r");
    6.  
    7. 	connectWifi();            //连接WIFI
    8. 	
    9. 	buff=TestWeatherApi();    //从网页API获得天气数据
    10. 	printf("%s\r\n", buff);
    11. 	http_data=https_get_data(buff);    //获得JSON部分
    12. 	mem_free(buff);
    13. 	printf("[http_data]:%s\r\n", http_data);
    14.  
    15. 	extract_all_from_json(http_data);    //解析JSON数据
    16. 	mem_free(http_data);
    17.  
    18.  
    19.     //LCD显示
    20. 	GUI_Write16CnCharMatrix(5,20,"日期：",VGA_WHITE,VGA_BLACK);
    21. 	GUI_Write16CnCharMatrix(53,20,city_weather.date,VGA_BLUE,VGA_BLACK);
    22. 	GUI_Write16CnCharMatrix(5,60,"城市：",VGA_WHITE,VGA_BLACK);
    23. 	GUI_Write16CnCharMatrix(53,60,city_weather.city,VGA_BLUE,VGA_BLACK);
    24. 	GUI_Write16CnCharMatrix(5,100,"温度：",VGA_WHITE,VGA_BLACK);
    25. 	GUI_Write16CnCharMatrix(53,100,city_weather.tem,VGA_BLUE,VGA_BLACK);
    26.  
    27.  
    28. 	while(1)
    29. 	{
    30. 			OSTimeDly(500);
    31. 	}
    32. }

     4、void connectWifi(void)

    1. void connectWifi(void)
    2. {
    3. 	UINT8 Err;
    4.  
    5. 	InfWiFiStop();
    6. 	OSTimeDly(10);
    7.  
    8. 	InfNetModeSet(PARAM_NET_MODE_STA_BSS); 
    9. 	InfAuthModeSet(PARAM_AUTH_MODE_WPA2PSK);
    10.  
    11.     //此处根据实际修改SSID/PASSWORD
    12. 	InfSsidSet("SSID",4);    /* set ssid */
    13. 	InfKeySet(0, "PASSWORD",8);  /* set pw */
    14.  
    15. 	InfEncModeSet(PARAM_ENC_MODE_AUTO);
    16. 	InfConTryTimesSet(0);                       /* set trytime */	
    17. 	InfWiFiStart();
    18.  
    19. 	//Waiting for connect success
    20. 	OSSemPend(pLinkUpSem, 0, &Err);
    21. }

    5、char*  TestWeatherApi(void)

    1. #define HTTP_HOST "v1.yiketianqi.com"
    2. #define HTTP_URL  "api?unescape=1&version=v61&appid=此处替换自己的ID&appsecret=此处替换自己的key"
    3. #define HOST_PORT "80"
    4. static const char* REQUEST = "GET " "/%s" " HTTP/1.1\r\n"
    5. "Host: " "%s" ":" HOST_PORT "\r\n"
    6. "User-Agent: AiPi-DSL_Dashboard\r\n"
    7. "\r\n";
    8.  
    9.  
    10. char*  TestWeatherApi(void)
    11. {
    12. 	char* https_request_handle = mem_malloc(512);
    13.     char *recv_data;
    14.     int sock; 
    15. 	UINT32 TargetIp;
    16.     struct sockaddr_in server_addr;
    17.  
    18. 		
    19. 	ip_addr_t hostip;
    20. 		
    21. 	netconn_gethostbyname(HTTP_HOST, &hostip);
    22. 	
    23. 	DBGPRINT_LWIP(DEBUG_TRACE, "HTTP_HOST:%s,IP:%d\n",HTTP_HOST,hostip.addr);
    24. 	
    25. 	TargetIp =hostip.addr;
    26.     DBGPRINT_LWIP(DEBUG_TRACE, "TargetIp:%d\n",TargetIp);
    27.     /* 分配用于存放接收数据的缓冲 */
    28.     recv_data = mem_malloc(1024*4);
    29.     if (recv_data == NULL)
    30.     {
    31.        DBGPRINT_LWIP(DEBUG_ERROR, "TCP Client  memory ERR\n");
    32.         return 0;
    33.     }
    34. 		
    35. 		/* 一、创建一个socket，类型是SOCKET_STREAM，TCP类型 */
    36. 		if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    37. 		{
    38. 				/* 创建socket失败 */
    39. 				DBGPRINT_LWIP(DEBUG_ERROR, "TCP Client Socket error\n");
    40. 				/* 释放接收缓冲 */
    41. 				mem_free(recv_data);
    42. 				return 0;
    43. 		}
    44.  
    45. 		/* 初始化预连接的服务端地址 */
    46. 		server_addr.sin_family = AF_INET;
    47. 		server_addr.sin_port = htons(atoi(HOST_PORT)); 
    48. 		server_addr.sin_addr.s_addr= TargetIp;
    49. 		memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
    50.  
    51. 		/* 二、连接到服务端 */
    52. 		if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
    53. 		{
    54. 				/* 连接失败 */
    55. 				DBGPRINT_LWIP(DEBUG_TRACE, "TCP Client connect error !");
    56. 				lwip_close(sock);
    57. 					 
    58. 				///*释放接收缓冲 */
    59. 				mem_free(recv_data);
    60. 				return 0;
    61. 				//OSTimeDly(2000);
    62. 		}
    63. 		else
    64. 		{
    65. 				DBGPRINT_LWIP(DEBUG_TRACE, "TCP Client connect OK!\n");
    66. 		}
    67.  
    68. 		memset(https_request_handle, 0, 256);
    69.         sprintf(https_request_handle, REQUEST, HTTP_URL, HTTP_HOST);
    70. 		
    71. 		/* 三、http请求 */
    72. 		if(write(sock, https_request_handle, strlen(https_request_handle))<0)
    73. 		{
    74. 			DBGPRINT_LWIP(DEBUG_TRACE, "http write error !");
    75. 			close(sock);
    76. 		}
    77. 		
    78. 		/* 四、读http返回结果 */
    79. 		read(sock, recv_data, 1024*4);
    80. 		
    81. 		shutdown(sock, SHUT_RDWR);
    82.         close(sock);
    83. 		mem_free(https_request_handle);
    84.  
    85. 		
    86.    return recv_data;
    87. }

    6、static char* https_get_data(const char* https_request_data)

    1.  
    2. static char* https_get_data(const char* https_request_data)
    3. {
    4.     char* request_data = https_request_data;
    5.     static char* https_data;
    6. 	char* request_value;
    7. 	size_t i;
    8.  
    9.     https_data = mem_malloc(1024*3);
    10.     memset(https_data, 0, 1024*3);
    11.     request_data += 2;
    12.  
    13.     request_value = strtok(request_data, "\n");
    14.     for (i = 0; i < 15; i++)
    15.     {
    16. 		if (i==14) strcpy(https_data, request_value);
    17.         memset(request_value, 0, strlen(request_value));
    18.         request_value = strtok(NULL, "\n");
    19.     }
    20.  
    21.     return https_data;
    22. }

    7、json解析

    1. void extract_item_from_json(const char *json_str,char *itemname,char *target)
    2. {
    3. 	char *start = strstr(json_str, itemname); // 查找"cityEn":"  
    4. 	char *end;
    5. 	size_t len=20;
    6. 	char item[20]; // +1 for null terminator
    7.  
    8. 	 if (start != NULL) {  
    9.         start += strlen(itemname); // 跳过itemname 
    10.         end = strchr(start, '"'); // 查找下一个双引号  
    11.         if (end != NULL) {  
    12.             // 提取  
    13.             len = end - start;  
    14.             strncpy(item, start, len);  
    15.             item[len] = '\0'; // 添加字符串结束符  
    16.             printf("Item: %s\n", item);  
    17.  
    18. 			strncpy(target, item, len);
    19. 			target[len] = '\0'; // 添加字符串结束符 
    20.  
    21. 		    
    22.         }  
    23.     } else {  
    24.         printf("Item[%s] not found in the JSON string.\n",itemname);  
    25.     }  
    26. }
    27.  
    28. void extract_all_from_json(const char *json_str)
    29. {
    30. 	extract_item_from_json(json_str,"\"cityEn\":\"",city_weather.city);
    31. 	extract_item_from_json(json_str,"\"tem\":\"",city_weather.tem);
    32. 	extract_item_from_json(json_str,"\"date\":\"",city_weather.date);
    33. }

    二、说明

    1、NL6621 SDK二次开发，还是用KEIL4吧，KEIL5编译太慢了。

    2、没用CJSON，不是不想用，尝试了好长时间还是用不了CJSON，最后JSON自己解析了。

    3、编译的bin文件，不要超过192k，否则没法烧录，编译也会失败。

    4、scatter_loader.scat没有为适应NuDevTool ver1.11.0.exe修改，需要用bootTool.exe或bootTool_Ack_0822.exe烧录。

    1.  
    2. ; 0x10100-0x40000 for download SRAM FW(including 32KB for customer), interrupt vector locate in 0x10100
    3. LOAD_REGION 0x00010100 0x0002FF00  {    ; load region size_region
    4.     
    5.     ROM  0x00010100 0x0002FF00  {  ; load address = execution address
    6.         *.o (RESET, +First)    ; interrupt vector table, do not change it
    7.         *(InRoot$$Sections)
    8.         .ANY (+RO)
    9.     }

    5、需要用NuDevTool ver1.11.0.exe烧录工具将字库gb2312_80.bin烧录到0xB0000，不烧录字库运行不了。

    #define FLASH_ADDR_BASE 0xB0000

    6、源码链接：

    链接：https://pan.baidu.com/s/1KQwfkdXDj2R9A_3XGqbgWA?pwd=cmpn 
    提取码：cmpn

  • 相关阅读:
    第二届全国高校计算机技能竞赛——C++赛道 题解
    docker服务部署、迁移与备份、dockerfile、私有仓库
    C语言每日一题（19）回文素数
    CMake学习教程（一）
    2.3IP详解及配置
    扁平化iOS风商务工作汇报PPT模板
    字符设备驱动框架（字符设备基础一）
    2023.05.28 学习周报
    java线程调度
    UI组件库Kendo UI for Vue原生组件中文 - 按钮概述
  • 原文地址：https://blog.csdn.net/weixin_44067125/article/details/139174817