EC800_FTP_OTA(4752).c 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437
  1. /* 连接到FTP服务器 ,从FTP服务器中下载文件,下载逻辑 */
  2. /* includes ----------------------------------------------------------*/
  3. #include "EC800_FTP_OTA.h"
  4. /* typedef -----------------------------------------------------------*/
  5. ftpInfo s_ftpInfo = {
  6. .account = "cdzupdate",
  7. .passWord = "cdz2021!Z",
  8. .fileType = 1,
  9. .transmode = 1,
  10. .rsptimeout = 90,
  11. .ftpAddr = "39.98.211.244",
  12. .ftpPort = 21,
  13. .textDirectory = "/data/cdz",
  14. .textName = "centralCtrSys.bin",
  15. };
  16. /* define ------------------------------------------------------------*/
  17. // 登陆到FTP服务器
  18. // 第一步:配置和激活 PDP 上下文
  19. #define AT_QIACT_1 "AT+QIACT=1\r\n" // 激活 PDP 上下文 1
  20. #define AT_QIACT_query "AT+QIACT?\r\n" // 查询 PDP 上下文状态
  21. #define AT_QFTPCFG_ID_1 "AT+QFTPCFG=\"contextid\",1\r\n" // 查询 PDP 上下文状态
  22. // 第二步: 配置用户账号和传输设置
  23. #define AT_QFTPCFG_ACCOUNT "AT+QFTPCFG=\"account\",\"%s\",\"%s\"\r\n" // 设置用户名和密码。
  24. #define AT_QFTPCFG_FILE(fileType) "AT+QFTPCFG=\"filetype\"," #fileType "\r\n" // 设置文件类型为ASCII AT+QFTPCFG="filetype",1
  25. #define AT_QFTPCFG_TRANS(mode) "AT+QFTPCFG=\"transmode\"," #mode "\r\n" // 设置为被动传输方式AT+QFTPCFG="transmode",1
  26. #define AT_QFTPCFG_TIMEOUT(time) "AT+QFTPCFG=\"rsptimeout\"," #time "\r\n" // 设置最大响应时间(默认为90秒)
  27. //第三步:登录FTP服务器。
  28. #define AT_QFTPOPEN(addr,port) "AT+QFTPOPEN=\"" #addr "\"," #port "\r\n" // 登录FTP服务器。
  29. // 从FTP服务器下载文件 本项目文件较小,选择直接通过COM口输出下载数据
  30. #define AT_QFTPCWD(directory) "AT+QFTPCWD=\"" #directory "\"\r\n" // 设置当前目录。
  31. #define AT_QFTPSIZE(textName) "AT+QFTPSIZE=\"" #textName "\"\r\n" // 查询 FTP(S)服务器 test_my1.txt 文件大小
  32. #define AT_QFTPGET(textName, startByte, downloadNum) \
  33. "AT+QFTPGET=\"" #textName "\",\"COM:\"," #startByte "," #downloadNum "\r\n" // 下载文件, 通过COM口输出特定字段的数据
  34. // 一次下载的字节个数
  35. #define DOWNLOAD_BYTE_LEN (512)
  36. /* macro -------------------------------------------------------------*/
  37. /* variables ---------------------------------------------------------*/
  38. /* function prototypes -----------------------------------------------*/
  39. /* 1.登陆到FTP服务器--------------------------------------------------------*/
  40. static uint8_t logIn_step = 0;
  41. /**
  42. * @brief 通过EC800登录FTP
  43. * @param NONE
  44. * @note NONE
  45. * @retval 无
  46. */
  47. void EC800_LogIn_FTP(void){
  48. char* found = NULL;
  49. uint8_t errorCnt = 0; // 错误计数
  50. ftpInfo *p_ftpInfo = &s_ftpInfo;
  51. char atCmd[100] = {0}; // 静态缓冲区用于存放AT命令
  52. p_ftpInfo->fileType = p_ftpInfo->fileType; // 避免报警告
  53. switch(logIn_step){
  54. case 0: // 配置和激活 PDP 上下文
  55. // EC800M_SendCommand(AT_QIACT_1);
  56. //
  57. // found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
  58. //
  59. // if (found != NULL) {
  60. // printf("Activation successful\r\n");
  61. // }else{
  62. // errorCnt++;
  63. // printf("Activation unsuccessful\r\n");
  64. // }
  65. EC800M_SendCommand(AT_QIACT_query);
  66. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  67. if (found != NULL) {
  68. printf("PDP Context Status OK\r\n");
  69. }else{
  70. errorCnt++;
  71. printf("PDP Context Status error\r\n");
  72. }
  73. EC800M_SendCommand(AT_QFTPCFG_ID_1);
  74. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  75. if (found != NULL) {
  76. printf("Set PDP context to 1.\r\n");
  77. }else{
  78. errorCnt++;
  79. printf("ERROR! Set PDP context to 1.\r\n");
  80. }
  81. if(errorCnt == 0){
  82. logIn_step = 1;
  83. }
  84. break;
  85. case 1: // 配置用户账号和传输设置
  86. snprintf(atCmd, sizeof(atCmd), "AT+QFTPCFG=\"account\",\"%s\",\"%s\"\r\n", p_ftpInfo->account, p_ftpInfo->passWord);
  87. EC800M_SendCommand(atCmd);
  88. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  89. if (found != NULL) {
  90. printf("FINISH! Set username and password.\r\n");
  91. }else{
  92. errorCnt++;
  93. printf("ERROR! Set username and password.\r\n");
  94. }
  95. snprintf(atCmd, sizeof(atCmd), "AT+QFTPCFG=\"filetype\",%d\r\n", p_ftpInfo->fileType);
  96. EC800M_SendCommand(atCmd);
  97. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  98. if (found != NULL) {
  99. printf("FINISH! Set username and password.\r\n");
  100. }else{
  101. errorCnt++;
  102. printf("ERROR! Set username and password.\r\n");
  103. }
  104. snprintf(atCmd, sizeof(atCmd), "AT+QFTPCFG=\"transmode\",%d\r\n", p_ftpInfo->transmode);
  105. EC800M_SendCommand(atCmd);
  106. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  107. if (found != NULL) {
  108. printf("FINISH! Set to passive transfer mode.\r\n");
  109. }else{
  110. errorCnt++;
  111. printf("ERROR! Set to passive transfer mode.\r\n");
  112. }
  113. snprintf(atCmd, sizeof(atCmd), "AT+QFTPCFG=\"rsptimeout\",%d\r\n", p_ftpInfo->rsptimeout);
  114. EC800M_SendCommand(atCmd);
  115. found = EC800M_RecRespond(g_usart4_rx_buf, AT_RESP_OK);
  116. if (found != NULL) {
  117. printf("FINISH! Set username and password.\r\n");
  118. }else{
  119. errorCnt++;
  120. printf("ERROR! Set username and password.\r\n");
  121. }
  122. if(errorCnt == 0){
  123. logIn_step = 2;
  124. }
  125. break;
  126. case 2: // 登录FTP服务器。
  127. snprintf(atCmd, sizeof(atCmd), "AT+QFTPOPEN=\"%s\",%d\r\n", p_ftpInfo->ftpAddr, p_ftpInfo->ftpPort);
  128. EC800M_SendCommand(atCmd);
  129. errorCnt = Accept_and_Compare_Str("+QFTPOPEN: 0,0");
  130. if(errorCnt == 1){
  131. errorCnt = 0;
  132. printf("FINISH! Log in to the FTP server.\r\n");
  133. }else{
  134. printf("ERROR! Log in to the FTP server.\r\n");
  135. }
  136. if(errorCnt == 0){
  137. logIn_step = 3;
  138. }
  139. break;
  140. default :
  141. break;
  142. }
  143. }
  144. /* 2.从FTP服务器上下载文件--------------------------------------------------------*/
  145. /**
  146. * @brief 剔除除去固件的其他的数据
  147. * @param NONE
  148. * @note NONE
  149. * @retval 无
  150. */
  151. int extract_data_as_uint32(char* input, uint32_t* output, size_t output_size) {
  152. const char* start_marker = "\r\nCONNECT\r\n";
  153. const char* end_marker = "\r\nOK\r\n";
  154. const char* start;
  155. const char* end;
  156. // 寻找开始标记
  157. start = strstr(input, start_marker);
  158. if (start != NULL) {
  159. // 如果发现开始标记,移动指针越过开始标记
  160. start += strlen(start_marker);
  161. } else {
  162. // 如果没有发现开始标记,则从输入串的开始处理
  163. start = input;
  164. }
  165. // 寻找结束标记
  166. end = search_sequence(start, USART4_REC_LEN - (start - input), end_marker, strlen(end_marker));
  167. if (end == NULL) {
  168. return HAL_ERROR;
  169. }
  170. // 计算要提取数据的长度
  171. size_t data_length = end - start;
  172. // 确保提取的数据长度为4的倍数,适用于 uint32_t
  173. if (data_length % sizeof(uint32_t) != 0) {
  174. return HAL_ERROR;
  175. }
  176. // 计算 uint32_t 的数量
  177. size_t data_length_uint32 = data_length / sizeof(uint32_t);
  178. if (data_length_uint32 > output_size) { // 确保输出缓冲区能够存放提取的数据
  179. return HAL_ERROR;
  180. }
  181. // 提取数据并转换为 uint32_t 数组
  182. memcpy(output, start, data_length_uint32 * sizeof(uint32_t));
  183. memset(input, 0, USART4_REC_LEN); // 清空输入缓冲区
  184. return HAL_OK;
  185. }
  186. uint8_t writeFlashPage(uint32_t address, uint32_t *pData) {
  187. if (FLASH_Erase(address, 1) != HAL_OK) {
  188. return 0;
  189. }
  190. if (FLASH_Write(address, pData, (FLASH_PAGE_SIZE / sizeof(uint32_t))) != HAL_OK) {
  191. return 0;
  192. }
  193. return 1;
  194. }
  195. #define AT_CMD_SIZE 100
  196. uint32_t totalBytesReceived = 0;
  197. uint32_t currentFlashAddress = APP2_ADDRESS;
  198. uint32_t buffer[FLASH_PAGE_SIZE / sizeof(uint32_t)] = {0}; // 2KB缓冲区
  199. uint32_t bufferIndex = 0; // 缓冲区当前索引(以uint32_t为单位)
  200. /**
  201. * @brief 更新固件
  202. * @note 执行过程中不能使用printf(会触发hardfault),暂不清楚原因
  203. * @retval 0表示未完成更新,1表示更新完成
  204. */
  205. uint8_t UpdateFirmware(void) {
  206. ftpInfo *p_ftpInfo = &s_ftpInfo;
  207. char atCmd[AT_CMD_SIZE] = {0}; // 用于存放AT命令的静态缓冲区
  208. if (totalBytesReceived < p_ftpInfo->filesize) {
  209. // 计算剩余要接收的字节数
  210. uint32_t remaining = p_ftpInfo->filesize - totalBytesReceived;
  211. uint32_t bytesToRead = remaining < DOWNLOAD_BYTE_LEN ? remaining : DOWNLOAD_BYTE_LEN;
  212. // 设置FTP信息
  213. p_ftpInfo->startAddr = totalBytesReceived;
  214. p_ftpInfo->byteNum = bytesToRead;
  215. // 发送AT指令以开始接收
  216. snprintf(atCmd, AT_CMD_SIZE, "AT+QFTPGET=\"%s\",\"COM:\",%u,%u\r\n",
  217. p_ftpInfo->textName, p_ftpInfo->startAddr, bytesToRead);
  218. EC800M_SendCommand(atCmd);
  219. // 只有当还有数据需要接收时,才进行下载和写入操作
  220. if (Accept_and_Compare_Str("+QFTPGET: 0,")) { // 接收成功
  221. // 临时缓冲区,用于存放这次接收的数据
  222. uint32_t tempBuffer[DOWNLOAD_BYTE_LEN / sizeof(uint32_t)] = {0};
  223. memset(tempBuffer, 0xff, DOWNLOAD_BYTE_LEN); // 保证内存数据为缺省值0xff
  224. if (extract_data_as_uint32(g_usart4_rx_buf, tempBuffer, sizeof(tempBuffer) / sizeof(uint32_t)) != HAL_OK) {
  225. // printf("ERROR! UpdateFirmware_extract_data\n");
  226. return 0;
  227. }
  228. // 将临时缓冲区中的数据追加到主缓冲区
  229. for (uint32_t i = 0; i < (DOWNLOAD_BYTE_LEN / sizeof(uint32_t)); i++) {
  230. buffer[bufferIndex++] = tempBuffer[i];
  231. // 如果主缓冲区满了,写入Flash
  232. if (bufferIndex == (FLASH_PAGE_SIZE / sizeof(uint32_t))) {
  233. s_param_boot.pageNumMove += 1;
  234. if (!writeFlashPage(currentFlashAddress, buffer)) {
  235. // printf("ERROR! Write to flash failed\n");
  236. return 0;
  237. }
  238. // 重置缓冲区索引,准备下一轮数据接收
  239. memset(buffer, 0xFF, FLASH_PAGE_SIZE); // 保证内存数据为缺省值0xff
  240. bufferIndex = 0;
  241. currentFlashAddress += FLASH_PAGE_SIZE;
  242. }
  243. }
  244. totalBytesReceived += bytesToRead;
  245. } else {
  246. // printf("ERROR! Receive fault!\n");
  247. return 0;
  248. }
  249. // 如果下载完成,则处理剩余数据并写入最后一部分
  250. if (totalBytesReceived >= p_ftpInfo->filesize) {
  251. // 检查buffer是否有未写入的数据
  252. if (bufferIndex > 0) {
  253. s_param_boot.pageNumMove += 1;
  254. // 写入最后一页数据
  255. if (!writeFlashPage(currentFlashAddress, buffer)) {
  256. // printf("ERROR! Write to flash failed\n");
  257. return 0;
  258. }
  259. }
  260. return 1; // 更新完成
  261. }
  262. }
  263. return 0; // 更新未完成
  264. }
  265. uint8_t downloadStep = 0;
  266. /**
  267. * @brief FTP服务器上下载文件
  268. * @param NONE
  269. * @note 每一个任务周期过来下载2k的数据,以保证其他任务的正常运行
  270. * @retval 无
  271. */
  272. void EC800_FTP_DownloadText(void){
  273. uint8_t errorCnt = 0; // 错误计数
  274. ftpInfo *p_ftpInfo = &s_ftpInfo;
  275. char atCmd[100] = {0}; // 静态缓冲区用于存放AT命令
  276. uint8_t backTemp = 0; // 返回值临时变量
  277. switch(downloadStep){
  278. case 0: // 设置文件目录
  279. snprintf(atCmd, sizeof(atCmd), "AT+QFTPCWD=\"%s\"\r\n", p_ftpInfo->textDirectory);
  280. EC800M_SendCommand(atCmd);
  281. errorCnt = Accept_and_Compare_Str("+QFTPCWD: 0,0");
  282. if (errorCnt == 1) {
  283. errorCnt = 0;
  284. printf("FINISH! Set the file directory.\r\n");
  285. }else{
  286. printf("ERROR! Set the file directory.\r\n");
  287. }
  288. if(errorCnt == 0){
  289. downloadStep = 1;
  290. }
  291. break;
  292. case 1: // 获取文件长度
  293. snprintf(atCmd, sizeof(atCmd), "AT+QFTPSIZE=\"%s\"\r\n", p_ftpInfo->textName);
  294. EC800M_SendCommand(atCmd);
  295. errorCnt = Accept_and_Compare_Str("+QFTPSIZE: 0,");
  296. if (errorCnt == 1) {
  297. errorCnt = 0;
  298. printf("FINISH! Get the length of the file.\r\n");
  299. // 使用sscanf从字符串中解析整数
  300. if(sscanf(g_usart4_rx_buf, "\r\n+QFTPSIZE: %*d,%u", &(p_ftpInfo->filesize)) == 1) {
  301. // 解析成功,filesize变量现在包含值1000
  302. printf("The filesize is: %u\n", p_ftpInfo->filesize);
  303. } else {
  304. // 解析失败
  305. errorCnt++;
  306. printf("Failed to parse the filesize.\n");
  307. }
  308. }else{
  309. printf("ERROR! Get the length of the file.\r\n");
  310. }
  311. if(errorCnt == 0){
  312. downloadStep = 2;
  313. }
  314. break;
  315. case 2:
  316. // 判断当前所处APP地址 选取更新地址
  317. currentFlashAddress = APP2_ADDRESS;
  318. downloadStep = 3;
  319. break;
  320. case 3: // 更新固件
  321. backTemp = UpdateFirmware();
  322. if(backTemp == 1){
  323. downloadStep = 4;
  324. }
  325. break;
  326. case 4: // 固件更新完成,设置更新标志,并复位
  327. s_param_boot.updateFlag = 1; // 需要更新固件并搬移
  328. Write_paramArea();
  329. downloadStep = 5;
  330. break;
  331. default :
  332. break;
  333. }
  334. }
  335. /* 3. OTA升级从FTP流程--------------------------------------------------------*/
  336. uint8_t upgradeStep = 0;
  337. /**
  338. * @brief OTA升级从FTP
  339. * @param NONE
  340. * @note NONE
  341. * @retval 无
  342. */
  343. void EC800_FTP_OTA_Upgrade(void){
  344. ec800Date *p_ec800Date = &s_ec800Date;
  345. // 等待ec800模块初始化完成 并满足更新条件
  346. if(!((p_ec800Date->ec800InitFlag) && (p_ec800Date->hardwareUpdate))){
  347. return;
  348. }
  349. switch (upgradeStep){
  350. case 0: // 登陆到FTP服务器
  351. EC800_LogIn_FTP();
  352. if(logIn_step == 3){
  353. upgradeStep = 1;
  354. }
  355. break;
  356. case 1: // 从FTP服务器上下载文件
  357. EC800_FTP_DownloadText();
  358. if(downloadStep == 5){
  359. upgradeStep = 2;
  360. }
  361. break;
  362. case 2: // 复位升级
  363. osDelay(1000);
  364. HAL_NVIC_SystemReset();
  365. break;
  366. default:
  367. break;
  368. }
  369. }