/******************************************************************************* * File Name : UDPClient.c * Description : * Created on : 2021Äê1ÔÂ9ÈÕ * Author : www.hido-studio.com *******************************************************************************/ /******************************************************************************* * Include Files * *******************************************************************************/ #include "UDPClient.h" #include "Socket.h" #include "HIDO_Debug.h" #include "Internet.h" #include "stdio.h" #include "string.h" #include "HIDO_Timer.h" #include "HIDO_Util.h" #if 0 #include "Battery.h" #endif #include "global_param.h" #include "SPIFlash.h" #include "AppConfig.h" #include "DBG.h" #include "stm32l0xx_hal.h" #if 0 #include "OTA.h" #include "Log.h" #include "APL.h" #include "qxwz_sdk.h" #include "TTS.h" #include "TONE.h" #include "EC600SFSM.h" #endif #include "WS2812.h" /******************************************************************************* * Macro * *******************************************************************************/ #define STRCMP(cmd, header) strncmp((HIDO_CHAR *)_u8Data, header, sizeof(header) - 1) /******************************************************************************* * Type Definition * *******************************************************************************/ typedef enum { UDP_CLIENT_STATE_IDLE, UDP_CLIENT_STATE_CONNECTING, UDP_CLIENT_STATE_CONNECTED, }E_UDPClientState; /******************************************************************************* * Local Variable * *******************************************************************************/ static HIDO_INT32 l_i32UDPCLientID = 0; static E_UDPClientState l_eUDPCLientState = UDP_CLIENT_STATE_IDLE; static HIDO_UINT32 l_u32HeartBeatTick = 0; static HIDO_UINT8 l_au8CmdBuff[1024]; /******************************************************************************* * Local Function Declaration * *******************************************************************************/ HIDO_INT32 UDPClient_Heartbeat(HIDO_VOID); /******************************************************************************* * Local Function * *******************************************************************************/ /******************************************************************************* * Function Name : UDPClient_CmdParse * Description : * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ uint16_t beepontime; static HIDO_INT32 UDPClient_CmdParse(HIDO_UINT8 *_u8Data, HIDO_UINT32 _u32Len) { HIDO_CHAR *apcSplitStr[12]; HIDO_UINT32 u32SplitCnt = 0; HIDO_UINT32 u32Len = 0; HIDO_Debug("%s\r\n", l_au8CmdBuff); /* $config,id,gps_hz,ip,port */ if(STRCMP(_u8Data, "$GPS_S,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(u32SplitCnt < 5) { return HIDO_ERR; } /* É豸ID¼ì²é */ if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { HIDO_UINT32 u32Temp = 0; HIDO_BOOL bChange = HIDO_FALSE; HIDO_UINT8 au8IP[4]; /* GPS HZ */ u32Temp = HIDO_UtilStrToInt(apcSplitStr[2]); if(u32Temp != g_com_map[GPS_HZ]) { g_com_map[GPS_HZ] = u32Temp; bChange = HIDO_TRUE; } /* IP=192.168.1.1 */ HIDO_UtilIPStringToByteArrary(apcSplitStr[3], au8IP); /* IP±ä»¯ */ if((au8IP[0] != g_com_map[IP_0]) || (au8IP[1] != g_com_map[IP_1]) || (au8IP[2] != g_com_map[IP_2]) || (au8IP[3] != g_com_map[IP_3])) { bChange = HIDO_TRUE; g_com_map[IP_0] = au8IP[0]; g_com_map[IP_1] = au8IP[1]; g_com_map[IP_2] = au8IP[2]; g_com_map[IP_3] = au8IP[3]; l_eUDPCLientState = UDP_CLIENT_STATE_IDLE; } /* ¶Ë¿Ú=0-65535 */ if( g_com_map[PORT] != HIDO_UtilStrToInt(apcSplitStr[4])) { g_com_map[PORT] = HIDO_UtilStrToInt(apcSplitStr[4]); bChange = HIDO_TRUE; } if(bChange) { save_com_map_to_flash(); g_com_map[CNT_RESTART] = 1; } } } /* $update,id,url,version */ else if(STRCMP(_u8Data, "$CHAICHUGPS_S,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(u32SplitCnt < 5) { return HIDO_ERR; } /* É豸ID¼ì²é */ if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { HIDO_UINT32 u32Temp = 0; HIDO_BOOL bChange = HIDO_FALSE; HIDO_UINT8 au8IP[4]; /* GPS HZ */ u32Temp = HIDO_UtilStrToInt(apcSplitStr[2]); if(u32Temp != g_com_map[CHAICHUGPS_HZ]) { g_com_map[CHAICHUGPS_HZ] = u32Temp; bChange = HIDO_TRUE; } /* IP=192.168.1.1 */ HIDO_UtilIPStringToByteArrary(apcSplitStr[3], au8IP); /* IP±ä»¯ */ if((au8IP[0] != g_com_map[IP_0]) || (au8IP[1] != g_com_map[IP_1]) || (au8IP[2] != g_com_map[IP_2]) || (au8IP[3] != g_com_map[IP_3])) { bChange = HIDO_TRUE; g_com_map[IP_0] = au8IP[0]; g_com_map[IP_1] = au8IP[1]; g_com_map[IP_2] = au8IP[2]; g_com_map[IP_3] = au8IP[3]; l_eUDPCLientState = UDP_CLIENT_STATE_IDLE; } /* ¶Ë¿Ú=0-65535 */ if( g_com_map[PORT] != HIDO_UtilStrToInt(apcSplitStr[4])) { g_com_map[PORT] = HIDO_UtilStrToInt(apcSplitStr[4]); bChange = HIDO_TRUE; } if(bChange) { save_com_map_to_flash(); g_com_map[CNT_RESTART] = 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]) { /* °æ±¾ºÅ±È½Ï,¡°´ó¡±²ÅÉý¼¶ */ if(strcmp(apcSplitStr[3], APP_CONFIG_VERSION) > 0) { /* ÖØÆô½øÈëOTAģʽÉý¼¶ */ uint16_t tmp = 0xCCCC; HIDO_Debug("goto OTA Application\r\n"); SPIFlash_Erase(SPI_FLASH_ID_0, APP_CONFIG_IAPFLAG_MAP, 2, SPI_FLASH_SECTOR_ERASE_MODE_4K); SPIFlash_Write(SPI_FLASH_ID_0, APP_CONFIG_IAPFLAG_MAP, (HIDO_UINT8*)&tmp, sizeof(tmp)); SPIFlash_Erase(SPI_FLASH_ID_0, APP_CONFIG_IAP_PARAM_MAP, 256, SPI_FLASH_SECTOR_ERASE_MODE_4K); SPIFlash_Write(SPI_FLASH_ID_0, APP_CONFIG_IAP_PARAM_MAP, (HIDO_UINT8*)apcSplitStr[2], strlen(apcSplitStr[2]) + 1); HAL_Delay(10); //Reboot(0); } } } /* $getlog,id,url */ else if(STRCMP(_u8Data, "$getlog,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(u32SplitCnt < 3) { return HIDO_ERR; } /* É豸ID¼ì²é */ if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { #if 0 Log_Upload(apcSplitStr[2]); #endif } } /* $control,id,bepper,time */ else if(STRCMP(_u8Data, "$control,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(u32SplitCnt < 3) { return HIDO_ERR; } /* ?õôID??? */ if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { if(strcmp(apcSplitStr[2],"beeper")==0) { beepontime = HIDO_UtilStrToInt(apcSplitStr[3]); } if(strcmp(apcSplitStr[2],"TTS")==0) { GPIOD->BSRR = 0X0004; //´ò¿ªTTSµçÔ´ // delay_ms(800); //ÔÙ¶ÌÒ»µã£¬»á¶ªÊ§ÓïÒôµÄµÚÒ»¸ö×Ö£¬²»ÊDz»¶Á£¬¶øÊǾÍÏñûÓÐÏ·¢µÚÒ»¸ö×Ö //TTS_Play((HIDO_UINT8 *)apcSplitStr[3], strlen(apcSplitStr[3])); //·þÎñÆ÷ÓïÒô²¥±¨ u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$Receivevoice,%X\r\n", g_com_map[DEV_ID]); Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_au8CmdBuff, u32Len); u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$Receivevoice,%X\r\n", g_com_map[DEV_ID]); Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_au8CmdBuff, u32Len); } } } else if(STRCMP(_u8Data, "$userdata,") == 0) { #if 0 if(DBG_GetMode() == DBG_MODE_CFG) HIDO_Debug2("%s\r\n", l_au8CmdBuff); #endif } else if(STRCMP(_u8Data, "$settone,") == 0) { HIDO_DataStruct stData; HIDO_DataStruct stId; if(HIDO_UtilParseFormat(_u8Data, _u32Len, "$settone,%p,%p\r\n", &stId, &stData) == 2) { ((char *)stId.m_pData)[stId.m_u32Len] = '\0'; if(g_com_map[DEV_ID] == HIDO_UtilHexStrToInt((char *)stId.m_pData)) { #if 0 TONE_Play((HIDO_UINT8 *)stData.m_pData, stData.m_u32Len); #endif u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$Receivevoice,%X\r\n", g_com_map[DEV_ID]); //TTSÊÕµ½»Ø¸´ Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_au8CmdBuff, u32Len); } } }else if(STRCMP(_u8Data, "$setpara,") == 0) { uint16_t tempindex,tempval; u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { if(u32SplitCnt < 2) { return HIDO_ERR; } tempindex = HIDO_UtilStrToInt(apcSplitStr[2]); tempval = HIDO_UtilStrToInt(apcSplitStr[3]); if(tempindex == MOTOR_ONTIME_INDEX) { beepontime = tempval; }else{ if(tempindex < COM_MAP_SIZE) g_com_map[tempindex] = tempval; save_com_map_to_flash(); g_com_map[CNT_RESTART] = 1; } } } else if(STRCMP(_u8Data, "$readpara,") == 0) { uint16_t tempindex,templen,buffer_len,datalen; char send_buffer[500]; u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); if(HIDO_UtilHexStrToInt(apcSplitStr[1]) == g_com_map[DEV_ID]) { if(u32SplitCnt < 2) { return HIDO_ERR; } tempindex = HIDO_UtilStrToInt(apcSplitStr[2]); templen = HIDO_UtilStrToInt(apcSplitStr[3]); buffer_len = sprintf(send_buffer,"$replypara,"); datalen = sprintf(&send_buffer[buffer_len],"%x,",g_com_map[DEV_ID]); buffer_len += datalen; for(uint16_t i=tempindex;i= 10000) { heartbeasend_flag = 0; l_u32HeartBeatTick = u32CurTick; UDPClient_Heartbeat(); // if(nomove_flag==1) // {zuihoufasong_falg=1;} userkey_state4g = 0; } } else { if((u32CurTick - l_u32HeartBeatTick) >= 1000) { heartbeasend_flag = 0; l_u32HeartBeatTick = u32CurTick; UDPClient_Heartbeat(); userkey_state4g = 0; } } } } else { loraled=LEDOFF; l_eUDPCLientState = UDP_CLIENT_STATE_IDLE; } return HIDO_OK; } /******************************************************************************* * Function Name : UDPClient_Upload * Description : UDP¿Í»§¶ËÉÏ´«Êý¾Ý * Input : * Output : * Return : * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ extern uint8_t fangchai_flag; extern uint8_t bat_percent; HIDO_INT32 UDPClient_UploadGPS(HIDO_CHAR *_pcGGA) {uint16_t state_flag; static HIDO_CHAR l_acUploadBuff[1024]; static HIDO_UINT32 l_u32UploadBuffLen = 0; static HIDO_UINT32 l_u32UdpsendTick = 0; if(UDP_CLIENT_STATE_CONNECTED == l_eUDPCLientState) { state_flag = 0; state_flag = fangchai_flag; HIDO_UINT32 u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "%s,%X,%02x,%x,%d,%d,%d%\r\n", _pcGGA, g_com_map[DEV_ID], bat_percent,0,0,0,state_flag); if((l_u32UploadBuffLen + u32Len) < sizeof(l_acUploadBuff)) { memcpy(l_acUploadBuff + l_u32UploadBuffLen, l_au8CmdBuff, u32Len); l_u32UploadBuffLen += u32Len; } //memcpy(l_acUploadBuff + l_u32UploadBuffLen, l_au8CmdBuff, u32Len); //l_u32UploadBuffLen += u32Len; // if((l_u32UploadBuffLen + u32Len )> sizeof(l_acUploadBuff)) if((HIDO_TimerGetTick() - l_u32UdpsendTick) >= 200) { l_u32UdpsendTick = HIDO_TimerGetTick(); Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_acUploadBuff, l_u32UploadBuffLen); l_u32UploadBuffLen = 0; } } return HIDO_OK; } HIDO_INT32 UDPClient_Uploadhex(uint8_t *_pcGGA,uint16_t u32Len) { static HIDO_CHAR l_acUploadBuff[1024]; static HIDO_UINT32 l_u32UploadBuffLen = 0; static HIDO_UINT32 l_u32UdpsendTick = 0; if(UDP_CLIENT_STATE_CONNECTED == l_eUDPCLientState) { memcpy(l_acUploadBuff + l_u32UploadBuffLen, _pcGGA, u32Len); l_u32UploadBuffLen += u32Len; // if((l_u32UploadBuffLen + u32Len )> sizeof(l_acUploadBuff)) if((HIDO_TimerGetTick() - l_u32UdpsendTick) >= 200) { l_u32UdpsendTick = HIDO_TimerGetTick(); Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_acUploadBuff, l_u32UploadBuffLen); l_u32UploadBuffLen = 0; } } return HIDO_OK; } /******************************************************************************* * Function Name : UDPClient_Heartbeat * Description : ÐÄÌø·¢ËÍ * Input : None * Output : None * Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ uint8_t bat_percent2 = 0; extern uint8_t input_5v_flag; extern uint8_t nomove_flag; //extern qxwz_sdk_config_t sdk_config; HIDO_INT32 UDPClient_Heartbeat(HIDO_VOID) { HIDO_UINT32 u32Len = 0; if(UDP_CLIENT_STATE_CONNECTED == l_eUDPCLientState) { if(g_com_map[RTCMMODE_INDEX] == RTCMMODE_TCP) { u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$XTB,%X,%02u%%,%d.%d,%s,%d,3:%d.%d.%d.%d:%d.", g_com_map[DEV_ID], bat_percent, 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]); }else if(g_com_map[RTCMMODE_INDEX] == RTCMMODE_NTRIP) { // u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$XTB,%X,%02u%%,%d.%d,%s,%d,2%s %s", // g_com_map[DEV_ID], bat_percent, g_com_map[VERSION]>>8,g_com_map[VERSION]&0xff, Module_GetCCID(),userkey_state4g,(char *)&g_com_map[NTRIP_HOST_INDEX],(char *)&g_com_map[NTRIP_USERNANME_INDEX]); }else if(g_com_map[RTCMMODE_INDEX] == RTCMMODE_NONE) { u32Len = HIDO_UtilSnprintf((HIDO_CHAR *)l_au8CmdBuff, sizeof(l_au8CmdBuff), "$XTB,%X,%02u%%,%d.%d,%s,%d,1.,%d,%d,%d", g_com_map[DEV_ID], bat_percent, g_com_map[VERSION]>>8,g_com_map[VERSION]&0xff, Module_GetCCID(),userkey_state4g,input_5v_flag,fangchai_flag,nomove_flag,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]); } Socket_Send(l_i32UDPCLientID, (HIDO_UINT8 *)l_au8CmdBuff, u32Len); } return HIDO_OK; } /******************************************************************************* * Function Name : UDPClient_Init * Description : UDP¿Í»§¶Ë³õʼ»¯ * Input : None * Output : None * Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü * Author : www.hido-studio.com * Modified Date: : 2021Äê1ÔÂ9ÈÕ *******************************************************************************/ HIDO_INT32 UDPClient_Init(void) { Socket_Create(&l_i32UDPCLientID, SOCKET_TYPE_UDP, UDPClient_SocketEventProc, HIDO_NULL); return HIDO_OK; }