12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250 |
- #include "tt808.h"
- #include "usart.h"
- #include "key.h"
- #include <stdio.h>
- #include <time.h>
- #include <stdlib.h>
- #include <string.h>
- #include "rtc.h"
- #include "database.h"
- //*整型
- int rlt;
- uint16_t uploadtime=0; //上传时间
- uint16_t hccd = 0;//ascii个数(*2)
- uint8_t header[12]; //处理头部
- uint8_t index_2c = 0;
- uint8_t MIPurc[100]; //接收平台数据
- uint8_t MIPurc1[100]; //接收平台数据
- uint8_t MIPurcXXTCSJ[100];//平台下行透传数据
- uint8_t speedBegin=0;
- uint8_t speedEnd=0;
- uint8_t speed[10]; //处理头部
- uint8_t DTUurc[100]; //接收平台数据
- uint8_t DTUurc1[15]; //接收平台数据
- int pushpullcount = 0;
- double dSpeed=0;
- double dlatitude=0;
- double dlongitude=0;
- char cSpeed[10];
- char clatitude[15];
- char clongitude[15];
- char csatellitesNum[5];
- char MGNSSLOC[100]; //接收定位数据
- char CSQ[12]; //接收定位数据
- char MGNSSLOC_time[6]; //接收定位数据
- uint32_t Stamp =0;
- uint8_t GNSSdata[40]={0};
- //*结构体
- TT808 tt808;
- extern TipsFlag tipsflag;
- extern Menu_table menu;
- extern bool refresh;
- extern LockInfo lockinfo;
- //*布尔
- bool authFlag = false;
- bool GnssFlag = false;
- bool Offline = false;
- bool Retrans = false;
- bool Online = false;
- bool reIME = false;
- bool reAuth = false;//回复权限
- /**
- 时间 纬度(北纬) 经度(东经) 水平精度因子 海拔高度 定位类型(1无,2 2d,3 3d) 运动角度 水平运动速度(KM/h) 水平运动速度(Knots) 日月年 卫星数量 差分定位标识(1单点,2差分)
- eg.+MGNSSLOC: 015032.301,3014.8605N,12001.9250E,1.8, 17.6, 3, 0.00, 3.6, 1.9, 080424, 12, 1
- */
- void reconn(void)
- {
- char TCPconnvalue[120];
- TcpConn(TCPconnvalue, 1, JLPTIP, JLPTPORT,0); //cid=1 tcpConnmode=0 普通模式
- if(sendCmd_4G(TCPconnvalue, "+MIPOPEN: 1,0", 1, 1)) //TCP连接 0普通模式 2缓存模式 1透传模式
- {
- printf("重连成功\r\n");
- }
- }
- uint8_t Messagetemp_length=0;
- uint8_t MessageHandleData[100]; //放入封装后数据
- uint8_t tcppacket[100]; //消息数据
- void MessageHandle(uint16_t MessageID)
- {
- Flash_ReadBytes((uint16_t*)&(tt808.LSH),tt808serialNum,1);//读取loc头部是否发生写入
- if(tt808.LSH==0xFFFF)
- {
- tt808.LSH=0;//初始未写入
- }
- uint16_t MessageAttributeData = Messagetemp_length;
- MessageAttributeData |= ( Messagetemp_length | (TCPJMFSNULL<<10)); // 将长度左移3位后和加密方式进行按位或操作(001 RSA ,000 无加密)
-
- header[0] = ((MessageID>>8)&0xff);
- header[1] = (MessageID&0xff); //消息ID
- header[2] = ((MessageAttributeData>>8)&0xff);
- header[3] = (MessageAttributeData&0xff); //消息属性
- //*test phoneNumxy
- //*work phoneNum
- if(phonenull)
- {
- header[4] = 0x00;
- header[5] = 0x00;
- header[6] = 0x16;
- header[7] = 0x00;
- header[8] = 0x00;
- header[9] = 0x08; //“手机号”
- phonenum[0]=0x0000;
- phonenum[1]=0x1600;
- phonenum[2]=0x0008;
-
- }
- else
- {
- header[4] = (phonenum[0]>>8)&0xff;
- header[5] = (phonenum[0])&0xff;
- header[6] = (phonenum[1]>>8)&0xff;
- header[7] = (phonenum[1])&0xff;
- header[8] = (phonenum[2]>>8)&0xff;
- header[9] = (phonenum[2])&0xff; //“手机号”
- }
- header[10] = ((tt808.LSH>>8)&0xff);
- header[11] = (tt808.LSH&0xff);
-
- int index = 0;
- tcppacket[index++] = TT808FLAG; // Set the headflag 0x7E
-
- for (int i = 0; i < 12; i++) {
- tcppacket[index++] = header[i];
- }
- // Copy message body to packet
- for (size_t i = 0; i < Messagetemp_length; i++) {
- tcppacket[index++] = MessageHandleData[i];
- }
- tcppacket[index++] = xorBytes(&tcppacket[1],12+Messagetemp_length);; // Set the checksum
- tcppacket[index++] = TT808FLAG; // Set the flag at the end
-
- // for (int i = 0; i < index; i++) {
- // printf("%02X ", tcppacket[i]); // 以十六进制格式打印每个元素
- // }
- printf("\r\n");
-
-
- //#if open4G ==1
- char TCPvalue[120];
- char *ptr = TCPvalue;
- ptr += sprintf(ptr, "AT+MIPSEND=1,%d,\"",index);
- for (int i = 0; i < index; i++) {
- ptr += sprintf(ptr, "%02X", tcppacket[i]);
- }
- sprintf(ptr, "\"\r\n");//TCPvalue
- if(sendCmd_4G(TCPvalue, "+MIPSEND:", 1, 1))//发送
- {
- printf("#等待回应\r\n");
- }
- //#endif
-
-
- tt808.LSH+=1;//需做写入处理
- Flash_WriteBytes((uint16_t*)&(tt808.LSH),tt808serialNum,1);
- }
- uint16_t swapBytes16(uint16_t value) {
- return (value >> 8) | (value << 8);
- }
- uint32_t swapBytes32(uint32_t value) {
- return ((value & 0xFF) << 24) | ((value & 0xFF00) << 8) |
- ((value >> 8) & 0xFF00) | ((value >> 24) & 0xFF);
- }
- /**
- * @breaf 消息体封装
- * Message[] 消息数据; length 消息数据长度; outMessage[] 封装后消息数据; MessageID 消息ID
- */
- extern BtFrame btframe;
- uint8_t Message_bodydata(uint8_t *Message, uint8_t length, uint8_t outMessage[],uint16_t MessageID)
- {
- int index = 0;
- uint8_t temp_length = 0;//加首尾 25/23/crc
-
- if(MessageID==MessageID_authentication || MessageID==MessageID_heartbeat || MessageID==MessageID_Getauth)//不加头尾(鉴权、心跳、获取权限)
- {
- temp_length = length;//不加首尾
- uint8_t temp_Message[temp_length];
-
- for (int i = 0; i < length; i++) {
- temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
- }
-
- temp_length = index;
-
- for(int i =0;i<temp_length;i++)
- {
- outMessage[i]=temp_Message[i];
- }
- }
- else if(MessageID==MessageID_location)//终端地址0200 补传0704
- {
-
- temp_length = length;//不加首尾
- //状态标志/纬度/经度/速度
- uint8_t temp_Message[temp_length];
- for (int i = 0; i < length; i++) {
- temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
- }
-
-
- for(int i =0;i<temp_length;i++)
- {
- outMessage[i]=temp_Message[i];
- }
- }
- else if(MessageID==MessageID_Retrans)// 补传0704+5
- {
- temp_length = length;//不加首尾
- uint8_t temp_Message[temp_length];
-
- temp_Message[index++] = 0x00;
- temp_Message[index++] = 0x01;
- temp_Message[index++] = 0x00;
- temp_Message[index++] = 0x00;
- temp_Message[index++] = 0x22;
-
-
- for (int i = 0; i < length; i++) {
- temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
- }
-
-
- for(int i =0;i<temp_length;i++)
- {
- outMessage[i]=temp_Message[i];
- }
- }
- else if(MessageID==MessageID_uploadLock)//上传锁信息
- {
- temp_length = length+9;//加4字节操作时间+4字节userIDbtframe.userId+1byte操作类型
-
- uint8_t temp_Message[temp_length];
- for (int i = 0; i < length; i++) {
- temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
- }
- uint32_t ntime = dblocptr->location.timeStamp;//现在时间
- temp_Message[index++]=(ntime>>24) & 0xff;
- temp_Message[index++]=(ntime>>16) & 0xff;
- temp_Message[index++]=(ntime>>8) & 0xff;
- temp_Message[index++]= ntime & 0xff;
-
- temp_Message[index++]=(btframe.userId>>24) & 0xff;
- temp_Message[index++]=(btframe.userId>>16) & 0xff;
- temp_Message[index++]=(btframe.userId>>8) & 0xff;
- temp_Message[index++]=(btframe.userId) & 0xff;
- temp_Message[index++] = macsetptr->sta;
-
- for(int i =0;i<temp_length;i++)
- {
- outMessage[i]=temp_Message[i];
- }
- }
- else//加首尾
- {
- temp_length = length+3;//加首尾 25/23/crc
- uint8_t temp_Message[temp_length];
-
- temp_Message[index++]=temp_length;
- temp_Message[index++]=0x2A;
- for (int i = 0; i < length; i++) {
- temp_Message[index++] = Message[i]; // 将消息头拷贝到报文中
- }
- temp_Message[index++]=0x23;
- temp_Message[index++]=xorBytes(&temp_Message[1],temp_length-1);
- temp_length = index;
-
- for(int i =0;i<temp_length;i++)
- {
- outMessage[i]=temp_Message[i];
- }
- }
- return temp_length;
- }
- /*需要传入消息体长度sizeof(Message)/sizeof(Message[0]);*/
- void tt808FsFunc(uint8_t* Message, uint8_t length, uint16_t MessageID)
- {
- HAL_Delay(200);
- Messagetemp_length = Message_bodydata(Message, length, MessageHandleData, MessageID);
- MessageHandle(MessageID);
- }
- void printBytes(uint8_t *data, size_t length) {
- for (size_t i = 0; i < length; i++) {
- printf("%02x ", data[i]);
- }
- printf("\n");
- }
- // 函数用于提取第7到第8个逗号之间的字符串
- void extractString(char* receiveStr, char* result, uint8_t start, uint16_t end)
- {
- int comma_count = 0;
- int start_index = -1;
- int end_index = -1;
- int length = strlen(receiveStr);
- // 遍历字符串,统计逗号数量和记录起始和结束索引
- for (int i = 0; i < length; i++)
- {
- if (receiveStr[i] == ',')
- {
- comma_count++;
- if (comma_count == start)
- {
- start_index = i + 1; // 第start个逗号之后的字符
- }
- else if (comma_count == end)
- {
- if(start==1 && end==2)//*纬度去尾符号
- {
- end_index = i-1; // 第end个逗号之前的字符
- }
- else if(start==2 && end==3)//*经度去尾符号
- {
- end_index = i-1; // 第end个逗号之前的字符
- }
- else
- {
- end_index = i; // 第end个逗号之前的字符
- }
-
- break;
- }
- }
- }
-
- // 提取字符串并存储在result数组中
- if (start_index != -1 && end_index != -1 && start_index < end_index)
- {
- strncpy(result, receiveStr + start_index, end_index - start_index);
- result[end_index - start_index] = '\0'; // 添加字符串结束符
- }
- }
- void extractStringPoint(char* receiveStr, char* result, uint8_t start, uint16_t end)
- {
- int comma_count = 0;
- int start_index = -1;
- int end_index = -1;
- int length = strlen(receiveStr);
- // 遍历字符串,统计逗号数量和记录起始和结束索引
-
- for (int i = 0; i < length; i++)
- {
- if(start==0 && end==1)// = -> .
- {
- start_index = start; // 第start个逗号之后的字符
- if (receiveStr[i] == '.')
- {
- comma_count++;
- }
- else if (comma_count == end)
- {
- end_index = i-1; // 第end个逗号之前的字符
- break;
- }
- }
- else if(start==3 && end==4)
- {
- if (receiveStr[i] == '.')
- {
- comma_count++;
- if (comma_count == start)
- {
- start_index = i + 1; // 第start个逗号之后的字符
- }
- }
- else if(receiveStr[i] == ':')
- {
- end_index = i;
- }
- }
- else if(start==4 && end==5)
- {
- if (receiveStr[i] == ':')
- {
- comma_count=4;
- if (comma_count == start)
- {
- start_index = i+1; // 第start个逗号之后的字符
- }
- end_index = start_index+4;
- break;
- }
- }
-
- else
- {
- if (receiveStr[i] == '.')
- {
- comma_count++;
- if (comma_count == start)
- {
- start_index = i + 1; // 第start个逗号之后的字符
- }
- else if (comma_count == end)
- {
- end_index = i; // 第end个逗号之前的字符
- break;
- }
- }
- }
- }
-
- // 提取字符串并存储在result数组中
- if (start_index != -1 && end_index != -1 && start_index < end_index)
- {
- strncpy(result, receiveStr + start_index, end_index - start_index);
- result[end_index - start_index] = '\0'; // 添加字符串结束符
- }
- }
- double convertToDouble(char* str) {
- if(str == csatellitesNum)
- {
- uint8_t result;
- sscanf(str, "%hhu", &result);
- return result;
- }
- else
- {
- double result;
- sscanf(str, "%lf", &result);
- return result;
- }
- }
- char hex2asc(const char *hex)
- {
- char asc = 0;
- char a = (hex[0]>='A' && hex[0]<='F')?(hex[0]^32):hex[0];
- char b = (hex[1]>='A' && hex[1]<='F')?(hex[1]^32):hex[1];
- if ((a>='0' && a<='9' || a>='a' && a<='f') && (b>='0' && b<='9' || b>='a' && b<='f')){
- asc = ((('a'<=a && a<='f')?(a-'a')+10:a-'0')<<4)|(('a'<=b && b<='f')?(b-'a')+10:b-'0');
- }
- return asc;
- }
- uint8_t testHex2Asc(const char *hex) {
- char asc = hex2asc(hex);
- printf("Hex: %s\tASC: %d\n", hex, asc);
- return asc;
- }
- char *bin2hex(char *hex, const unsigned char *bin, int size)
- {
- size_t i;
- for(i=0; i<size; i++)
- {
- sprintf(hex+i*2, "%02x", bin[i]);
- }
- hex[i+i] = 0;
- return hex;
- }
- int hex2bin(unsigned char *bin, const char *hex)
- {
- const char *h = hex;
- unsigned char *b = bin;
- int rlt = 0;
- while(*h){
- *b++ = hex2asc(h);
- h = h + 2;
- rlt++;
- }
- return rlt;//长度
- }
- // 将单个十六进制数转换为 BCD 码
- uint8_t hexToBcd(uint8_t hex) {
- return ((hex / 10) << 4) | (hex % 10);
- }
- // 将整数数组中的所有十六进制数转换为 BCD 码
- void hexArrayToBcd(uint8_t* array, size_t length, uint8_t* out) {//时间用
- array[3]+=8;
- for (size_t i = 0; i < length; i++) {
- out[i] = hexToBcd(array[i]);
- }
- }
- void hexToBcd_arr(uint8_t* array, size_t length, uint8_t* out) {//通用
- for (size_t i = 0; i < length; i++) {
- out[i] = hexToBcd(array[i]);
- }
- }
- char input_strings[20]={0};
- char reIp0[10];
- char reIp1[10];
- char reIp2[10];
- char reIp3[10];
- char reIpP[10];
- Ipaddr ipaddr;
- MacSet macset;
- MacSet *macsetptr = &macset;
- char Newip[30];
- extern bool wdiFlag;
- char MqttReBuff[200];
- char MqttWorkBuff[200];
- char Mqtttotal_len[10];
- char payload_len[10];
- uint8_t Mqtttotal_lenu8=0;
- uint8_t payload_lenu8=0;
- void Process_str_collections(void) {
- // 循环遍历从0到macCount-1的每个索引
- for (int i = 0; i < macset.macCount; i++) {
- AtPRocess(
- lockinfo.SNname[i],
- macset.SNCONN[i],
- macset.SNED[i],
- macset.SNDIS[i]
- );
- }
- }
- void MqttRe(void)
- {
- if(strncmp((const char *)U4_4GrecvBuff, "+MQTTURC: \"publish\"", strlen("+MQTTURC: \"publish\""))==0)//接收到发布信息
- {
- memcpy(MqttReBuff,&U4_4GrecvBuff[2],U4_4GrecvLength-2);//全部copy
- //printf("@接收到Mqtt消息%s\r\n",MqttReBuff);
- extractString(MqttReBuff, Mqtttotal_len,4 ,5);//采集<total_len>
- extractString(MqttReBuff, payload_len,5 ,6);//采集<payload_len>
- Mqtttotal_lenu8 = atoi(Mqtttotal_len);
- payload_lenu8 = atoi(payload_len);
-
-
- //printf("%d,%d\r\n",Mqtttotal_lenu8,payload_lenu8);
- if(Mqtttotal_lenu8==payload_lenu8)
- {
- memcpy(MqttWorkBuff, &MqttReBuff[U4_4GrecvLength - payload_lenu8-4], payload_lenu8);
- printf("%s\r\n",MqttWorkBuff);
-
- }
- //*处理摘取字段
- if(strncmp((const char*)&MqttWorkBuff, "DTU+FLASH=deleteloc", strlen("DTU+FLASH=deleteloc"))==0)
- {
- dblocptr->headinfo.loc_pushIndex=0;
- dblocptr->headinfo.loc_pullIndex=0;
- Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
- printf("更新刻度成功\r\n");
- }
- else if(strncmp((char*)MqttWorkBuff, "DTU+JT808_IMEI=", strlen("DTU+JT808_IMEI="))==0)//修改IME号
- {
- memcpy(DTUurc1,MqttWorkBuff+15,12);
- const char *hex = (const char *)DTUurc1; // 将 uint8_t * 转换为 const char *
- int size = strlen(hex) / 2; // 计算二进制数据的长度
- unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
- rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
- memcpy(DTUurc, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
- free(bin); // 释放内存
-
- reIME = true;
- HAL_Delay(500);
- }
- else if(strncmp((char*)MqttWorkBuff, "DTU+JT808_SERVER=", strlen("DTU+JT808_SERVER="))==0)
- {
- memcpy(input_strings,MqttWorkBuff+17,20);
- extractStringPoint(input_strings,reIp0,0,1);
- extractStringPoint(input_strings,reIp1,1,2);
- extractStringPoint(input_strings,reIp2,2,3);
- extractStringPoint(input_strings,reIp3,3,4);
- extractStringPoint(input_strings,reIpP,4,5);
- ipaddr.IP0 = atoi(reIp0);
- ipaddr.IP1 = atoi(reIp1);
- ipaddr.IP2 = atoi(reIp2);
- ipaddr.IP3 = atoi(reIp3);
- ipaddr.IPp = atoi(reIpP);
- //printf("%d.%d.%d.%d:%d",ipaddr.IP0,ipaddr.IP1,ipaddr.IP2,ipaddr.IP3,ipaddr.IPp);
- HAL_StatusTypeDef writeSta = Flash_WriteBytes((uint16_t*)&(ipaddr.IP0),ReIPAddr,5);
- if(writeSta == HAL_OK)
- {
- char *ptr = Newip;
- ptr += sprintf(ptr, "%d.", ipaddr.IP0);
- ptr += sprintf(ptr, "%d.", ipaddr.IP1);
- ptr += sprintf(ptr, "%d.", ipaddr.IP2);
- ptr += sprintf(ptr, "%d", ipaddr.IP3);
- printf("更换IP成功\r\n");
- }
- //ptr += sprintf(ptr, ":%d", ipaddr.IPp);
- //printf("%s\r\n",Newip);
- HAL_Delay(500);
- printf("即将重启\r\n");
- wdiFlag = true;
- }
- else if(strncmp((char*)MqttWorkBuff, "DTU+VER=?", strlen("DTU+VER=?"))==0)
- {
- printf("%s\r\n",version);
- }
-
- else if(strncmp((char*)MqttWorkBuff, "DTU+MANUALMODE=1", strlen("DTU+MANUALMODE=1"))==0)
- {
- ManualWork = 1;
- Flash_WriteBytes(&ManualWork,ManualWorkaddr,1);
- printf("手动模式开启\r\n");
- }
- else if(strncmp((char*)MqttWorkBuff, "DTU+MANUALMODE=0", strlen("DTU+MANUALMODE=0"))==0)
- {
- ManualWork = 0;
- Flash_WriteBytes(&ManualWork,ManualWorkaddr,1);
- printf("手动模式关闭\r\n");
- }
-
-
-
-
- HAL_StatusTypeDef WriteSta;
- //*PDA需求 485写入MAC号
- if(strncmp((char*)MqttWorkBuff, "DTU+ADDMAC", strlen("DTU+ADDMAC"))==0)
- {
-
- macset.macCount=0;
- workedLock=0;
- memset(devices,0,8);
- erase_flash(MacDbBodyAddr);
- if(payload_lenu8>12){
- memcpy(macset.MACtemp[0],MqttWorkBuff+11,12);
- processPdadata(macset.MACtemp[0],macset.mactemp[0],macset.mac[0]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[0],MacDbBodyAddr,3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>25){
- memcpy(macset.MACtemp[1],MqttWorkBuff+24,12);
- processPdadata(macset.MACtemp[1],macset.mactemp[1],macset.mac[1]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[1],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>38){
- memcpy(macset.MACtemp[2],MqttWorkBuff+37,12);
- processPdadata(macset.MACtemp[2],macset.mactemp[2],macset.mac[2]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[2],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>51){
- memcpy(macset.MACtemp[3],MqttWorkBuff+50,12);
- processPdadata(macset.MACtemp[3],macset.mactemp[3],macset.mac[3]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[3],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>64){
- memcpy(macset.MACtemp[4],MqttWorkBuff+63,12);
- processPdadata(macset.MACtemp[4],macset.mactemp[4],macset.mac[4]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[4],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>77){
- memcpy(macset.MACtemp[5],MqttWorkBuff+76,12);
- processPdadata(macset.MACtemp[5],macset.mactemp[5],macset.mac[5]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[5],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>90){
- memcpy(macset.MACtemp[6],MqttWorkBuff+89,12);
- processPdadata(macset.MACtemp[6],macset.mactemp[6],macset.mac[6]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[6],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(payload_lenu8>103){
- memcpy(macset.MACtemp[7],MqttWorkBuff+102,12);
- processPdadata(macset.MACtemp[7],macset.mactemp[7],macset.mac[7]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[7],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
-
-
- for(int i = 0; i < macset.macCount; i++) {
- memset(lockinfo.SNname[i], 0, 13);
- }
- if(WriteSta == HAL_OK)
- {
- printf("更新MAC存储完成共->%d\r\n",macset.macCount);
- }
- WriteSta = Flash_WriteBytes(&macsetptr->macCount,MacDbHeadAddr,1);
- if(WriteSta == HAL_OK)
- {
- printf("更新存储刻度完成\r\n");
- }
- ReadSNname();//更新
- Process_str_collections();//处理连接字符串
- enterInterface_time = HAL_GetTick();
- menu.current=6;//提示mac
- refresh=true;
- }
-
-
-
-
- else if(strncmp((char*)MqttWorkBuff, "DTU+WORK=ALLOPEN", strlen("DTU+WORK=ALLOPEN"))==0)
- {
- enterInterface_time = HAL_GetTick();
- SET_MENU_STATUS(2,2,0,0);
- Allopen=true;
- }
- else if(strncmp((char*)MqttWorkBuff, "DTU+WORK=ALLCLOSE", strlen("DTU+WORK=ALLCLOSE"))==0)
- {
- enterInterface_time = HAL_GetTick();
- SET_MENU_STATUS(2,1,1,1);
- Allopen=true;
- }
-
-
-
-
-
-
-
-
-
-
-
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- memset(MqttReBuff,0,U4_4GrecvLength);
- memset(MqttWorkBuff,0,payload_lenu8);
- }
-
-
-
-
- }
- //*485测试命令
- void Test485Re(void)
- {
- //*test485 模拟
- if(strncmp((char*)U1_485recvBuff, "+MIPURC: \"disconn\",1,1", strlen("+MIPURC: \"disconn\",1,1"))==0)//"disconn" 平台断连
- {
- Offline=true;
- uploaweork=false;
- printf("@U1与平台断开连接\r\n");
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)U1_485recvBuff, "+MIPOPEN: 1,0", strlen("+MIPOPEN: 1,0"))==0)//连接平台
- {
- Offline=false;
- Online = true;
- uploaweork=true;
- printf("@U1设备已上线!!\r\n");
- refresh=true;
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)&U1_485recvBuff, "DTU+FLASH=deleteloc", strlen("DTU+FLASH=deleteloc"))==0)//连接平台
- {
- dblocptr->headinfo.loc_pushIndex=0;
- dblocptr->headinfo.loc_pullIndex=0;
- Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- printf("更新刻度成功\r\n");
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+JT808_IMEI=", strlen("DTU+JT808_IMEI="))==0)//修改IME号
- {
- memcpy(DTUurc1,U1_485recvBuff+15,12);
-
- const char *hex = (const char *)DTUurc1; // 将 uint8_t * 转换为 const char *
- int size = strlen(hex) / 2; // 计算二进制数据的长度
- unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
- rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
- memcpy(DTUurc, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
- free(bin); // 释放内存
-
- //memset(DTUurc1,0,100);
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- reIME = true;
- HAL_Delay(500);
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+JT808_SERVER=", strlen("DTU+JT808_SERVER="))==0)
- {
- memcpy(input_strings,U1_485recvBuff+17,20);
- extractStringPoint(input_strings,reIp0,0,1);
- extractStringPoint(input_strings,reIp1,1,2);
- extractStringPoint(input_strings,reIp2,2,3);
- extractStringPoint(input_strings,reIp3,3,4);
- extractStringPoint(input_strings,reIpP,4,5);
- ipaddr.IP0 = atoi(reIp0);
- ipaddr.IP1 = atoi(reIp1);
- ipaddr.IP2 = atoi(reIp2);
- ipaddr.IP3 = atoi(reIp3);
- ipaddr.IPp = atoi(reIpP);
- //printf("%d.%d.%d.%d:%d",ipaddr.IP0,ipaddr.IP1,ipaddr.IP2,ipaddr.IP3,ipaddr.IPp);
- HAL_StatusTypeDef writeSta = Flash_WriteBytes((uint16_t*)&(ipaddr.IP0),ReIPAddr,5);
- if(writeSta == HAL_OK)
- {
- char *ptr = Newip;
- ptr += sprintf(ptr, "%d.", ipaddr.IP0);
- ptr += sprintf(ptr, "%d.", ipaddr.IP1);
- ptr += sprintf(ptr, "%d.", ipaddr.IP2);
- ptr += sprintf(ptr, "%d", ipaddr.IP3);
- printf("更换IP成功\r\n");
- }
- //ptr += sprintf(ptr, ":%d", ipaddr.IPp);
- //printf("%s\r\n",Newip);
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- HAL_Delay(500);
- printf("即将重启\r\n");
- wdiFlag = true;
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+VER=?", strlen("DTU+VER=?"))==0)
- {
- printf("%s\r\n",version);
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
-
- else if(strncmp((char*)U1_485recvBuff, "DTU+WORK=ALLOPEN", strlen("DTU+WORK=ALLOPEN"))==0)
- {
- enterInterface_time = HAL_GetTick();
- SET_MENU_STATUS(2,2,0,0);
- Allopen=true;
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+WORK=ALLCLOSE", strlen("DTU+WORK=ALLCLOSE"))==0)
- {
- enterInterface_time = HAL_GetTick();
- SET_MENU_STATUS(2,1,1,1);
- Allopen=true;
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+MANUALMODE=1", strlen("DTU+MANUALMODE=1"))==0)
- {
- ManualWork = 1;
- Flash_WriteBytes(&ManualWork,ManualWorkaddr,1);
- printf("手动模式开启\r\n");
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)U1_485recvBuff, "DTU+MANUALMODE=0", strlen("DTU+MANUALMODE=0"))==0)
- {
- ManualWork = 0;
- Flash_WriteBytes(&ManualWork,ManualWorkaddr,1);
- printf("手动模式关闭\r\n");
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- REPdaMode();//PDA 485 MQTT
- }
-
- void AtPRocess(char *value, char conn[],char connected[],char disconn[]) {
- // 使用snprintf代替sprintf以确保不会发生缓冲区溢出
- snprintf(conn, strlen(value) + 12, "AT+CONN=%s\r\n", value);
- snprintf(connected, strlen(value) + 14, "+CONNECTED:0,%s", value);
- snprintf(disconn, strlen(value) + 12, "+DISCONN:0,%s", value);
- // printf("%s\r\n", conn);
- // printf("%s\r\n", connected);
- // printf("%s\r\n", disconn);
- }
- void processPdadata(char MACtemp[], uint8_t mactemp[],uint16_t mac[])
- {
- const char *hex = (const char *)MACtemp; // 将 uint8_t * 转换为 const char *
- int size = strlen(hex) / 2; // 计算二进制数据的长度
- unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
- rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
- memcpy(mactemp, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
- free(bin); // 释放内存
- mac[0] = mactemp[0]<<8|mactemp[1];
- mac[1] = mactemp[2]<<8|mactemp[3];
- mac[2] = mactemp[4]<<8|mactemp[5];
- }
- #define MAC_LENGTH 12
- #define MAC_DB_ENTRY_SIZE 3
- void REPdaMode(void)
- {
- HAL_StatusTypeDef WriteSta;
- //*PDA需求 485写入MAC号
- if(strncmp((char*)U1_485recvBuff, "DTU+ADDMAC", strlen("DTU+ADDMAC"))==0)
- {
- macset.macCount=0;
- workedLock=0;
- memset(devices,0,8);
- erase_flash(MacDbBodyAddr);
- if(U1_485recvLength>12){
- memcpy(macset.MACtemp[0],U1_485recvBuff+11,12);
- processPdadata(macset.MACtemp[0],macset.mactemp[0],macset.mac[0]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[0],MacDbBodyAddr,3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>25){
- memcpy(macset.MACtemp[1],U1_485recvBuff+24,12);
- processPdadata(macset.MACtemp[1],macset.mactemp[1],macset.mac[1]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[1],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>38){
- memcpy(macset.MACtemp[2],U1_485recvBuff+37,12);
- processPdadata(macset.MACtemp[2],macset.mactemp[2],macset.mac[2]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[2],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>51){
- memcpy(macset.MACtemp[3],U1_485recvBuff+50,12);
- processPdadata(macset.MACtemp[3],macset.mactemp[3],macset.mac[3]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[3],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>64){
- memcpy(macset.MACtemp[4],U1_485recvBuff+63,12);
- processPdadata(macset.MACtemp[4],macset.mactemp[4],macset.mac[4]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[4],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>77){
- memcpy(macset.MACtemp[5],U1_485recvBuff+76,12);
- processPdadata(macset.MACtemp[5],macset.mactemp[5],macset.mac[5]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[5],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>90){
- memcpy(macset.MACtemp[6],U1_485recvBuff+89,12);
- processPdadata(macset.MACtemp[6],macset.mactemp[6],macset.mac[6]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[6],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
- if(U1_485recvLength>103){
- memcpy(macset.MACtemp[7],U1_485recvBuff+102,12);
- processPdadata(macset.MACtemp[7],macset.mactemp[7],macset.mac[7]);
- WriteSta= Flash_WriteBytes(macsetptr->mac[7],MacDbBodyAddr+(macset.macCount*6),3);
- if(WriteSta== HAL_OK) macset.macCount += 1;}
-
-
-
- for(int i = 0; i < macset.macCount; i++) {
- memset(lockinfo.SNname[i], 0, 13);
- }
- if(WriteSta == HAL_OK)
- {
- printf("更新MAC存储完成共->%d\r\n",macset.macCount);
- }
- WriteSta = Flash_WriteBytes(&macsetptr->macCount,MacDbHeadAddr,1);
- if(WriteSta == HAL_OK)
- {
- printf("更新存储刻度完成\r\n");
- }
- ReadSNname();//更新
- Process_str_collections();//处理连接字符串
-
-
- enterInterface_time = HAL_GetTick();
- menu.current=6;//提示mac
- refresh=true;
- memset(U1_485recvBuff,0,BUFFER_SIZE);
- }
- }
- bool snConnected[NUM_OF_DEVICES] = {false};
- void ReBTcall(void)
- {
- for (int i = 0; i < NUM_OF_DEVICES; ++i) {
- if (strncmp((char*)autoRe, macsetptr->SNED[i], strlen(macsetptr->SNED[i])) == 0) {
- snConnected[i] = true;
- memset(autoRe, 0, BUFFER_SIZE);
- break; // Exit the loop once a match is found
- }
- }
- }
- //*工作命令
- void ReMIPURC(void)//DTU
- {
- //*设备上线,发送成功
- if(strncmp((char*)U4_4GrecvBuff, "+MIPOPEN: 1,0", strlen("+MIPOPEN: 1,0"))==0)//连接平台
- {
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- }
- ///*定位信息(MGNSS)
- else if(strncmp((char*)U4_4GrecvBuff, "+MGNSSURC: \"state\",1", strlen("+MGNSSURC: \"state\",1"))==0)
- {
- printf("@MGNSS设置成功\r\n");
-
- memset(U4_4GrecvBuff,0,strlen("+MGNSSURC: \"state\",1"));
- }
- else if(strncmp((char*)U4_4GrecvBuff, "+MGNSSURC: \"state\",0", strlen("+MGNSSURC: \"state\",0"))==0)//断开平台
- {
- printf("@主动取消GNSS\r\n");
- memset(U4_4GrecvBuff,0,strlen("+MGNSSURC: \"state\",0"));
- }
- ///*定位信息(基站)
- else if(((strncmp((char*)U4_4GrecvBuff, "+MGNSSLOC", strlen("+MGNSSLOC"))==0) || (strncmp((char*)U4_4GrecvBuff, "OK", strlen("OK"))==0)) && MgnssFlag) //监测平台回复+MGNSSLOC OK4f4b
- {
- memcpy(MGNSSLOC,&U4_4GrecvBuff[11],75);
- GnssFlag=true;
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- }
- ///*掉线
- #if open4G ==1
- else if(strncmp((char*)U4_4GrecvBuff, "+MIPURC: \"disconn\",1,1", strlen("+MIPURC: \"disconn\",1,1"))==0)//"disconn" 平台断连
- {
- Offline=true;
- printf("@未发送成功,平台断开连接\r\n");
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- uploaweork = false;
- reconn();//重连
- }
- 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
- {
- //TODO
- printf("@SIM卡缺失\r\n");
- Offline=true;
- signal = false;
- menu.current = 0xBB;
- tipsflag = NoSIM;
- refresh=true;
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- uploaweork = false;
- reconn();//重连
- }
-
- else if((strncmp((char*)U4_4GrecvBuff, "+MIPCALL: 1,0", strlen("+MIPCALL: 1,0"))==0))//意外断开平台连接!!!!//TCP未知错误
- {
- //TODO
- Offline=true;
- signal = false;
- printf("@与平台断开连接\r\n");
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- uploaweork = false;
- reconn();//重连
-
- }
- else if( (strncmp((char*)U4_4GrecvBuff, "+CME ERROR: 550", strlen("+CME ERROR: 550"))==0))
- {
- Offline=true;
- signal = false;
- printf("@未发送成功->TCP/IP未知错误\r\n");
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- uploaweork = false;
- reconn();//重连
-
- }
- else if((strncmp((char*)U4_4GrecvBuff, "+MIPOPEN: 1,571", strlen("+MIPOPEN: 1,571"))==0))//PDP激活失败
- {
- //TODO
- Offline=true;
- printf("@未发送成功,PDP激活失败\r\n");
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- uploaweork = false;
- reconn();//重连
- }
- #endif
- else if(U4_4GrecvBuff[1]== 0x43 && U4_4GrecvBuff[2]== 0x53 && U4_4GrecvBuff[3]== 0x51)//CSQ 信号
- {
- memcpy(CSQ,U4_4GrecvBuff,U4_4GrecvLength);
- dblocptr->location.CSQ = (uint8_t)(CSQ[6]&0xf*10)+(CSQ[7]&0xf);
- memset(CSQ,0,12);
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- }
- else if(strncmp((char*)U4_4GrecvBuff, "+MIPURC", strlen("+MIPURC"))==0) //监测平台回复+MIPURC:
- {
- uint8_t high_byte = (U4_4GrecvBuff[18]&0x0f) *10;
- uint8_t low_byte = U4_4GrecvBuff[19]&0x0f;
- hccd = high_byte + low_byte;
- memcpy(MIPurc1,&U4_4GrecvBuff[21],hccd*2);
- const char *hex = (const char *)MIPurc1; // 将 uint8_t * 转换为 const char *
- int size = strlen(hex) / 2; // 计算二进制数据的长度
- unsigned char *bin = (unsigned char *)malloc(size); // 分配足够的内存用于存储二进制数据
- rlt = hex2bin(bin, hex); // 调用hex2bin函数进行转换
- memcpy(MIPurc, bin, rlt); // 将 bin 中的 rlt 个字节复制到 MIPurc1 中 接收到的数据放入MIPurc1中
- free(bin); // 释放内存
-
- memset(U4_4GrecvBuff,0,BUFFER_SIZE);
- memset(MIPurc1,0,100);
-
- }
- }
- void MIPURCHandle(void)
- {
- #if open4G == 1
- if(MIPurc[0]==0x7E)
- {
- uint16_t PTXXID = MIPurc[1]<<8 | MIPurc[2]; //消息ID
- uint16_t xxtcLen = MIPurc[3]<<8 | MIPurc[4]; //数据长度
- uint16_t xxRE = MIPurc[15]<<8 | MIPurc[16]; //回复ID
- uint8_t YESorNO = MIPurc[17]; //00 success ; 01 fail
-
- if(PTXXID==XXID_pttyyd) //收到平台通用应答0x8001
- {
- if(xxRE == MessageID_authentication)//回复鉴权ID
- {
- if(YESorNO==YES)
- {
- printf("@鉴权应答yes\r\n");
- authFlag = true;
-
- Offline=false; //待判定假消息
- Online = true; //待判定假消息
- uploaweork=true;
- }
- else if(YESorNO==NO)
- {
- printf("@鉴权应答no\r\n");
- }
- memset(MIPurc,0,rlt);//rlt下发长度
- }
- else if(xxRE == MessageID_heartbeat)//回复鉴权ID
- {
- if(YESorNO==YES)
- {
- printf("@心跳应答yes\r\n");
- printf("@TCP连接成功!!\r\n");
- menu.current=0;
- refresh=true;
- }
- else if(YESorNO==NO)
- {
- printf("@心跳应答no\r\n");
- }
- memset(MIPurc,0,rlt);//rlt下发长度
-
- }
- else if(xxRE == MessageID_location)//回复鉴权ID
- {
- if(YESorNO==YES)
- {
- printf("@地址应答yes\r\n");
- }
- else if(YESorNO==NO)
- {
- printf("@地址应答no\r\n");
- }
- memset(MIPurc,0,rlt);//rlt下发长度
- }
- else if(xxRE == MessageID_Getauth)//获取权限
- {
- if(YESorNO==YES)
- {
- printf("@权限应答yes\r\n");
- reAuth=true;
- }
- else if(YESorNO==NO)
- {
- printf("@权限应答no\r\n");
- reAuth=false;
- }
- memset(MIPurc,0,rlt);//rlt下发长度
- }
- else if(xxRE == MessageID_uploadLock)//锁信息上传
- {
- if(YESorNO==YES)
- {
- printf("@锁信息上传应答yes\r\n");
- if(sendCmd_BT("AT+DISCONN=0\r\n","ERROR",1,2))
- {
- printf("已断开连接\r\n");
- }
- }
- else if(YESorNO==NO)
- {
- printf("@锁信息上传应答no\r\n");
- }
-
- memset(MIPurc,0,rlt);//rlt下发长度
- }
- }
- else if(PTXXID == XXID_ptxxtc) //收到平台消息透传 8900
- {
- authFlag = true;
- Offline=false; //待判定假消息
- Online = true; //待判定假消息
- uploaweork=true;
-
- uint8_t tcsjLen = MIPurc[13];
- memcpy(MIPurcXXTCSJ,&MIPurc[13],xxtcLen);
- printf("@得到透传数据,%d\r\n",tcsjLen);
- memset(MIPurc,0,rlt);//rlt下发长度
- }
- }
- else if(authFlag)
- {
- authFlag = false;
- HAL_Delay(500);
- uint8_t test[] = {0x05}; //test心跳
- tt808FsFunc(test,1,MessageID_heartbeat); //test心跳
- }
- #endif
- else if(reIME)
- {
- reIME=false;
- phonenum[0] = DTUurc[0]<<8|DTUurc[1];
- phonenum[1] = DTUurc[2]<<8|DTUurc[3];
- phonenum[2] = DTUurc[4]<<8|DTUurc[5];
- phonenull =false;
- Flash_WriteBytes(phonenum,phoneNumADDR,3);//更新ime
- //memset(DTUurc,0,100);
- printf("IMEI设置完成\r\n");
- printf("即将重启\r\n");
- wdiFlag = true;
- }
- }
- time_t timestamp ;
- void time_bj(void)
- {
- struct tm timeinfo;
- timeinfo.tm_year = tt808.Rtime[0]+2000-1900;
- timeinfo.tm_mon = tt808.Rtime[1]-1;
- timeinfo.tm_mday = tt808.Rtime[2];
- timeinfo.tm_hour = tt808.Rtime[3]-8;
- timeinfo.tm_min = tt808.Rtime[4];
- timeinfo.tm_sec = tt808.Rtime[5];
- timestamp = mktime(&timeinfo);
-
- dblocptr->location.timeStamp = timestamp;
- }
- void ReU4Proces(void)
- {
- if(GnssFlag)
- {
- GnssFlag=false;
- RTCtime();//同步时间
- // 调用函数提取字符串
- extractString(MGNSSLOC, cSpeed,7 ,8);//采集
- dSpeed = convertToDouble(cSpeed); //转换浮点数
- dSpeed*=10;
- // 调用函数提取字符串
- extractString(MGNSSLOC, clatitude,1 ,2);//采集
- dlatitude = convertToDouble(clatitude); //转换浮点数
- uint32_t latitudetemp=convertGPS(dlatitude);
- dblocptr->location.latitudeH = (latitudetemp>>16)&0xFFFF;
- dblocptr->location.latitudeH = swapBytes16(dblocptr->location.latitudeH);//转换H字节
- dblocptr->location.latitudeL = (latitudetemp)&0xFFFF;
- dblocptr->location.latitudeL = swapBytes16(dblocptr->location.latitudeL);//转换L字节
-
- extractString(MGNSSLOC, clongitude,2 ,3);//采集
- dlongitude = convertToDouble(clongitude); //转换浮点数
- uint32_t longitudetemp=convertGPS(dlongitude);
- dblocptr->location.longitudeH = (longitudetemp>>16)&0xFFFF;
- dblocptr->location.longitudeH = swapBytes16(dblocptr->location.longitudeH);//转换H字节
- dblocptr->location.longitudeL = (longitudetemp)&0xFFFF;
- dblocptr->location.longitudeL = swapBytes16(dblocptr->location.longitudeL);//转换L字节
-
- // printf("%d\r\n",dblocptr->location.latitude);
- // printf("%d\r\n",dblocptr->location.longitude);
- // printf("%08X\r\n",dblocptr->location.latitude);
- // printf("%08X\r\n",dblocptr->location.longitude);
-
- extractString(MGNSSLOC, csatellitesNum,10 ,11);//采集卫星个数
- dblocptr->location.satellitesNum = convertToDouble(csatellitesNum); //转换浮点数
- //printf("%d",tt808.satellitesNum);
-
-
- dblocptr->location.speed = (uint16_t)dSpeed;
- memset(MGNSSLOC,0,100);
- }
- }
- //*离线蓝牙锁
|