From 2c4086173a8915035aee593d16b3ea7edc6f5c15 Mon Sep 17 00:00:00 2001 From: chen <15335560115@163.com> Date: 星期二, 10 九月 2024 18:14:35 +0800 Subject: [PATCH] 初版仅gps1h上报加4G休眠,去掉uwb振动等 --- keil/include/src/TCPClient.c | 217 +++++++++++++++++++++++++++++++++++++----------------- 1 files changed, 149 insertions(+), 68 deletions(-) diff --git a/keil/include/src/TCPClient.c b/keil/include/src/TCPClient.c index d67aa40..9b56381 100644 --- a/keil/include/src/TCPClient.c +++ b/keil/include/src/TCPClient.c @@ -19,6 +19,7 @@ #include "Uart.h" #include "mk_4G.h" #include "mk_trace.h" +#include "dw_app_anchor.h" /******************************************************************************* * Macro * *******************************************************************************/ @@ -37,15 +38,21 @@ * 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); +void TCPReceiveMessageReply(void); /******************************************************************************* * Local Function * *******************************************************************************/ @@ -58,81 +65,102 @@ * Author : www.hido-studio.com * Modified Date: : 2021年1月9日 *******************************************************************************/ - Commend_Datestruct TCP_command; +extern uint8_t gps_4g_flag,search_open_flag; +extern Operation_step UWB_work_state; +Commend_Datestruct TCP_command; +uint8_t result; +char applyid[10]; static HIDO_INT32 TCPClient_DataProc(HIDO_UINT8 *_u8Data, HIDO_UINT32 _u32Len) { HIDO_CHAR *apcSplitStr[12]; HIDO_UINT32 u32SplitCnt = 0; - + LOG_INFO(TRACE_MODULE_APP, "收到数据\r\n"); - - if(STRCMP(_u8Data, "$instruct,") == 0) - { + + if(STRCMP(_u8Data, "$instruct,") == 0) + { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); TCP_command.tagId = HIDO_UtilHexStrToInt(apcSplitStr[3]); + if(g_com_map[DEV_ID]==TCP_command.tagId) { - TCP_command.type = HIDO_UtilHexStrToInt(apcSplitStr[1]); - + + TCP_command.type = HIDO_UtilStrToInt(apcSplitStr[1]); + memcpy(&applyid,apcSplitStr[2],8); + // TCP_command.applyID = HIDO_UtilStrToInt(apcSplitStr[2]); + TCP_command.gunLableId = HIDO_UtilHexStrToInt(apcSplitStr[4]); + TCP_command.warnDistance = HIDO_UtilStrToInt(apcSplitStr[5]); + TCP_command.alarmDistance = HIDO_UtilStrToInt(apcSplitStr[6]); + TCP_command.frequency = HIDO_UtilStrToInt(apcSplitStr[7]); + if(TCP_command.type>0&&TCP_command.type<8) + result = 1; + switch(TCP_command.type) { - case BIND_SUCCESS: - { - g_com_map[BIND_DEV_ID]=TCP_command.gunLableId; - g_com_map[ALARM_DISTANCE1]=TCP_command.warnDistance; - g_com_map[ALARM_DISTANCE2]=TCP_command.alarmDistance;//这个距离double和uint格式不符 - g_com_map[SEND_4G_FREQUENCY]=1000/TCP_command.frequency; - save_com_map_to_flash(); + 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; - case UNBIND: - // bind_resetbreak(); - case OPEN_GNSS: - gnss_forceopen(); - case CLOSE_VIBRATION: - // vibration_close(); - case QUARY_INFORMATION: + // 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: //?? - case CHANGE_POLL_FREQUENCY: - g_com_map[SEND_4G_FREQUENCY]=TCP_command.frequency; + + 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); } - } - - - //根据指令去执行 - - - // -#if 0 - if(STRCMP(_u8Data, "$control,") == 0) + } else if(STRCMP(_u8Data, "$message_reply,") == 0) { u32SplitCnt = HIDO_UtilStrSplit((HIDO_CHAR *)_u8Data, ',', apcSplitStr, HIDO_ARRARY_COUNT(apcSplitStr)); - if(u32SplitCnt < 3) + TCP_command.tagId = HIDO_UtilHexStrToInt(apcSplitStr[1]); + if(g_com_map[DEV_ID]==TCP_command.tagId) { - 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]); - - } - } - }else if(STRCMP(_u8Data, "$userdata,") == 0) - { - if(DBG_GetMode() == DBG_MODE_CFG) - HIDO_Debug2("%s\r\n", l_au8CmdBuff); - } -#endif return HIDO_OK; } @@ -153,6 +181,7 @@ { if(l_eTCPClientState == TCP_CLIENT_STATE_CONNECTING) { + TCPfail_flag = 0; l_eTCPClientState = TCP_CLIENT_STATE_IDLE; } @@ -168,6 +197,7 @@ } case SOCKET_EVENT_CLOSED: { + TCPfail_flag = 0; l_eTCPClientState = TCP_CLIENT_STATE_IDLE; break; } @@ -202,8 +232,42 @@ * Author : www.hido-studio.com * Modified Date: : 2021?1?9? *******************************************************************************/ -uint8_t TCPfail_flag = 0,flag_first_TCPconnect=1; -uint32_t TCPfailetimer; +extern uint8_t bat_percent,taglist_num; +uint8_t alarm_type; +extern double jd,wd; +extern int32_t distance; +void TCPHeartBeatUpload(void) +{ + HIDO_CHAR acHeart[200]; + HIDO_UINT32 u32HeartLen; +// if(alarm_type) +// { +// 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), "$message,GPS,%04x,%lf,%lf\r\n", \ + g_com_map[DEV_ID],jd,wd); + + Socket_Send(l_i32TCPClientID, (HIDO_UINT8 *)acHeart, u32HeartLen); +} + +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) @@ -215,14 +279,17 @@ { l_eTCPClientState = TCP_CLIENT_STATE_CONNECTING; -// HIDO_UtilSnprintf((HIDO_CHAR *) l_au8CmdBuff, sizeof(l_au8CmdBuff), "%u.%u.%u.%u", g_com_map[TCP_IP_0], -// g_com_map[TCP_IP_1], g_com_map[TCP_IP_2], g_com_map[TCP_IP_3]); -// Socket_Connect(l_i32TCPClientID, (HIDO_CHAR *) l_au8CmdBuff, g_com_map[TCP_PORT]); + 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; +// 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 { @@ -236,14 +303,18 @@ else if (TCP_CLIENT_STATE_CONNECTED == l_eTCPClientState) { + + + // if ((u32CurTick - l_u32HeartBeatTick) >= HIDO_TIMER_TICK_S(g_com_map[SEND_4G_SECOND])||flag_first_TCPconnect) if ((u32CurTick - l_u32HeartBeatTick) >= HIDO_TIMER_TICK_S(15)||flag_first_TCPconnect) - { + { flag_first_TCPconnect = 0; l_u32HeartBeatTick = u32CurTick; // 这里是自定义心跳 - 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); + //TCPHeartBeatUpload(); +// 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); } } } @@ -271,6 +342,11 @@ return HIDO_OK; } +HIDO_BOOL TCPClient_IsSendOver(HIDO_VOID) +{ + return Socket_IsSendQueueEmpty(l_i32TCPClientID); +} + /******************************************************************************* * Function Name : TCPClient_Init * Description : TCP客户端初始化 @@ -291,21 +367,26 @@ 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(0,0);//开启gps,4G + gps_air780_power_change(gps_power_state,0);//开启gps,4G delay_us(1500000); - gps_air780_power_change(0,1);//开启gps,4G + 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{ + } else { return 0; } } \ No newline at end of file -- Gitblit v1.9.3