stm32_ota/USER/USER_TCP/user_tcp.c

177 lines
7.2 KiB
C
Raw Blame History

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

#include "user_tcp.h"
#include "userapp.h"
/********************************************************************************
* @file gate_tcp.c
* @author 晏诚科技 Mr.Wang
* @version V1.0.0
* @date 11-Dec-2018
* @brief 提供Quectel模块EC20关于TCP/IP硬件驱动程序
******************************************************************************
* @attention
* 约定基本名词如下:
* contextID:链路ID connetcID通道ID channal连接通道
* EC20模块链路ID范围1~16每一个链路ID都会对应一个本地IP 通道ID范围0~11。
* 每一个链路ID可以有12个通道ID。
* 本驱动强制规定TCP/IP协议只用一个链路1D即contextID=1用于TCP链路。
* 通过不同的通道ID我们可以多台不同IP和端口的服务器。
* 结构体ChannalP_s封装了每一路连接通道的参数。
*******************************************************************************/
/*****************************************
*驱动可供外部使用的常变量
****************************************/
FrameQueue_s sTcp0Queue ; //需要TCP通道0 发送的数据在此环形缓冲区在OS中有个TCP发送的任务一直在发送TCP数据需要发送数据只需要将数据丢到此缓冲区即可
/*****************************************
*usertcp内部常变量
****************************************/
/*****************************************
*usertcp全局变量定义
****************************************/
ChannalP_s sChannal0 = { TCP_CONNECTID0, TCP_CONNECTID0_SERVERIP0, TCP_CONNECTID0_SERVERPORT0, TCP_CONNECTID0_LOCALPORT0 } ; //TCP通道0的参数实例化
/******connectId************serverIP*******************serverPort*****************localPort */
//ChannalP_s s_Channal1 = { TCP_CONNECTID1, TCP_CONNECTID1_SERVERIP, TCP_CONNECTID1_SERVERPORT, TCP_CONNECTID1_LOCALPORT }; //TCP通道1
//ChannalP_s s_Channal2 = { TCP_CONNECTID2, TCP_CONNECTID2_SERVERIP, TCP_CONNECTID2_SERVERPORT, TCP_CONNECTID2_LOCALPORT }; //TCP通道2
/**************************************************************************************************
* 名 称: void SetAppTcpIP(ChannalP_s *psChannal, char* ip)
* 功能说明: 设置登TCP服务器的IP
**************************************************************************************************/
void SetAppTcpIP(ChannalP_s *psChannal, char* ip)
{
memset(psChannal->serverIP , 0, MAX_IP_LEN ) ;
strcpy((char*)psChannal->serverIP, ip) ;
}
/**************************************************************************************************
* 名 称: void SetAppTcpPort(ChannalP_s *psChannal, char* port)
* 功能说明: 设置登TCP服务器的PORT
**************************************************************************************************/
void SetAppTcpPort(ChannalP_s *psChannal, char* port)
{
//memset(psChannal->serverPort , 0, MAX_IP_LEN ) ;
//strcpy((char*)psChannal->serverIP, ip) ;
psChannal->serverPort = atoi(port) ;
}
/*********************************************************************************************************************
* 名 称RunResult AppTcpInit(void)
* 功 能断开Socket 去激活TCP链路的PDP
*********************************************************************************************************************/
void TcpDisconnetc(void)
{
Close_Socket(TCP_CONNECTID0) ; //断开Socket
Deact_Context(TCP_CONTEXTID) ; //去激活TCP链路的PDP
}
/*********************************************************************************************************************
* 名 称RunResult AppTcpInit(void)
* 功 能初始化应用TCP链路的PDP和打开TCP0的通道SOCKET服务
* 说 明TCP0通道所连接的TCP服务器共计提供CHANNAL0_MAX_NUM个连接点硬件扫描连接上任意一个即可
*********************************************************************************************************************/
RunResult AppTcpInit(void)
{
RunResult runResult = TIMEOUT ;
runResult = Tcp_PDP_Init() ; //TCP链路PDP初始化
if( RUNOK == runResult)
{
runResult = TIMEOUT ;
runResult = Tcp_Channal_Init(&sChannal0) ;
if( RUNOK == runResult)
{
AppLogPrintf( "TCP Server连接成功:%s:%d ", sChannal0.serverIP, sChannal0.serverPort) ;
return(runResult) ;
}
else
{
ErrorLogPrintf("TCP Server连接失败:%s:%d ", sChannal0.serverIP, sChannal0.serverPort) ;
}
}
else
{
return(runResult) ;
}
return(runResult) ;
}
/**************************************************************************************************
* 名 称: RunResult TcpUpdata( UPDATATYPE_e updataType, char *format, ...)
* 说 明: 通过TCP将可变参数数据上传到TCP SERVER
* 入口参数:
* @param1 updataType: UPDATATYPE_e枚举类型数据表明数据帧类型
* @arg ERRORRAME
* @arg WARNINGFRAME
* @arg HEARTFRAME
* @arg LOGFRAME
* @arg UCMDBACKFRAME
* @param2 char *format,... 可变参变量
* @param3 ... :可变参数
* 出口参数:
* @param1 status: RunResult枚举类型数据
* 调用方法: TcpUpdata( BOOTTOTCPFRAME, "I am heart %d .", 5) ;
* 数据帧格式: (L0142MAC:31FFD405524E353728902251;00&I am heart 5 .$X)
* 注 意: 最大负载长度为TCP_LOADBUF_MAXLEN
************************************************************************************************************/
RunResult TcpUpdata( UPDATATYPE_e updataType, char *format, ...)
{
static uint8_t counter = 0x30 ;
RunResult status = RUNERR ;
char *upDataBuf = (char*)portMalloc(TCP_LOADBUF_MAXLEN+sizeof(TcpFrame_S)+32) ; //分配内存长度为负载长度+TcpFrame_S结构体长度
TcpFrame_S *sTcpFrameData = (TcpFrame_S *)upDataBuf ; //tcp数据帧变量
va_list ap;
va_start(ap, format);
int outLen = vsnprintf(&(sTcpFrameData->loadHead)+1 , TCP_LOADBUF_MAXLEN, (const char*)format, ap ) ; //到此为止所有的参数情况已经汇总到upDataBuf了
if((outLen<=0)||( outLen > TCP_LOADBUF_MAXLEN))
{
ErrorLogPrintf("%s,%d:upDataBuf spillover",__FILE__, __LINE__) ;
va_end (ap);
portFree(upDataBuf) ;
return RUNERR ;
}
sTcpFrameData->head = '(' ;
sTcpFrameData->frameType = updataType ;
sTcpFrameData->loadLen[0] = outLen/100 + 0x30;
sTcpFrameData->loadLen[1] = outLen%100/10 + 0x30 ;
sTcpFrameData->loadLen[2] = outLen%10 + 0x30;
sTcpFrameData->frameNum = counter ;
counter ++ ;
if( counter > 0x39 ) //防止counter字符数字溢出
{
counter = 0x30 ;
}
strncpy(sTcpFrameData->macHead, "MAC:", 4) ;
GetDeviceMacAddress(sTcpFrameData->macid, STRMACID) ;
sTcpFrameData->macTail = ';' ;
memset(sTcpFrameData->cmdCode, 0x30, 2) ;
sTcpFrameData->loadHead = '&' ;
// for(int n =0; n<outLen; n++) //将loadBuf中的0x0D 0x0A替换为*防止转发软件生成LOG混乱。
// {
// if( (*(sTcpFrameData->loadBuf+n) == 0x0D ) || (*(sTcpFrameData->loadBuf+n) == 0x0A) )
// {
// *(sTcpFrameData->loadBuf+n) = '*' ;
// }
// }
strncat(upDataBuf, "$X)\r\n", 3) ; //TcpFrame_S结构体的最后三个字节拼接到 upDataBuf尾部
// if( RW_OK != InsertQueueMemData(&sTcp0Queue, upDataBuf, strlen(upDataBuf)))
// {
// ErrorLogPrintf("%s,%d:sTcp0Queue spillover", __FILE__, __LINE__) ;
// }
if( TCPBIT_2 == true ) //网络状态正常
{
status = Tcp_SendData(&sChannal0, (uint8_t*)upDataBuf, strlen(upDataBuf)) ;
}
AppLogPrintf(upDataBuf) ;
portFree(upDataBuf) ;
return (status) ;
}