tt808.c 29 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199
  1. #include "tt808.h"
  2. #include "usart.h"
  3. #include <stdint.h>
  4. #include "rtc.h"
  5. #include <stdlib.h>
  6. //BYTE uint8_t
  7. //WORD uint16_t
  8. //DWORD uint32_t
  9. TT808 tt808;
  10. TCPCenterD tcpd;
  11. TCPClientD tcpc;
  12. bool XTflag = false;
  13. RTC_DateTypeDef GetData; //获取日期结构体
  14. RTC_TimeTypeDef GetTime; //获取时间结构体
  15. void newpacket(uint8_t *head,uint8_t *body,uint8_t outarr[]);
  16. void packageData(uint8_t flag, uint8_t *head, uint8_t *body, size_t bodylength, uint8_t *escaped_data, size_t *new_length);
  17. void tt808test(uint8_t* Bodyxxt, size_t bodylength, uint8_t XXLSH);
  18. // 发送一包内容为0x30 0x7e 0x08 0x7d 0x55的数据包,则经过封装如下:0x7e 0x30 0x7d 0x02 0x08 0x7d 0x01 0x55 0x7e
  19. extern RTC_HandleTypeDef hrtc;
  20. extern Time time;
  21. void RTCtime(void)
  22. {
  23. HAL_RTC_GetTime(&hrtc, &GetTime, RTC_FORMAT_BIN);
  24. /* Get the RTC current Date */
  25. HAL_RTC_GetDate(&hrtc, &GetData, RTC_FORMAT_BIN);
  26. time.tt[0] = GetData.Year;
  27. time.tt[1] = GetData.Month;
  28. time.tt[2] = GetData.Date;
  29. time.tt[3] = GetTime.Hours;
  30. time.tt[4] = GetTime.Minutes;
  31. time.tt[5] = GetTime.Seconds;
  32. }
  33. /**消息结构
  34. * 标识位 消息头 消息体 校验码 标识位
  35. * 0x7e 11BYTE MORE 1BYTE 0x7e
  36. *
  37. */
  38. /**消息头
  39. *
  40. * 消息ID(WORD) 消息体属性(WORD) 终端ID(BCD[6]) 消息流水号(WORD)
  41. * (0 1) (2 3) (4 5 6 7 8 9) (10 11)
  42. */
  43. /**消息体属性
  44. *
  45. * 消息体长度 数据加密方式 分包 保留
  46. * (0 1 2 3 4 5 6 7 8 9) (10 11 12) 13 (14 15)
  47. */
  48. // 校验码指从消息头开始,同后一字节异或,直到校验码前一个字节,占用一个字节。
  49. void printBinary(uint16_t num) {
  50. for (int i = 15; i >= 0; i--) {
  51. if (num & (1u << i)) {
  52. printf("1");
  53. } else {
  54. printf("0");
  55. }
  56. }
  57. printf("\n");
  58. }
  59. typedef struct Node {
  60. uint8_t data;
  61. struct Node* next;
  62. } Node;
  63. Node* createNode(uint8_t value) {
  64. Node* newNode = (Node*)malloc(sizeof(Node));
  65. newNode->data = value;
  66. newNode->next = NULL;
  67. return newNode;
  68. }
  69. void insertAfter(Node* prevNode, uint8_t value) {
  70. Node* newNode = createNode(value);
  71. newNode->next = prevNode->next;
  72. prevNode->next = newNode;
  73. }
  74. uint8_t escaped_data[100]; // 定义足够大的数组存储转义后的数据
  75. void escape_data(uint8_t* input, int length, uint8_t* escaped_data, size_t* new_length) {
  76. *new_length = 0;
  77. Node* head = createNode(input[0]); // 创建链表头节点
  78. Node* current = head;
  79. escaped_data[(*new_length)++] = input[0]; // 将第一个数据直接存入
  80. for (int i = 1; i < length; i++) {
  81. if (input[i] == 0x7E && (i != length - 1)) {
  82. escaped_data[(*new_length)++] = 0x7D;
  83. escaped_data[(*new_length)++] = 0x02;
  84. }
  85. else if (input[i] == 0x7D) {
  86. escaped_data[(*new_length)++] = 0x7D;
  87. escaped_data[(*new_length)++] = 0x01;
  88. }
  89. else {
  90. escaped_data[(*new_length)++] = input[i];
  91. }
  92. }
  93. // 释放链表内存
  94. current = head;
  95. Node* temp;
  96. while (current != NULL) {
  97. temp = current;
  98. current = current->next;
  99. free(temp);
  100. }
  101. }
  102. //uint8_t escaped_data[100]; // 假设足够大来存储转义后的数据
  103. size_t new_length = 0;
  104. // 数据封装函数
  105. void packageData(uint8_t flag, uint8_t *head, uint8_t *body, size_t bodylength, uint8_t *escaped_data, size_t *new_length)
  106. {
  107. // Calculate total length
  108. uint8_t len = 1 + 12 + bodylength + 1 + 1; // 1 byte for flag + 10 bytes for header + body length + 1 byte for checksum + 1 byte for flag
  109. uint8_t checksum = 0; // Initialize checksum
  110. // Calculate checksum from message header
  111. for (int i = 0; i < 12; i++) {
  112. checksum ^= head[i];
  113. }
  114. for (int i = 0; i < bodylength; i++) {
  115. checksum ^= body[i];
  116. }
  117. // Start building the packet
  118. uint8_t packet[len];
  119. int index = 0;
  120. packet[index++] = flag; // Set the flag
  121. // Copy message header to packet
  122. for (int i = 0; i < 12; i++) {
  123. packet[index++] = head[i];
  124. }
  125. // Copy message body to packet
  126. for (size_t i = 0; i < bodylength; i++) {
  127. packet[index++] = body[i];
  128. }
  129. packet[index++] = checksum; // Set the checksum
  130. packet[index++] = flag; // Set the flag at the end
  131. int packetlength = (sizeof(packet)/sizeof(packet[0]));
  132. // 执行转义处理
  133. escape_data(packet, packetlength, escaped_data, new_length);
  134. // 输出转义后的数据
  135. // for (int i = 0; i < *new_length; i++) {
  136. // printf("%02X ", escaped_data[i]);
  137. // }
  138. // printf("\n");
  139. // char TCPvalue[128];
  140. // char *ptr = TCPvalue;
  141. // ptr += sprintf(ptr, "AT+MIPSEND=1,%d,\"",sizeof(escaped_data));
  142. // for (int i = 0; i < sizeof(escaped_data); i++) {
  143. // ptr += sprintf(ptr, "%02X", escaped_data[i]);
  144. // }
  145. // sprintf(ptr, "\"\r\n");//TCPvalue
  146. // if(sendCmd_4G(TCPvalue, "+MIPSEND:", 1, 3))//发送11BYTE MAX1460
  147. // //if(sendCmd_4G("AT+MIPSEND=1,11,\"12345678900\"\r\n", "+MIPSEND:", 1, 3))//发送11BYTE MAX1460
  148. // {
  149. // printf("#发送完成\r\n");
  150. // }
  151. // memset(cmd_replyArray,0,sizeof(cmd_replyArray));
  152. // memcpy(cmd_replyArray,escaped_data,*new_length);
  153. }
  154. void reCenter(void);
  155. uint16_t xxid =0 ;
  156. uint8_t BusinessData[256] = {0}; // 定义业务数据数组
  157. uint8_t TCPCenterCrc=0;
  158. /**
  159. * @breaf 目前监测 U1485标志位 0x7E 0x2A 0x23 0x7E
  160. */
  161. bool U4re =false;
  162. bool newmac=false;
  163. bool genghaunmac =false;
  164. uint8_t BDmacNum =0;
  165. extern Menu_table menu;
  166. void newMacchange(uint8_t MIPurc1[])
  167. {
  168. //conn AT+CONN=101000000010\r\n
  169. //connected +CONNECTED:0,101000000010
  170. //dis +DISCONN:0,101000000010
  171. //snnum 0010
  172. BDmacNum = MIPurc1[17];//绑定的L1
  173. uint16_t mac = (MIPurc1[20] << 8) | MIPurc1[21]; //eg 0010
  174. // char SNconn[25];
  175. // char *ptr = SNconn;
  176. // ptr += sprintf(ptr, "AT+CONN=1010");
  177. // for (int i = 18; i < 22; i++) {
  178. // ptr += sprintf(ptr, "%02X", MIPurc1[i]);
  179. // }
  180. // sprintf(ptr, "\r\n");//TCPvalue
  181. //
  182. // char SNF[25];
  183. // char *ptr1 = SNF;
  184. // ptr1 += sprintf(ptr1, "+CONNECTED:0,1010");
  185. // for (int i = 18; i < 22; i++) {
  186. // ptr1 += sprintf(ptr1, "%02X", MIPurc1[i]);
  187. // }
  188. // //sprintf(ptr, "\r\n");//TCPvalue
  189. //
  190. //
  191. // char SNname[2];
  192. // char *ptr2 = SNname;
  193. // for (int i = 20; i < 22; i++) {
  194. // ptr2 += sprintf(ptr2, "%02X", MIPurc1[i]);
  195. // }
  196. // //sprintf(ptr, "\r\n");//TCPvalue
  197. //
  198. // char SND[25];
  199. // char *ptr3 = SND;
  200. // ptr3 += sprintf(ptr3, "+DISCONN:0,1010");
  201. // for (int i = 18; i < 22; i++) {
  202. // ptr3 += sprintf(ptr3, "%02X", MIPurc1[i]);
  203. // }
  204. if(BDmacNum==0x01)//M1
  205. {
  206. //xxid=0;
  207. menu.SN1name=NULL;
  208. menu.SN1=NULL;
  209. menu.SN1F=NULL;
  210. menu.SN1D=NULL;
  211. erase_flash(Sn1StatusAddr);
  212. erase_flash(Sn1Addr);
  213. erase_flash(serialNum1Addr);
  214. // menu.SN1 = SNconn;//AT+CONN=*********\r\n
  215. // menu.SN1F = SNF;//+CONNECTED:0,101000000010
  216. // menu.SN1name = SNname;
  217. // menu.SN1D = SND;
  218. Write_Information(Sn1Addr, mac);
  219. menu.home &= 0x0FFF;
  220. }
  221. else if(BDmacNum==0x02)//M2
  222. {
  223. menu.SN2name=NULL;
  224. menu.SN2=NULL;
  225. menu.SN2F=NULL;
  226. menu.SN2D=NULL;
  227. erase_flash(Sn2StatusAddr);
  228. erase_flash(Sn2Addr);
  229. erase_flash(serialNum2Addr);
  230. // menu.SN2 = SNconn;//AT+CONN=*********\r\n
  231. // menu.SN2F = SNF;//+CONNECTED:0,101000000010
  232. // menu.SN2name = SNname;
  233. // menu.SN2D = SND;
  234. Write_Information(Sn2Addr, mac);
  235. menu.home &= 0xF0FF;
  236. }
  237. else if(BDmacNum==0x03)//M3
  238. {
  239. menu.SN3name=NULL;
  240. menu.SN3=NULL;
  241. menu.SN3F=NULL;
  242. menu.SN3D=NULL;
  243. erase_flash(Sn3StatusAddr);
  244. erase_flash(Sn3Addr);
  245. erase_flash(serialNum3Addr);
  246. // menu.SN3 = SNconn;//AT+CONN=*********\r\n
  247. // menu.SN3F = SNF;//+CONNECTED:0,101000000010
  248. // menu.SN3name = SNname;
  249. // menu.SN3D = SND;
  250. Write_Information(Sn3Addr, mac);
  251. menu.home &= 0xFF0F;
  252. }
  253. else if(BDmacNum==0x04)//M4
  254. {
  255. menu.SN4name=NULL;
  256. menu.SN4=NULL;
  257. menu.SN4F=NULL;
  258. menu.SN4D=NULL;
  259. erase_flash(Sn4StatusAddr);
  260. erase_flash(Sn4Addr);
  261. erase_flash(serialNum4Addr);
  262. // menu.SN4 = SNconn;//AT+CONN=*********\r\n
  263. // menu.SN4F = SNF;//+CONNECTED:0,101000000010
  264. // menu.SN4name = SNname;
  265. // menu.SN4D = SND;
  266. Write_Information(Sn4Addr, mac);
  267. menu.home &= 0xFFF0;
  268. }
  269. readLockStatusinit();
  270. // scanMac();
  271. }
  272. uint8_t hext[100]={0};
  273. uint8_t cmd_replyArray[] = {0};
  274. uint32_t DTUID=0x64747531;
  275. uint16_t length;
  276. void wsj(uint8_t flag);
  277. void tcphuifu(void);
  278. int tcpdataLength = 0;
  279. void wjwd(void);
  280. uint8_t MIPurc[100];
  281. uint8_t MIPurc1[100];
  282. uint8_t MIPurcXXTCSJ[100];//平台下行透传数据
  283. bool MIPurcReFlag = false;
  284. uint16_t hccd = 0;
  285. char high[]={0};
  286. bool chuliSJ = false;
  287. char hex2asc(const char *hex)
  288. {
  289. char asc = 0;
  290. char a = (hex[0]>='A' && hex[0]<='F')?(hex[0]^32):hex[0];
  291. char b = (hex[1]>='A' && hex[1]<='F')?(hex[1]^32):hex[1];
  292. if ((a>='0' && a<='9' || a>='a' && a<='f') && (b>='0' && b<='9' || b>='a' && b<='f')){
  293. asc = ((('a'<=a && a<='f')?(a-'a')+10:a-'0')<<4)|(('a'<=b && b<='f')?(b-'a')+10:b-'0');
  294. }
  295. return asc;
  296. }
  297. char *bin2hex(char *hex, const unsigned char *bin, int size)
  298. {
  299. size_t i;
  300. for(i=0; i<size; i++)
  301. {
  302. sprintf(hex+i*2, "%02x", bin[i]);
  303. }
  304. hex[i+i] = 0;
  305. return hex;
  306. }
  307. int hex2bin(unsigned char *bin, const char *hex)
  308. {
  309. const char *h = hex;
  310. unsigned char *b = bin;
  311. int rlt = 0;
  312. while(*h){
  313. *b++ = hex2asc(h);
  314. h = h + 2;
  315. rlt++;
  316. }
  317. return rlt;//长度
  318. }
  319. int rlt;
  320. char year_str[3];
  321. char month_str[3];
  322. char day_str[3];
  323. char hour_str[3];
  324. char minute_str[3];
  325. char second_str[3];
  326. void ZHSJ(uint8_t outTt[],char in[])//转换数据
  327. {
  328. const char *hex = (const char *)in; // 将 uint8_t * 转换为 const char *
  329. int size = strlen(hex) / 2; // 计算二进制数据的长度
  330. unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
  331. hex2bin(bin, hex); // 调用hex2bin函数进行转换
  332. memcpy(outTt, bin, 1); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
  333. free(bin); // 释放内存
  334. }
  335. void ZHSN(uint8_t outTt[],char in[])//转换SN
  336. {
  337. const char *hex = (const char *)in; // 将 uint8_t * 转换为 const char *
  338. int size = strlen(hex) / 2; // 计算二进制数据的长度
  339. unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
  340. hex2bin(bin, hex); // 调用hex2bin函数进行转换
  341. memcpy(outTt, bin, 2); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
  342. free(bin); // 释放内存
  343. }
  344. void wsj(uint8_t flag )
  345. {
  346. if(flag==0)
  347. {
  348. if (sendCmd_4G("AT+CCLK?\r\n", "OK", 1, 1))
  349. {
  350. memcpy(year_str, &g_ML307A_8buf_Down[8], 2); // 复制两个字符
  351. memcpy(month_str, &g_ML307A_8buf_Down[11], 2);
  352. memcpy(day_str, &g_ML307A_8buf_Down[14], 2);
  353. memcpy(hour_str, &g_ML307A_8buf_Down[17], 2);
  354. memcpy(minute_str, &g_ML307A_8buf_Down[20], 2);
  355. memcpy(second_str, &g_ML307A_8buf_Down[23], 2);
  356. year_str[2] = '\0'; // 添加空字符结束符
  357. month_str[2] = '\0';
  358. day_str[2] = '\0';
  359. hour_str[2] = '\0';
  360. minute_str[2] = '\0';
  361. second_str[2] = '\0';
  362. // time.year = (uint8_t)atoi(year_str); // 使用atoi函数将字符转换为数字并赋值给time.year转16
  363. // time.month = (uint8_t)atoi(month_str);
  364. // time.day = (uint8_t)atoi(day_str);
  365. // time.hour = (uint8_t)atoi(hour_str)+8;
  366. // time.minute = (uint8_t)atoi(minute_str);
  367. // time.second = (uint8_t)atoi(second_str);
  368. ZHSJ(&time.tt[0],year_str);
  369. ZHSJ(&time.tt[1],month_str);
  370. ZHSJ(&time.tt[2],day_str);
  371. ZHSJ(&time.tt[3],hour_str);
  372. ZHSJ(&time.tt[4],minute_str);
  373. ZHSJ(&time.tt[5],second_str);
  374. tongbushijian(time.tt[0], time.tt[1], time.tt[2], time.tt[3], time.tt[4], time.tt[5]);
  375. }
  376. }
  377. else
  378. {
  379. /* 上面通过AT指令问 */
  380. RTCtime();//上电同步时间
  381. }
  382. }
  383. uint8_t xxtnewlength=0;
  384. uint8_t xxtfz[100];
  385. uint8_t tcppacket[100];
  386. uint8_t xxtFZ(uint8_t xxt[], uint8_t xxtlength, uint8_t outXxt[],uint16_t XXID)
  387. {
  388. int index = 0;
  389. uint8_t newlength = xxtlength+3;
  390. uint8_t newXxt[newlength];
  391. if(XXID==XXIDzdjq || XXID==XXIDzdxt || XXID==XXIDzddz)//不加头尾(鉴权、心跳、地址)
  392. {
  393. for (int i = 0; i < xxtlength; i++) {
  394. newXxt[index++] = xxt[i]; // 将消息头拷贝到报文中
  395. }
  396. newlength = index;
  397. for(int i =0;i<newlength;i++)
  398. {
  399. outXxt[i]=newXxt[i];
  400. }
  401. }
  402. else
  403. {
  404. newXxt[index++]=newlength;
  405. newXxt[index++]=0x2A;
  406. for (int i = 0; i < xxtlength; i++) {
  407. newXxt[index++] = xxt[i]; // 将消息头拷贝到报文中
  408. }
  409. newXxt[index++]=0x23;
  410. newXxt[index++]=xorBytes(&newXxt[1],newlength-1);
  411. newlength = index;
  412. for(int i =0;i<newlength;i++)
  413. {
  414. outXxt[i]=newXxt[i];
  415. }
  416. }
  417. //test
  418. // for (int i = 0; i < newlength; i++) {
  419. // printf("%02X ", newXxt[i]); // 以十六进制格式打印每个元素
  420. // }
  421. return newlength;
  422. }
  423. uint8_t header[12];
  424. void chuli(uint16_t XXID)
  425. {
  426. uint16_t XXTSXdata = xxtnewlength;
  427. XXTSXdata |= ( xxtnewlength | (TCPJMFSNULL<<10)); // 将长度左移3位后和加密方式进行按位或操作(001 RSA ,000 无加密)
  428. header[0] = ((XXID>>8)&0xff);
  429. header[1] = (XXID&0xff);
  430. header[2] = ((XXTSXdata>>8)&0xff);
  431. header[3] = (XXTSXdata&0xff);
  432. header[4] = 0x00;
  433. header[5] = 0x00;
  434. header[6] = 0x16;
  435. header[7] = 0x00;
  436. header[8] = 0x00;
  437. header[9] = 0x08;
  438. header[10] = ((tt808.LSH>>8)&0xff);;
  439. header[11] = (tt808.LSH&0xff);;
  440. int index = 0;
  441. tcppacket[index++] = TT808FLAG; // Set the flag
  442. for (int i = 0; i < 12; i++) {
  443. tcppacket[index++] = header[i];
  444. }
  445. // Copy message body to packet
  446. for (size_t i = 0; i < xxtnewlength; i++) {
  447. tcppacket[index++] = xxtfz[i];
  448. }
  449. tcppacket[index++] = xorBytes(&tcppacket[1],12+xxtnewlength);; // Set the checksum
  450. tcppacket[index++] = TT808FLAG; // Set the flag at the end
  451. // for (int i = 0; i < index; i++) {
  452. // printf("%02X ", tcppacket[i]); // 以十六进制格式打印每个元素
  453. // }
  454. char TCPvalue[100];
  455. char *ptr = TCPvalue;
  456. ptr += sprintf(ptr, "AT+MIPSEND=1,%d,\"",index);
  457. for (int i = 0; i < index; i++) {
  458. ptr += sprintf(ptr, "%02X", tcppacket[i]);
  459. }
  460. sprintf(ptr, "\"\r\n");//TCPvalue
  461. if(sendCmd_4G(TCPvalue, "+MIPSEND:", 1, 1))//发送11BYTE MAX1460
  462. {
  463. printf("#发送完成\r\n");
  464. }
  465. tt808.LSH+=1;
  466. }
  467. /*需要传入消息体长度sizeof(xxt)/sizeof(xxt[0]);*/
  468. void tt808FsFunc(uint8_t xxt[], uint8_t xxtlength, uint16_t XXID)
  469. {
  470. xxtnewlength = xxtFZ(xxt, xxtlength, xxtfz, XXID);
  471. chuli(XXID);
  472. }
  473. void ReMLBSLOC(void)
  474. {
  475. if(g_ML307A_8buf_Down[1]==0x4D && g_ML307A_8buf_Down[2]==0x4C && g_ML307A_8buf_Down[3]==0x42 \
  476. && g_ML307A_8buf_Down[4]==0x53 && g_ML307A_8buf_Down[5]==0x4C && g_ML307A_8buf_Down[6]==0x4F \
  477. && g_ML307A_8buf_Down[7]==0x43 && g_ML307A_8buf_Down[8]==0x3A)//检测MLBSLOC:定位
  478. {
  479. memcpy(JD_str, &g_ML307A_8buf_Down[14], 12);
  480. memcpy(WD_str, &g_ML307A_8buf_Down[27], 11);
  481. double num;
  482. double num1;
  483. num = atof(JD_str);
  484. num1 = atof(WD_str);
  485. num = num* 1000000;
  486. num1= num1* 1000000;
  487. JD_dw = (uint32_t)num;
  488. WD_dw = (uint32_t)num1;
  489. }
  490. }
  491. void ReMIPURC(void)
  492. {
  493. //4D 49 50 55 52 43
  494. if(g_ML307A_8buf_Down[1]==0x4D && g_ML307A_8buf_Down[2]==0x49 && g_ML307A_8buf_Down[3]==0x50 \
  495. && g_ML307A_8buf_Down[4]==0x55 && g_ML307A_8buf_Down[5]==0x52 && g_ML307A_8buf_Down[6]==0x43 ) //监测平台回复
  496. {
  497. uint8_t high_byte = (g_ML307A_8buf_Down[18]&0x0f) *10;
  498. uint8_t low_byte = g_ML307A_8buf_Down[19]&0x0f;
  499. hccd = high_byte + low_byte;
  500. memcpy(MIPurc,&g_ML307A_8buf_Down[21],hccd*2);
  501. const char *hex = (const char *)MIPurc; // 将 uint8_t * 转换为 const char *
  502. int size = strlen(hex) / 2; // 计算二进制数据的长度
  503. unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
  504. rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
  505. memcpy(MIPurc1, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
  506. free(bin); // 释放内存
  507. memset(g_ML307A_8buf_Down,0,u4length);
  508. }
  509. }
  510. uint16_t nowMac1;
  511. uint16_t nowMac2;
  512. uint16_t nowMac3;
  513. uint16_t nowMac4;
  514. extern BtFrame btframe;
  515. extern void close_lock(BtFrame btframe);
  516. extern void open_lock(BtFrame btframe);
  517. uint8_t WbscLength =0;//数据长度
  518. uint8_t WbscCmd = 0;//指令代码 0x32
  519. uint16_t WbscHmac = 0;//高位mac
  520. uint16_t WbscLmac = 0;//低位mac
  521. bool Ptsjf = false;
  522. extern bool locDw;
  523. bool Timetb=false;
  524. bool JQflag = false;
  525. uint8_t sjfNowStatus = 0;
  526. void MIPURCHandle(void)
  527. {
  528. if(MIPurc1[0]==0x7E)
  529. {
  530. uint16_t PTXXID = MIPurc1[1]<<8 | MIPurc1[2]; //消息ID
  531. uint16_t xxtcLen = MIPurc1[3]<<8 | MIPurc1[4]; //数据长度
  532. uint16_t xxRE = MIPurc1[15]<<8 | MIPurc1[16]; //回复ID
  533. uint8_t YESorNO = MIPurc1[17]; //00 success ; 01 fail
  534. if(PTXXID==XXIDpttyyd) //收到平台通用应答0x8001
  535. {
  536. if(xxRE == XXIDzdjq)//回复鉴权ID
  537. {
  538. if(YESorNO==YES)
  539. {
  540. //printf("@鉴权应答yes\r\n");
  541. JQflag = true;
  542. }
  543. else if(YESorNO==NO)
  544. {
  545. //printf("@鉴权应答no\r\n");
  546. }
  547. memset(MIPurc1,0,rlt);//rlt下发长度
  548. }
  549. else if(xxRE==XXIDzdxt)//回复心跳ID
  550. {
  551. if(YESorNO==YES)
  552. {
  553. //printf("@心跳应答yes\r\n");
  554. XTflag = true;
  555. if(!Timetb)
  556. {
  557. wsj(0);
  558. }
  559. locDw = true;
  560. }
  561. else if(YESorNO==NO)
  562. {
  563. //printf("@心跳应答no\r\n");
  564. }
  565. memset(MIPurc1,0,rlt);//rlt下发长度
  566. }
  567. else if(xxRE==XXIDzddz)//回复地址ID
  568. {
  569. if(YESorNO==YES)
  570. {
  571. //printf("@地址应答yes\r\n");
  572. }
  573. else if(YESorNO==NO)
  574. {
  575. //printf("@地址应答no\r\n");
  576. }
  577. memset(MIPurc1,0,rlt);//rlt下发长度
  578. }
  579. else if(xxRE==XXIDwbsc) //收到平台施解封命令0x0300
  580. {
  581. if(YESorNO==YES)
  582. {
  583. //printf("@文本上传回复yes\r\n");
  584. }
  585. else if(YESorNO==NO)
  586. {
  587. //printf("@文本上传回复no\r\n");;
  588. }
  589. memset(MIPurc1,0,rlt);//rlt下发长度
  590. }
  591. }
  592. else if(PTXXID == XXIDptxxtc) //收到平台消息透传 8900
  593. {
  594. uint8_t tcsjLen = MIPurc1[13];
  595. memcpy(MIPurcXXTCSJ,&MIPurc1[13],xxtcLen);
  596. printf("@得到透传数据,%d\r\n",tcsjLen);
  597. JQflag = true;
  598. // time.tt[0] = MIPurcXXTCSJ[22];
  599. // time.tt[1] = MIPurcXXTCSJ[23];
  600. // time.tt[2] = MIPurcXXTCSJ[24];
  601. // time.tt[3] = MIPurcXXTCSJ[25];
  602. // time.tt[4] = MIPurcXXTCSJ[26];
  603. // time.tt[5] = MIPurcXXTCSJ[27];
  604. //
  605. //
  606. // tongbushijian(time.tt[0], time.tt[1], time.tt[2], time.tt[3], time.tt[4], time.tt[5]);
  607. //Timetb=true;
  608. memset(MIPurc1,0,rlt);//rlt下发长度
  609. // memset(MIPurcXXTCSJ,0,xxtcLen);//rlt下发长度
  610. } // 标头 消息ID 消息体属性 电话号 流水号 长度+2A 操作+CMD MAC号 gate1b+bill8b+linecode2b+key6b+vaildtime1b+备用4b+时间6b 23+流水号2b+校验
  611. else if(PTXXID==XXIDwbsc) //收到平台文本上传 eg.+MIPURC: "rtcp",1,50,7E 0300 0046 000016000008 2890 282A 1532 00000010 00 0000000000000000 0000 000000000000 00 00000000 230001220000 23 0001 99 7E
  612. {
  613. //printf("@得到平台施解封数据\r\n");
  614. nowMac1 = locksnu8.L1snT8[0]<<8 | locksnu8.L1snT8[1];//L1绑定的低字节&0xff
  615. nowMac2 = locksnu8.L2snT8[0]<<8 | locksnu8.L2snT8[1];//L2绑定的低字节&0xff
  616. nowMac3 = locksnu8.L3snT8[0]<<8 | locksnu8.L3snT8[1];//L3绑定的低字节&0xff
  617. nowMac4 = locksnu8.L4snT8[0]<<8 | locksnu8.L4snT8[1];//L4绑定的低字节&0xff
  618. WbscLength = MIPurc1[13];//数据长度
  619. WbscCmd = MIPurc1[16];//指令代码 0x32
  620. WbscHmac = MIPurc1[17] << 8 | MIPurc1[18];//高位mac
  621. WbscLmac = MIPurc1[19] << 8 | MIPurc1[20];//低位mac
  622. if(WbscCmd==0x32)//1532
  623. {
  624. printf("@得到平台施封数据,ID:%04x\r\n",WbscLmac);
  625. XTflag = false;
  626. locDw = false;
  627. if(nowMac1 == WbscLmac && L1bd)//施封L1
  628. {
  629. printf("@施封L1,ID:%04x,%04x\r\n",WbscLmac,nowMac1);
  630. {//施封具体
  631. if(sendCmd_BT(menu.SN1,"ERROR",1,1))
  632. {
  633. SET_MENU_STATUS(4,1,0,3);
  634. HAL_Delay(400);
  635. }
  636. else if(sendCmd_BT(menu.SN1,menu.SN1F,1,2))
  637. {
  638. SET_MENU_STATUS(4,1,0,3);
  639. HAL_Delay(400);
  640. }
  641. }
  642. sjfNowStatus = tt808.L1Lockstatus;
  643. }
  644. else if(nowMac2 == WbscLmac && L2bd)//施封L2
  645. {
  646. printf("@施封L2,ID:%04x,%04x\r\n",WbscLmac,nowMac2);
  647. {//施封具体
  648. if(sendCmd_BT(menu.SN2,"ERROR",1,1))
  649. {
  650. SET_MENU_STATUS(5,1,0,3);
  651. HAL_Delay(400);
  652. }
  653. else if(sendCmd_BT(menu.SN2,menu.SN2F,1,2))
  654. {
  655. SET_MENU_STATUS(5,1,0,3);
  656. HAL_Delay(400);
  657. }
  658. }
  659. sjfNowStatus = tt808.L2Lockstatus;
  660. }
  661. else if(nowMac3 == WbscLmac && L3bd)//施封L3
  662. {
  663. printf("@施封L3,ID:%04x,%04x\r\n",WbscLmac,nowMac3);
  664. {//施封具体
  665. if(sendCmd_BT(menu.SN3,"ERROR",1,1))
  666. {
  667. SET_MENU_STATUS(6,1,0,3);
  668. HAL_Delay(400);
  669. }
  670. else if(sendCmd_BT(menu.SN3,menu.SN3F,1,2))
  671. {
  672. SET_MENU_STATUS(6,1,0,3);
  673. HAL_Delay(400);
  674. }
  675. }
  676. sjfNowStatus = tt808.L3Lockstatus;
  677. }
  678. else if(nowMac4 == WbscLmac && L4bd)//施封L4
  679. {
  680. printf("@施封L4,ID:%04x,%04x\r\n",WbscLmac,nowMac4);
  681. {//施封具体
  682. if(sendCmd_BT(menu.SN4,"ERROR",1,1))
  683. {
  684. SET_MENU_STATUS(7,1,0,3);
  685. HAL_Delay(400);
  686. }
  687. else if(sendCmd_BT(menu.SN4,menu.SN4F,1,2))
  688. {
  689. SET_MENU_STATUS(7,1,0,3);
  690. HAL_Delay(400);
  691. }
  692. }
  693. sjfNowStatus = tt808.L4Lockstatus;
  694. }
  695. else
  696. {
  697. printf("@未绑定此MAC\r\n");
  698. }
  699. Ptsjf = true;
  700. memset(MIPurc1,0,rlt);//rlt下发长度
  701. }
  702. else if(WbscCmd==0x38)//1538
  703. {
  704. printf("@得到平台解封数据,ID:%04x\r\n",WbscLmac);
  705. XTflag = false;
  706. locDw = false;
  707. if(nowMac1 == WbscLmac && L1bd)//解锁L1
  708. {
  709. printf("@解封L1,ID:%04x,%04x\r\n",WbscLmac,nowMac1);
  710. {//解封具体
  711. if(sendCmd_BT(menu.SN1,"ERROR",1,2))
  712. {
  713. HAL_Delay(400);
  714. SET_MENU_STATUS(4,0,0,3);
  715. }
  716. else if(sendCmd_BT(menu.SN1,menu.SN1F,2,2))
  717. {
  718. HAL_Delay(400);
  719. SET_MENU_STATUS(4,0,0,3);
  720. }
  721. }
  722. sjfNowStatus = tt808.L1Lockstatus;
  723. }
  724. else if(nowMac2 == WbscLmac && L2bd)//解锁L2
  725. {
  726. printf("@解封L2,ID:%04x,%04x\r\n",WbscLmac,nowMac2);
  727. {//解封具体
  728. if(sendCmd_BT(menu.SN2,"ERROR",1,2))
  729. {
  730. HAL_Delay(400);
  731. SET_MENU_STATUS(5,0,0,3);
  732. }
  733. else if(sendCmd_BT(menu.SN2,menu.SN2F,2,2))
  734. {
  735. HAL_Delay(400);
  736. SET_MENU_STATUS(5,0,0,3);
  737. }
  738. }
  739. sjfNowStatus = tt808.L2Lockstatus;
  740. }
  741. else if(nowMac3 == WbscLmac && L3bd)//解锁L3
  742. {
  743. printf("@解封L3,ID:%04x,%04x\r\n",WbscLmac,nowMac3);
  744. {//解封具体
  745. if(sendCmd_BT(menu.SN3,"ERROR",1,2))
  746. {
  747. HAL_Delay(400);
  748. SET_MENU_STATUS(6,0,0,3);
  749. }
  750. else if(sendCmd_BT(menu.SN3,menu.SN3F,2,2))
  751. {
  752. HAL_Delay(400);
  753. SET_MENU_STATUS(6,0,0,3);
  754. }
  755. }
  756. sjfNowStatus = tt808.L3Lockstatus;
  757. }
  758. else if(nowMac4 == WbscLmac && L4bd)//解锁L4
  759. {
  760. printf("@解封L4,ID:%04x,%04x\r\n",WbscLmac,nowMac4);
  761. {//解封具体
  762. if(sendCmd_BT(menu.SN4,"ERROR",1,2))
  763. {
  764. HAL_Delay(400);
  765. SET_MENU_STATUS(7,0,0,3);
  766. }
  767. else if(sendCmd_BT(menu.SN4,menu.SN4F,2,2))
  768. {
  769. HAL_Delay(400);
  770. SET_MENU_STATUS(7,0,0,3);
  771. }
  772. }
  773. sjfNowStatus = tt808.L4Lockstatus;
  774. }
  775. else
  776. {
  777. printf("@未绑定此MAC\r\n");
  778. }
  779. Ptsjf = true;
  780. memset(MIPurc1,0,rlt);//rlt下发长度
  781. }
  782. else if(WbscCmd==0x02)//1202 eg.+MIPURC: "rtcp",1,22,7E030000140000160000082890132A1202010000000301240401123456230001997E
  783. {
  784. printf("@得到平台绑定MAC数据\r\n");
  785. genghaunmac=true;
  786. locDw =false;
  787. XTflag = false;
  788. }
  789. }
  790. }
  791. }
  792. /*
  793. 0-3报警标志
  794. 4-7状态
  795. 8-11纬度
  796. 12-15经度
  797. 16-17高程
  798. 18-19速度
  799. 20-21方向
  800. 22-27时间
  801. */
  802. /**
  803. "报警标志对象": {
  804. "[bit31]非法开门报警": "0",
  805. "[bit30]侧翻预警": "0",
  806. "[bit29]碰撞预警": "0",
  807. "[bit28]车辆非法位移": "0",
  808. "[bit27]车辆非法点火": "0",
  809. "[bit26]车辆被盗(通过车辆防盗器)": "0",
  810. "[bit25]车辆油量异常": "0",
  811. "[bit24]车辆VSS故障": "0",
  812. "[bit23]路线偏离报警": "0",
  813. "[bit22]路段行驶时间不足/过长": "0",
  814. "[bit21]进出路线": "0",
  815. "[bit20]进出区域": "0",
  816. "[bit19]超时停车": "0",
  817. "[bit18]当天累计驾驶超时": "0",
  818. "[bit15~bit17]保留": "000",
  819. "[bit14]疲劳驾驶预警": "0",
  820. "[bit13]超速预警": "0",
  821. "[bit12]道路运输证IC卡模块故障": "0",
  822. "[bit11]摄像头故障": "0",
  823. "[bit10]TTS模块故障": "0",
  824. "[bit9]终端LCD或显示器故障": "0",
  825. "[bit8]终端主电源掉电": "0",
  826. "[bit7]终端主电源欠压": "0",
  827. "[bit6]GNSS天线短路": "0",
  828. "[bit5]GNSS天线未接或被剪断": "0",
  829. "[bit4]GNSS模块发生故障": "0",
  830. "[bit3]危险预警": "0",
  831. "[bit2]疲劳驾驶": "0",
  832. "[bit1]超速报警": "0",
  833. "[bit0]紧急报警,触动报警开关后触发": "0"
  834. "状态标志对象": {
  835. "[bit22~bit31]保留": "0000000000",
  836. "[0]bit21": "未使用Galileo卫星进行定位",
  837. "[0]bit20": "未使用GLONASS卫星进行定位",
  838. "[0]bit19": "未使用北斗卫星进行定位",
  839. "[0]bit18": "未使用GPS卫星进行定位",
  840. "[0]bit17": "门5关",
  841. "[0]bit16": "门4关",
  842. "[0]bit15": "门3关",
  843. "[0]bit14": "门2关",
  844. "[0]bit13": "门1关",
  845. "[0]bit12": "车门解锁",
  846. "[0]bit11": "车辆电路正常",
  847. "[0]bit10": "车辆油路正常",
  848. "[00]bit8~bit9": "空车",
  849. "[bit6~bit7]保留": "00",
  850. "[0]bit5": "经纬度未经保密插件加密",
  851. "[0]bit4": "运营状态",
  852. "[0]bit3": "东经",
  853. "[0]bit2": "北纬",
  854. "[0]bit1": "未定位",
  855. "[0]bit0": "ACC关"
  856. "[01CD81D6]纬度": 30245334,
  857. "[0727A76F]经度": 120039279,
  858. "[0000]高程": 0,
  859. "[0000]速度": 0,
  860. "[0000]方向": 0,
  861. "[180323093105]定位时间": "2018-03-23 09:31:05",
  862. */
  863. LBSset lbsset;
  864. uint8_t LBSdata[28];
  865. uint8_t LockStatusData[21];
  866. void Lbsprocess(void)
  867. {
  868. wsj(1); //问时间
  869. LBSdata[0] = (lbsset.bjbz>>24)&0xff;
  870. LBSdata[1] = (lbsset.bjbz>>16)&0xff;
  871. LBSdata[2] = (lbsset.bjbz>>8)&0xff;
  872. LBSdata[3] = lbsset.bjbz&0xff;
  873. LBSdata[4] = (lbsset.zt>>24)&0xff;
  874. LBSdata[5] = (lbsset.zt>>16)&0xff;
  875. LBSdata[6] = (lbsset.zt>>8)&0xff;
  876. LBSdata[7] = lbsset.zt&0xff;
  877. LBSdata[8] = (WD_dw>>24)&0xff;
  878. LBSdata[9] = (WD_dw>>16)&0xff;
  879. LBSdata[10] =(WD_dw>>8)&0xff;
  880. LBSdata[11] = WD_dw&0xff;
  881. LBSdata[12] = (JD_dw>>24)&0xff;
  882. LBSdata[13] = (JD_dw>>16)&0xff;
  883. LBSdata[14] = (JD_dw>>8)&0xff;
  884. LBSdata[15] = JD_dw&0xff;
  885. LBSdata[16] = (lbsset.gaocheng>>8)&0xff;
  886. LBSdata[17] = lbsset.gaocheng&0xff;
  887. LBSdata[18] = (lbsset.sudu>>8)&0xff;
  888. LBSdata[19] = lbsset.sudu&0xff;
  889. LBSdata[20] = (lbsset.fangxiang>>8)&0xff;
  890. LBSdata[21] = lbsset.fangxiang&0xff;
  891. LBSdata[22] = time.tt[0];
  892. LBSdata[23] = time.tt[1];
  893. LBSdata[24] = time.tt[2];
  894. LBSdata[25] = time.tt[3]+DongbaquTime;//加东八区
  895. LBSdata[26] = time.tt[4];
  896. LBSdata[27] = time.tt[5];
  897. }
  898. /**
  899. 操作指令(1B,上行0x01,)+SubCmd(1B)+LockID(4B)+Gate(1B)+ Voltage(1B)+LockStatus(1B)+
  900. MotoStatus (1B)+ 备用 (4B)+Ver (1B)+绝对时间(6B)
  901. */
  902. void LockStatusUpload(LockSNu8 locksnu8, uint8_t Locknum)
  903. {
  904. wsj(1); //问时间
  905. LockStatusData[0] = 0x01;//操作上行
  906. LockStatusData[1] = 0x01;//01锁信息上传 02旋钮破坏 03锁体破坏报警 04锁杆剪断报警 05锁杆打开报警 F2申请动态密码/申请开锁
  907. LockStatusData[2] = 0x00;//默认ID
  908. LockStatusData[3] = 0x00;
  909. if(Locknum==0x1)
  910. {
  911. LockStatusData[4] = locksnu8.L1snT8[0];//L1绑定的低字节>>4&0xff
  912. LockStatusData[5] = locksnu8.L1snT8[1];//L1绑定的低字节&0xff
  913. LockStatusData[8] = tt808.L1Lockstatus;//LockStatus
  914. }
  915. else if(Locknum==0x2)
  916. {
  917. LockStatusData[4] = locksnu8.L2snT8[0];
  918. LockStatusData[5] = locksnu8.L2snT8[1];
  919. LockStatusData[8] = tt808.L2Lockstatus;//LockStatus
  920. }
  921. else if(Locknum==0x3)
  922. {
  923. LockStatusData[4] = locksnu8.L3snT8[0];
  924. LockStatusData[5] = locksnu8.L3snT8[1];
  925. LockStatusData[8] = tt808.L3Lockstatus;//LockStatus
  926. }
  927. else if(Locknum==0x4)
  928. {
  929. LockStatusData[4] = locksnu8.L4snT8[0];
  930. LockStatusData[5] = locksnu8.L4snT8[1];
  931. LockStatusData[8] = tt808.L4Lockstatus;//LockStatus
  932. }
  933. LockStatusData[6] = 0x00;//Gate
  934. LockStatusData[7] = 0x00;//Voltage
  935. LockStatusData[9] = 0x00;//MotoStatus
  936. LockStatusData[10] = 0x00;//备用
  937. LockStatusData[11] = 0x00;//备用
  938. LockStatusData[12] = 0x00;//备用
  939. LockStatusData[13] = 0x00;//备用
  940. LockStatusData[14] = 0x00;//VER
  941. LockStatusData[15] = time.tt[0];//year
  942. LockStatusData[16] = time.tt[1];//month
  943. LockStatusData[17] = time.tt[2];//day
  944. LockStatusData[18] = time.tt[3]+DongbaquTime;//hour
  945. LockStatusData[19] = time.tt[4];//minute
  946. LockStatusData[20] = time.tt[5];//second
  947. tt808FsFunc(LockStatusData,21,XXIDwbsc);
  948. }
  949. uint32_t uploadtime = 0;
  950. void gettimeupload_Normal(void)
  951. {
  952. if(HAL_GetTick() - uploadtime >= 40000)//60000=1min
  953. {
  954. uploadtime = HAL_GetTick();
  955. Lbsprocess(); //test地址
  956. tt808FsFunc(LBSdata,28,XXIDzddz); //test地址
  957. if(L1bd)
  958. {
  959. LockStatusUpload(locksnu8,1);
  960. HAL_Delay(50);
  961. }
  962. if(L2bd)
  963. {
  964. LockStatusUpload(locksnu8,2);
  965. HAL_Delay(50);
  966. }
  967. if(L3bd)
  968. {
  969. LockStatusUpload(locksnu8,3);
  970. HAL_Delay(50);
  971. }
  972. if(L4bd)
  973. {
  974. LockStatusUpload(locksnu8,4);
  975. HAL_Delay(50);
  976. }
  977. }
  978. }
  979. void gettimeupload_Emergency(void)
  980. {
  981. Lbsprocess(); //test地址
  982. tt808FsFunc(LBSdata,28,XXIDzddz); //test地址
  983. if(L1bd && menu.current==4)
  984. {
  985. LockStatusUpload(locksnu8,1);
  986. }
  987. if(L2bd && menu.current==5)
  988. {
  989. LockStatusUpload(locksnu8,2);
  990. }
  991. if(L3bd && menu.current==6)
  992. {
  993. LockStatusUpload(locksnu8,3);
  994. }
  995. if(L4bd && menu.current==7)
  996. {
  997. LockStatusUpload(locksnu8,4);
  998. }
  999. refresh=true;
  1000. }