dtu/Core/Src/net4g.c

#include "net4g.h"



extern UART_HandleTypeDef huart3;
extern UART_HandleTypeDef huart4;
extern UART_HandleTypeDef huart5;
extern UART_HandleTypeDef huart1;

uint8_t step_4G = 0;
bool resetML307A =false;


uint32_t g_ML307ACnt =0;            // 接收计数
uint8_t g_ML307A_8buf[200] ={0} ;
uint8_t g_ML307A_8buf_Down[200]={0};

uint8_t u4RecvFlag = 0;                                               		// 串口4接收标志串口接收完成标志
//char g_ML307A_8buf_Down[100] = {0};                                                   // 接收缓存 



uint8_t ML307A_Init(void)
{		
	
	//startDTU=false;
//	int txLen = sprintf((char *)recvBuff, "ML307A_Init...\r\n");
//	HAL_UART_Transmit(&huart1,recvBuff,txLen,(txLen-1));	
//	uint8_t result = 0;
#ifdef debug4GInfo
	#if debug4GInfo == 1
	printf("ML307A_Init...\r\n");
	#endif
#endif
    switch(step_4G)
    {
        case 0:
            if(sendCmd("AT\r\n","OK", 10, 5))                                   // 测试AT指令功能是否正常
            {
                step_4G++;
#ifdef debug4GInfo
				#if debug4GInfo == 1
				printf("CMD:AT\t##Reply message matching\r\n");
				#endif
#endif
				//start4G=false;
            }
            else
            {
#ifdef debug4GInfo
				#if debug4GInfo == 1
                printf("Err:AT\r\n");
				#endif
#endif
                reset_4G();
                break;
            } 
//        case 1:
//            if(sendCmd("AT+CPIN?\r\n","+CPIN: READY\r\n\r\nOK", 20, 2))                   // 查询SIM卡是否正常，返回ready则表示SIM卡正常
//            {
//                step_4G++;
//				int txLen = sprintf((char *)recvBuff, "CPIN OK\r\n");
//				HAL_UART_Transmit(&huart1,recvBuff,txLen,(txLen-1));	
//            }
//            else
//            {
//                printf("Err:AT+CPIN?\r\n");                                     // 20秒内，无法识别SIM状态，重启模块
//                reset_4G();
//                break;
//            }
//        case 2:
//            if(sendCmd("AT+CREG?\r\n","+CREG: 0,1", 90, 2))                     // 查询模组是否注册上GSM网络
//            {
//                step_4G++;                 
//				int txLen = sprintf((char *)recvBuff, "CREG OK\r\n");
//				HAL_UART_Transmit(&huart1,recvBuff,txLen,(txLen-1));	                    
//            }
//            else
//            {
//                printf("Err:AT+CREG?\r\n");                                     // 90秒内，没有注册上CS业务，重启模块 
//                reset_4G();
//                break;
//            }
//        case 3:
//            if(sendCmd("AT+CGREG?\r\n","+CGREG: 0,1", 60, 2))                   // 查询模组是否注册上GPRS网络
//            {
//                step_4G++;                                                 
//            }
//            else
//            {
//                printf("Err:AT+CGREG?\r\n");                                    // 60秒内，没有注册上PS业务
//                reset();        
//                break;
//            }
//        case 4:
//            if(sendCmd("AT+QICSGP=1,1,\"CMNET\",\"\",\"\",1\r\n", "OK", 40, 3)) // 查询模组是否注册上GPRS网络
//            {
//                result = ML307A_NetConfig();                          
//            }
//            else
//            {
//                printf("Err:AT+QICSGP=1,1\r\n");                                // 如果3次都没停止成功或超过40秒没有回应，则重启模块
//                reset();
//                break;
//            }
    }
    //return result;
	return 1;
}




uint8_t ML307A_NetConfig(void)
{	   
	//uint8_t result = 0;
//    if(sendCmd("AT+QIDEACT=1\r\n", "OK", 40, 1))                                // 在激活GPRS场景之前先关闭GPRS场景，确保连接正确
//    {
//        if(sendCmd("AT+QIACT=1\r\n", "OK", 150, 1))                              // 激活移动场景
//        {
//            ML307A_Connect();
//        } 
//        else																	// 等待150秒后，没有响应重启模块
//        {
//            printf("Err:AT+QIACT=1\r\n");                                       // 重启模块
//            reset();
//        }
		return 1;
//    }      
//    else																		// 等待40秒后，没有响应重启模块
//    {
//        printf("Err:AT+QIDEACT=1\r\n");                                         // 重启模块
//        reset();
//		return 0;
//    }     
}

/**
 @brief 连接TCP服务器
 @param 无
 @return 无
*/
void ML307A_Connect(void)
{
    if(sendCmd("AT+QIOPEN=1,0,\"TCP\",\"180.97.81.180\",53540,0,1\r\n", "+QIOPEN:", 150, 5))    
    {
        printf("Connect Success\r\n");
    }      
    else
    {
        printf("Err:AT+QIOPEN=1,0\r\n");
    }       
}

/**
 @brief 发送数据到TCP服务器
 @param pString -[in] 发送数据
 @return 无
*/
void ML307A_Send(char *pString)
{
    if(sendCmd("AT+QISEND=0\r\n", ">", 60, 1)) 
    {
        if(sendCmd("AT+QISEND=0,0\r\n", "\r\nOK", 5, 24))                   // 2分钟后（每5秒查询一次，共24次）
        {
            /* 发送数据成功，对方收到数据 */
        }
        else
        {
            printf("Err:AT+QISEND=0\r\n");                                      
            if(sendCmd("AT+QICLOSE=0\r\n", "OK", 10, 1))                // TCP连接出现异常，关闭TCP连接
            {
                printf("AT+QICLOSE\r\n");
                ML307A_Connect();
            }
            else
            {
                reset_4G();                                                // 等待10秒，没有响应重启模块
            } 
        }
    }
    else
    {
        reset_4G();                                                        // 等待60秒，没有响应重启模块
    }
}


/**
 @brief 从TCP服务器接收数据
 @param pRecvDataBuf -[out] 接收数据
 @return 接收数据长度
*/
uint32_t ML307A_Receive(char *pRecvDataBuf)
{
    uint32_t recvDataLen = 0;
    if(u4RecvFlag)                                                    // 如果串口接收完成
    {
        if(strstr((const char *)g_ML307A_8buf_Down, "+QIURC: \"recv\",0,") != NULL)    // 如果检索到关键词
        {
            memcpy(pRecvDataBuf, g_ML307A_8buf_Down, g_ML307ACnt);
            recvDataLen = g_ML307ACnt;
        }
        clearBuffer();
    }	
    return recvDataLen;
}

void USART_SendString(UART_HandleTypeDef *huart, char *str)
{
	
		HAL_UART_Transmit(huart, (uint8_t*)str, strlen(str), 0xFFFF);
    HAL_UART_Transmit(&huart1, (uint8_t*)str, strlen(str), 0xFFFF);//485
    HAL_UART_Transmit(&huart3, (uint8_t*)str, strlen(str), 0xFFFF);//ttl
	
}

void USART_SendHexArray(UART_HandleTypeDef *huart, uint8_t *data, int length)
{
	
	HAL_UART_Transmit(huart,data, length, 0xFFFF);
  HAL_UART_Transmit(&huart1,data, length, 0xFFFF);//485
  HAL_UART_Transmit(&huart3, data, length, 0xFFFF);//ttl
}

/*********************************************************************
 * LOCAL FUNCTIONS
 */
/**
 @brief 发送AT命令
 @param pCmd -[in] 命令字符串
 @param pRes -[in] 需要检测的返回命令字符串
 @param timeOut -[in] 等待时间
 @param sendNum -[in] 命令发送次数
 @return 1 - 成功；0 - 失败
*/
uint8_t sendCmd(char *pCmd, char *pRes, uint32_t timeOut, uint8_t sendNum)
{
    uint8_t i = 0;
    uint32_t time;
    clearBuffer();                                                              // 清空缓存	
    for(i = 0; i < sendNum; i++)
	{
        time = timeOut * 10;
        USART_SendString(&huart4, pCmd);
//		int txLen = sprintf((char *)recvBuff, "Send AT >>%s",pCmd);
//		HAL_UART_Transmit(&huart1,recvBuff,txLen,(txLen-1));	
#ifdef debug4GInfo
				#if debug4GInfo == 1
				printf("Send AT >>%s",pCmd);
				#endif
#endif
		
        while(time--)
        {
            if(u4RecvFlag)                                              // 如果串口接收完成
            {
				HAL_Delay(10);
//				int txLen = sprintf((char *)recvBuff, "R_AT >>%s<<",g_ML307A_8buf_Down);
//				HAL_UART_Transmit(&huart1,recvBuff,txLen,(txLen-1));	
//				HAL_UART_Transmit(&huart3,recvBuff,txLen,(txLen-1));	
//				HAL_UART_Transmit(&huart4, (uint8_t *)g_ML307A_8buf_Down, recvLength, HAL_MAX_DELAY);
#ifdef debug4GInfo
				#if debug4GInfo == 1
				printf("RE>>%s",g_ML307A_8buf_Down);
				#endif
#endif
                if(strstr((const char *)g_ML307A_8buf_Down, pRes) != NULL)             // 如果检索到关键词
                {
                    //printf("%s", g_ML307A_8buf_Down);
                    return 1;
                }
				else{
					
					u4RecvFlag = 0;
                   //printf("null %s", g_ML307A_8buf_Down);
				}
            }	
			HAL_Delay(100);                                                   // 等待100毫秒
        }
		
        clearBuffer();
    }
    return 0;
}

/**
 @brief 清空缓存
 @param 无
 @return 无
*/
void clearBuffer(void)
{		
	recvLength = 0;//清除计数
	recvDndFlag = 0;//清除接收结束标志位
	
	memset(g_ML307A_8buf_Down, 0, 500);
	memset(g_ML307A_8buf_Down, 0, 500);
	
	u4RecvFlag = 0;
	printf("bufclear\r\n");
}






/**
 @brief 重启模块
 @param 无
 @return 无
*/
void reset_4G(void)
{
	printf("reset_4g\n");    
	step_4G = 0;
	resetML307A = true;
	HAL_GPIO_WritePin(GPIOA, GPIO_PIN_1, GPIO_PIN_RESET);
	HAL_Delay(5000);
	HAL_GPIO_WritePin(GPIOA, GPIO_PIN_1, GPIO_PIN_SET);
}