|
@@ -92,6 +92,10 @@ static void TcpTask(void* arg)
|
|
|
{
|
|
|
sendQueueMsg(QMSG_ID_SOCK_SENDPKG, 0);
|
|
|
}
|
|
|
+ else if(Timer_count%100==0)
|
|
|
+ {
|
|
|
+ TcpService = 0x00;
|
|
|
+ }
|
|
|
if (xQueueReceive(psEventQueueHandle, &queueItem, 0))
|
|
|
{
|
|
|
switch(queueItem->messageId)
|
|
@@ -138,7 +142,6 @@ static void TcpTask(void* arg)
|
|
|
case QMSG_ID_SOCK_RECVPKG:
|
|
|
TcpDataInfoRecvHandle();
|
|
|
osDelay(100);
|
|
|
- TcpService=0x00;
|
|
|
break;
|
|
|
case QMSG_ID_NW_IP_SUSPEND:
|
|
|
if (socContext.id >= 0 && socContext.status != APP_SOCKET_CONNECTION_CLOSED)
|
|
@@ -221,8 +224,8 @@ static void TcpDataInfoAssembleSend()
|
|
|
UINT8 TEMP_NUM=0;
|
|
|
TEMP_NUM = BATT_TEMP_NUM+2;//TEMP_NUM为BMS温度总检测数量
|
|
|
UINT16 DataLen;
|
|
|
- //if(send_counter%1==0)
|
|
|
- if(0)
|
|
|
+ if(send_counter%1==0)
|
|
|
+ //if(0)
|
|
|
{
|
|
|
osStatus_t result = osMutexAcquire(UartMutex, osWaitForever);
|
|
|
appGetSystemTimeUtcSync(&TimeStracture);
|
|
@@ -277,7 +280,7 @@ static void TcpDataInfoAssembleSend()
|
|
|
BattToTcpInfo.battInfo.battPackVol[0] = BattU >> 8;
|
|
|
BattToTcpInfo.battInfo.battPackVol[1] = BattU & 0xFF;
|
|
|
temp = ((UartReadMsg.data[(0x09+BATT_CELL_VOL_NUM+TEMP_NUM)*2+1])>>1)&0x03;
|
|
|
- BattToTcpInfo.battInfo.chrgState = ((temp&0x01)<<01)|(temp>>0x01);
|
|
|
+ BattToTcpInfo.battInfo.mosState = ((temp&0x01)<<01)|(temp>>0x01);
|
|
|
BattToTcpInfo.battInfo.battSOC = UartReadMsg.data[(0x0B+BATT_CELL_VOL_NUM+TEMP_NUM)*2+1];
|
|
|
BattToTcpInfo.battInfo.battSOH = UartReadMsg.data[(0x0C+BATT_CELL_VOL_NUM+TEMP_NUM)*2+1];
|
|
|
memcpy(BattToTcpInfo.battInfo.batCellBalenceState,&UartReadMsg.data[(0x06+BATT_CELL_VOL_NUM+TEMP_NUM)*2],4);
|
|
@@ -298,8 +301,8 @@ static void TcpDataInfoAssembleSend()
|
|
|
tcpipConnectionSend(socContext.id, (UINT8 *)&BattToTcpInfo, sizeof(BattToTcpInfo), 0, 0, 0);
|
|
|
|
|
|
}
|
|
|
- //if(send_counter%6==0)
|
|
|
- if(0)
|
|
|
+ if(send_counter%6==0)
|
|
|
+ //if(0)
|
|
|
{
|
|
|
osStatus_t result = osMutexAcquire(GpsMutex, osWaitForever);
|
|
|
appGetSystemTimeUtcSync(&TimeStracture);
|
|
@@ -389,6 +392,7 @@ static void TcpDataInfoAssembleSend()
|
|
|
VerMsgToTcpInfo.VerInfo.APPVersion[3] = (APPSWVERSION)& 0xFF;
|
|
|
VerMsgToTcpInfo.VerInfo.BmsType = BMS_MANUFACTURE;
|
|
|
VerMsgToTcpInfo.VerInfo.BmsInfo = BMS_INFO;
|
|
|
+ VerMsgToTcpInfo.VerInfo.DataModuleType = DATA_MODULE_TYPE;
|
|
|
VerMsgToTcpInfo.CRC = bcc_chk((UINT8 *)&VerMsgToTcpInfo, sizeof(VerMsgToTcpInfo)-1 );
|
|
|
tcpipConnectionSend(socContext.id, (UINT8 *)&VerMsgToTcpInfo, sizeof(VerMsgToTcpInfo), 0, 0, 0);
|
|
|
}
|
|
@@ -407,7 +411,6 @@ static void TcpDataInfoAssembleSend()
|
|
|
static void TcpDataInfoRecvHandle()
|
|
|
{
|
|
|
TcpipConnectionRecvDataInd *TcpRecvData;
|
|
|
- TcpService = 0x01;//应答标志
|
|
|
osMessageQueueGet(TcpRecvHandle,&TcpRecvData,0,0);
|
|
|
osDelay(100);
|
|
|
UINT8 Tcp_Cmd;
|
|
@@ -419,6 +422,10 @@ static void TcpDataInfoRecvHandle()
|
|
|
if((*(Ptr+0)==TCP_START_SYM1)&&(*(Ptr+1)==TCP_START_SYM2))//服务器起始信息
|
|
|
{
|
|
|
Tcp_Cmd = *(Ptr+2);//命令标志
|
|
|
+ if(*(Ptr+3)==0xFE)
|
|
|
+ {
|
|
|
+ TcpService=0x01;
|
|
|
+ }
|
|
|
switch (Tcp_Cmd)
|
|
|
{
|
|
|
case TCP_QUERY_SYM:
|
|
@@ -595,7 +602,7 @@ static void socketAppConnectionCallBack(UINT8 connectionEventType, void *bodyEve
|
|
|
memcpy(rcvbuffer,rcvInd,sizeof(TcpipConnectionRecvDataInd));
|
|
|
osMessageQueuePut(TcpRecvHandle,&rcvbuffer,0,1000);
|
|
|
sendQueueMsg(QMSG_ID_SOCK_RECVPKG, 0);
|
|
|
- #ifdef USING_PRINTF1
|
|
|
+ #ifdef USING_PRINTF
|
|
|
uint8_t* Ptr;
|
|
|
Ptr=rcvInd->data;
|
|
|
printf("socketAppConnectionCallBack socket connection %u receive length %u data:", rcvInd->connectionId, rcvInd->length);
|