/******************************************************************************* * File Name : TCPClient.c * Description : * Created on : 2021?1?9? * Author : www.hido-studio.com *******************************************************************************/ /******************************************************************************* * Include Files * *******************************************************************************/ #include "TCPClient.h" #include "Socket.h" #include "HIDO_Debug.h" #include "Internet.h" #include "string.h" #include "HIDO_Timer.h" #include "HIDO_Util.h" #include "global_param.h" #include "Uart.h" #include "mk_4G.h" #include "mk_trace.h" #include "dw_app_anchor.h" #include "mk_flash.h" #include /******************************************************************************* * Macro * *******************************************************************************/ #define STRCMP(cmd, header) strncmp((HIDO_CHAR *)_u8Data, header, sizeof(header) - 1) /******************************************************************************* * Type Definition * *******************************************************************************/ typedef enum { TCP_CLIENT_STATE_IDLE, TCP_CLIENT_STATE_CONNECTING, TCP_CLIENT_STATE_CONNECTED, } E_TCPClientState; /******************************************************************************* * Local Variable * *******************************************************************************/ HIDO_INT32 l_i32TCPClientID = 0; extern uint8_t gps_power_state; static E_TCPClientState l_eTCPClientState = TCP_CLIENT_STATE_IDLE; static HIDO_UINT32 l_u32HeartBeatTick = 0; static HIDO_UINT8 l_au8CmdBuff[1024]; uint8_t TCPfail_flag = 0,flag_first_TCPconnect=1; uint32_t TCPfailetimer; uint16_t ip0,ip1,ip2,ip3,port; /******************************************************************************* * Local Function Declaration * *******************************************************************************/ HIDO_INT32 TCPClient_Heartbeat(HIDO_VOID); void TCPHeartBeatUpload(); void UDPClient_UploadGPS(void); void TCPReceiveMessageReply(void); /******************************************************************************* * Local Function * *******************************************************************************/ /******************************************************************************* * Function Name : TCPClient_DataProc * Description : * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ extern uint8_t gps_4g_flag,search_open_flag,gps_open_flag,gps_wait_count,gps_need_data_flag,gps_wait_count2; extern Operation_step UWB_work_state; Commend_Datestruct TCP_command; uint8_t result; char applyid[10]; uint16_t receive_id; uint16_t g_com_position; uint16_t g_com_num; int16_t beepontime; HIDO_UINT8 *_u8Data_temp1=NULL; HIDO_UINT32 _u32Len_temp; extern int32_t distance; extern uint8_t GPS_GGAmessage[150],userkey_state,gps_timeout_flag; extern uint16_t g_spsum,g_snum,ave_sp; extern uint32_t u32GGaLenth; extern char GGA_Final_message[1024]; extern uint32_t gga_num; uint8_t beep_start_flag; static HIDO_INT32 TCPClient_DataProc(HIDO_UINT8 *_u8Data, HIDO_UINT32 _u32Len) { HIDO_CHAR *apcSplitStr[12]; HIDO_UINT32 u32SplitCnt = 0; HIDO_CHAR acResponse[200]; HIDO_CHAR temp_acResponse[200]; _u8Data_temp1=_u8Data; _u32Len_temp=_u32Len; HIDO_CHAR acReadponse[200]; HIDO_UINT32 datalenth; HIDO_UINT32 u32ResponseLen; HIDO_UINT32 u32ReadResponseLen; LOG_INFO(TRACE_MODULE_APP, "ÊÕµ½Êý¾Ý\r\n"); if(STRCMP(_u8Data, "$setpara,") == 0) { u32ResponseLen = snprintf(acResponse, 12+_u32Len, "$setparaok,%s\r\n", \ _u8Data); memcpy(temp_acResponse,acResponse,sizeof(acResponse)); u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); receive_id = HIDO_UtilHexStrToInt(apcSplitStr[1]); if(g_com_map[DEV_ID]==receive_id) { g_com_position=HIDO_UtilStrToInt(apcSplitStr[2]); if(g_com_position!=CNT_RESTART&&g_com_position!=0&&g_com_position!=CNT_UPDATE) { Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)temp_acResponse, u32ResponseLen); g_com_map[g_com_position]=HIDO_UtilStrToInt(apcSplitStr[3]); } if(g_com_map[SEND_4G_SECOND]<30) { gps_open_flag=0; gps_wait_count=0; gps_wait_count2=0; gps_need_data_flag=1;//Çл»×´Ì¬ memset(GGA_Final_message, 0, sizeof(GGA_Final_message));//Çå¿Õ½ÓÊÕµ½µÄÓÃÍêµÄÊý×é u32GGaLenth=0; gga_num=0;//Çå0ÓÐЧ´ÎÊý }else{ gps_open_flag=1; gps_wait_count=0; gps_wait_count2=0; gps_need_data_flag=1;//Çл»×´Ì¬ } // switch(TCP_command.type) // { // case BIND_SUCCESS: // { // g_com_map[ALARM_DISTANCE1]= TCP_command.warnDistance; // g_com_map[ALARM_DISTANCE2]=TCP_command.alarmDistance; // // g_com_map[SEND_4G_FREQUENCY]=1000/TCP_command.frequency; // if(g_com_map[BIND_DEV_ID]!=TCP_command.gunLableId) // { // g_com_map[BIND_DEV_ID]=TCP_command.gunLableId; // UWB_work_state = SEARCH_DEV; // search_open_flag = 1; // } // } // break; // case UNBIND: // g_com_map[BIND_DEV_ID] = 0; // UWB_work_state = UN_BIND; // break; // // bind_resetbreak(); // case OPEN_GNSS: // gps_4g_flag = 1; // break; // case CLOSE_VIBRATION: // g_com_map[MOTOR_ENABLE]=0; // break; // case OPEN_VIBRATION: // g_com_map[MOTOR_ENABLE]=1; // break; // case QUARY_INFORMATION: // //?? // break; // case CHANGE_POLL_FREQUENCY: // g_com_map[SEND_4G_SECOND]=TCP_command.frequency*60; // break; // } // result = 1; // TCPHeartBeatUpload(); // if(TCP_command.type!=QUARY_INFORMATION||TCP_command.type!=OPEN_GNSS) save_com_map_to_flash(); // result = 0; // memset(&applyid,0,8); } } else if(STRCMP(_u8Data, "$readpara,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); receive_id = HIDO_UtilHexStrToInt(apcSplitStr[1]); if(g_com_map[DEV_ID]==receive_id) { g_com_position=HIDO_UtilStrToInt(apcSplitStr[2]); g_com_num= HIDO_UtilStrToInt(apcSplitStr[3]); u32ReadResponseLen = snprintf(acReadponse, sizeof(acReadponse), "$replypara,%04x,%d", \ receive_id,g_com_position); for(uint16_t i=0;i0) beep_start_flag=1; } } } /* $update,id,url,version */ else if(STRCMP(_u8Data, "$update,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(u32SplitCnt < 4) { return HIDO_ERR; } /* É豸ID¼ì²é */ if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { // ota_flag=1; // LOG_INFO(TRACE_MODULE_APP,"OTAÎļþµØÖ·Ãû³Æ:%s.\r\n",(char *)&apcSplitStr[2]); // uart_send(UART_ID1, (char *)&apcSplitStr[2],strlen(apcSplitStr[3]), NULL); // memcpy(testdata,(HIDO_UINT8*)apcSplitStr[2],strlen(apcSplitStr[2]) + 1); // OTA_Start((HIDO_UINT8*)apcSplitStr[2]); // g_com_map[OTA_FLAG]=1; // g_com_map[OTA_URL_CHANGDU]=strlen(apcSplitStr[2]) + 1; // memcpy(g_com_map+OTA_URL_INDEX,(HIDO_UINT8*)apcSplitStr[2],strlen(apcSplitStr[2]) + 1); // save_com_map_to_flash(); // delay_us(100000); uint16_t tmp = 0xCCCC; __disable_irq(); result=flash_open(FLASH_ID0,NULL); if(!result) { flash_erase(FLASH_ID0, APP_CONFIG_IAPFLAG_SECTOR_ADDR, FLASH_SECTOR_SIZE);//²Á³ýAPPFLAG flash_write_nbytes(FLASH_ID0, APP_CONFIG_IAPFLAG_MAP, (uint8_t*)&tmp, sizeof(tmp)); flash_erase(FLASH_ID0, APP_CONFIG_IAP_PARAM_MAP, FLASH_SECTOR_SIZE);//²Á³ýAPPFLAG flash_write_nbytes(FLASH_ID0, APP_CONFIG_IAP_PARAM_MAP, (HIDO_UINT8*)apcSplitStr[2], strlen(apcSplitStr[2]) + 1); } __enable_irq(); NVIC_SystemReset(); //Èí¸´Î»»Øµ½bootloader } } return HIDO_OK; } /******************************************************************************* * Function Name : TCPClient_SocketEventProc * Description : * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021?1?9? *******************************************************************************/ static HIDO_VOID TCPClient_SocketEventProc(HIDO_INT32 _i32SockID, E_SocketEvent _eEvent, HIDO_VOID *_pData) { switch(_eEvent) { case SOCKET_EVENT_CONNECT_FAILED: { if(l_eTCPClientState == TCP_CLIENT_STATE_CONNECTING) { TCPfail_flag = 0; l_eTCPClientState = TCP_CLIENT_STATE_IDLE; } break; } case SOCKET_EVENT_CONNECTED: { if(l_eTCPClientState == TCP_CLIENT_STATE_CONNECTING) { l_eTCPClientState = TCP_CLIENT_STATE_CONNECTED; } break; } case SOCKET_EVENT_CLOSED: { TCPfail_flag = 0; l_eTCPClientState = TCP_CLIENT_STATE_IDLE; break; } case SOCKET_EVENT_RECV_DATA: { HIDO_INT32 i32Ret = 0; HIDO_UINT32 u32RecvLen = 0; i32Ret = Socket_Recv(l_i32TCPClientID, l_au8CmdBuff, sizeof(l_au8CmdBuff) - 1, &u32RecvLen); if(HIDO_OK == i32Ret) { TCPClient_DataProc(l_au8CmdBuff, u32RecvLen); } memset(l_au8CmdBuff,0,sizeof(l_au8CmdBuff)); break; } default: { break; } } } /******************************************************************************* * Global Function * *******************************************************************************/ /******************************************************************************* * Function Name : * Description : * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021?1?9? *******************************************************************************/ extern uint8_t bat_percent,taglist_num; uint8_t alarm_type; extern double jd,wd; extern char GGA_Format_message[200]; void UDPClient_UploadGPS(void) { // if(gps_open_flag||userkey_state) // air780_led_on(); HIDO_CHAR acHeart[200]; HIDO_UINT32 u32HeartLen; ave_sp = g_spsum/g_snum; g_spsum = 0; g_snum = 0; // if(alarm_type==1) // { // u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message,alarm,%04x,%d,%04x,%d,%02u%%,%d,%d,%lf,%lf,%s,%d,%d,0\r\n", \ // g_com_map[DEV_ID],GetUWBBindState(),g_com_map[BIND_DEV_ID],alarm_type,bat_percent,g_com_map[ALARM_DISTANCE1],g_com_map[ALARM_DISTANCE2],jd,wd,applyid,result,distance); // } else { // u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message,heart,%04x,%d,%04x,%d,%02u%%,%d,%d,%lf,%lf,%s,%d,%d,0\r\n", \ // g_com_map[DEV_ID],GetUWBBindState(),g_com_map[BIND_DEV_ID],alarm_type,bat_percent,g_com_map[ALARM_DISTANCE1],g_com_map[ALARM_DISTANCE2],jd,wd,applyid,result,distance); // } u32HeartLen = snprintf(acHeart, sizeof(acHeart), "%s,%04x,%x,%d,%d,0,0\r\n", \ GPS_GGAmessage,g_com_map[DEV_ID],bat_percent,userkey_state,gps_timeout_flag); memset(GPS_GGAmessage, 0, sizeof(GPS_GGAmessage)); // if(userkey_state!=1){ Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)acHeart, u32HeartLen); // } // if (userkey_state){ // TCPHeartBeatUpload();//Á¢¼´ÉÏ´«ÐÄÌø°ü // Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)GGA_Final_message, u32GGaLenth); // memset(GGA_Final_message, 0, sizeof(GGA_Final_message));//Çå¿Õ½ÓÊÕµ½µÄÓÃÍêµÄÊý×é // u32GGaLenth=0; // gga_num=0;//Çå0ÓÐЧ´ÎÊý // } //userkey_state = 0; // air780_led_off(); } void UDPClient_UploadGPS_10pack(void)//10°ü·¢Ë͹¦ÄÜ { air780_led_on(); Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)GGA_Final_message, u32GGaLenth); memset(GGA_Final_message, 0, sizeof(GGA_Final_message));//Çå¿Õ½ÓÊÕµ½µÄÓÃÍêµÄÊý×é u32GGaLenth=0; gga_num=0;//Çå0ÓÐЧ´ÎÊý air780_led_off(); } void UDPClient_UploadGPS_1pack(void)//µ¥°ü·¢Ë͹¦ÄÜ { air780_led_on(); Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)GGA_Format_message, sizeof(GGA_Format_message)); memset(GGA_Format_message, 0, sizeof(GGA_Format_message));//Çå¿Õ½ÓÊÕµ½µÄÓÃÍêµÄÊý×é gga_num=0;//Çå0ÓÐЧ´ÎÊý air780_led_off(); } void TCPHeartBeatUpload() { HIDO_CHAR acHeart1[200]; HIDO_UINT32 u32HeartLen; ave_sp = g_spsum/g_snum; g_spsum = 0; g_snum = 0; // if(alarm_type==1) // { // u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message,alarm,%04x,%d,%04x,%d,%02u%%,%d,%d,%lf,%lf,%s,%d,%d,0\r\n", \ // g_com_map[DEV_ID],GetUWBBindState(),g_com_map[BIND_DEV_ID],alarm_type,bat_percent,g_com_map[ALARM_DISTANCE1],g_com_map[ALARM_DISTANCE2],jd,wd,applyid,result,distance); // } else { // u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message,heart,%04x,%d,%04x,%d,%02u%%,%d,%d,%lf,%lf,%s,%d,%d,0\r\n", \ // g_com_map[DEV_ID],GetUWBBindState(),g_com_map[BIND_DEV_ID],alarm_type,bat_percent,g_com_map[ALARM_DISTANCE1],g_com_map[ALARM_DISTANCE2],jd,wd,applyid,result,distance); // } // u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$XTB,%X,%02u%%,%d.%d,%s,%d,1.", // g_com_map[DEV_ID], bat_percent2, g_com_map[VERSION]>>8,g_com_map[VERSION]&0xff, Module_GetCCID(),userkey_state4g,g_com_map[TCP_IP_0],g_com_map[TCP_IP_1],g_com_map[TCP_IP_2],g_com_map[TCP_IP_3],g_com_map[TCP_PORT]); u32HeartLen = snprintf(acHeart1, sizeof(acHeart1), "$XTB,%04x,%02u%%,%d.%d,%s,%d,1\r\n", \ g_com_map[DEV_ID],bat_percent,g_com_map[VERSION]>>8,g_com_map[VERSION]&0xff,Module_GetCCID(),userkey_state); Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)acHeart1, u32HeartLen); userkey_state=0; } void TCPReceiveMessageReply(void) { HIDO_CHAR acHeart[200]; HIDO_UINT32 u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$rec_message,%04x",g_com_map[DEV_ID]); Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)acHeart, u32HeartLen); } //void _4GAlarmUpload(uint8_t alarm) //{ // alarm_type = alarm; // TCPHeartBeatUpload(); // if(alarm_type == 2) // alarm_type = 0; //} HIDO_INT32 TCPClient_Poll(void) { if (Internet_IsIPReady() == HIDO_TRUE) { HIDO_UINT32 u32CurTick = HIDO_TimerGetTick(); if (TCP_CLIENT_STATE_IDLE == l_eTCPClientState) { if (!TCPfail_flag) { l_eTCPClientState = TCP_CLIENT_STATE_CONNECTING; HIDO_UtilSnprintf((HIDO_CHAR *) l_au8CmdBuff, sizeof(l_au8CmdBuff), "%u.%u.%u.%u", ip0,ip1, ip2, ip3); Socket_Connect(l_i32TCPClientID, (HIDO_CHAR *) l_au8CmdBuff, port); // HIDO_UtilSnprintf((HIDO_CHAR *) l_au8CmdBuff, sizeof(l_au8CmdBuff), "123.57.87.125"); // Socket_Connect(l_i32TCPClientID, (HIDO_CHAR *) l_au8CmdBuff, 8888); // HIDO_UtilSnprintf((HIDO_CHAR *) l_au8CmdBuff, sizeof(l_au8CmdBuff), "111.198.60.6"); // Socket_Connect(l_i32TCPClientID, (HIDO_CHAR *) l_au8CmdBuff, 1234); TCPfail_flag = 1; } else { if (u32CurTick - TCPfailetimer > HIDO_TIMER_TICK_S(5)) { TCPfailetimer = u32CurTick; TCPfail_flag = 0; } } } else if (TCP_CLIENT_STATE_CONNECTED == l_eTCPClientState) { if ((u32CurTick - l_u32HeartBeatTick) >= HIDO_TIMER_TICK_S(60)||flag_first_TCPconnect) //if ((u32CurTick - l_u32HeartBeatTick) >= HIDO_TIMER_TICK_S(g_com_map[SEND_4G_SECOND])||flag_first_TCPconnect) { flag_first_TCPconnect = 0; l_u32HeartBeatTick = u32CurTick; // ÕâÀïÊÇ×Ô¶¨ÒåÐÄÌø if(g_com_map[HEARTBEAT]) TCPHeartBeatUpload(); //UDPClient_UploadGPS();//ÏȲ»ÅªÐÄÌø // HIDO_CHAR acHeart[128]; // HIDO_UINT32 u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message heart,%04x,00001,1,50,50,50,,,,\r\n", g_com_map[DEV_ID]); // Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)acHeart, u32HeartLen); } } } else { l_eTCPClientState = TCP_CLIENT_STATE_IDLE; } return HIDO_OK; } /******************************************************************************* * Function Name : TCPClient_Upload * Description : * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ HIDO_INT32 TCPClient_Upload(HIDO_UINT8 *_pu8Data, HIDO_UINT32 _u32Len) { Socket_Send(l_i32TCPClientID, _pu8Data, _u32Len); return HIDO_OK; } HIDO_BOOL TCPClient_IsSendOver(HIDO_VOID) { return Socket_IsSendQueueEmpty(l_i32TCPClientID); } /******************************************************************************* * Function Name : TCPClient_Init * Description : TCP¿Í»§¶Ë³õʼ»¯ * Input : None * Output : None * Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ HIDO_INT32 TCPClient_Init(void) { l_eTCPClientState = TCP_CLIENT_STATE_IDLE; Socket_Create(&l_i32TCPClientID, SOCKET_TYPE_UDP, TCPClient_SocketEventProc, HIDO_NULL); // ÕâÀïÊǹ̶¨µÄÐÄÌø£¬ÓÉ4G×ÔÐз¢ËÍ #if 0 HIDO_CHAR acHeart[64]; HIDO_UINT32 u32HeartLen = snprintf(acHeart, sizeof(acHeart), "$message heart2,%04x\r\n", g_com_map[DEV_ID]); Socket_HeartbeatConfig(l_i32TCPClientID, (HIDO_UINT8 *)acHeart, u32HeartLen, 180); #endif return HIDO_OK; } char str[17]= {"AT+IPR=9600;&W\r\n"}; void AIR780E_Reset(void) { gps_air780_power_change(gps_power_state,0);//¿ªÆôgps£¬4G delay_us(1500000); gps_air780_power_change(gps_power_state,1);//¿ªÆôgps£¬4G // delay_us(3000000); // Uart_ReConfigBaudRate(UART_ID_4G,115200); // uart_send(UART_ID0, str,17, NULL); // Uart_ReConfigBaudRate(UART_ID_4G,9600); } uint8_t IfTCPConnected(void) { if(TCP_CLIENT_STATE_CONNECTED == l_eTCPClientState) { return 1; } else { return 0; } }