EC800(778).c 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636
  1. //----------------------------说明
  2. // 程序使用hal库,数据传输使用的串口,串口设置为发送+dma,接收+dma+空闲中断的模式
  3. #include "EC800.h"
  4. //-----------------------------变量定义
  5. //---------
  6. ec800Date s_ec800Date = {
  7. .ip = "39.98.37.180",
  8. .port = 32449,
  9. .clientid = "NULL",
  10. .username = "hechun",
  11. .password = "admin123",
  12. // .username = "SZC30010-AE01",
  13. // .password = "qazSZC30010-AE01",
  14. };
  15. messageDate s_messageDate = {0};
  16. typedef struct{
  17. uint8_t maxSpeed; // 服务器下发的允许最大车速
  18. uint16_t year; // 上传时间 年
  19. uint8_t month; // 上传时间 月
  20. uint8_t day; // 上传时间 日
  21. uint8_t hour; // 上传时间 时
  22. uint8_t minute; // 上传时间 分
  23. uint8_t sec; // 上传时间 秒
  24. }recDate;
  25. recDate s_recDate = {0};
  26. nmea_msg s_nmea_msg = {0};
  27. nmea_utc_time s_nmea_utc_time = {0};
  28. // AT指令响应超时时间定义
  29. #define REC_TIMEOUT (10000) // 1ms
  30. /**
  31. * @brief 计算字符串的长度
  32. * @param str: 所需计算字符串的指针
  33. * @note
  34. * @retval 无
  35. */
  36. int EC800_calculateStringLength(const char* str) {
  37. int length = 0;
  38. while (str[length] != '\0') {
  39. length++;
  40. }
  41. return length;
  42. }
  43. /**
  44. * @brief 发送指令函数
  45. * @param command: 指令
  46. * @param enterNum: 进入函数次数,只有第一次的时候清除buff
  47. * @note
  48. * @retval 无
  49. */
  50. void EC800M_SendCommand(const char* command)
  51. {
  52. uint32_t stringLen = 0;
  53. stringLen = EC800_calculateStringLength(command);
  54. // 使用DMA
  55. // //等待发送状态OK
  56. // while(HAL_DMA_GetState(&hdma_usart3_tx) == HAL_DMA_STATE_BUSY) osDelay(1);
  57. // //发送数据
  58. // HAL_UART_Transmit_DMA(&huart3, (uint8_t*)command, stringLen);
  59. // 不使用发送dma
  60. HAL_UART_Transmit(&huart4, (uint8_t*)command, stringLen, 1000);
  61. }
  62. /**
  63. * @brief 接收指令回复函数
  64. * @param haystack: 接收的字符串数据
  65. * @param needle: 正确回复的数据
  66. * @note
  67. * @retval 无
  68. */
  69. char* EC800M_RecRespond(char *haystack, const char *needle ){
  70. char* p = NULL;
  71. HAL_UART_Receive_DMA(&huart4, (uint8_t*)g_usart4_rx_buf, USART4_REC_LEN); //设置接收缓冲区
  72. // __HAL_UART_ENABLE_IT(&huart4, UART_IT_IDLE);
  73. while(g_usart4_rx_sta == 0) osDelay(1);
  74. // __HAL_UART_DISABLE_IT(&huart4, UART_IT_IDLE); // 关闭空闲中断
  75. g_usart4_rx_sta= 0;
  76. p = strstr(haystack, needle);
  77. memset(haystack, 0, USART4_REC_LEN); // 清除数据buff
  78. HAL_UART_DMAStop(&huart4);
  79. return p;
  80. }
  81. // 自定义的搜索函数
  82. void* search_sequence(const void* haystack, size_t haystack_len, const void* needle, size_t needle_len) {
  83. const unsigned char* h = (const unsigned char*)haystack;
  84. const unsigned char* n = (const unsigned char*)needle;
  85. // 如果needle为空或haystack长度小于needle长度,则直接返回NULL
  86. if (needle_len == 0 || haystack_len < needle_len) {
  87. return NULL;
  88. }
  89. for (size_t i = 0; i <= haystack_len - needle_len; ++i) {
  90. size_t j;
  91. for (j = 0; j < needle_len; ++j) {
  92. if (h[i + j] != n[j]) {
  93. break; // 如果当前字符不匹配,则跳出内层循环
  94. }
  95. }
  96. if (j == needle_len) {
  97. return (void*)(h + i); // 找到匹配的序列,返回其在haystack中的位置
  98. }
  99. }
  100. // 如果遍历了整个haystack都没有找到匹配的序列,则返回NULL
  101. return NULL;
  102. }
  103. // 接收并比较响应字符串
  104. uint8_t Accept_and_Compare_Str(const char* needle){
  105. uint8_t temp = 0;
  106. static uint16_t timeOutCnt = 0; // 超时计数
  107. HAL_UART_Receive_DMA(&huart4, (uint8_t*)g_usart4_rx_buf, USART4_REC_LEN); //设置接收缓冲区
  108. // __HAL_UART_ENABLE_IT(&huart4, UART_IT_IDLE);
  109. while(!temp) {
  110. osDelay(1);
  111. if(search_sequence(g_usart4_rx_buf, USART4_REC_LEN, needle, strlen(needle))){
  112. temp = 1;
  113. }
  114. if(search_sequence(g_usart4_rx_buf, USART4_REC_LEN, "ERROR", strlen("ERROR"))){
  115. temp = 2;
  116. }
  117. if(timeOutCnt < REC_TIMEOUT){
  118. timeOutCnt++;
  119. }else{
  120. timeOutCnt = 0;
  121. temp = 3;
  122. }
  123. }
  124. g_usart4_rx_sta = 0;
  125. HAL_UART_DMAStop(&huart4);
  126. // __HAL_UART_DISABLE_IT(&huart4, UART_IT_IDLE); // 关闭空闲中断
  127. return temp;
  128. }
  129. /**
  130. * @brief 接收使能函数
  131. * @note
  132. * @retval 无
  133. */
  134. void EC800_recEnable(void){
  135. HAL_UART_Receive_DMA(&huart4, (uint8_t*)g_usart4_rx_buf, USART4_REC_LEN); //设置接收缓冲区
  136. __HAL_UART_ENABLE_IT(&huart4, UART_IT_IDLE);
  137. while(g_usart4_rx_sta == 0) osDelay(1);
  138. }
  139. /**
  140. * @brief 提取检查信号响应字符串字段中的信号量并进行信号判断
  141. * @param data: 响应的信号量指针
  142. * @note
  143. * @retval 无
  144. */
  145. static uint8_t EC800_extractSignal(char *data){
  146. char *token;
  147. int field_1;
  148. // 使用strtok函数提取字段
  149. token = strtok(data, ":,");
  150. while (token != NULL) {
  151. field_1 = atoi(token); // 转换为整数类型
  152. token = strtok(NULL, ":,");
  153. memset(data, 0, USART4_REC_LEN); // 清除数据buff
  154. g_usart4_rx_sta = 0; // 清除接收状态
  155. if (field_1 < 31) {
  156. return 1;
  157. } else {
  158. return 0;
  159. }
  160. }
  161. return 0;
  162. }
  163. /**
  164. * @brief 获取IMSI号
  165. * @param 无
  166. * @note
  167. * @retval 1: imsi没有获取到 0;imsi获取到
  168. */
  169. uint8_t EC800_getIMSI(void){
  170. char* found = NULL;
  171. char number[16]; // 15 digits + 1 for null terminator
  172. int numberIndex = 0;
  173. int numberFound = 0;
  174. EC800M_SendCommand(AT_CIMI);
  175. EC800_recEnable();
  176. found = strstr(g_usart4_rx_buf, AT_RESP_OK);
  177. if (found != NULL) {
  178. printf("IMSI is get\r\n");
  179. }else{
  180. printf("IMSI is not get\r\n");
  181. return 1;
  182. }
  183. for (int i = 0; i < strlen(g_usart4_rx_buf); i++) {
  184. if (isdigit(g_usart4_rx_buf[i])) {
  185. number[numberIndex] = g_usart4_rx_buf[i];
  186. numberIndex++;
  187. if (numberIndex >= 15) {
  188. numberFound = 1;
  189. break;
  190. }
  191. }
  192. }
  193. number[numberIndex] = '\0';
  194. if (numberFound) {
  195. memcpy(s_messageDate.imsi, number, strlen(number));
  196. printf("IMSI is: %s\n", number);
  197. } else {
  198. printf("Error: Unable to extract the number\n");
  199. }
  200. return 0;
  201. }
  202. /**
  203. * @brief EC800M确认网络并链接MQTT服务器
  204. * @param NONE
  205. * @note
  206. * @retval 无
  207. */
  208. uint8_t linkStep = 0;
  209. void EC800M_link(void){
  210. uint8_t temp = 0;
  211. char command[100] = {0};
  212. char errrCnt = 0; // 错误计数
  213. switch(linkStep){
  214. case 0: // 基础配置
  215. EC800M_SendCommand(AT_CMD_TEST);
  216. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  217. printf("Module status normal\r\n");
  218. }else{
  219. errrCnt++;
  220. printf("Module status abnormal\r\n");
  221. }
  222. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  223. if(errrCnt == 0){
  224. linkStep = 1;
  225. }else{
  226. errrCnt = 0;
  227. }
  228. break;
  229. case 1: // 获取ISMI号
  230. errrCnt = EC800_getIMSI();
  231. if(errrCnt == 0){
  232. linkStep = 2;
  233. }else{
  234. errrCnt = 0;
  235. }
  236. break;
  237. case 2:
  238. EC800M_SendCommand(AT_CMD_ATE0);
  239. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  240. printf("Cancel module echo\r\n");
  241. }else{
  242. errrCnt++;
  243. printf("Failed to cancel module echo\r\n");
  244. }
  245. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  246. if(errrCnt == 0){
  247. linkStep = 3;
  248. }else{
  249. errrCnt = 0;
  250. }
  251. break;
  252. case 3:
  253. EC800M_SendCommand(AT_CMD_CPIN);
  254. if (Accept_and_Compare_Str(AT_RESP_CPIN_READY) == 1) {
  255. printf("SIM card normal\r\n");
  256. }else{
  257. errrCnt++;
  258. printf("SIM card abnormal\r\n");
  259. }
  260. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  261. if(errrCnt == 0){
  262. linkStep = 4;
  263. }else{
  264. errrCnt = 0;
  265. }
  266. break;
  267. case 4:
  268. EC800M_SendCommand(AT_CMD_CSQ);
  269. EC800_recEnable();
  270. temp = EC800_extractSignal(g_usart4_rx_buf);
  271. if (temp) {
  272. printf("signal normal\r\n");
  273. }else{
  274. errrCnt++;
  275. printf("signal abnormal\r\n");
  276. }
  277. if(errrCnt == 0){
  278. linkStep = 5;
  279. }else{
  280. errrCnt = 0;
  281. }
  282. break;
  283. case 5:
  284. EC800M_SendCommand(AT_CMD_CREG);
  285. // EC800_recEnable();
  286. // // 使用字符串处理函数判断是否为正常状态
  287. // if (strstr(g_usart4_rx_buf, "1") != NULL || strstr(g_usart4_rx_buf, "5") != NULL) {
  288. // printf("The module successfully registered on the GSM network\r\n");
  289. // } else {
  290. // errrCnt++;
  291. // printf("The module failed to register on the GSM network\r\n");
  292. // }
  293. if((Accept_and_Compare_Str("+CREG: 0,1") == 1) || (Accept_and_Compare_Str("+CREG: 0,5") == 1)){
  294. printf("The module successfully registered on the GSM network\r\n");
  295. }else{
  296. errrCnt++;
  297. printf("The module failed to register on the GSM network\r\n");
  298. }
  299. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  300. g_usart4_rx_sta = 0; // 清除接收状态
  301. if(errrCnt == 0){
  302. linkStep = 6;
  303. }else{
  304. errrCnt = 0;
  305. }
  306. break;
  307. case 6:
  308. EC800M_SendCommand(AT_CMD_QIDEACT);
  309. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  310. printf("Successfully disabled mobile scene\r\n");
  311. }else{
  312. errrCnt++;
  313. printf("Failed to disable mobile scene\r\n");
  314. }
  315. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  316. if(errrCnt == 0){
  317. linkStep = 7;
  318. }else{
  319. errrCnt = 0;
  320. }
  321. break;
  322. case 7:
  323. EC800M_SendCommand(AT_CMD_QIACT);
  324. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  325. printf("Successfully enabled mobile scene\r\n");
  326. }else{
  327. errrCnt++;
  328. printf("Failed to enable mobile scene\r\n");
  329. }
  330. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  331. if(errrCnt == 0){
  332. linkStep = 8;
  333. }else{
  334. errrCnt = 0;
  335. }
  336. break;
  337. case 8: // 连接mqtt服务器
  338. sprintf(command, "AT+QMTCFG=\"qmtping\",0,%d\r\n", 30);
  339. EC800M_SendCommand(command);
  340. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  341. printf("MQTT heartbeat set successfully\r\n");
  342. }else{
  343. errrCnt++;
  344. printf("Failed to set MQTT heartbeat\r\n");
  345. }
  346. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  347. if(errrCnt == 0){
  348. linkStep = 9;
  349. }else{
  350. errrCnt = 0;
  351. }
  352. break;
  353. case 9:
  354. EC800M_SendCommand(AT_CMD_QMTCFG_SET_DATA_MODE);
  355. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  356. printf("Data receiving mode set successfully.\r\n");
  357. }else{
  358. errrCnt++;
  359. printf("Failed to set data receiving mode\r\n");
  360. }
  361. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  362. if(errrCnt == 0){
  363. linkStep = 10;
  364. }else{
  365. errrCnt = 0;
  366. }
  367. break;
  368. case 10:
  369. sprintf(command,"AT+QMTOPEN=0,\"%s\",%d\r\n", s_ec800Date.ip, s_ec800Date.port);
  370. EC800M_SendCommand(command);
  371. // found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
  372. // found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_QMTOPEN);
  373. //
  374. // if (found != NULL) {
  375. // printf("Successfully opened a network for the module\r\n");
  376. // }else{
  377. // errrCnt++;
  378. // printf("Failed to open a network for the module\r\n");
  379. // }
  380. temp = Accept_and_Compare_Str(AT_RESP_QMTOPEN);
  381. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  382. if (temp == 1) {
  383. printf("Successfully opened a network for the module\r\n");
  384. }else{
  385. errrCnt++;
  386. printf("Failed to open a network for the module\r\n");
  387. }
  388. if(errrCnt == 0){
  389. linkStep = 11;
  390. }else{
  391. errrCnt = 0;
  392. }
  393. break;
  394. case 11:
  395. sprintf(command,"AT+QMTCONN=0,%s,%s,%s\r\n",s_ec800Date.clientid, s_ec800Date.username, s_ec800Date.password);
  396. EC800M_SendCommand(command);
  397. if (Accept_and_Compare_Str(AT_RESP_QMTCONN) == 1) {
  398. printf("Successfully connected to the MQTT server\r\n");
  399. }else{
  400. errrCnt++;
  401. printf("Failed to connect to the MQTT server\r\n");
  402. }
  403. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  404. if(errrCnt == 0){
  405. linkStep = 12;
  406. }else{
  407. errrCnt = 0;
  408. }
  409. break;
  410. default: break;
  411. }
  412. }
  413. /**
  414. * @brief EC800M初始化GNSS
  415. * @param NONE
  416. * @note
  417. * @retval 无
  418. */
  419. uint8_t gnssStep = 0;
  420. void EC800_gnss_init(void){
  421. char errrCnt = 0; // 错误计数
  422. switch(gnssStep){
  423. case 6:
  424. EC800M_SendCommand(AT_QGPS_0);
  425. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  426. printf("Turn off the GNSS module\r\n");
  427. }else{
  428. errrCnt++;
  429. printf("Failed to turn off the GNSS module\r\n");
  430. }
  431. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  432. if(errrCnt == 0){
  433. gnssStep = 7;
  434. }else{
  435. gnssStep = 7;
  436. }
  437. break;
  438. case 7:
  439. EC800M_SendCommand(AT_QGPS_1);
  440. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  441. printf("Turn on the GNSS module\r\n");
  442. }else{
  443. errrCnt++;
  444. printf("Failed to turn on the GNSS module\r\n");
  445. }
  446. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  447. if(errrCnt == 0){
  448. gnssStep = 8;
  449. }else{
  450. errrCnt = 0;
  451. }
  452. break;
  453. case 0:
  454. EC800M_SendCommand(AT_QGPSCFG_out_port);
  455. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  456. printf("Outputting NMEA Sentences via Serial Debugging\r\n");
  457. }else{
  458. errrCnt++;
  459. printf("The NMEA sentence output is set incorrectly\r\n");
  460. }
  461. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  462. if(errrCnt == 0){
  463. gnssStep = 1;
  464. }else{
  465. errrCnt = 0;
  466. }
  467. break;
  468. case 1:
  469. EC800M_SendCommand(AT_QGPSCFG_nmeasrc);
  470. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  471. printf("Enabling NMEA sentence retrieval via AT+QGPSGNMEA\r\n");
  472. }else{
  473. errrCnt++;
  474. printf("Failed to enable retrieving NMEA sentences via AT+QGPSGNMEA\r\n");
  475. }
  476. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  477. if(errrCnt == 0){
  478. gnssStep = 2;
  479. }else{
  480. errrCnt = 0;
  481. }
  482. break;
  483. case 2:
  484. EC800M_SendCommand(AT_QGPSCFG_gpsnmeatype);
  485. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  486. printf("Configuring the output type of NMEA sentences to all formats\r\n");
  487. }else{
  488. errrCnt++;
  489. printf("Failed to configure the output type of NMEA sentences to all formats\r\n");
  490. }
  491. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  492. if(errrCnt == 0){
  493. gnssStep = 3;
  494. }else{
  495. errrCnt = 0;
  496. }
  497. break;
  498. case 3:
  499. EC800M_SendCommand(AT_QGPSCFG_gnssconfig);
  500. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  501. printf("Configuring the supported GNSS satellite navigation systems to GPS+BeiDou\r\n");
  502. }else{
  503. errrCnt++;
  504. printf("Failed to configure the supported GNSS satellite navigation systems to GPS+BeiDou\r\n");
  505. }
  506. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  507. if(errrCnt == 0){
  508. gnssStep = 4;
  509. }else{
  510. errrCnt = 0;
  511. }
  512. break;
  513. case 4:
  514. EC800M_SendCommand(AT_QGPSCFG_autogps);
  515. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  516. printf("Disable GNSS auto-start\r\n");
  517. }else{
  518. errrCnt++;
  519. printf("Failed to disable GNSS auto-start\r\n");
  520. }
  521. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  522. if(errrCnt == 0){
  523. gnssStep = 5;
  524. }else{
  525. errrCnt = 0;
  526. }
  527. break;
  528. case 5:
  529. EC800M_SendCommand(AT_QGPSCFG_apflash);
  530. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  531. printf("Disable AP-Flash quick start function\r\n");
  532. }else{
  533. errrCnt++;
  534. printf("Failed to disable AP-Flash quick start function\r\n");
  535. }
  536. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  537. if(errrCnt == 0){
  538. gnssStep = 6;
  539. }else{
  540. errrCnt = 0;
  541. }
  542. break;
  543. default:
  544. break;
  545. }
  546. }
  547. //UTC时间转换为任意时区时间,如果是转换为北京时间,timezone传8即可
  548. void utc_to_local_time(nmea_utc_time* utc_time, int8_t timezone, nmea_utc_time* local_time)
  549. {
  550. int year,month,day,hour;
  551. int lastday = 0; //last day of this month 本月天数
  552. int lastlastday = 0; //last day of last month 上个月天数
  553. year = utc_time->year; //utc time
  554. month = utc_time->month;
  555. day = utc_time->date;
  556. hour = utc_time->hour + timezone;
  557. //1月大,2月小,3月大,4月小,5月大,6月小,7月大,8月大,9月小,10月大,11月小,12月大
  558. if(month==1 || month==3 || month==5 || month==7 || month==8 || month==10 || month==12)
  559. {
  560. lastday = 31;//本月天数
  561. lastlastday = 30;//这里应该补上上个月的天数
  562. if(month == 3)
  563. {
  564. if((year%400 == 0)||(year%4 == 0 && year%100 != 0))//if this is lunar year
  565. lastlastday = 29;
  566. else
  567. lastlastday = 28;
  568. }
  569. if(month == 8 || month == 1)//这里应该是8月和1月,因为8月和1月的上一个月(7月和12月)的天数是31天的
  570. lastlastday = 31;
  571. }
  572. else if(month == 4 || month == 6 || month == 9 || month == 11)
  573. {
  574. lastday = 30;
  575. lastlastday = 31;
  576. }
  577. else
  578. {
  579. lastlastday = 31;
  580. if((year%400 == 0)||(year%4 == 0 && year%100 != 0))
  581. lastday = 29;
  582. else
  583. lastday = 28;
  584. }
  585. if(hour >= 24)// if >24, day+1
  586. {
  587. hour -= 24;
  588. day += 1;
  589. if(day > lastday)// next month, day-lastday of this month
  590. {
  591. day -= lastday;
  592. month += 1;
  593. if(month > 12)// next year, month-12
  594. {
  595. month -= 12;
  596. year += 1;
  597. }
  598. }
  599. }
  600. if(hour < 0)// if <0, day-1
  601. {
  602. hour += 24;
  603. day -= 1;
  604. if(day < 1)// month-1, day=last day of last month
  605. {
  606. day = lastlastday;
  607. month -= 1;
  608. if(month < 1)// last year, month=12
  609. {
  610. month = 12;
  611. year -= 1;
  612. }
  613. }
  614. }
  615. // transfer value to local_time
  616. local_time->year = year;
  617. local_time->month = month;
  618. local_time->date = day;
  619. local_time->hour = hour;
  620. local_time->min = utc_time->min;
  621. local_time->sec = utc_time->sec;
  622. }
  623. /**
  624. * @brief 常用时间格式转时间戳
  625. * @param NONE
  626. * @note
  627. * @retval 无
  628. */
  629. uint32_t EC800_mktime (unsigned int year, unsigned int mon,
  630. unsigned int day, unsigned int hour,
  631. unsigned int min, unsigned int sec)
  632. {
  633. if (0 >= (int) (mon -= 2)){ /**//* 1..12 -> 11,12,1..10 */
  634. mon += 12; /**//* Puts Feb last since it has leap day */
  635. year -= 1;
  636. }
  637. return (((
  638. (unsigned long) (year/4 - year/100 + year/400 + 367*mon/12 + day) +
  639. year*365 - 719499
  640. )*24 + hour /**//* now have hours */
  641. )*60 + min /**//* now have minutes */
  642. )*60 + sec; /**//* finally seconds */
  643. }
  644. /**
  645. * @brief 读取GNSS的数据
  646. * @param NONE
  647. * @note
  648. * @retval 无
  649. */
  650. void EC800_readGnssDate(void){
  651. EC800M_SendCommand(AT_QGPSGNMEA_RMC);
  652. // EC800_recEnable();
  653. // found = strstr(g_usart4_rx_buf, AT_RESP_OK);
  654. if (Accept_and_Compare_Str(AT_RESP_OK) == 1) {
  655. printf("Location information received successfully\r\n");
  656. }else{
  657. printf("Location information reception failed\r\n");
  658. return ;
  659. }
  660. printf("Location information:%s\r\n", g_usart4_rx_buf);
  661. NMEA_GNRMC_Analysis(&s_nmea_msg, (uint8_t*)g_usart4_rx_buf);
  662. utc_to_local_time(&(s_nmea_msg.utc), 8, &s_nmea_utc_time);
  663. printf("timer-%d/%d/%d %d:%d:%d\r\n",s_nmea_utc_time.year,s_nmea_utc_time.month,s_nmea_utc_time.date,s_nmea_utc_time.hour,s_nmea_utc_time.min,s_nmea_utc_time.sec);
  664. s_messageDate.Timestamp = EC800_mktime(s_nmea_utc_time.year,s_nmea_utc_time.month,s_nmea_utc_time.date,s_nmea_utc_time.hour,s_nmea_utc_time.min,s_nmea_utc_time.sec);
  665. g_usart3_rx_sta= 0;
  666. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff
  667. printf("latitude:%d%d--longitude:%d%d\r\n", s_nmea_msg.latitude, s_nmea_msg.nshemi, s_nmea_msg.longitude, s_nmea_msg.ewhemi);
  668. /* 尝试获取互斥量,等待无限长时间 */
  669. if(osMutexAcquire(s_messageDate_locationHandle, osWaitForever) == osOK)
  670. {
  671. /* 安全地访问s_rs485RecDate结构体 */
  672. s_messageDate.latitude = s_nmea_msg.latitude;
  673. s_messageDate.nshemi = s_nmea_msg.nshemi;
  674. s_messageDate.longitude = s_nmea_msg.longitude;
  675. s_messageDate.ewhemi = s_nmea_msg.ewhemi;
  676. /* 访问完成,释放互斥量 */
  677. osMutexRelease(s_messageDate_locationHandle);
  678. }
  679. }
  680. /**
  681. * @brief EC800M订阅主题
  682. * @param topic1: 订阅的主题名称1字符串形式
  683. * @param topic2: 订阅的主题名称2字符串形式
  684. * @note
  685. * @retval 无
  686. */
  687. uint8_t EC800_subscribeToTopic(const char* topic1){
  688. char command[100] = {0};
  689. uint8_t recTemp = 0;
  690. sprintf(command, "AT+QMTSUB=0,1,\"%s\",0\r\n", topic1);
  691. EC800M_SendCommand(command);
  692. recTemp = Accept_and_Compare_Str(AT_RESP_QMTSUB);
  693. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  694. if (recTemp == 1) {
  695. printf("Subscription to the topic successful\r\n");
  696. return 1;
  697. }else if (recTemp == 2){
  698. printf("Subscription to the topic failed\r\n");
  699. return 0;
  700. }
  701. return 0;
  702. }
  703. /**
  704. * @brief EC800M发布消息
  705. * @param topic: 消息发布的主题 字符串形式
  706. * @param message: 发布的消息 字符串形式
  707. * @param len: 发布消息的字节长度
  708. * @note
  709. * @retval 无
  710. */
  711. uint8_t EC800_publishMessage(const char* topic, const char* message, uint16_t len){
  712. char command[100] = {0};
  713. char* responseCmd = ">";
  714. static uint8_t publishStep = 0;
  715. uint8_t recBack = 0;
  716. switch(publishStep){
  717. case 0:
  718. sprintf(command,"AT+QMTPUBEX=0,0,0,0,\"%s\",%d\r\n",topic,len);
  719. EC800M_SendCommand(command);
  720. // found = EC800M_RecRespond(g_usart4_rx_buf, responseCmd);
  721. if (Accept_and_Compare_Str(responseCmd) == 1) {
  722. printf("The topic has been linked\r\n");
  723. publishStep = 1;
  724. }else{
  725. printf("The topic link failed\r\n");
  726. publishStep = 0;
  727. }
  728. // break;
  729. case 1:
  730. EC800M_SendCommand(message);
  731. // found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
  732. // found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_QMTPUBEX);
  733. // if (found != NULL) {
  734. // printf("The message has been successfully posted\r\n");
  735. // publishStep = 0;
  736. // }else{
  737. // printf("Message publication failed\r\n");
  738. // publishStep = 0;
  739. // }
  740. recBack = Accept_and_Compare_Str(AT_RESP_QMTPUBEX);
  741. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清空输入缓冲区
  742. if (recBack == 1) {
  743. publishStep = 0;
  744. printf("The message has been successfully posted\r\n");
  745. }else{
  746. printf("Message publication failed\r\n");
  747. publishStep = 0;
  748. }
  749. break;
  750. default:
  751. break;
  752. }
  753. return recBack;
  754. }
  755. /**
  756. * @brief 登录 topic
  757. * @param NONE
  758. * @note topic 101
  759. * @retval 无
  760. */
  761. uint8_t Login_Topic(void){
  762. cJSON *root = NULL;
  763. char *jsonString = NULL;
  764. uint8_t temp = 0;
  765. char command[50] = {0};
  766. // 定义对象 { }
  767. root = cJSON_CreateObject();
  768. // 插入元素,对应 键值对
  769. cJSON_AddItemToObject(root, "msgType", cJSON_CreateString("json"));
  770. cJSON_AddItemToObject(root, "imsi", cJSON_CreateString(s_messageDate.imsi));
  771. cJSON_AddItemToObject(root, "hardVersion", cJSON_CreateString(HARD_VERSION));
  772. cJSON_AddItemToObject(root, "softVersion", cJSON_CreateString(SOFT_VERSION));
  773. sprintf(command, "%x%x%x", s_messageDate.devId[0], s_messageDate.devId[1], s_messageDate.devId[2]);
  774. cJSON_AddItemToObject(root, "devId", cJSON_CreateString(command));
  775. cJSON_AddItemToObject(root, "protocolVersion", cJSON_CreateString(PROTOCOL_VERSION));
  776. cJSON_AddItemToObject(root, "devType", cJSON_CreateNumber(DEV_TYPE));
  777. cJSON_AddItemToObject(root, "txnNo", cJSON_CreateNumber(s_messageDate.Timestamp));
  778. // 将 JSON 对象转换为字符串
  779. jsonString = cJSON_Print(root);
  780. cJSON_Delete(root);
  781. temp = EC800_publishMessage("toServer/mqtt/101", jsonString, strlen(jsonString));
  782. free(jsonString);
  783. return temp;
  784. }
  785. /**
  786. * @brief 下位机请求围栏数据
  787. * @param NONE
  788. * @note topic 604
  789. * @retval 无
  790. */
  791. uint8_t requesting_Fence_Data(void){
  792. cJSON *root = NULL;
  793. char *jsonString = NULL;
  794. uint8_t temp = 0;
  795. char command[50] = {0};
  796. // 定义对象 { }
  797. root = cJSON_CreateObject();
  798. // 插入元素,对应 键值对
  799. cJSON_AddItemToObject(root, "msgType", cJSON_CreateString("json"));
  800. cJSON_AddItemToObject(root, "imsi", cJSON_CreateString(s_messageDate.imsi));
  801. cJSON_AddItemToObject(root, "hardVersion", cJSON_CreateString(HARD_VERSION));
  802. cJSON_AddItemToObject(root, "softVersion", cJSON_CreateString(SOFT_VERSION));
  803. sprintf(command, "%x%x%x", s_messageDate.devId[0], s_messageDate.devId[1], s_messageDate.devId[2]);
  804. cJSON_AddItemToObject(root, "devId", cJSON_CreateString(command));
  805. // cJSON_AddItemToObject(root, "vin", cJSON_CreateString((char *)s_messageDate.VIN));
  806. cJSON_AddItemToObject(root, "vin", cJSON_CreateString("5Xt2Aq8Jb9L"));
  807. cJSON_AddItemToObject(root, "protocolVersion", cJSON_CreateString(PROTOCOL_VERSION));
  808. cJSON_AddItemToObject(root, "txnNo", cJSON_CreateNumber(s_messageDate.Timestamp));
  809. cJSON_AddItemToObject(root, "devType", cJSON_CreateNumber(DEV_TYPE));
  810. // 将 JSON 对象转换为字符串
  811. jsonString = cJSON_Print(root);
  812. cJSON_Delete(root);
  813. temp = EC800_publishMessage("toServer/mqtt/604", jsonString, strlen(jsonString));
  814. free(jsonString);
  815. return temp;
  816. }
  817. /**
  818. * @brief EC800M与服务器进行时间对时
  819. * @note
  820. * @retval 无
  821. */
  822. uint8_t EC800_time_calibration(void){
  823. cJSON *root = NULL;
  824. char *jsonString = NULL;
  825. uint8_t temp = 0;
  826. char command[50] = {0};
  827. // 定义对象 { }
  828. root = cJSON_CreateObject();
  829. // 插入元素,对应 键值对
  830. cJSON_AddItemToObject(root, "msgType", cJSON_CreateString("json"));
  831. cJSON_AddItemToObject(root, "imsi", cJSON_CreateString(s_messageDate.imsi));
  832. cJSON_AddItemToObject(root, "hardVersion", cJSON_CreateString(HARD_VERSION));
  833. cJSON_AddItemToObject(root, "softVersion", cJSON_CreateString(SOFT_VERSION));
  834. sprintf(command, "%x%x%x", s_messageDate.devId[0], s_messageDate.devId[1], s_messageDate.devId[2]);
  835. cJSON_AddItemToObject(root, "devId", cJSON_CreateString(command));
  836. cJSON_AddItemToObject(root, "protocolVersion", cJSON_CreateString(PROTOCOL_VERSION));
  837. cJSON_AddItemToObject(root, "txnNo", cJSON_CreateNumber(s_messageDate.Timestamp));
  838. cJSON_AddItemToObject(root, "devType", cJSON_CreateNumber(DEV_TYPE));
  839. // 将 JSON 对象转换为字符串
  840. jsonString = cJSON_Print(root);
  841. cJSON_Delete(root);
  842. temp = EC800_publishMessage("toServer/mqtt/105", jsonString, strlen(jsonString));
  843. free(jsonString);
  844. return temp;
  845. }
  846. /**
  847. * @brief 将服务器响应的字符串中的年月日进行分离
  848. * @note
  849. * @retval 无
  850. */
  851. void parseServerTime(char* str){
  852. char year[5];
  853. char month[3];
  854. char day[3];
  855. char hour[3];
  856. char minute[3];
  857. char second[3];
  858. strncpy(year, str, 4);
  859. year[4] = '\0';
  860. strncpy(month, str + 4, 2);
  861. month[2] = '\0';
  862. strncpy(day, str + 6, 2);
  863. day[2] = '\0';
  864. strncpy(hour, str + 8, 2);
  865. hour[2] = '\0';
  866. strncpy(minute, str + 10, 2);
  867. minute[2] = '\0';
  868. strncpy(second, str + 12, 2);
  869. second[2] = '\0';
  870. s_recDate.year = atoi(year);
  871. s_recDate.month = atoi(month);
  872. s_recDate.day = atoi(day);
  873. s_recDate.hour = atoi(hour);
  874. s_recDate.minute = atoi(minute);
  875. s_recDate.sec = atoi(second);
  876. s_messageDate.Timestamp = EC800_mktime(s_recDate.year,s_recDate.month,s_recDate.day,s_recDate.hour,s_recDate.minute,s_recDate.sec);
  877. printf("Year (int): %d\n", s_recDate.year);
  878. printf("Month (int): %d\n", s_recDate.month);
  879. printf("Day (int): %d\n", s_recDate.day);
  880. printf("Hour (int): %d\n", s_recDate.hour);
  881. printf("Minute (int): %d\n", s_recDate.minute);
  882. printf("Second (int): %d\n", s_recDate.sec);
  883. }
  884. /**
  885. * @brief 解析对时数据帧的响应
  886. * @note
  887. * @retval 无
  888. */
  889. void EC800_parseRespondTime(cJSON *root, cJSON *item){
  890. uint8_t temp = 0;
  891. // 获取"resultCode"字段的值
  892. item = cJSON_GetObjectItem(root, "resultCode");
  893. if (item == NULL) {
  894. printf("Field \"resultCode\" not found\n");
  895. }else{
  896. // 打印"resultCode"字段的值
  897. printf("resultCode: %d\n", item->valueint);
  898. if((item->valueint) == 1){
  899. printf("The upload of synchronized data was successful.\n");
  900. temp = 1; // 上传成功
  901. }else{
  902. printf("The upload of synchronized data has failed.\n");
  903. }
  904. }
  905. if(temp == 1){
  906. item = cJSON_GetObjectItem(root, "serverTime");
  907. if (item == NULL) {
  908. printf("Field \"serverTime\" not found\n");
  909. }else{
  910. // 打印"serverTime"字段的值
  911. printf("serverTime: %s\n", item->valuestring);
  912. parseServerTime(item->valuestring);
  913. }
  914. }
  915. }
  916. /**
  917. * @brief EC800M上传实时数据
  918. * @note
  919. * @retval 无
  920. */
  921. uint8_t EC800_uploadRealDate(void){
  922. cJSON *root = NULL;
  923. char *jsonString = NULL;
  924. cJSON *rt000 = NULL;
  925. cJSON *rt000Object1 = NULL;
  926. uint8_t temp = 0;
  927. char command[50] = {0};
  928. // 定义对象 { }
  929. root = cJSON_CreateObject();
  930. //
  931. // 插入元素,对应 键值对
  932. cJSON_AddItemToObject(root, "msgType", cJSON_CreateString("json"));
  933. cJSON_AddItemToObject(root, "imsi", cJSON_CreateString(s_messageDate.imsi));
  934. cJSON_AddItemToObject(root, "hardVersion", cJSON_CreateString(HARD_VERSION));
  935. cJSON_AddItemToObject(root, "softVersion", cJSON_CreateString(SOFT_VERSION));
  936. sprintf(command, "%x%x%x", s_messageDate.devId[0], s_messageDate.devId[1], s_messageDate.devId[2]);
  937. cJSON_AddItemToObject(root, "devId", cJSON_CreateString(command));
  938. cJSON_AddItemToObject(root, "protocolVersion", cJSON_CreateString(PROTOCOL_VERSION));
  939. cJSON_AddItemToObject(root, "txnNo", cJSON_CreateNumber(s_messageDate.Timestamp));
  940. cJSON_AddItemToObject(root, "devType", cJSON_CreateNumber(DEV_TYPE));
  941. // 定义 { } 对象
  942. rt000Object1 = cJSON_CreateObject();
  943. cJSON_AddItemToObject(rt000Object1, "rt003", cJSON_CreateNumber(s_messageDate.vehicleStatus));
  944. cJSON_AddItemToObject(rt000Object1, "rt025", cJSON_CreateNumber(s_messageDate.demandVol));
  945. cJSON_AddItemToObject(rt000Object1, "rt026", cJSON_CreateNumber(s_messageDate.demandCur));
  946. cJSON_AddItemToObject(rt000Object1, "rt027", cJSON_CreateString((char *)s_messageDate.VIN));
  947. cJSON_AddItemToObject(rt000Object1, "rt028", cJSON_CreateString(s_messageDate.lat_long_data));
  948. cJSON_AddItemToObject(rt000Object1, "rt029", cJSON_CreateNumber(s_messageDate.drivDirection));
  949. cJSON_AddItemToObject(rt000Object1, "rt030", cJSON_CreateNumber(s_messageDate.vehicleSpeed));
  950. cJSON_AddItemToObject(rt000Object1, "rt031", cJSON_CreateNumber(s_messageDate.dailyDrivTime));
  951. cJSON_AddItemToObject(rt000Object1, "rt032", cJSON_CreateNumber(s_messageDate.dailyDrivMileage));
  952. cJSON_AddItemToObject(rt000Object1, "rt033", cJSON_CreateNumber(s_messageDate.accTotalDrivTime_h_min));
  953. cJSON_AddItemToObject(rt000Object1, "rt034", cJSON_CreateNumber((s_messageDate.accTotalMileage_h << 16) + s_messageDate.accTotalMileage_l));
  954. cJSON_AddItemToObject(rt000Object1, "rt035", cJSON_CreateNumber(s_messageDate.runTime));
  955. // 定义 [ ] 数组
  956. rt000 = cJSON_CreateArray();
  957. // 往数组中添加元素
  958. cJSON_AddItemToArray(rt000, rt000Object1);
  959. // 将子项插入根项中
  960. cJSON_AddItemToObject(root, "rt000", rt000);
  961. //
  962. // 将 JSON 对象转换为字符串
  963. jsonString = cJSON_Print(root);
  964. cJSON_Delete(root);
  965. temp = EC800_publishMessage("toServer/mqtt/201", jsonString, strlen(jsonString));
  966. free(jsonString);
  967. return temp;
  968. }
  969. /**
  970. * @brief 解析实时数据响应
  971. * @note
  972. * @retval 无
  973. */
  974. void EC800_respondRealDate(cJSON *root, cJSON *item){
  975. // 获取"name"字段的值
  976. item = cJSON_GetObjectItem(root, "resultCode");
  977. if (item == NULL) {
  978. printf("Field \"resultCode\" not found\n");
  979. }else{
  980. // 打印"name"字段的值
  981. printf("resultCode: %d\n", item->valueint);
  982. if((item->valueint) == 1){
  983. printf("Uploaded real-time data successfully\n");
  984. }else{
  985. printf("The upload of real-time data has failed\n");
  986. }
  987. }
  988. }
  989. /**
  990. * @brief 解析升級数据
  991. * @note
  992. * @retval 无
  993. */
  994. void EC800_respondUpdateDate(cJSON *root, cJSON *item, ftpInfo *p_ftpInfo){
  995. /* 获取address对象 */
  996. cJSON *hardwareUpdate = cJSON_GetObjectItem(root, "paramList");
  997. if (hardwareUpdate == NULL) {
  998. printf("Failed to parse paramList data\n");
  999. return ;
  1000. }
  1001. // 获取"name"字段的值
  1002. item = cJSON_GetObjectItem(hardwareUpdate, "function");
  1003. if (item == NULL) {
  1004. printf("Field \"update\" not found\n");
  1005. }else{
  1006. // 打印"name"字段的值
  1007. printf("function: %d\n", item->valueint);
  1008. // 1:表示固件更新 当后台下发升级指令,并且行车状态为静止态允许更新固件
  1009. if(((item->valueint) == 1) && (s_comData.driveStatus == 0x02)){
  1010. s_ec800Date.hardwareUpdate = 1; // 更新固件
  1011. printf("update begin\n");
  1012. }else{
  1013. printf("no update\n");
  1014. }
  1015. }
  1016. // 获取"ftpAddr"字段的值
  1017. item = cJSON_GetObjectItem(hardwareUpdate, "ftpAddr");
  1018. if (item == NULL) {
  1019. printf("Field \"ftpAddr\" not found\n");
  1020. }else{
  1021. printf("ftpAddr: %s\n", item->valuestring);
  1022. /* 复制字符串到ftpInfo结构体的ftpAddr成员 */
  1023. strncpy(p_ftpInfo->ftpAddr, item->valuestring, sizeof(p_ftpInfo->ftpAddr) - 1);
  1024. /* 确保字符串以空字符结尾 */
  1025. p_ftpInfo->ftpAddr[sizeof(p_ftpInfo->ftpAddr) - 1] = '\0';
  1026. }
  1027. // 获取"ftpPort"字段的值
  1028. item = cJSON_GetObjectItem(hardwareUpdate, "ftpPort");
  1029. if (item == NULL) {
  1030. printf("Field \"ftpPort\" not found\n");
  1031. }else{
  1032. // 打印"name"字段的值
  1033. printf("ftpPort: %d\n", item->valueint);
  1034. p_ftpInfo->ftpPort = item->valueint;
  1035. }
  1036. // 获取"account"字段的值
  1037. item = cJSON_GetObjectItem(hardwareUpdate, "account");
  1038. if (item == NULL) {
  1039. printf("Field \"account\" not found\n");
  1040. }else{
  1041. printf("account: %s\n", item->valuestring);
  1042. /* 复制字符串到ftpInfo结构体的ftpAddr成员 */
  1043. strncpy(p_ftpInfo->account, item->valuestring, sizeof(p_ftpInfo->ftpAddr) - 1);
  1044. /* 确保字符串以空字符结尾 */
  1045. p_ftpInfo->ftpAddr[sizeof(p_ftpInfo->account) - 1] = '\0';
  1046. }
  1047. // 获取"passWord"字段的值
  1048. item = cJSON_GetObjectItem(hardwareUpdate, "passWord");
  1049. if (item == NULL) {
  1050. printf("Field \"passWord\" not found\n");
  1051. }else{
  1052. printf("account: %s\n", item->valuestring);
  1053. /* 复制字符串到ftpInfo结构体的ftpAddr成员 */
  1054. strncpy(p_ftpInfo->passWord, item->valuestring, sizeof(p_ftpInfo->ftpAddr) - 1);
  1055. /* 确保字符串以空字符结尾 */
  1056. p_ftpInfo->ftpAddr[sizeof(p_ftpInfo->passWord) - 1] = '\0';
  1057. }
  1058. // 获取"passWord"字段的值
  1059. item = cJSON_GetObjectItem(hardwareUpdate, "textDirectory");
  1060. if (item == NULL) {
  1061. printf("Field \"textDirectory\" not found\n");
  1062. }else{
  1063. printf("textDirectory: %s\n", item->valuestring);
  1064. /* 复制字符串到ftpInfo结构体的ftpAddr成员 */
  1065. strncpy(p_ftpInfo->textDirectory, item->valuestring, sizeof(p_ftpInfo->ftpAddr) - 1);
  1066. /* 确保字符串以空字符结尾 */
  1067. p_ftpInfo->ftpAddr[sizeof(p_ftpInfo->textDirectory) - 1] = '\0';
  1068. }
  1069. // 获取"passWord"字段的值
  1070. item = cJSON_GetObjectItem(hardwareUpdate, "textName");
  1071. if (item == NULL) {
  1072. printf("Field \"textName\" not found\n");
  1073. }else{
  1074. printf("textName: %s\n", item->valuestring);
  1075. /* 复制字符串到ftpInfo结构体的ftpAddr成员 */
  1076. strncpy(p_ftpInfo->textName, item->valuestring, sizeof(p_ftpInfo->ftpAddr) - 1);
  1077. /* 确保字符串以空字符结尾 */
  1078. p_ftpInfo->ftpAddr[sizeof(p_ftpInfo->textName) - 1] = '\0';
  1079. }
  1080. }
  1081. /**
  1082. * @brief 解析围栏经纬度数据
  1083. * @note
  1084. * @param root: cJSON 根对象
  1085. * @param Latitude: 纬度数组
  1086. * @param Longitude: 经度数组
  1087. * @retval 成功返回1,失败返回0
  1088. */
  1089. int parse_Latitude_Longitude_Data(cJSON *root, double Latitude[], double Longitude[]) {
  1090. // 确保输入不为空
  1091. if (root == NULL) {
  1092. printf("Root object is NULL\n");
  1093. return 0;
  1094. }
  1095. // 获取 polygonLat 数组
  1096. cJSON *polygonLat = cJSON_GetObjectItem(root, "polygonLat");
  1097. if (polygonLat == NULL || polygonLat->type != cJSON_Array) {
  1098. printf("polygonLat is not an array or is missing\n");
  1099. return 0;
  1100. }
  1101. // 获取 polygonLng 数组
  1102. cJSON *polygonLng = cJSON_GetObjectItem(root, "polygonLon");
  1103. if (polygonLng == NULL || polygonLat->type != cJSON_Array) {
  1104. printf("polygonLng is not an array or is missing\n");
  1105. return 0;
  1106. }
  1107. // 获取数组大小并检查是否匹配和是否超出预定义的最大大小
  1108. int polygonLatSize = cJSON_GetArraySize(polygonLat);
  1109. int polygonLngSize = cJSON_GetArraySize(polygonLng);
  1110. if (polygonLatSize != polygonLngSize || polygonLatSize > REC_COORDINATE_DEPTH) {
  1111. printf("Array sizes mismatch or exceed maximum allowed size\n");
  1112. return 0;
  1113. }
  1114. // 解析 polygonLat 数组
  1115. for (int i = 0; i < polygonLatSize; ++i) {
  1116. cJSON *latItem = cJSON_GetArrayItem(polygonLat, i);
  1117. if (latItem == NULL || latItem->type != cJSON_Number) {
  1118. printf("Lat item is not a number or is missing\n");
  1119. return 0;
  1120. }
  1121. Latitude[i] = latItem->valuedouble;
  1122. }
  1123. // 解析 polygonLng 数组
  1124. for (int i = 0; i < polygonLngSize; ++i) {
  1125. cJSON *lngItem = cJSON_GetArrayItem(polygonLng, i);
  1126. if (lngItem == NULL || lngItem->type != cJSON_Number) {
  1127. printf("Lng item is not a number or is missing\n");
  1128. return 0;
  1129. }
  1130. Longitude[i] = lngItem->valuedouble;
  1131. }
  1132. return 1; // 成功
  1133. }
  1134. /**
  1135. * @brief 解析登录响应
  1136. * @note
  1137. * @return
  1138. */
  1139. void parse_Login_Response(cJSON *root, cJSON *item){
  1140. // 获取"name"字段的值
  1141. item = cJSON_GetObjectItem(root, "resultCode");
  1142. if (item == NULL) {
  1143. printf("Field \"resultCode\" not found\n");
  1144. }else{
  1145. // 打印"name"字段的值
  1146. printf("resultCode: %d\n", item->valueint);
  1147. if((item->valueint) == 1){
  1148. s_messageDate.loginResult = 1; // 登录成功
  1149. printf("Login response data successfully\n");
  1150. }else{
  1151. printf("Login response has failed\n");
  1152. }
  1153. }
  1154. }
  1155. /**
  1156. * @brief 通信响应解析
  1157. * @param p_ec800Date: ec800Date结构体的指针数据
  1158. * @note
  1159. * @return 当前的控制命令
  1160. */
  1161. short EC800_respondParse(ec800Date *p_ec800Date){
  1162. cJSON *root = NULL;
  1163. cJSON *item = NULL;
  1164. uint8_t rec_back = 0;
  1165. uint16_t cmd = 0;
  1166. // 找到JSON数据的起始位置
  1167. const char* start = strchr(g_usart4_rx_buf, '{');
  1168. if (start == NULL) {
  1169. printf("JSON data not found\n");
  1170. return 0;
  1171. }
  1172. // 解析JSON数据
  1173. root = cJSON_Parse(start);
  1174. if (root == NULL) {
  1175. printf("Failed to parse JSON data\n");
  1176. cJSON_Delete(root);
  1177. return 0;
  1178. }
  1179. // 获取"controlCode"字段的值
  1180. item = cJSON_GetObjectItem(root, "controlCode");
  1181. if (item == NULL) {
  1182. printf("Field \"devId\" not found\n");
  1183. }else{
  1184. // 打印"controlCode"字段的值
  1185. printf("controlCode: %d\n", item->valueint);
  1186. cmd = item->valueint;
  1187. }
  1188. // 解析对应命令的对应数据
  1189. switch(cmd){
  1190. case 102:
  1191. parse_Login_Response(root, item);
  1192. break;
  1193. case 106:
  1194. EC800_parseRespondTime(root, item);
  1195. break;
  1196. case 202:
  1197. EC800_respondRealDate(root, item);
  1198. break;
  1199. case 602:
  1200. EC800_respondUpdateDate(root, item, &s_ftpInfo);
  1201. break;
  1202. case 605:
  1203. rec_back = parse_Latitude_Longitude_Data(root, polygonLat, polygonLng);
  1204. if(rec_back == 1){ // 接收成功
  1205. p_ec800Date->fenceRecSuccess = 1;
  1206. }
  1207. break;
  1208. default :
  1209. break;
  1210. }
  1211. cJSON_Delete(root);
  1212. return (cmd);
  1213. }
  1214. /**
  1215. * @brief EC800M状态转换与使用
  1216. * @note
  1217. * @retval 无
  1218. */
  1219. uint8_t stateStep = 0;
  1220. void EC800_stateTransition_use(void){
  1221. uint16_t right = 1; // 返回是否为正确
  1222. static uint16_t timesCnt = 0;
  1223. static uint8_t tudeErrcnt = 0; // 定位信息错误计数
  1224. ec800Date *p_ec800Date = &s_ec800Date;
  1225. char command[100] = {0};
  1226. static uint8_t respondSt = 0; // 响应状态指示 1: 为等待响应 2:成功响应
  1227. static uint8_t timeoutCnt = 0; // 超时计数
  1228. switch(stateStep){
  1229. case 0: // 初始化模块
  1230. EC800M_link();
  1231. if(linkStep == 12){
  1232. stateStep = 1;
  1233. p_ec800Date->ec800InitFlag = 1; // 初始化完成
  1234. }else{
  1235. p_ec800Date->ec800InitFlag = 0; // 初始化未完成
  1236. }
  1237. break;
  1238. case 1: // 初始化GNSS
  1239. EC800_gnss_init();
  1240. if(gnssStep == 8){
  1241. stateStep = 2;
  1242. }
  1243. break;
  1244. case 2: // 订阅主题
  1245. sprintf(command, "toclient/%d/%x%x%x", DEV_TYPE, s_messageDate.devId[0], s_messageDate.devId[1], s_messageDate.devId[2]);
  1246. right = EC800_subscribeToTopic(command);
  1247. if(right != 1){ // 发布消息失败,可能断开链接
  1248. // stateStep = 0; // 重新初始化
  1249. }else{
  1250. stateStep = 3;
  1251. }
  1252. break;
  1253. case 3: // 登录服务器主题
  1254. right = Login_Topic();
  1255. if(right == 1){
  1256. respondSt = 1; // 等待响应
  1257. stateStep = 8; // 去步骤6等待登录响应 收到登录响应后,发布实时消息
  1258. }
  1259. break;
  1260. case 4: // 下位机请求围栏数据
  1261. if(s_comData.vinRecSuccess == 1){ // 成功接收到车辆vin
  1262. right = requesting_Fence_Data();
  1263. if(right == 1){
  1264. respondSt = 1; // 等待响应
  1265. stateStep = 8; // 去步骤6等待登录响应 收到登录响应后,发布实时消息
  1266. }
  1267. }else{ // 初始化时与车通信故障 跳转上传实时信息,上报故障,跳过围栏获取
  1268. if(BIT_CHECK(s_comData.Malfunction, com485)){
  1269. stateStep = 5;
  1270. }
  1271. }
  1272. break;
  1273. case 5:
  1274. // 获取定位信息
  1275. EC800_readGnssDate();
  1276. // 没有获取到定位信息 重复获取三次
  1277. if((s_messageDate.latitude == 0) && (s_messageDate.longitude == 0)){
  1278. tudeErrcnt++;
  1279. if(tudeErrcnt == 4){
  1280. tudeErrcnt = 0;
  1281. stateStep = 6;
  1282. }
  1283. }else{
  1284. tudeErrcnt = 0;
  1285. stateStep = 6;
  1286. }
  1287. break;
  1288. case 6: // 与服务器对时
  1289. right = EC800_time_calibration();
  1290. if(right == 1){
  1291. respondSt = 1; // 等待响应
  1292. stateStep = 8; // 去步骤6等待对时响应 收到对时响应后,发布实时消息
  1293. }
  1294. break;
  1295. case 7: // 发布消息
  1296. right = EC800_uploadRealDate();
  1297. stateStep = 8;
  1298. // if(right == 0){ // 发布消息失败,可能断开链接
  1299. // stateStep = 0; // 重新初始化
  1300. // linkStep = 0;
  1301. // stateStep = 6;
  1302. // }else if(right == 1){
  1303. // stateStep = 6;
  1304. // }
  1305. break;
  1306. case 8: // 接收消息
  1307. HAL_UART_Receive_DMA(&huart4, (uint8_t*)g_usart4_rx_buf, USART4_REC_LEN); //设置接收缓冲区
  1308. // __HAL_UART_ENABLE_IT(&huart4, UART_IT_IDLE);
  1309. if(g_usart4_rx_sta!=0){
  1310. HAL_UART_Transmit(&huart1, (uint8_t*)g_usart4_rx_buf, strlen(g_usart4_rx_buf), HAL_MAX_DELAY); // 打印数据除去URC
  1311. right = EC800_respondParse(&s_ec800Date);
  1312. if((right == CTR_CODE_LOGIN) && (s_messageDate.loginResult == 1)){ // 登录响应
  1313. stateStep = 4;
  1314. right = 0;
  1315. timesCnt = 0;
  1316. respondSt = 2; // 成功响应
  1317. }else if(right == CTR_CODE_LOGIN){ // 登录响应 未登录成功
  1318. stateStep = 3;
  1319. right = 0;
  1320. timesCnt = 0;
  1321. respondSt = 2; // 成功响应
  1322. }else if(right == CTR_CODE_FENCES){ // 围栏数据响应
  1323. stateStep = 5;
  1324. right = 0;
  1325. timesCnt = 0;
  1326. respondSt = 2; // 成功响应
  1327. }
  1328. else if(right == CTR_CODE_JUDETIME){ // 对时响应
  1329. stateStep = 7;
  1330. right = 0;
  1331. timesCnt = 0;
  1332. respondSt = 2; // 成功响应
  1333. }else if(right == CTR_CODE_REMOTE){ // 固件更新
  1334. stateStep = 0xff; // 停止占用4G模块
  1335. }
  1336. memset(g_usart4_rx_buf, 0, USART4_REC_LEN); // 清除数据buff,接收新的数据
  1337. g_usart4_rx_sta = 0; // 清除接收状态
  1338. }
  1339. // 转弯行驶中
  1340. if(turnFlag == 1){
  1341. if(timesCnt < TURN_INTERVAL_TIME_MS){
  1342. timesCnt++;
  1343. }else{
  1344. timesCnt= 0;
  1345. stateStep = 5;
  1346. HAL_UART_DMAStop(&huart4);
  1347. // __HAL_UART_DISABLE_IT(&huart4, UART_IT_IDLE);
  1348. }
  1349. }else{ // 正常行驶中
  1350. if(timesCnt < PUBLISH_TIME_MS){
  1351. timesCnt++;
  1352. }else{
  1353. timesCnt= 0;
  1354. stateStep = 5;
  1355. HAL_UART_DMAStop(&huart4);
  1356. // __HAL_UART_DISABLE_IT(&huart4, UART_IT_IDLE);
  1357. }
  1358. }
  1359. // 通信超时判断
  1360. if(respondSt == 1){ // 等待响应状态
  1361. if(timeoutCnt < PUBLISH_TIME_MS){
  1362. timeoutCnt ++;
  1363. }else{
  1364. timeoutCnt = PUBLISH_TIME_MS;
  1365. BIT_SET(s_comData.Malfunction, errorMqtt); // 置位MQTT故障
  1366. }
  1367. }
  1368. break;
  1369. default:
  1370. break;
  1371. }
  1372. }