TricycleCentralControlMotherboard/si/centralCtrSys.si4project/Backup/EC800_FTP_OTA(7027).c

/* 连接到FTP服务器   ，从FTP服务器中下载文件，下载逻辑 */
/* includes ----------------------------------------------------------*/
#include "EC800_FTP_OTA.h"

/* typedef -----------------------------------------------------------*/
typedef struct{
	const char *account; 		// 用户名
	const char *passWord; 		// 密码
	uint8_t fileType; 			// 文件类型 1；ASCII
	uint8_t transmode; 			// 传输模式 1：被动
	uint8_t rsptimeout; 		// 最大响应时间 90

	const char * ftpAddr; 		// ftp服务器地址
	uint16_t ftpPort; 			// ftp服务器端口
	
	const char * textDirectory; // 下载文件的文件所在目录
	const char *textName; 		// 下载文件的文件名称
	uint32_t filesize;			// 下载的文件大小
	uint8_t startAddr; 			// 下载文件的起始字节
	uint8_t byteNum;  			// 一次获取的字节个数
}ftpInfo;
ftpInfo s_ftpInfo = {
	.account = "cdzupdate",
	.passWord = "cdz2021!Z",
	.fileType = 1,
	.transmode = 1,
	.rsptimeout = 90,
	
	.ftpAddr = "39.98.211.244",
	.ftpPort = 21,
	.textDirectory = "/data/cdz",
	.textName = "centralCtrSys.bin",
	};

/* define ------------------------------------------------------------*/
// 登陆到FTP服务器
// 第一步：配置和激活 PDP 上下文
#define 	AT_QIACT_1									"AT+QIACT=1\r\n" // 激活 PDP 上下文 1
#define 	AT_QIACT_query								"AT+QIACT?\r\n"  // 查询 PDP 上下文状态 
#define 	AT_QFTPCFG_ID_1								"AT+QFTPCFG=\"contextid\",1\r\n"  // 查询 PDP 上下文状态
// 第二步： 配置用户账号和传输设置
#define 	AT_QFTPCFG_ACCOUNT(account_id,password)		"AT+QFTPCFG=\"account\",\"" #account_id "\",\"" #password "\"\r\n" // 设置用户名和密码。
#define 	AT_QFTPCFG_FILE(fileType)					"AT+QFTPCFG=\"filetype\"," #fileType "\r\n" // 设置文件类型为ASCII AT+QFTPCFG="filetype",1
#define 	AT_QFTPCFG_TRANS(mode)						"AT+QFTPCFG=\"transmode\"," #mode "\r\n" // 设置为被动传输方式AT+QFTPCFG="transmode",1
#define 	AT_QFTPCFG_TIMEOUT(time)					"AT+QFTPCFG=\"rsptimeout\"," #time "\r\n" // 设置最大响应时间（默认为90秒）
//第三步：登录FTP服务器。
#define 	AT_QFTPOPEN(addr,port)						"AT+QFTPOPEN=\"" #addr "\"," #port "\r\n" // 登录FTP服务器。

// 从FTP服务器下载文件 本项目文件较小，选择直接通过COM口输出下载数据
#define 	AT_QFTPCWD(directory)						"AT+QFTPCWD=\"" #directory "\"\r\n" // 设置当前目录。
#define 	AT_QFTPSIZE(textName)						"AT+QFTPSIZE=\"" #textName "\"\r\n" // 查询 FTP(S)服务器 test_my1.txt 文件大小
#define AT_QFTPGET(textName, startByte, downloadNum) \
    "AT+QFTPGET=\"" #textName "\",\"COM:\"," #startByte "," #downloadNum "\r\n" // 下载文件， 通过COM口输出特定字段的数据

/* macro -------------------------------------------------------------*/

/* variables ---------------------------------------------------------*/

/* function prototypes -----------------------------------------------*/

/* 1.登陆到FTP服务器--------------------------------------------------------*/
static uint8_t logIn_step = 0;

/**
 * @brief       通过EC800登录FTP
 * @param       NONE
 * @note       	NONE
 * @retval      无
 */
void EC800_LogIn_FTP(void){
	char* found = NULL;
	uint8_t errorCnt = 0; // 错误计数
	ftpInfo *p_ftpInfo = &s_ftpInfo;

	p_ftpInfo->fileType = p_ftpInfo->fileType; // 避免报警告

	switch(logIn_step){
		case 0: // 配置和激活 PDP 上下文
			EC800M_SendCommand(AT_QIACT_1);
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("Activation successful\r\n");
			}else{
				errorCnt++;
				printf("Activation unsuccessful\r\n");
			}	

			EC800M_SendCommand(AT_QIACT_query);

			EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("PDP Context Status OK\r\n");
			}else{
				errorCnt++;
				printf("PDP Context Status error\r\n");
			}	

			EC800M_SendCommand(AT_QFTPCFG_ID_1);
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("Set PDP context to 1.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set PDP context to 1.\r\n");
			}	

			if(errorCnt == 0){
				logIn_step = 1;
			}
			break;
		case 1: // 配置用户账号和传输设置
			EC800M_SendCommand(AT_QFTPCFG_ACCOUNT(p_ftpInfo->account, p_ftpInfo->passWord));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("FINISH! Set username and password.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set username and password.\r\n");
			}	

			EC800M_SendCommand(AT_QFTPCFG_FILE(p_ftpInfo->fileType));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("FINISH! Set username and password.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set username and password.\r\n");
			}	

			EC800M_SendCommand(AT_QFTPCFG_TRANS(p_ftpInfo->transmode));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("FINISH! Set to passive transfer mode.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set to passive transfer mode.\r\n");
			}	

			EC800M_SendCommand(AT_QFTPCFG_TIMEOUT(p_ftpInfo->rsptimeout));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			if (found != NULL) {
				printf("FINISH! Set username and password.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set username and password.\r\n");
			}	

			if(errorCnt == 0){
				logIn_step = 1;
			}
			break;
		case 2: // 登录FTP服务器。
			EC800M_SendCommand(AT_QFTPOPEN(p_ftpInfo->ftpAddr, p_ftpInfo->ftpPort));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
			found = EC800M_RecRespond(g_usart3_rx_buf, "+QFTPOPEN: 0,0");

			if (found != NULL) {
				printf("FINISH! Log in to the FTP server.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Log in to the FTP server.\r\n");
			}	

			if(errorCnt == 0){
				logIn_step = 3;
			}
			break;
		default :
			break;
	}

	
}

/* 2.从FTP服务器上下载文件--------------------------------------------------------*/


//int extract_data(const char* input, char* output, size_t output_size) {
//    const char* start_marker = "CONNECT\r\n";
//    const char* end_marker = "\r\nOK";
//    const char* start;
//    const char* end;
//
//    // 寻找开始标记
//    start = strstr(input, start_marker);
//    if (start == NULL) {
//        return HAL_ERROR;
//    }
//
//    // 移动指针越过开始标记
//    start += strlen(start_marker);
//
//    // 寻找结束标记
//    end = strstr(start, end_marker);
//    if (end == NULL) {
//        return HAL_ERROR;
//    }
//
//    // 计算要提取数据的长度
//    size_t data_length = end - start;
//    if (data_length >= output_size) { // 确保输出缓冲区能够存放提取的数据
//        return HAL_ERROR;
//    }
//
//    // 提取数据
//    memcpy(output, start, data_length);
//
//    // 在输出字符串最后添加一个null终止符
//    output[data_length] = '\0';
//    
//    return HAL_OK;
//}
int extract_data_as_uint32(const char* input, uint32_t* output, size_t output_size) {
    const char* start_marker = "CONNECT\r\n";
    const char* end_marker = "\r\nOK";
    const char* start;
    const char* end;

    // 寻找开始标记
    start = strstr(input, start_marker);
    if (start == NULL) {
        return HAL_ERROR;
    }

    // 移动指针越过开始标记
    start += strlen(start_marker);

    // 寻找结束标记
    end = strstr(start, end_marker);
    if (end == NULL) {
        return HAL_ERROR;
    }

    // 计算要提取数据的长度
    size_t data_length = end - start;
    // 确保提取的数据长度为4的倍数，适用于 uint32_t
    if (data_length % sizeof(uint32_t) != 0) {
        return HAL_ERROR;
    }
    // 计算 uint32_t 的数量
    size_t data_length_uint32 = data_length / sizeof(uint32_t);
    if (data_length_uint32 > output_size) { // 确保输出缓冲区能够存放提取的数据
        return HAL_ERROR;
    }

    // 提取数据并转换为 uint32_t 数组
    memcpy(output, start, data_length_uint32 * sizeof(uint32_t));
    
    return HAL_OK;
}



void UpdateFirmware(void) {
	char* found = NULL;
	ftpInfo *p_ftpInfo = &s_ftpInfo;
    uint32_t totalBytesReceived = 0;
    uint32_t currentFlashAddress = APP1_ADDRESS;
    uint32_t buffer[FLASH_PAGE_SIZE / sizeof(uint32_t)];  // 2KB缓冲区
    uint8_t returnTemp = 0; // 用于接收返回值的临时变量

    while (totalBytesReceived < (p_ftpInfo->filesize)) {
        // 计算剩余要接收的字节数
        uint32_t remaining = (p_ftpInfo->filesize) - totalBytesReceived;
        uint32_t bytesToRead = remaining < FLASH_PAGE_SIZE ? remaining : FLASH_PAGE_SIZE;

        p_ftpInfo->startAddr = totalBytesReceived;
        p_ftpInfo->byteNum = bytesToRead;

        // 发送AT指令以开始接收
        EC800M_SendCommand(AT_QFTPGET(p_ftpInfo->textName, p_ftpInfo->startAddr, p_ftpInfo->byteNum)); 
        EC800_recEnable();  // 开始接收数据

		found = strstr(g_usart3_rx_buf, AT_RESP_OK);
		while(!found) osDelay(1);
        // 接收数据处理到buffer 剔除除去固件的其他的数据
		returnTemp = extract_data_as_uint32(g_usart3_rx_buf, buffer, FLASH_PAGE_SIZE / sizeof(uint32_t));
		if(returnTemp != HAL_OK){
			printf("ERROR! UpdateFirmware_extract_data\n");
			break;
		}

        // 将接收到的数据写入Flash
        if (FLASH_Write(currentFlashAddress, buffer, FLASH_PAGE_SIZE / sizeof(uint32_t)) != HAL_OK) {
            // 错误处理
            printf("ERROR! UpdateFirmware_FLASH_Write\n");
            break;
        }

        // 更新地址和接收统计
        currentFlashAddress += FLASH_PAGE_SIZE;
        totalBytesReceived += bytesToRead;
    }

    // 根据实际情况实现接收完成后的操作
}


uint8_t downloadStep = 0;
uint8_t textBuff[2048] = {0}; // 下载的文件缓冲区
/**
 * @brief       FTP服务器上下载文件
 * @param       NONE
 * @note       	NONE
 * @retval      无
 */
void EC800_FTP_DownloadText(void){
	char* found = NULL;
	uint8_t errorCnt = 0; // 错误计数
	ftpInfo *p_ftpInfo = &s_ftpInfo;

	switch(downloadStep){
		case 0: // 设置文件目录
			EC800M_SendCommand(AT_QFTPCWD(p_ftpInfo->textDirectory));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);
			found = EC800M_RecRespond(g_usart3_rx_buf, "+QFTPCWD: 0,0");

			if (found != NULL) {
				printf("FINISH! Set the file directory.\r\n");
			}else{
				errorCnt++;
				printf("ERROR! Set the file directory.\r\n");
			}	

			if(errorCnt == 0){
				downloadStep = 1;
			}
			break;
		case 1: // 获取文件长度
			EC800M_SendCommand(AT_QFTPSIZE(p_ftpInfo->textName));
			
			found = EC800M_RecRespond(g_usart3_rx_buf, AT_RESP_OK);

			EC800_recEnable();

			// 使用sscanf从字符串中解析整数
		    if(sscanf(g_usart3_rx_buf, "+QFTPSIZE: %*d,%u", &(p_ftpInfo->filesize)) == 1) {
		        // 解析成功，filesize变量现在包含值1000
		        printf("The filesize is: %u\n", p_ftpInfo->filesize);
		    } else {
		        // 解析失败
		        errorCnt++;
		        printf("Failed to parse the filesize.\n");
		    }

			if(errorCnt == 0){
				downloadStep = 2;
			}
			break;
		case 2:
			UpdateFirmware();
			break;
		default :
			break;
	}
}

/* 3. OTA升级从FTP流程--------------------------------------------------------*/
uint8_t upgradeStep = 0;
/**
 * @brief       OTA升级从FTP
 * @param       NONE
 * @note       	NONE
 * @retval      无
 */
void EC800_FTP_OTA_Upgrade(void){
	switch (upgradeStep){
		case 0: // 登陆到FTP服务器
			EC800_LogIn_FTP();
			if(logIn_step == 3){
				upgradeStep = 1;
			}
			break;
		case 1: // 从FTP服务器上下载文件
			EC800_FTP_DownloadText();
			break;
		default:
			break;
	}
}