tt808.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764
  1. #include "tt808.h"
  2. #include "usart.h"
  3. #include "key.h"
  4. #include <stdio.h>
  5. #include <time.h>
  6. #include <stdlib.h>
  7. #include <string.h>
  8. #include "rtc.h"
  9. #include "database.h"
  10. //*整型
  11. int rlt;
  12. uint16_t uploadtime=0; //上传时间
  13. uint16_t hccd = 0;//ascii个数(*2)
  14. uint8_t header[12]; //处理头部
  15. uint8_t index_2c = 0;
  16. uint8_t MIPurc[100]; //接收平台数据
  17. uint8_t MIPurc1[100]; //接收平台数据
  18. uint8_t MIPurcXXTCSJ[100];//平台下行透传数据
  19. uint8_t speedBegin=0;
  20. uint8_t speedEnd=0;
  21. uint8_t speed[10]; //处理头部
  22. uint8_t DTUurc[100]; //接收平台数据
  23. uint8_t DTUurc1[15]; //接收平台数据
  24. int pushpullcount = 0;
  25. double dSpeed=0;
  26. double dlatitude=0;
  27. double dlongitude=0;
  28. char cSpeed[10];
  29. char clatitude[15];
  30. char clongitude[15];
  31. char csatellitesNum[5];
  32. char MGNSSLOC[100]; //接收定位数据
  33. char CSQ[12]; //接收定位数据
  34. char MGNSSLOC_time[6]; //接收定位数据
  35. uint32_t Stamp =0;
  36. uint8_t GNSSdata[40]={0};
  37. //*结构体
  38. TT808 tt808;
  39. extern TipsFlag tipsflag;
  40. extern Menu_table menu;
  41. extern bool refresh;
  42. //*布尔
  43. bool authFlag = false;
  44. bool GnssFlag = false;
  45. bool Offline = false;
  46. bool Retrans = false;
  47. bool Online = false;
  48. bool reIME = false;
  49. /**
  50. 时间 纬度(北纬) 经度(东经) 水平精度因子 海拔高度 定位类型(1无,2 2d,3 3d) 运动角度 水平运动速度(KM/h) 水平运动速度(Knots) 日月年 卫星数量 差分定位标识(1单点,2差分)
  51. eg.+MGNSSLOC: 015032.301,3014.8605N,12001.9250E,1.8, 17.6, 3, 0.00, 3.6, 1.9, 080424, 12, 1
  52. */
  53. void reconn(void)
  54. {
  55. char TCPconnvalue[120];
  56. TcpConn(TCPconnvalue, 1, JLPTIP, JLPTPORT,0); //cid=1 tcpConnmode=0 普通模式
  57. if(sendCmd_4G(TCPconnvalue, "+MIPOPEN: 1,0", 1, 1)) //TCP连接 0普通模式 2缓存模式 1透传模式
  58. {
  59. printf("重连成功\r\n");
  60. }
  61. }
  62. uint8_t Messagetemp_length=0;
  63. uint8_t MessageHandleData[100]; //放入封装后数据
  64. uint8_t tcppacket[100]; //消息数据
  65. void MessageHandle(uint16_t MessageID)
  66. {
  67. Flash_ReadBytes((uint16_t*)&(tt808.LSH),tt808serialNum,1);//读取loc头部是否发生写入
  68. if(tt808.LSH==0xFFFF)
  69. {
  70. tt808.LSH=0;//初始未写入
  71. }
  72. uint16_t MessageAttributeData = Messagetemp_length;
  73. MessageAttributeData |= ( Messagetemp_length | (TCPJMFSNULL<<10)); // 将长度左移3位后和加密方式进行按位或操作(001 RSA ,000 无加密)
  74. header[0] = ((MessageID>>8)&0xff);
  75. header[1] = (MessageID&0xff); //消息ID
  76. header[2] = ((MessageAttributeData>>8)&0xff);
  77. header[3] = (MessageAttributeData&0xff); //消息属性
  78. //*test phoneNumxy
  79. //*work phoneNum
  80. if(phonenull)
  81. {
  82. header[4] = 0x00;
  83. header[5] = 0x00;
  84. header[6] = 0x16;
  85. header[7] = 0x00;
  86. header[8] = 0x00;
  87. header[9] = 0x08; //“手机号”
  88. }
  89. else
  90. {
  91. header[4] = (phonenum[0]>>8)&0xff;
  92. header[5] = (phonenum[0])&0xff;
  93. header[6] = (phonenum[1]>>8)&0xff;
  94. header[7] = (phonenum[1])&0xff;
  95. header[8] = (phonenum[2]>>8)&0xff;
  96. header[9] = (phonenum[2])&0xff; //“手机号”
  97. }
  98. header[10] = ((tt808.LSH>>8)&0xff);
  99. header[11] = (tt808.LSH&0xff);
  100. int index = 0;
  101. tcppacket[index++] = TT808FLAG; // Set the headflag 0x7E
  102. for (int i = 0; i < 12; i++) {
  103. tcppacket[index++] = header[i];
  104. }
  105. // Copy message body to packet
  106. for (size_t i = 0; i < Messagetemp_length; i++) {
  107. tcppacket[index++] = MessageHandleData[i];
  108. }
  109. tcppacket[index++] = xorBytes(&tcppacket[1],12+Messagetemp_length);; // Set the checksum
  110. tcppacket[index++] = TT808FLAG; // Set the flag at the end
  111. for (int i = 0; i < index; i++) {
  112. printf("%02X ", tcppacket[i]); // 以十六进制格式打印每个元素
  113. }
  114. printf("\r\n");
  115. //#if open4G ==1
  116. char TCPvalue[120];
  117. char *ptr = TCPvalue;
  118. ptr += sprintf(ptr, "AT+MIPSEND=1,%d,\"",index);
  119. for (int i = 0; i < index; i++) {
  120. ptr += sprintf(ptr, "%02X", tcppacket[i]);
  121. }
  122. sprintf(ptr, "\"\r\n");//TCPvalue
  123. if(sendCmd_4G(TCPvalue, "+MIPSEND:", 1, 1))//发送
  124. {
  125. printf("#等待回应\r\n");
  126. }
  127. //#endif
  128. tt808.LSH+=1;//需做写入处理
  129. Flash_WriteBytes((uint16_t*)&(tt808.LSH),tt808serialNum,1);
  130. }
  131. uint16_t swapBytes16(uint16_t value) {
  132. return (value >> 8) | (value << 8);
  133. }
  134. uint32_t swapBytes32(uint32_t value) {
  135. return ((value & 0xFF) << 24) | ((value & 0xFF00) << 8) |
  136. ((value >> 8) & 0xFF00) | ((value >> 24) & 0xFF);
  137. }
  138. /**
  139. * @breaf 消息体封装
  140. * Message[] 消息数据; length 消息数据长度; outMessage[] 封装后消息数据; MessageID 消息ID
  141. */
  142. uint8_t Message_bodydata(uint8_t *Message, uint8_t length, uint8_t outMessage[],uint16_t MessageID)
  143. {
  144. int index = 0;
  145. uint8_t temp_length = 0;//加首尾 25/23/crc
  146. if(MessageID==MessageID_authentication || MessageID==MessageID_heartbeat)//不加头尾(鉴权、心跳)
  147. {
  148. temp_length = length;//不加首尾
  149. uint8_t temp_Message[temp_length];
  150. for (int i = 0; i < length; i++) {
  151. temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
  152. }
  153. temp_length = index;
  154. for(int i =0;i<temp_length;i++)
  155. {
  156. outMessage[i]=temp_Message[i];
  157. }
  158. }
  159. else if(MessageID==MessageID_location)//终端地址0200 补传0704
  160. {
  161. temp_length = length;//不加首尾
  162. //状态标志/纬度/经度/速度
  163. uint8_t temp_Message[temp_length];
  164. for (int i = 0; i < length; i++) {
  165. temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
  166. }
  167. for(int i =0;i<temp_length;i++)
  168. {
  169. outMessage[i]=temp_Message[i];
  170. }
  171. }
  172. else if(MessageID==MessageID_Retrans)// 补传0704+5
  173. {
  174. temp_length = length;//不加首尾
  175. uint8_t temp_Message[temp_length];
  176. temp_Message[index++] = 0x00;
  177. temp_Message[index++] = 0x01;
  178. temp_Message[index++] = 0x00;
  179. temp_Message[index++] = 0x00;
  180. temp_Message[index++] = 0x22;
  181. for (int i = 0; i < length; i++) {
  182. temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
  183. }
  184. for(int i =0;i<temp_length;i++)
  185. {
  186. outMessage[i]=temp_Message[i];
  187. }
  188. }
  189. else//加首尾
  190. {
  191. temp_length = length+3;//加首尾 25/23/crc
  192. uint8_t temp_Message[temp_length];
  193. temp_Message[index++]=temp_length;
  194. temp_Message[index++]=0x2A;
  195. for (int i = 0; i < length; i++) {
  196. temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
  197. }
  198. temp_Message[index++]=0x23;
  199. temp_Message[index++]=xorBytes(&temp_Message[1],temp_length-1);
  200. temp_length = index;
  201. for(int i =0;i<temp_length;i++)
  202. {
  203. outMessage[i]=temp_Message[i];
  204. }
  205. }
  206. return temp_length;
  207. }
  208. /*需要传入消息体长度sizeof(Message)/sizeof(Message[0]);*/
  209. void tt808FsFunc(uint8_t* Message, uint8_t length, uint16_t MessageID)
  210. {
  211. HAL_Delay(200);
  212. Messagetemp_length = Message_bodydata(Message, length, MessageHandleData, MessageID);
  213. MessageHandle(MessageID);
  214. }
  215. void printBytes(uint8_t *data, size_t length) {
  216. for (size_t i = 0; i < length; i++) {
  217. printf("%02x ", data[i]);
  218. }
  219. printf("\n");
  220. }
  221. // 函数用于提取第7到第8个逗号之间的字符串
  222. void extractString(char* receiveStr, char* result, uint8_t start, uint16_t end)
  223. {
  224. int comma_count = 0;
  225. int start_index = -1;
  226. int end_index = -1;
  227. int length = strlen(receiveStr);
  228. // 遍历字符串,统计逗号数量和记录起始和结束索引
  229. for (int i = 0; i < length; i++)
  230. {
  231. if (receiveStr[i] == ',')
  232. {
  233. comma_count++;
  234. if (comma_count == start)
  235. {
  236. start_index = i + 1; // 第start个逗号之后的字符
  237. }
  238. else if (comma_count == end)
  239. {
  240. if(start==1 && end==2)//*纬度去尾符号
  241. {
  242. end_index = i-1; // 第end个逗号之前的字符
  243. }
  244. else if(start==2 && end==3)//*经度去尾符号
  245. {
  246. end_index = i-1; // 第end个逗号之前的字符
  247. }
  248. else
  249. {
  250. end_index = i; // 第end个逗号之前的字符
  251. }
  252. break;
  253. }
  254. }
  255. }
  256. // 提取字符串并存储在result数组中
  257. if (start_index != -1 && end_index != -1 && start_index < end_index)
  258. {
  259. strncpy(result, receiveStr + start_index, end_index - start_index);
  260. result[end_index - start_index] = '\0'; // 添加字符串结束符
  261. }
  262. }
  263. void process_string(char** input_strings, char** output_strings, int start_index, int end_index) {
  264. char* start_ptr;
  265. char* end_ptr;
  266. char* input = input_strings[start_index];
  267. int count = 0;
  268. if (start_index == 4) {
  269. start_ptr = strchr(input, ':') + 1; // 寻找第一个冒号,并指向冒号后的字符
  270. count = sscanf(start_ptr, "%d", &output_strings[4]);
  271. } else {
  272. start_ptr = strchr(input, '=') + 1; // 寻找第一个等号,并指向等号后的字符
  273. for (int i = 0; i <= end_index; i++) {
  274. end_ptr = strchr(start_ptr, '.'); // 寻找下一个点号,并指向点号后的字符
  275. if (end_ptr == NULL) {
  276. end_ptr = strchr(start_ptr, '\0'); // 如果是最后一个区间,指向字符串末尾
  277. }
  278. if (end_ptr != NULL) {
  279. *end_ptr = '\0'; // 将点号替换为字符串结束符,截断字符串
  280. count = sscanf(start_ptr, "%d", &output_strings[i]);
  281. start_ptr = end_ptr + 1; // 移动指针到下一个区间的开头
  282. } else {
  283. break;
  284. }
  285. }
  286. }
  287. }
  288. double convertToDouble(char* str) {
  289. if(str == csatellitesNum)
  290. {
  291. uint8_t result;
  292. sscanf(str, "%hhu", &result);
  293. return result;
  294. }
  295. else
  296. {
  297. double result;
  298. sscanf(str, "%lf", &result);
  299. return result;
  300. }
  301. }
  302. char hex2asc(const char *hex)
  303. {
  304. char asc = 0;
  305. char a = (hex[0]>='A' && hex[0]<='F')?(hex[0]^32):hex[0];
  306. char b = (hex[1]>='A' && hex[1]<='F')?(hex[1]^32):hex[1];
  307. if ((a>='0' && a<='9' || a>='a' && a<='f') && (b>='0' && b<='9' || b>='a' && b<='f')){
  308. asc = ((('a'<=a && a<='f')?(a-'a')+10:a-'0')<<4)|(('a'<=b && b<='f')?(b-'a')+10:b-'0');
  309. }
  310. return asc;
  311. }
  312. uint8_t testHex2Asc(const char *hex) {
  313. char asc = hex2asc(hex);
  314. printf("Hex: %s\tASC: %d\n", hex, asc);
  315. return asc;
  316. }
  317. char *bin2hex(char *hex, const unsigned char *bin, int size)
  318. {
  319. size_t i;
  320. for(i=0; i<size; i++)
  321. {
  322. sprintf(hex+i*2, "%02x", bin[i]);
  323. }
  324. hex[i+i] = 0;
  325. return hex;
  326. }
  327. int hex2bin(unsigned char *bin, const char *hex)
  328. {
  329. const char *h = hex;
  330. unsigned char *b = bin;
  331. int rlt = 0;
  332. while(*h){
  333. *b++ = hex2asc(h);
  334. h = h + 2;
  335. rlt++;
  336. }
  337. return rlt;//长度
  338. }
  339. // 将单个十六进制数转换为 BCD 码
  340. uint8_t hexToBcd(uint8_t hex) {
  341. return ((hex / 10) << 4) | (hex % 10);
  342. }
  343. // 将整数数组中的所有十六进制数转换为 BCD 码
  344. void hexArrayToBcd(uint8_t* array, size_t length, uint8_t* out) {//时间用
  345. array[3]+=8;
  346. for (size_t i = 0; i < length; i++) {
  347. out[i] = hexToBcd(array[i]);
  348. }
  349. }
  350. void hexToBcd_arr(uint8_t* array, size_t length, uint8_t* out) {//通用
  351. for (size_t i = 0; i < length; i++) {
  352. out[i] = hexToBcd(array[i]);
  353. }
  354. }
  355. char* input_strings[]={0};
  356. char* reIp0[5];
  357. char* reIp1[5];
  358. char* reIp2[5];
  359. char* reIp3[5];
  360. char* reIpP[5];
  361. void Test485Re(void)
  362. {
  363. //*test485 模拟
  364. if(strncmp((char*)U1_485recvBuff, "+MIPURC: \"disconn\",1,1", strlen("+MIPURC: \"disconn\",1,1"))==0)//"disconn" 平台断连
  365. {
  366. Offline=true;
  367. uploaweork=false;
  368. printf("@U1与平台断开连接\r\n");
  369. memset(U1_485recvBuff,0,BUFFER_SIZE);
  370. }
  371. else if(strncmp((char*)U1_485recvBuff, "+MIPOPEN: 1,0", strlen("+MIPOPEN: 1,0"))==0)//连接平台
  372. {
  373. Offline=false;
  374. Online = true;
  375. uploaweork=true;
  376. printf("@U1设备已上线!!\r\n");
  377. refresh=true;
  378. memset(U1_485recvBuff,0,BUFFER_SIZE);
  379. }
  380. else if(strncmp((char*)&U1_485recvBuff, "DTU+FLASH=deleteloc", strlen("DTU+FLASH=deleteloc"))==0)//连接平台
  381. {
  382. dblocptr->headinfo.loc_pushIndex=0;
  383. dblocptr->headinfo.loc_pullIndex=0;
  384. Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
  385. memset(U1_485recvBuff,0,BUFFER_SIZE);
  386. printf("更新定位刻度\r\n");
  387. }
  388. else if(strncmp((char*)U1_485recvBuff, "DTU+IME", strlen("DTU+IME"))==0)//修改IME号
  389. {
  390. memcpy(DTUurc1,&U1_485recvBuff[8],12);
  391. const char *hex = (const char *)DTUurc1; // 将 uint8_t * 转换为 const char *
  392. int size = strlen(hex) / 2; // 计算二进制数据的长度
  393. unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
  394. rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
  395. memcpy(DTUurc, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
  396. free(bin); // 释放内存
  397. //memset(DTUurc1,0,100);
  398. memset(U1_485recvBuff,0,BUFFER_SIZE);
  399. reIME = true;
  400. }
  401. else if(strncmp((char*)U1_485recvBuff, "DTU+IP", strlen("DTU+IP"))==0)
  402. {
  403. printf("更换IP\r\n");
  404. memcpy(input_strings,U1_485recvBuff+7,20);
  405. // process_string(input_strings,reIp0,0,1);//获取192
  406. // process_string(input_strings,reIp1,1,2);//获取168
  407. // process_string(input_strings,reIp2,2,3);//获取1
  408. // process_string(input_strings,reIp3,3,4);//获取2
  409. // process_string(input_strings,reIpP,4,5);//获取port
  410. memset(U1_485recvBuff,0,BUFFER_SIZE);
  411. }
  412. }
  413. void ReMIPURC(void)
  414. {
  415. //*工作
  416. //*设备上线,发送成功
  417. if(strncmp((char*)U4_4GrecvBuff, "+MIPOPEN: 1,0", strlen("+MIPOPEN: 1,0"))==0)//连接平台
  418. {
  419. // Offline=false; //待判定假消息
  420. // Online = true; //待判定假消息
  421. // uploaweork=true;
  422. printf("@TCP连接成功!!\r\n");
  423. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  424. }
  425. ///*定位信息(MGNSS)
  426. else if(strncmp((char*)U4_4GrecvBuff, "+MGNSSURC: \"state\",1", strlen("+MGNSSURC: \"state\",1"))==0)
  427. {
  428. printf("@MGNSS设置成功\r\n");
  429. memset(U4_4GrecvBuff,0,strlen("+MGNSSURC: \"state\",1"));
  430. }
  431. else if(strncmp((char*)U4_4GrecvBuff, "+MGNSSURC: \"state\",0", strlen("+MGNSSURC: \"state\",0"))==0)//断开平台
  432. {
  433. printf("@主动取消GNSS\r\n");
  434. memset(U4_4GrecvBuff,0,strlen("+MGNSSURC: \"state\",0"));
  435. }
  436. ///*定位信息(基站)
  437. else if(((strncmp((char*)U4_4GrecvBuff, "+MGNSSLOC", strlen("+MGNSSLOC"))==0) || (strncmp((char*)U4_4GrecvBuff, "OK", strlen("OK"))==0)) && MgnssFlag) //监测平台回复+MGNSSLOC OK4f4b
  438. {
  439. memcpy(MGNSSLOC,&U4_4GrecvBuff[11],75);
  440. GnssFlag=true;
  441. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  442. }
  443. ///*掉线
  444. #if open4G ==1
  445. else if(strncmp((char*)U4_4GrecvBuff, "+MIPURC: \"disconn\",1,1", strlen("+MIPURC: \"disconn\",1,1"))==0)//"disconn" 平台断连
  446. {
  447. Offline=true;
  448. printf("@未发送成功,平台断开连接\r\n");
  449. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  450. uploaweork = false;
  451. reconn();//重连
  452. }
  453. else if((strncmp((char*)U4_4GrecvBuff, "+CPIN: SIM REMOVED", strlen("+CPIN: SIM REMOVED"))==0) || (strncmp((char*)U4_4GrecvBuff, "+CME ERROR: 10", strlen("+CME ERROR: 10"))==0) )//无SIM
  454. {
  455. //TODO
  456. printf("@SIM卡缺失\r\n");
  457. Offline=true;
  458. signal = false;
  459. menu.current = 0xBB;
  460. tipsflag = NoSIM;
  461. refresh=true;
  462. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  463. uploaweork = false;
  464. reconn();//重连
  465. }
  466. else if((strncmp((char*)U4_4GrecvBuff, "+MIPCALL: 1,0", strlen("+MIPCALL: 1,0"))==0))//意外断开平台连接!!!!//TCP未知错误
  467. {
  468. //TODO
  469. Offline=true;
  470. signal = false;
  471. printf("@与平台断开连接\r\n");
  472. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  473. uploaweork = false;
  474. reconn();//重连
  475. }
  476. else if( (strncmp((char*)U4_4GrecvBuff, "+CME ERROR: 550", strlen("+CME ERROR: 550"))==0))
  477. {
  478. Offline=true;
  479. signal = false;
  480. printf("@未发送成功->TCP/IP未知错误\r\n");
  481. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  482. uploaweork = false;
  483. reconn();//重连
  484. }
  485. else if((strncmp((char*)U4_4GrecvBuff, "+MIPOPEN: 1,571", strlen("+MIPOPEN: 1,571"))==0))//PDP激活失败
  486. {
  487. //TODO
  488. Offline=true;
  489. printf("@未发送成功,PDP激活失败\r\n");
  490. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  491. uploaweork = false;
  492. reconn();//重连
  493. }
  494. #endif
  495. else if(U4_4GrecvBuff[1]== 0x43 && U4_4GrecvBuff[2]== 0x53 && U4_4GrecvBuff[3]== 0x51)//CSQ 信号
  496. {
  497. memcpy(CSQ,U4_4GrecvBuff,U4_4GrecvLength);
  498. dblocptr->location.CSQ = (uint8_t)(CSQ[6]&0xf*10)+(CSQ[7]&0xf);
  499. memset(CSQ,0,12);
  500. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  501. }
  502. else if(strncmp((char*)U4_4GrecvBuff, "+MIPURC", strlen("+MIPURC"))==0) //监测平台回复+MIPURC:
  503. {
  504. uint8_t high_byte = (U4_4GrecvBuff[18]&0x0f) *10;
  505. uint8_t low_byte = U4_4GrecvBuff[19]&0x0f;
  506. hccd = high_byte + low_byte;
  507. memcpy(MIPurc1,&U4_4GrecvBuff[21],hccd*2);
  508. const char *hex = (const char *)MIPurc1; // 将 uint8_t * 转换为 const char *
  509. int size = strlen(hex) / 2; // 计算二进制数据的长度
  510. unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
  511. rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
  512. memcpy(MIPurc, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
  513. free(bin); // 释放内存
  514. memset(U4_4GrecvBuff,0,BUFFER_SIZE);
  515. memset(MIPurc1,0,100);
  516. }
  517. }
  518. void MIPURCHandle(void)
  519. {
  520. #if open4G == 1
  521. if(MIPurc[0]==0x7E)
  522. {
  523. uint16_t PTXXID = MIPurc[1]<<8 | MIPurc[2]; //消息ID
  524. uint16_t xxtcLen = MIPurc[3]<<8 | MIPurc[4]; //数据长度
  525. uint16_t xxRE = MIPurc[15]<<8 | MIPurc[16]; //回复ID
  526. uint8_t YESorNO = MIPurc[17]; //00 success ; 01 fail
  527. if(PTXXID==XXID_pttyyd) //收到平台通用应答0x8001
  528. {
  529. if(xxRE == MessageID_authentication)//回复鉴权ID
  530. {
  531. if(YESorNO==YES)
  532. {
  533. printf("@鉴权应答yes\r\n");
  534. authFlag = true;
  535. }
  536. else if(YESorNO==NO)
  537. {
  538. printf("@鉴权应答no\r\n");
  539. }
  540. memset(MIPurc,0,rlt);//rlt下发长度
  541. }
  542. else if(xxRE == MessageID_heartbeat)//回复鉴权ID
  543. {
  544. if(YESorNO==YES)
  545. {
  546. printf("@心跳应答yes\r\n");
  547. }
  548. else if(YESorNO==NO)
  549. {
  550. printf("@心跳应答no\r\n");
  551. }
  552. memset(MIPurc,0,rlt);//rlt下发长度
  553. }
  554. else if(xxRE == MessageID_location)//回复鉴权ID
  555. {
  556. if(YESorNO==YES)
  557. {
  558. printf("@地址应答yes\r\n");
  559. }
  560. else if(YESorNO==NO)
  561. {
  562. printf("@地址应答no\r\n");
  563. }
  564. memset(MIPurc,0,rlt);//rlt下发长度
  565. }
  566. }
  567. else if(PTXXID == XXID_ptxxtc) //收到平台消息透传 8900
  568. {
  569. uint8_t tcsjLen = MIPurc[13];
  570. memcpy(MIPurcXXTCSJ,&MIPurc[13],xxtcLen);
  571. printf("@得到透传数据,%d\r\n",tcsjLen);
  572. memset(MIPurc,0,rlt);//rlt下发长度
  573. }
  574. }
  575. else if(authFlag)
  576. {
  577. authFlag = false;
  578. HAL_Delay(500);
  579. uint8_t test[] = {0x05}; //test心跳
  580. tt808FsFunc(test,1,MessageID_heartbeat); //test心跳
  581. }
  582. #endif
  583. else if(reIME)
  584. {
  585. reIME=false;
  586. phonenum[0] = DTUurc[0]<<8|DTUurc[1];
  587. phonenum[1] = DTUurc[2]<<8|DTUurc[3];
  588. phonenum[2] = DTUurc[4]<<8|DTUurc[5];
  589. phonenull =false;
  590. Flash_WriteBytes(phonenum,phoneNumADDR,3);//更新ime
  591. //memset(DTUurc,0,100);
  592. printf("IME设置\r\n");
  593. }
  594. }
  595. time_t timestamp ;
  596. void time_bj(void)
  597. {
  598. struct tm timeinfo;
  599. timeinfo.tm_year = tt808.Rtime[0]+2000-1900;
  600. timeinfo.tm_mon = tt808.Rtime[1]-1;
  601. timeinfo.tm_mday = tt808.Rtime[2];
  602. timeinfo.tm_hour = tt808.Rtime[3]-8;
  603. timeinfo.tm_min = tt808.Rtime[4];
  604. timeinfo.tm_sec = tt808.Rtime[5];
  605. timestamp = mktime(&timeinfo);
  606. dblocptr->location.timeStamp = timestamp;
  607. }
  608. void ReU4Proces(void)
  609. {
  610. if(GnssFlag)
  611. {
  612. GnssFlag=false;
  613. RTCtime();//同步时间
  614. // 调用函数提取字符串
  615. extractString(MGNSSLOC, cSpeed,7 ,8);//采集
  616. dSpeed = convertToDouble(cSpeed); //转换浮点数
  617. dSpeed*=10;
  618. // 调用函数提取字符串
  619. extractString(MGNSSLOC, clatitude,1 ,2);//采集
  620. dlatitude = convertToDouble(clatitude); //转换浮点数
  621. uint32_t latitudetemp=convertGPS(dlatitude);
  622. dblocptr->location.latitudeH = (latitudetemp>>16)&0xFFFF;
  623. dblocptr->location.latitudeH = swapBytes16(dblocptr->location.latitudeH);//转换H字节
  624. dblocptr->location.latitudeL = (latitudetemp)&0xFFFF;
  625. dblocptr->location.latitudeL = swapBytes16(dblocptr->location.latitudeL);//转换L字节
  626. extractString(MGNSSLOC, clongitude,2 ,3);//采集
  627. dlongitude = convertToDouble(clongitude); //转换浮点数
  628. uint32_t longitudetemp=convertGPS(dlongitude);
  629. dblocptr->location.longitudeH = (longitudetemp>>16)&0xFFFF;
  630. dblocptr->location.longitudeH = swapBytes16(dblocptr->location.longitudeH);//转换H字节
  631. dblocptr->location.longitudeL = (longitudetemp)&0xFFFF;
  632. dblocptr->location.longitudeL = swapBytes16(dblocptr->location.longitudeL);//转换L字节
  633. // printf("%d\r\n",dblocptr->location.latitude);
  634. // printf("%d\r\n",dblocptr->location.longitude);
  635. // printf("%08X\r\n",dblocptr->location.latitude);
  636. // printf("%08X\r\n",dblocptr->location.longitude);
  637. extractString(MGNSSLOC, csatellitesNum,10 ,11);//采集卫星个数
  638. dblocptr->location.satellitesNum = convertToDouble(csatellitesNum); //转换浮点数
  639. //printf("%d",tt808.satellitesNum);
  640. dblocptr->location.speed = (uint16_t)dSpeed;
  641. if(dSpeed !=0 && dlongitude!=0 && dlatitude!=0) //有数据进行更新!
  642. {
  643. signal = true;
  644. if(menu.current == 0xBB && tipsflag!= ConnOK)
  645. {
  646. menu.current = 0;
  647. refresh=true;
  648. }
  649. else if(tipsflag == Back && signal)
  650. {
  651. menu.current = 0;
  652. refresh=true;
  653. }
  654. }
  655. else
  656. {
  657. if(signal && sys_mode[0]!=0xFFFF)
  658. {
  659. signal = false;
  660. menu.current = 0xBB;
  661. tipsflag = Nosignal;
  662. refresh=true;
  663. }
  664. }
  665. memset(MGNSSLOC,0,100);
  666. }
  667. }
  668. //int countregular = 0;
  669. //void Regular_reporting_Loc(void)
  670. //{
  671. // countregular+=1;
  672. // if(countregular==3 && !Offline )//在线状态10s更新状态,30s上传 (各种状态正常在线,直接上传信息)
  673. // {
  674. // countregular=0;
  675. // tt808FsFunc((uint8_t*)&(dblocptr->location.alarmFlagH), 34, MessageID_location);
  676. // }
  677. //
  678. //}
  679. //+MIPURC: "disconn",1,1