NB_APP_Code/src/AppTaskTcp.c

/****************************************************************************
 *
 * Copy right:   Qx.Chen jie
 * File name:    TcpTask.c
 * Description:  主要负责：1.数据发送、定时心跳上报，2.数据接收、命令接收及处理，3.Fota函数调用，4.驻网及失败状态监测与上报
 * History:      2021-07-05
 * Version:      V3.0
 ****************************************************************************/
#include "AppTaskTcp.h"
#include "numeric.h"

//局部变量申请
static StaticTask_t gProcess_Tcp_Task_t;
static UINT8 gProcess_Tcp_TaskStack[PROC_TCP_TASK_STACK_SIZE];
static QueueHandle_t psEventQueueHandle; //状态转换队列句柄
static osThreadId_t TcpTaskId = NULL;

static eventCallbackMessage_t *queueItem = NULL;
static UINT8 gImsi[16] = {0};
static UINT32 gCellID = 0;
static QueueHandle_t TcpRecvHandle = NULL;
static UINT8 TcpRecvEnd = 0;
static UINT32 send_counter = 0;
static void sendQueueMsg(UINT32 msgId, UINT32 xTickstoWait);
static INT32 socketRegisterPSUrcCallback(urcID_t eventID, void *param, UINT32 paramLen);
static void socketAppConnectionCallBack(UINT8 connectionEventType, void *bodyEvent);
static void TcpDataInfoRecvHandle();
static void TcpDataInfoAssembleSend();
static void TcpHeartDataSend();
static void TcpTask(void *arg)
{
    appSetEDRXSettingSync(0, 5, 1800000);
    appSetPSMSettingSync(0, 3 * 60 * 60, 10);
    appSetCFUN(1);
    psEventQueueHandle = xQueueCreate(APP_EVENT_QUEUE_SIZE, sizeof(eventCallbackMessage_t *));
    if (psEventQueueHandle == NULL)
    {
        return;
    }
    if (TcpRecvHandle == NULL)
    {
        TcpRecvHandle = osMessageQueueNew(3, sizeof(TcpipConnectionRecvDataInd *), NULL);
    }
    osDelay(5000); //等待驻网延时5s
    while (true)
    {
        osDelay(100);
        if (gProcess_app == WORK && TCPWorkState == 0x00 && AppNVMData.EOLState == 1 && TimeCounter % 10 == 0)
        {
            sendQueueMsg(QMSG_ID_SOCK_SENDPKG, 0);
        }
        else if (gProcess_app == LISTEN && TimeCounter % (10 * 60 * 3) == 0)
        {
            sendQueueMsg(QMSG_ID_SOCK_LISTEN, 0);
            send_counter = 0;
        }
        if (TCPWorkState != 0 && TimeCounter % 10 == 0)
        {
            TcpRecvEnd++;
            if (TcpRecvEnd > 10)
            {
                TcpRecvEnd = 0;
                TCPWorkState = 0;
            }
        }
        if (xQueueReceive(psEventQueueHandle, &queueItem, 0))
        {
            switch (queueItem->messageId)
            {
            case QMSG_ID_NW_IP_READY:
                if (socContext.id < 0)
                {
                    struct addrinfo hints;
                    struct addrinfo *servinfo = NULL;
                    char *Tcp_ip_des;
                    memset(&hints, 0, sizeof(hints));
                    hints.ai_family = AF_INET;
                    hints.ai_socktype = SOCK_STREAM;
                    getaddrinfo(TCP_ADD, NULL, &hints, &servinfo);
                    Tcp_ip_des = ip4addr_ntoa((const ip4_addr_t *)(&(servinfo->ai_addr->sa_data[2])));
#ifdef USING_PRINTF1
                    printf("\nservinfo-%d:\n", servinfo->ai_addr->sa_len);
                    for (int i = 0; i < 4; i++)
                        printf("%d ", servinfo->ai_addr->sa_data[2 + i]);
                    printf("\nTcp_ip_des-%d:\n", sizeof(Tcp_ip_des));
                    for (int i = 0; i < 16; i++)
                        printf("%c", *(Tcp_ip_des + i));
#endif
                    socContext.id = tcpipConnectionCreate(TCPIP_CONNECTION_PROTOCOL_TCP, PNULL, 0, Tcp_ip_des, TCP_PORT, socketAppConnectionCallBack);
                    if (NULL != servinfo)
                    {
                        freeaddrinfo(servinfo);
                    }
                }
                if (socContext.id >= 0)
                {
                    TcpErrorcount = 0;
                    socContext.status = APP_SOCKET_CONNECTION_CONNECTED;
#ifdef USING_PRINTF
                    printf("create connection %u success\n", socContext.id);
#endif
                    ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_2, P_INFO, 1, "create connection %u success", socContext.id);
                }
                else
                {
                    sendQueueMsg(QMSG_ID_NW_IP_NOREACHABLE, 0);
#ifdef USING_PRINTF
                    printf("create connection fail\n");
#endif
                    ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_3, P_ERROR, 0, "create connection fail");
                }
                break;
            case QMSG_ID_NW_IP_NOREACHABLE:
            {
                TcpErrorcount++;
                socContext.id = -1;
                appSetCFUN(0);
                osDelay(5000);
                appSetCFUN(1);
                osDelay(10000);
#ifdef USING_PRINTF
                printf("Network restart\n");
#endif
            }
            break;
            case QMSG_ID_SOCK_SENDPKG:
                if (socContext.id >= 0 && socContext.status == APP_SOCKET_CONNECTION_CONNECTED)
                {
                    NmAtiSyncRet netstatus1;
                    appGetNetInfoSync(0, &netstatus1);
                    if (netstatus1.body.netInfoRet.netifInfo.netStatus == NM_NETIF_ACTIVATED || netstatus1.body.netInfoRet.netifInfo.netStatus == NM_NETIF_ACTIVATED_INFO_CHNAGED)
                    {
                        TcpDataInfoAssembleSend();
                    }
                    else
                    {
                        sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
                    }
                }
                else
                {
                    sendQueueMsg(QMSG_ID_NW_IP_READY, 0);
#ifdef USING_PRINTF
                    printf("connection %u or status invalid", socContext.id, socContext.status);
#endif
                    ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_9, P_ERROR, 2, "connection %u or status invalid", socContext.id, socContext.status);
                }
                break;
            case QMSG_ID_SOCK_RECVPKG:
            {
                TcpDataInfoRecvHandle();
                osDelay(100);
                TcpRecvEnd = 0;
                break;
            }
            case QMSG_ID_NW_IP_SUSPEND:
                if (socContext.id >= 0 && socContext.status != APP_SOCKET_CONNECTION_CLOSED)
                {
                    if (tcpipConnectionClose(socContext.id) < 0)
                    {
#ifdef USING_PRINTF
                        printf("close connection %u success", socContext.id);
#endif
                        socContext.id = -1;
                        socContext.status = APP_SOCKET_CONNECTION_CLOSED;
                        ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_4, P_INFO, 1, "close connection %u success", socContext.id);
                    }
                    else
                    {
#ifdef USING_PRINTF
                        printf("close connection %u fail", socContext.id);
#endif
                        ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_5, P_ERROR, 1, "close connection %u fail", socContext.id);
                    }
                }
                else
                {
                    sendQueueMsg(QMSG_ID_NW_IP_NOREACHABLE, 0);
#ifdef USING_PRINTF
                    printf("connection %u or status invalid", socContext.id, socContext.status);
#endif
                    ECOMM_TRACE(UNILOG_PLA_APP, ecTestCaseTcpClient_6, P_ERROR, 2, "connection %u or status invalid", socContext.id, socContext.status);
                }
                break;
            case QMSG_ID_SOCK_LISTEN:
            {
                if (socContext.id >= 0 && socContext.status == APP_SOCKET_CONNECTION_CONNECTED)
                {
#ifdef USING_PRINTF
                    printf("[%d]QMSG_ID_SOCK_LISTEN\n", __LINE__);
#endif
                    TcpHeartDataSend();
                }
                else
                {
                    sendQueueMsg(QMSG_ID_NW_IP_READY, 0);
#ifdef USING_PRINTF
                    printf("connection %u or status invalid", socContext.id, socContext.status);
#endif
                }
                break;
            }
            case QMSG_ID_SOCK_EXIT:
#ifdef USING_PRINTF
                printf("QMSG_ID_SOCK_EXIT queueItem->messageId:%x\n", queueItem->messageId);
#endif
#ifdef USING_PRINTF
                printf("socket exit\n");
#endif
                appSetCFUN(0);
                osDelay(1000);
                break;
            }
            free(queueItem);
        } //if
    }     //while 循环
}
/***********************************************************************************************************************
 * 网络组包发送函数
 * 输入：空
 * 输出：空
 * 处理：将相关信息组包之后进行按一定频率发送，每次调用间隔为1s
***********************************************************************************************************************/
static void TcpDataInfoAssembleSend()
{
    OsaUtcTimeTValue TimeStracture;

    INT8 snr = 0;
    INT8 rsnr = 0;

    UINT16 DataLen = 0;
    UINT16 BattSendFreq = 30;
    UINT8 GpsSendFreq = 30;

    UINT16 year;
    UINT8 month, day, hour, minute, sec;
    UTC8TimeType UTC8TimeTcp;
    UINT8 i = 0;
    INT16 len = -1;
    UINT8 *SendBuffer = NULL;
    appGetSignalInfoSync(&csq, &snr, &rsnr);
    BattSendFreq = AppDataInfo.BattInfoSendFreqNomal;
    GpsSendFreq = AppDataInfo.PosInfoSendFreqNormal;
    if (getbit(PadInterrupt, 3) == 1 || getbit(PadInterrupt, 4) == 1) //有震动产生,提高位置信息发送频率
    {
        GpsSendFreq = AppDataInfo.PosInfoSendFreqHigh;
        if (send_counter % 10 == 0)
        {
            clrbit(PadInterrupt, 3);
            clrbit(PadInterrupt, 4);
        }
    }

    if (BattWorkStateDelay == BATT_IDLE_SYM)
    {
        BattSendFreq = 10 * 60;
    }
    else
    {
        BattSendFreq = 10;
    }
    /*
    if(FALSE)
    {
        UINT16 ErrorTemp = 0x00;
        UINT8 ProtocolHeaderLen = 25;       //电池信息协议头部加校验码长度，此长度不更改
        UINT8 ProtocolFixedLen = 60;        //电池信息协议固定总长度 如协议新增，需要更改此长度
        UINT8 ProtocolFluctedLen = AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + BMS_OTHER_TEMP + NB_OTHER_TEMP_NUM;//电池信息协议变动长度
        SendBuffer = malloc(ProtocolFixedLen + ProtocolFluctedLen);
        if(SendBuffer==NULL)
        {
            return;
        }
        appGetSystemTimeUtcSync(&TimeStracture);
        year=(TimeStracture.UTCtimer1&0xffff0000)>>16;
        month=(TimeStracture.UTCtimer1&0xff00)>>8;
        day=TimeStracture.UTCtimer1&0xff;
        hour=(TimeStracture.UTCtimer2&0xff000000)>>24;
        minute=(TimeStracture.UTCtimer2&0xff0000)>>16;
        sec=(TimeStracture.UTCtimer2&0xff00)>>8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp,year,month,day,hour,minute,sec);
        appGetSignalInfoSync(&csq,&snr,&rsnr);
        *(SendBuffer + 0 ) = TCP_START_SYM1;                        //起始码-1
        *(SendBuffer + 1 ) = TCP_START_SYM2;                        //起始码-2
        *(SendBuffer + 2 ) = TCP_CMD_SYM;                           //命令标识-3
        *(SendBuffer + 3 ) = TCP_ANS_SYM;                           //应答标识-4
        memcpy(SendBuffer + 4,AppNVMData.battSN,BATT_SN_LEN);       //SN码 5-21
        *(SendBuffer + 21 ) = TCP_ENCPT_DISABLE;                    //加密方式-22
        DataLen = ProtocolFixedLen + ProtocolFluctedLen -ProtocolHeaderLen;        //电池信息单元协议固定长度
        *(SendBuffer + 22 ) = (DataLen>>8) & 0xFF;                  //数据长度H-23
        *(SendBuffer + 23 ) = DataLen & 0xFF;                       //数据长度L-24
        *(SendBuffer + 24 ) = (UTC8TimeTcp.year - 0x07D0) & 0xFF; 	//year-25
        *(SendBuffer + 25 ) = UTC8TimeTcp.month & 0xFF;				//month-26
        *(SendBuffer + 26 ) = UTC8TimeTcp.day & 0xFF;				//day-27
        *(SendBuffer + 27 ) = UTC8TimeTcp.hour & 0xFF; 			    //hour-28
        *(SendBuffer + 28 ) = UTC8TimeTcp.minute & 0xFF;			//mins-29
        *(SendBuffer + 29 ) = UTC8TimeTcp.second & 0xFF;			//sec-30
        *(SendBuffer + 30 ) = BATTMSG;                              //电池信息发送-31
        *(SendBuffer + 31 ) = (UTC8TimeTcp.year - 0x07D0) & 0xFF; 	//year-32
        *(SendBuffer + 32 ) = UTC8TimeTcp.month & 0xFF;				//month-33
        *(SendBuffer + 33 ) = UTC8TimeTcp.day & 0xFF;				//day-34
        *(SendBuffer + 34 ) = UTC8TimeTcp.hour & 0xFF; 			    //hour-35
        *(SendBuffer + 35 ) = UTC8TimeTcp.minute & 0xFF;			//mins-36
        *(SendBuffer + 36 ) = UTC8TimeTcp.second & 0xFF;			//sec-37
        *(SendBuffer + 37 ) = csq;                                  //信号强度-38
        *(SendBuffer + 38 ) = 0x00;                                 //故障等级-39
        if(osOK==osMutexAcquire(Error_Mutex, 100))
        {
            ErrorTemp = GetErrorNum((UINT16 *)ErrorNum,sizeof(ErrorNum));
        }
        else
        {
            ErrorTemp = 0x0000;
        }
        osMutexRelease(Error_Mutex);
        *(SendBuffer + 39 ) = ErrorTemp>>8;                         //故障代码H-40
        *(SendBuffer + 40 ) = ErrorTemp & 0xFF;                     //故障代码L-41
        *(SendBuffer + 41 ) = battI>>8;                             //电流-42
        *(SendBuffer + 42 ) = battI & 0xFF;                         //电流-43
        *(SendBuffer + 43 ) = battPackVol >> 8;                     //电压-44
        *(SendBuffer + 44 ) = battPackVol & 0xFF;                   //电压-45
        *(SendBuffer + 45 ) = battPackVol >> 8;                     //电压-46
        *(SendBuffer + 46 ) = battPackVol & 0xFF;                   //电压-47
        *(SendBuffer + 47 ) = battMOSSwitchState;                   //mos状态-48
        *(SendBuffer + 48 ) = battSOC;                              //soc-49
        *(SendBuffer + 49 ) = battSOH;                              //soh-50
        *(SendBuffer + 50 ) = (battBalanceoInfo>>24)&0xFF;
        *(SendBuffer + 51 ) = (battBalanceoInfo>>16)&0xFF;
        *(SendBuffer + 52 ) = (battBalanceoInfo>>8)&0xFF;
        *(SendBuffer + 53 ) = battBalanceoInfo&0xFF;          //均衡状态-51-54
        *(SendBuffer + 54 ) = AppNVMData.BattCellCount;             //电压个数-55
        for(i=0;i<AppNVMData.BattCellCount;i++)                     //单体电压 
		{
			*(SendBuffer + 54 + i*2 + 1)  = (battCellU[i]>>8) & 0xFF;
			*(SendBuffer + 54 + i*2 + 2) = battCellU[i] & 0xFF;
		}
        *(SendBuffer + 55 + AppNVMData.BattCellCount*2) = AppNVMData.BattTempCount;                                     //模组温度个数
        memcpy((SendBuffer + 55 + AppNVMData.BattCellCount*2 + 1),&battCellTemp,AppNVMData.BattTempCount);                  //模组温度
        *(SendBuffer + 56 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount) = battWorkState;                         //电池工作状态
        *(SendBuffer + 57 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount) = battHeatEnableState;               //电池加热使能
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount) =  BMS_OTHER_TEMP+NB_OTHER_TEMP_NUM; //其他温度个数
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 1 ) = MOSTemp;                           //mos温度
		*(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 2 ) = packTemp;                          //环境温度
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 3 ) = fastChargeTemp;                    //快充温度
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 4) = normalChargeTemp;                  //慢充温度
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 5) = heatTemp1;                         //加热温度1
        *(SendBuffer + 58 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount + 6) = heatTemp2;                         //加热温度2
        *(SendBuffer + 59 + AppNVMData.BattCellCount*2 + AppNVMData.BattTempCount +  BMS_OTHER_TEMP+NB_OTHER_TEMP_NUM) = bcc_chk(SendBuffer, ProtocolFixedLen + ProtocolFluctedLen - 1 );//校验码                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   
        if(UartRecvFlag)
        {
            len = tcpipConnectionSend(socContext.id, SendBuffer, ProtocolFixedLen + ProtocolFluctedLen, 0, 0, 0);
            #ifdef USING_PRINTF1
                printf("Batt-[%d]:\n",len);
            #endif
            if(len>0)
            {
                TcpSendLen = 0x02 | TcpSendLen;
            }
            else
            {
                TcpSendLen = 0xFD & TcpSendLen;
                sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
            }
        }
        if(SendBuffer!=NULL)
        {
            free(SendBuffer);
        }
        SendBuffer=NULL;
    }
    */
    GpsSendFreq = min(3 * 60, BattSendFreq);
    if (send_counter % GpsSendFreq == 0 && send_counter != 0)
    {
        osMessageQueueReset(GpsRecvHandle);
        GPSInfo *GpsRecvData = NULL;
        GPSMsgtoTcpType GpsToTcpInfo;
        UINT16 tac = 0;
        UINT32 cellId = 0;
        appGetLocationInfoSync(&tac, &cellId);
        appGetSystemTimeUtcSync(&TimeStracture);
        year = (TimeStracture.UTCtimer1 & 0xffff0000) >> 16;
        month = (TimeStracture.UTCtimer1 & 0xff00) >> 8;
        day = TimeStracture.UTCtimer1 & 0xff;
        hour = (TimeStracture.UTCtimer2 & 0xff000000) >> 24;
        minute = (TimeStracture.UTCtimer2 & 0xff0000) >> 16;
        sec = (TimeStracture.UTCtimer2 & 0xff00) >> 8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp, year, month, day, hour, minute, sec);
        DataLen = (UINT16)sizeof(GpsToTcpInfo.gpsInfo);
        GpsToTcpInfo.startSymbol[0] = TCP_START_SYM1;
        GpsToTcpInfo.startSymbol[1] = TCP_START_SYM2;
        GpsToTcpInfo.cmdSymbol = TCP_CMD_SYM;
        GpsToTcpInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(GpsToTcpInfo.SN, AppNVMData.battSN, BATT_SN_LEN);
        GpsToTcpInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
        GpsToTcpInfo.dataLength[0] = (DataLen >> 8) & 0xFF;
        GpsToTcpInfo.dataLength[1] = DataLen & 0xFF;
        GpsToTcpInfo.gpsInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF; //year
        GpsToTcpInfo.gpsInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;           //month
        GpsToTcpInfo.gpsInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;             //day
        GpsToTcpInfo.gpsInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;            //hour
        GpsToTcpInfo.gpsInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;          //mins
        GpsToTcpInfo.gpsInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;          //sec
        GpsToTcpInfo.gpsInfo.msgMark = GPSMSG;
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF; //year
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[1] = UTC8TimeTcp.month & 0xFF;           //month
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[2] = UTC8TimeTcp.day & 0xFF;             //day
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;            //hour
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;          //mins
        GpsToTcpInfo.gpsInfo.msgCollectionTimeUTC[5] = UTC8TimeTcp.second & 0xFF;
        osStatus_t ret = osMessageQueueGet(GpsRecvHandle, &GpsRecvData, 0, 2000);
        if (ret == 0)
        {
            memcpy((UINT8 *)&GpsToTcpInfo.gpsInfo.locateMark, GpsRecvData, sizeof(GPSInfo));
            GpsToTcpInfo.gpsInfo.Tac[0] = tac >> 8;
            GpsToTcpInfo.gpsInfo.Tac[1] = tac & 0xFF;
            GpsToTcpInfo.gpsInfo.CellID[0] = cellId >> 24;
            GpsToTcpInfo.gpsInfo.CellID[0] = cellId >> 16;
            GpsToTcpInfo.gpsInfo.CellID[0] = cellId >> 8;
            GpsToTcpInfo.gpsInfo.CellID[0] = cellId;
            GpsToTcpInfo.CRC = bcc_chk((UINT8 *)&GpsToTcpInfo, sizeof(GPSMsgtoTcpType) - 1);
            //if(GpsToTcpInfo.gpsInfo.locateMark==0x01)
            if (1)
            {
                len = tcpipConnectionSend(socContext.id, (UINT8 *)&GpsToTcpInfo, sizeof(GpsToTcpInfo), 0, 0, 0);
#ifdef USING_PRINTF1
                for (int i = 0; i < sizeof(GpsToTcpInfo); i++)
                {
                    printf("%02x ", *((UINT8 *)&GpsToTcpInfo + i));
                }
                printf("-[%d]-Gpslen:%d\n", __LINE__, len);
#endif
                if (len > 0)
                {
                    TcpSendLen = 0x04 | TcpSendLen;
                }
                else
                {
                    TcpSendLen = 0xFB & TcpSendLen;
                    sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
                }
            }
        }
        if (GpsRecvData != NULL)
            free(GpsRecvData);
        GpsRecvData = NULL;
    }
    if (send_counter == 1) //版本信息上报 上报频率为每次重启后上报或者每次更新后上报或者每天上报一次均可
    {
        VersionMsgtoTcpType VerMsgToTcpInfo;
        CHAR iccid[20];
        CHAR imei[15];
        appGetIccidNumSync(iccid);
        appGetImeiNumSync(imei);
        // CHAR *verData = NULL;
        // verData = appGetNBVersionInfo();
        // #ifdef USING_PRINTF
        //     printf("verData:%s\n",verData);
        // #endif
        appGetSystemTimeUtcSync(&TimeStracture);
        year = (TimeStracture.UTCtimer1 & 0xffff0000) >> 16;
        month = (TimeStracture.UTCtimer1 & 0xff00) >> 8;
        day = TimeStracture.UTCtimer1 & 0xff;
        hour = (TimeStracture.UTCtimer2 & 0xff000000) >> 24;
        minute = (TimeStracture.UTCtimer2 & 0xff0000) >> 16;
        sec = (TimeStracture.UTCtimer2 & 0xff00) >> 8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp, year, month, day, hour, minute, sec);
        DataLen = (UINT16)sizeof(VerMsgToTcpInfo.VerInfo);
        VerMsgToTcpInfo.startSymbol[0] = TCP_START_SYM1;
        VerMsgToTcpInfo.startSymbol[1] = TCP_START_SYM2;
        VerMsgToTcpInfo.cmdSymbol = TCP_CMD_SYM;
        VerMsgToTcpInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(VerMsgToTcpInfo.SN, AppNVMData.battSN, BATT_SN_LEN);
        VerMsgToTcpInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
        VerMsgToTcpInfo.dataLength[0] = (DataLen >> 8) & 0xFF;
        VerMsgToTcpInfo.dataLength[1] = DataLen & 0xFF;
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF; //year
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;           //month
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;             //day
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;            //hour
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;          //mins
        VerMsgToTcpInfo.VerInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;          //sec
        VerMsgToTcpInfo.VerInfo.msgMark = VERSIONMSG;
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF; //year
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[1] = UTC8TimeTcp.month & 0xFF;           //month
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[2] = UTC8TimeTcp.day & 0xFF;             //day
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;            //hour
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;          //mins
        VerMsgToTcpInfo.VerInfo.msgCollectionTimeUTC[5] = UTC8TimeTcp.second & 0xFF;
        memcpy(VerMsgToTcpInfo.VerInfo.ICCID, iccid, 20);
        memcpy(VerMsgToTcpInfo.VerInfo.IMEI, imei, 15);
        VerMsgToTcpInfo.VerInfo.BMSHwVersion[0] = AppNVMData.BmsHwVersion / 10;
        VerMsgToTcpInfo.VerInfo.BMSHwVersion[1] = AppNVMData.BmsHwVersion % 10;
        VerMsgToTcpInfo.VerInfo.BMSSwVersion[0] = 0;
        VerMsgToTcpInfo.VerInfo.BMSSwVersion[1] = 0;
        VerMsgToTcpInfo.VerInfo.BMSSwVersion[2] = AppNVMData.BmsSwVersion / 10;
        VerMsgToTcpInfo.VerInfo.BMSSwVersion[3] = AppNVMData.BmsSwVersion % 10;
        VerMsgToTcpInfo.VerInfo.NBHwVersion[0] = (HWVERSION >> 8) & 0xFF;
        VerMsgToTcpInfo.VerInfo.NBHwVersion[1] = (HWVERSION)&0xFF;
        VerMsgToTcpInfo.VerInfo.BLVersion[0] = (BLSWVERSION >> 24) & 0xFF;
        VerMsgToTcpInfo.VerInfo.BLVersion[1] = (BLSWVERSION >> 16) & 0xFF;
        VerMsgToTcpInfo.VerInfo.BLVersion[2] = (BLSWVERSION >> 8) & 0xFF;
        VerMsgToTcpInfo.VerInfo.BLVersion[3] = (BLSWVERSION)&0xFF;
        VerMsgToTcpInfo.VerInfo.DRVVersion[0] = (DRVSWVERSION >> 24) & 0xFF;
        VerMsgToTcpInfo.VerInfo.DRVVersion[1] = (DRVSWVERSION >> 16) & 0xFF;
        VerMsgToTcpInfo.VerInfo.DRVVersion[2] = (DRVSWVERSION >> 8) & 0xFF;
        VerMsgToTcpInfo.VerInfo.DRVVersion[3] = (DRVSWVERSION)&0xFF;
        VerMsgToTcpInfo.VerInfo.APPVersion[0] = (APPSWVERSION >> 24) & 0xFF;
        VerMsgToTcpInfo.VerInfo.APPVersion[1] = (APPSWVERSION >> 16) & 0xFF;
        VerMsgToTcpInfo.VerInfo.APPVersion[2] = (APPSWVERSION >> 8) & 0xFF;
        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);
        if (NB_Fota_update_flag == FALSE)
        {
            len = tcpipConnectionSend(socContext.id, (UINT8 *)&VerMsgToTcpInfo, sizeof(VerMsgToTcpInfo), 0, 0, 0);
            if (len > 0)
            {
                TcpSendLen = 0x01 | TcpSendLen;
            }
            else
            {
                TcpSendLen = 0xFE & TcpSendLen;
                sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
            }
        }
    }
    if ((send_counter) % (BattSendFreq * 3) == 0) //90发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year = (TimeStracture.UTCtimer1 & 0xffff0000) >> 16;
        month = (TimeStracture.UTCtimer1 & 0xff00) >> 8;
        day = TimeStracture.UTCtimer1 & 0xff;
        hour = (TimeStracture.UTCtimer2 & 0xff000000) >> 24;
        minute = (TimeStracture.UTCtimer2 & 0xff0000) >> 16;
        sec = (TimeStracture.UTCtimer2 & 0xff00) >> 8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp, year, month, day, hour, minute, sec);
        UINT8 Tcptype = 0x90;
        UINT16 BufferLen = 0x56;
        SendBuffer = malloc(BufferLen);
        TcpDataAssemble(Tcptype, SendBuffer, UTC8TimeTcp);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen, 0, 0, 0);
#ifdef USING_PRINTF1
        printf("[%d]DebugMsg-[%d]:\n", __LINE__, len);
        for (UINT16 i = 0; i < BufferLen; i++)
        {
            printf("%02x ", *(SendBuffer + i));
        }
        printf("[%d]\n", __LINE__);
#endif
        if (SendBuffer != NULL)
        {
            free(SendBuffer);
        }
        SendBuffer = NULL;
        if (len > 0)
        {
            ;
        }
        else
        {
            sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
        }
    }
    if ((send_counter - 1) % BattSendFreq == 0) //91发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year = (TimeStracture.UTCtimer1 & 0xffff0000) >> 16;
        month = (TimeStracture.UTCtimer1 & 0xff00) >> 8;
        day = TimeStracture.UTCtimer1 & 0xff;
        hour = (TimeStracture.UTCtimer2 & 0xff000000) >> 24;
        minute = (TimeStracture.UTCtimer2 & 0xff0000) >> 16;
        sec = (TimeStracture.UTCtimer2 & 0xff00) >> 8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp, year, month, day, hour, minute, sec);
        UINT8 Tcptype = 0x91;
        UINT16 BufferLen = 0x54 + CELL_NUM * 2 + CELL_TEMP_NUM;
        SendBuffer = malloc(BufferLen);
        TcpDataAssemble(Tcptype, SendBuffer, UTC8TimeTcp);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen, 0, 0, 0);
#ifdef USING_PRINTF1
        printf("[%d]0x91-[%d]:\n", __LINE__, len);
        for (UINT16 i = 0; i < BufferLen; i++)
        {
            printf("%02x ", *(SendBuffer + i));
        }
        printf("[%d]\n", __LINE__);
#endif
        if (SendBuffer != NULL)
        {
            free(SendBuffer);
        }
        SendBuffer = NULL;
        if (len > 0)
        {
            ;
        }
        else
        {
            sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
        }
    }
    if ((send_counter - 2) % (BattSendFreq * 4) == 0) //92发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year = (TimeStracture.UTCtimer1 & 0xffff0000) >> 16;
        month = (TimeStracture.UTCtimer1 & 0xff00) >> 8;
        day = TimeStracture.UTCtimer1 & 0xff;
        hour = (TimeStracture.UTCtimer2 & 0xff000000) >> 24;
        minute = (TimeStracture.UTCtimer2 & 0xff0000) >> 16;
        sec = (TimeStracture.UTCtimer2 & 0xff00) >> 8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp, year, month, day, hour, minute, sec);
        UINT8 Tcptype = 0x92;
        UINT16 BufferLen = 0x4E;
        SendBuffer = malloc(BufferLen);
        TcpDataAssemble(Tcptype, SendBuffer, UTC8TimeTcp);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen, 0, 0, 0);
#ifdef USING_PRINTF1
        printf("[%d]DebugMsg-[%d]:\n", __LINE__, len);
        for (UINT16 i = 0; i < BufferLen; i++)
        {
            printf("%02x ", *(SendBuffer + i));
        }
        printf("[%d]\n", __LINE__);
#endif
        if (SendBuffer != NULL)
        {
            free(SendBuffer);
        }
        SendBuffer = NULL;
        if (len > 0)
        {
            ;
        }
        else
        {
            sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
        }
    }
    /*调试信息字符发送形式，但是发送流量会大2倍
    if((send_counter)%10==0)//90发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year=(TimeStracture.UTCtimer1&0xffff0000)>>16;
        month=(TimeStracture.UTCtimer1&0xff00)>>8;
        day=TimeStracture.UTCtimer1&0xff;
        hour=(TimeStracture.UTCtimer2&0xff000000)>>24;
        minute=(TimeStracture.UTCtimer2&0xff0000)>>16;
        sec=(TimeStracture.UTCtimer2&0xff00)>>8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp,year,month,day,hour,minute,sec);
        DebugMsgtoTcpType DebugMsgInfo;
        UINT8 Tcptype =0x90;
        UINT16 BufferLen1 = 0x55,BufferLen = 0;
        UINT8 *rbuf = NULL;
        rbuf = malloc(BufferLen1);
        BufferLen = BufferLen1*2;
        SendBuffer = malloc(BufferLen+sizeof(DebugMsgInfo));
        TcpDataAssemble(Tcptype,rbuf,UTC8TimeTcp);
        for(UINT16 i=0;i<BufferLen1;i++)
        {
            sprintf((char *)(SendBuffer+sizeof(DebugMsgInfo)-1+i*2),"%02x",*(rbuf+i));
        }
        if(rbuf!=NULL)
        {
            free(rbuf);
        }
        rbuf=NULL;
        DataLen=sizeof(DebugMsgInfo.DebugInfo) + BufferLen;
        DebugMsgInfo.startSymbol[0] = TCP_START_SYM1;
	    DebugMsgInfo.startSymbol[1] = TCP_START_SYM2;
	    DebugMsgInfo.cmdSymbol = TCP_CMD_SYM;
	    DebugMsgInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(DebugMsgInfo.SN, AppNVMData.battSN,BATT_SN_LEN);
        DebugMsgInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
	    DebugMsgInfo.dataLength[0] = (DataLen>>8) & 0xFF;
	    DebugMsgInfo.dataLength[1] = DataLen & 0xFF;
        DebugMsgInfo.DebugInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF;	//year
        DebugMsgInfo.DebugInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;								//month
        DebugMsgInfo.DebugInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;									//day
        DebugMsgInfo.DebugInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;  						    //hour
        DebugMsgInfo.DebugInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;						    //mins
        DebugMsgInfo.DebugInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;							//sec
        DebugMsgInfo.DebugInfo.msgMark = DEBUGMSG;
        DebugMsgInfo.DebugInfo.DebugLen[0] = BufferLen>>8;
        DebugMsgInfo.DebugInfo.DebugLen[1] = BufferLen;
        memcpy(SendBuffer,(UINT8 *)&DebugMsgInfo,sizeof(DebugMsgInfo)-1);
        DebugMsgInfo.CRC = bcc_chk(SendBuffer, BufferLen+sizeof(DebugMsgInfo)-1);
        memcpy(SendBuffer+BufferLen+sizeof(DebugMsgInfo)-1,&DebugMsgInfo.CRC,1);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen+sizeof(DebugMsgInfo), 0, 0, 0);
        #ifdef USING_PRINTF
            printf("[%d]DebugMsg-[%d]-[%d]:\n",__LINE__,BufferLen,len);
        #endif
        #ifdef USING_PRINTF1
            printf("[%d]DebugMsg-[%d]:\n",__LINE__,len);
            for (UINT16 i = 0; i < BufferLen*2+sizeof(DebugMsgInfo); i++)
            {
                printf("%02x ",*(SendBuffer + i));
            }
        #endif
        if(SendBuffer!=NULL)
        {
            free(SendBuffer);
        }
        SendBuffer=NULL;
    }
    if((send_counter+1)%10==0)//91发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year=(TimeStracture.UTCtimer1&0xffff0000)>>16;
        month=(TimeStracture.UTCtimer1&0xff00)>>8;
        day=TimeStracture.UTCtimer1&0xff;
        hour=(TimeStracture.UTCtimer2&0xff000000)>>24;
        minute=(TimeStracture.UTCtimer2&0xff0000)>>16;
        sec=(TimeStracture.UTCtimer2&0xff00)>>8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp,year,month,day,hour,minute,sec);
        DebugMsgtoTcpType DebugMsgInfo;
        UINT8 Tcptype =0x91;
        UINT16 BufferLen1 = 0x53 + numOfCells*2 + numOfCellTemp,BufferLen = 0;
        UINT8 *rbuf = NULL;
        BufferLen = BufferLen1*2;
        rbuf = malloc(BufferLen1);
        SendBuffer = malloc(BufferLen+sizeof(DebugMsgInfo));
        TcpDataAssemble(Tcptype,rbuf,UTC8TimeTcp);
        for(UINT16 i=0;i<BufferLen1;i++)
        {
            sprintf((char *)(SendBuffer+sizeof(DebugMsgInfo)-1+i*2),"%02x",*(rbuf+i));
        }
        if(rbuf!=NULL)
        {
            free(rbuf);
        }
        rbuf=NULL;
        DataLen=sizeof(DebugMsgInfo.DebugInfo) + BufferLen;
        DebugMsgInfo.startSymbol[0] = TCP_START_SYM1;
	    DebugMsgInfo.startSymbol[1] = TCP_START_SYM2;
	    DebugMsgInfo.cmdSymbol = TCP_CMD_SYM;
	    DebugMsgInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(DebugMsgInfo.SN, AppNVMData.battSN,BATT_SN_LEN);
        DebugMsgInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
	    DebugMsgInfo.dataLength[0] = (DataLen>>8) & 0xFF;
	    DebugMsgInfo.dataLength[1] = DataLen & 0xFF;
        DebugMsgInfo.DebugInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF;	//year
        DebugMsgInfo.DebugInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;								//month
        DebugMsgInfo.DebugInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;									//day
        DebugMsgInfo.DebugInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;  						    //hour
        DebugMsgInfo.DebugInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;						    //mins
        DebugMsgInfo.DebugInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;							//sec
        DebugMsgInfo.DebugInfo.msgMark = DEBUGMSG;
        DebugMsgInfo.DebugInfo.DebugLen[0] = BufferLen>>8;
        DebugMsgInfo.DebugInfo.DebugLen[1] = BufferLen;
        memcpy(SendBuffer,(UINT8 *)&DebugMsgInfo,sizeof(DebugMsgInfo)-1);
        DebugMsgInfo.CRC = bcc_chk(SendBuffer, BufferLen+sizeof(DebugMsgInfo)-1);
        memcpy(SendBuffer+BufferLen+sizeof(DebugMsgInfo)-1,&DebugMsgInfo.CRC,1);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen+sizeof(DebugMsgInfo), 0, 0, 0);
        #ifdef USING_PRINTF
            printf("[%d]DebugMsg-[%d]-[%d]:\n",__LINE__,BufferLen,len);
        #endif
        #ifdef USING_PRINTF1
            printf("[%d]DebugMsg-[%d]:\n",__LINE__,len);
            for (UINT16 i = 0; i < BufferLen*2+sizeof(DebugMsgInfo); i++)
            {
                printf("%c ",*(SendBuffer + i));
            }
        #endif
        if(SendBuffer!=NULL)
        {
            free(SendBuffer);
        }
        SendBuffer=NULL;
    }
    if((send_counter+2)%60==0)//92发送
    {
        appGetSystemTimeUtcSync(&TimeStracture);
        year=(TimeStracture.UTCtimer1&0xffff0000)>>16;
        month=(TimeStracture.UTCtimer1&0xff00)>>8;
        day=TimeStracture.UTCtimer1&0xff;
        hour=(TimeStracture.UTCtimer2&0xff000000)>>24;
        minute=(TimeStracture.UTCtimer2&0xff0000)>>16;
        sec=(TimeStracture.UTCtimer2&0xff00)>>8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp,year,month,day,hour,minute,sec);
        DebugMsgtoTcpType DebugMsgInfo;
        UINT8 Tcptype =0x92;
        UINT16 BufferLen1 = 0x4D,BufferLen = 0;
        UINT8 *rbuf = NULL;
        rbuf = malloc(BufferLen1);
        BufferLen = BufferLen1*2;
        SendBuffer = malloc(BufferLen+sizeof(DebugMsgInfo));
        TcpDataAssemble(Tcptype,rbuf,UTC8TimeTcp);
        for(UINT16 i=0;i<BufferLen1;i++)
        {
            sprintf((char *)(SendBuffer+sizeof(DebugMsgInfo)-1+i*2),"%02x",*(rbuf+i));
        }
        if(rbuf!=NULL)
        {
            free(rbuf);
        }
        rbuf=NULL;
        #ifdef USING_PRINTF
            printf("[%d]DebugMsg-[%d]:\n",__LINE__,BufferLen);
        #endif        
        DataLen=sizeof(DebugMsgInfo.DebugInfo) + BufferLen;
        DebugMsgInfo.startSymbol[0] = TCP_START_SYM1;
	    DebugMsgInfo.startSymbol[1] = TCP_START_SYM2;
	    DebugMsgInfo.cmdSymbol = TCP_CMD_SYM;
	    DebugMsgInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(DebugMsgInfo.SN, AppNVMData.battSN,BATT_SN_LEN);
        DebugMsgInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
	    DebugMsgInfo.dataLength[0] = (DataLen>>8) & 0xFF;
	    DebugMsgInfo.dataLength[1] = DataLen & 0xFF;
        DebugMsgInfo.DebugInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF;	//year
        DebugMsgInfo.DebugInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;								//month
        DebugMsgInfo.DebugInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;									//day
        DebugMsgInfo.DebugInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;  						    //hour
        DebugMsgInfo.DebugInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;						    //mins
        DebugMsgInfo.DebugInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;							//sec
        DebugMsgInfo.DebugInfo.msgMark = DEBUGMSG;
        DebugMsgInfo.DebugInfo.DebugLen[0] = BufferLen>>8;
        DebugMsgInfo.DebugInfo.DebugLen[1] = BufferLen;
        memcpy(SendBuffer,(UINT8 *)&DebugMsgInfo,sizeof(DebugMsgInfo)-1);
        DebugMsgInfo.CRC = bcc_chk(SendBuffer, BufferLen+sizeof(DebugMsgInfo)-1);
        memcpy(SendBuffer+BufferLen+sizeof(DebugMsgInfo)-1,&DebugMsgInfo.CRC,1);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen+sizeof(DebugMsgInfo), 0, 0, 0);
        #ifdef USING_PRINTF1
            printf("[%d]DebugMsg-[%d]:\n",__LINE__,len);
            for (UINT16 i = 0; i < BufferLen*2+sizeof(DebugMsgInfo); i++)
            {
                printf("%c ",*(SendBuffer + i));
            }
        #endif
        if(SendBuffer!=NULL)
        {
            free(SendBuffer);
        }
        SendBuffer=NULL;
    }
    */
    /*
    if(FALSE)//调试信息暂时不发，需调整之后发送
    {
        DebugMsgtoTcpType DebugMsgInfo;
        UINT16 BufferLen = 0;
        slpManWakeSrc_e Wakeup_source;
        Wakeup_source =  slpManGetWakeupSrc();//获取唤醒源
        #ifdef DEBUGLOG
            Debug_printf("[%d]\n",Wakeup_source);
        #endif
        BufferLen = Debug_GetSize();
        if(BufferLen==0)
        {
            send_counter++;
            return;
        }
        else if(BufferLen>200)
        {
            Debug_Del_Logfile();
            #ifdef DEBUGLOG
                Debug_printf("oversize-Sys:%d\n",AppDataInfo.SysReStartCount);
            #endif
            BufferLen = Debug_GetSize();
        }
        UINT8 rbuf[BufferLen];
        Debug_Read_Logfile(rbuf,BufferLen);
        SendBuffer = malloc(BufferLen+sizeof(DebugMsgInfo));
        memcpy(SendBuffer+sizeof(DebugMsgInfo)-1, rbuf,BufferLen);
        appGetSystemTimeUtcSync(&TimeStracture);
        year=(TimeStracture.UTCtimer1&0xffff0000)>>16;
        month=(TimeStracture.UTCtimer1&0xff00)>>8;
        day=TimeStracture.UTCtimer1&0xff;
        hour=(TimeStracture.UTCtimer2&0xff000000)>>24;
        minute=(TimeStracture.UTCtimer2&0xff0000)>>16;
        sec=(TimeStracture.UTCtimer2&0xff00)>>8;
        UTCToBeijing((UTC8TimeType *)&UTC8TimeTcp,year,month,day,hour,minute,sec);
        DataLen=sizeof(DebugMsgInfo.DebugInfo) + BufferLen;
        DebugMsgInfo.startSymbol[0] = TCP_START_SYM1;
	    DebugMsgInfo.startSymbol[1] = TCP_START_SYM2;
	    DebugMsgInfo.cmdSymbol = TCP_CMD_SYM;
	    DebugMsgInfo.ansSymbol = TCP_ANS_SYM;
        memcpy(DebugMsgInfo.SN, AppNVMData.battSN,BATT_SN_LEN);
        DebugMsgInfo.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
	    DebugMsgInfo.dataLength[0] = (DataLen>>8) & 0xFF;
	    DebugMsgInfo.dataLength[1] = DataLen & 0xFF;
        DebugMsgInfo.DebugInfo.sendTimeUTC[0] = (UTC8TimeTcp.year - 0x07D0) & 0xFF;	//year
        DebugMsgInfo.DebugInfo.sendTimeUTC[1] = UTC8TimeTcp.month & 0xFF;								//month
        DebugMsgInfo.DebugInfo.sendTimeUTC[2] = UTC8TimeTcp.day & 0xFF;									//day
        DebugMsgInfo.DebugInfo.sendTimeUTC[3] = UTC8TimeTcp.hour & 0xFF;  						    //hour
        DebugMsgInfo.DebugInfo.sendTimeUTC[4] = UTC8TimeTcp.minute & 0xFF;						    //mins
        DebugMsgInfo.DebugInfo.sendTimeUTC[5] = UTC8TimeTcp.second & 0xFF;							//sec
        DebugMsgInfo.DebugInfo.msgMark = DEBUGMSG;
        DebugMsgInfo.DebugInfo.DebugLen[0] = BufferLen>>8;
        DebugMsgInfo.DebugInfo.DebugLen[1] = BufferLen;
        memcpy(SendBuffer,(UINT8 *)&DebugMsgInfo,sizeof(DebugMsgInfo)-1);
        DebugMsgInfo.CRC = bcc_chk(SendBuffer, BufferLen+sizeof(DebugMsgInfo)-1);
        memcpy(SendBuffer+BufferLen+sizeof(DebugMsgInfo)-1,&DebugMsgInfo.CRC,1);
        len = tcpipConnectionSend(socContext.id, SendBuffer, BufferLen+sizeof(DebugMsgInfo), 0, 0, 0);
        #ifdef USING_PRINTF1
            printf("DebugMsg-[%d]:\n",len);
            // for (int i = 0; i < BufferLen+sizeof(DebugMsgInfo); i++)
            // {
            //     printf("%02x ",*(SendBuffer + i));
            // }
        #endif
        if(len>0)
        {
            Debug_Del_Logfile();
        }
        if(SendBuffer!=NULL)
        {
            free(SendBuffer);
        }
        SendBuffer=NULL;
    }
    */
    if (send_counter > 0xffff)
    {
        send_counter = 0;
    }
    else
    {
        send_counter++;
    }
}
static void TcpHeartDataSend()
{
    UINT8 len = 0;
    HeartMsgtoTcpType HeartMsgToTcp;
    HeartMsgToTcp.startSymbol[0] = TCP_START_SYM1;
    HeartMsgToTcp.startSymbol[1] = TCP_START_SYM2;
    HeartMsgToTcp.cmdSymbol = TCP_HEART_SYM;
    HeartMsgToTcp.ansSymbol = TCP_ANS_SYM;
    memcpy(HeartMsgToTcp.SN, AppNVMData.battSN, BATT_SN_LEN);
    HeartMsgToTcp.encryptMethod = TCP_ENCPT_DISABLE; //not encrypt
    HeartMsgToTcp.dataLength[0] = 0;
    HeartMsgToTcp.dataLength[1] = 0;
    HeartMsgToTcp.CRC = bcc_chk((UINT8 *)&HeartMsgToTcp, sizeof(HeartMsgToTcp) - 1);
    len = tcpipConnectionSend(socContext.id, (UINT8 *)&HeartMsgToTcp, sizeof(HeartMsgToTcp), 0, 0, 0);
    if (len < 0)
    {
        sendQueueMsg(QMSG_ID_NW_IP_SUSPEND, 0);
    }
#ifdef USING_PRINTF1
    printf("HeartMsg-[%d]:\n", len);
    for (int i = 0; i < sizeof(HeartMsgToTcp); i++)
        printf("%02x ", *((UINT8 *)&HeartMsgToTcp + i));
#endif
}
static void TcpDataInfoRecvHandle()
{
    TcpipConnectionRecvDataInd *TcpRecvData = NULL;
    osMessageQueueGet(TcpRecvHandle, &TcpRecvData, 0, 0);
    UINT8 Tcp_Cmd;
    UINT8 *Ptr;
    UINT8 TcpCmdAnswer[31];
    TcpCmdAnswer[0] = TCP_START_SYM1;
    TcpCmdAnswer[1] = TCP_START_SYM1;
    if (TcpRecvData != NULL && TcpRecvData->length != 0)
    {
        Ptr = TcpRecvData->data;
        if ((*(Ptr + 0) == TCP_START_SYM1) && (*(Ptr + 1) == TCP_START_SYM2)) //服务器起始信息
        {
            Tcp_Cmd = *(Ptr + 2); //命令标志
            if (*(Ptr + 3) == 0xFE)
            {
                TCPWorkState = 0x01;
            }
            switch (Tcp_Cmd)
            {
            case TCP_QUERY_SYM:
                break;
            case TCP_SETCMD_SYM:
                break;
            case TCP_CONCMD_SYM:
            {
                TcpCmdAnswer[2] = TCP_CONCMD_SYM;
                if (*(Ptr + 30) == 0x01) //远程升级命令
                {
                    Fota_Func(Ptr, socContext.id);
                }
                else if (*(Ptr + 30) == 0x88) //BMS远程升级数据传输命令
                {
                    Fota_Func(Ptr, socContext.id);
                }
                else
                {
                    TcpCmdAnswer[3] = 0x0f;
                    memcpy(&TcpCmdAnswer[4], (Ptr + 4), BATT_SN_LEN);
                    TcpCmdAnswer[21] = TCP_ENCPT_DISABLE;
                    TcpCmdAnswer[22] = 0x00;
                    TcpCmdAnswer[23] = 0x06;
                    memcpy(&TcpCmdAnswer[24], (Ptr + 24), 6);
                    TcpCmdAnswer[30] = bcc_chk(TcpCmdAnswer, 30);
                    tcpipConnectionSend(socContext.id, TcpCmdAnswer, 31, 0, 0, 0);
                }
                break;
            }
            default:
            {
                break;
            }
            }
        }
        if (TcpRecvData != NULL)
        {
            free(TcpRecvData);
        }
        TcpRecvData = NULL;
    }
}
//Tcp线程初始化
void AppTaskTcpInit(void *arg)
{
    osThreadAttr_t task_attr;
    registerPSEventCallback(NB_GROUP_ALL_MASK, socketRegisterPSUrcCallback);
    memset(&task_attr, 0, sizeof(task_attr));
    memset(gProcess_Tcp_TaskStack, 0xA5, PROC_TCP_TASK_STACK_SIZE);
    task_attr.name = "Tcp_Task";
    task_attr.stack_mem = gProcess_Tcp_TaskStack;
    task_attr.stack_size = PROC_TCP_TASK_STACK_SIZE;
    task_attr.priority = osPriorityBelowNormal7;
    task_attr.cb_mem = &gProcess_Tcp_Task_t;
    task_attr.cb_size = sizeof(StaticTask_t);
    TcpTaskId = osThreadNew(TcpTask, NULL, &task_attr);
}
void AppTaskTcpDeInit(void *arg)
{
    osThreadTerminate(TcpTaskId);
    TcpTaskId = NULL;
}
//Tcp 状态转换函数
static void sendQueueMsg(UINT32 msgId, UINT32 xTickstoWait)
{
    eventCallbackMessage_t *queueMsg = NULL;
    queueMsg = malloc(sizeof(eventCallbackMessage_t));
    queueMsg->messageId = msgId;
    if (psEventQueueHandle)
    {
        if (pdTRUE != xQueueSend(psEventQueueHandle, &queueMsg, xTickstoWait))
        {
            ECOMM_TRACE(UNILOG_PLA_APP, sendQueueMsg_1, P_ERROR, 0, "xQueueSend error");
        }
    }
}
//Tcp状态注册函数
static INT32 socketRegisterPSUrcCallback(urcID_t eventID, void *param, UINT32 paramLen)
{
    CmiSimImsiStr *imsi = NULL;
    CmiPsCeregInd *cereg = NULL;

    NmAtiNetifInfo *netif = NULL;

    switch (eventID)
    {
    case NB_URC_ID_SIM_READY:
    {
        imsi = (CmiSimImsiStr *)param;
        memcpy(gImsi, imsi->contents, imsi->length);
#ifdef USING_PRINTF
        printf("SIM ready(imsi=%s)\n", (UINT8 *)imsi->contents);
#endif
        break;
    }
    case NB_URC_ID_MM_SIGQ:
    {
//rssi = *(UINT8 *)param;
#ifdef USING_PRINTF1
        printf("RSSI signal=%d\n", rssi);
#endif
        break;
    }
    case NB_URC_ID_PS_BEARER_ACTED:
    {
#ifdef USING_PRINTF
        printf("Default bearer activated\n");
#endif
        break;
    }
    case NB_URC_ID_PS_BEARER_DEACTED:
    {
#ifdef USING_PRINTF
        printf("Default bearer Deactivated\n");
#endif
        break;
    }
    case NB_URC_ID_PS_CEREG_CHANGED:
    {
        cereg = (CmiPsCeregInd *)param;
        gCellID = cereg->celId;

#ifdef USING_PRINTF
        printf("URCCallBack:CEREG changed act:%d celId:%d locPresent:%d tac:%d\n", cereg->act, cereg->celId, cereg->locPresent, cereg->tac);
#endif
        break;
    }
    case NB_URC_ID_PS_NETINFO:
    {
        netif = (NmAtiNetifInfo *)param;
        if (netif->netStatus == NM_NETIF_ACTIVATED)
            sendQueueMsg(QMSG_ID_NW_IP_READY, 0);
        break;
    }
    }
    return 0;
}
//Tcpz连接状态回调函数
static void socketAppConnectionCallBack(UINT8 connectionEventType, void *bodyEvent)
{
    switch (connectionEventType)
    {
    case TCPIP_CONNECTION_STATUS_EVENT:
    {
        TcpipConnectionStatusInd *statusInd;
        statusInd = (TcpipConnectionStatusInd *)bodyEvent;
        if (statusInd != PNULL)
        {
            if (statusInd->status == TCPIP_CONNECTION_STATUS_CLOSED)
            {
#ifdef USING_PRINTF
                printf("socketAppConnectionCallBack socket connection %u closed,cause %u", statusInd->connectionId, statusInd->cause);
#endif
                ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_1, P_ERROR, 2, "socketAppConnectionCallBack socket connection %u closed,cause %u", statusInd->connectionId, statusInd->cause);
                if (statusInd->connectionId == socContext.id)
                {
                    socContext.id = -1;
                    socContext.status = APP_SOCKET_CONNECTION_CLOSED;
                }
            }
            else if (statusInd->status == TCPIP_CONNECTION_STATUS_CONNECTING)
            {
#ifdef USING_PRINTF
                printf("socketAppConnectionCallBack socket connection %u is connecting", statusInd->connectionId);
#endif
                ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_2, P_INFO, 1, "socketAppConnectionCallBack socket connection %u is connecting", statusInd->connectionId);
                if (statusInd->connectionId == socContext.id)
                {
                    socContext.status = APP_SOCKET_CONNECTION_CONNECTING;
                }
            }
            else if (statusInd->status == TCPIP_CONNECTION_STATUS_CONNECTED)
            {
#ifdef USING_PRINTF
                printf("socketAppConnectionCallBack socket connection %u is connected", statusInd->connectionId);
#endif
                ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_3, P_ERROR, 1, "socketAppConnectionCallBack socket connection %u is connected", statusInd->connectionId);
                if (statusInd->connectionId == socContext.id)
                {
                    socContext.status = APP_SOCKET_CONNECTION_CONNECTED;
                }
            }
        }
        else
        {
#ifdef USING_PRINTF
            printf("socketAppConnectionCallBack invalid connection status event");
#endif
            ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_4, P_ERROR, 0, "socketAppConnectionCallBack invalid connection status event");
        }

        break;
    }
    case TCPIP_CONNECTION_RECEIVE_EVENT:
    {
        TcpipConnectionRecvDataInd *rcvInd = PNULL;
        TcpipConnectionRecvDataInd *rcvbuffer = NULL;
        rcvInd = (TcpipConnectionRecvDataInd *)bodyEvent;
        if (rcvInd != PNULL)
        {
            rcvbuffer = malloc(sizeof(TcpipConnectionRecvDataInd));
            memcpy(rcvbuffer, rcvInd, sizeof(TcpipConnectionRecvDataInd));
            osMessageQueuePut(TcpRecvHandle, &rcvbuffer, 0, 1000);
            sendQueueMsg(QMSG_ID_SOCK_RECVPKG, 0);
#ifdef USING_PRINTF
            // uint8_t* Ptr;
            // Ptr=rcvInd->data;
            printf("socket connection %u receive length %u data:\n", rcvInd->connectionId, rcvInd->length);
            // for(int i = 0;i<rcvInd->length;i++)
            //     printf("%x  ",*(Ptr+i));
            // printf("\n");
#endif
            ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_5, P_INFO, 2, "socketAppConnectionCallBack socket connection %u receive length %u data", rcvInd->connectionId, rcvInd->length);
        }
        else
        {
#ifdef USING_PRINTF
            printf("socketAppConnectionCallBack invalid connection rcv event");
#endif
            ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_6, P_ERROR, 0, "socketAppConnectionCallBack invalid connection rcv event");
        }
        break;
    }
    case TCPIP_CONNECTION_UL_STATUS_EVENT:
    {
        TcpipConnectionUlDataStatusInd *ulStatusInd;
        ulStatusInd = (TcpipConnectionUlDataStatusInd *)bodyEvent;
        if (ulStatusInd != PNULL)
        {
            if (ulStatusInd->status == Tcpip_Connection_UL_DATA_SUCCESS)
            {
#ifdef USING_PRINTF
                printf("socketAppConnectionCallBack socket connection %u sequence %u data has sent success", ulStatusInd->connectionId, ulStatusInd->sequence);
#endif
                ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_7, P_INFO, 2, "socketAppConnectionCallBack socket connection %u sequence %u data has sent success", ulStatusInd->connectionId, ulStatusInd->sequence);
            }
            else if (ulStatusInd->status == Tcpip_Connection_UL_DATA_FAIL)
            {
#ifdef USING_PRINTF
                printf("socketAppConnectionCallBack socket connection %u sequence %u data has sent fail", ulStatusInd->connectionId, ulStatusInd->sequence);
#endif
                ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_8, P_WARNING, 2, "socketAppConnectionCallBack socket connection %u sequence %u data has sent fail", ulStatusInd->connectionId, ulStatusInd->sequence);
            }
        }
        else
        {
#ifdef USING_PRINTF
            printf("socketAppConnectionCallBack invalid connection ul status event");
#endif
            ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_9, P_ERROR, 0, "socketAppConnectionCallBack invalid connection ul status event");
        }
        break;
    }
    default:
#ifdef USING_PRINTF
        printf("socketAppConnectionCallBack invalid event type %u", connectionEventType);
#endif
        ECOMM_TRACE(UNILOG_PLA_APP, socketAppConnectionCallBack_10, P_ERROR, 1, "socketAppConnectionCallBack invalid event type %u", connectionEventType);
        break;
    }
}