dtu_gateway/bootloader/HW/Source/ota_message.c

#include "ota_message.h"
#include "gd32f10x.h"
#include "w25q32.h"
#include "ec800m.h"
#include "usart.h"
#include "delay.h"
#include <stdio.h>
static OTA_MESSAGE ota_message = {0};
void clear_ota_message_config_block(void);
void write_ota_message_to_flash(uint32_t *data, int size){
	uint8_t *pdata = (uint8_t *)data;
	W25Q32_PageWrite(pdata,256*OTA_EVENT_BLOCK);//写在第二扇区的第一页中
}

/*
 *  函数名：save_ota_message_config_params(OTA_MESSAGE *params)
 *  输入参数：无
 *  输出参数：无
 *  返回值：无
 *  函数作用：保存ota事件的信息
 */
int save_ota_message_config_params(OTA_MESSAGE *params)
{
		if(params == NULL)
				return -1;
		memset(&ota_message, 0, sizeof(OTA_MESSAGE));	
		memcpy(&ota_message, params, sizeof(OTA_MESSAGE)); 
	  clear_ota_message_config_block();
		write_ota_message_to_flash((uint32_t *)&ota_message,sizeof(OTA_MESSAGE));
		return 0;
}

// 模块下载download校验值
static uint16_t checksum(const char *str, uint16_t len)
{
  uint16_t sum = 0;
  uint8_t odd = 0;

  // 如果字符串长度为奇数，则将最后一个字符设置为高8位，低8位设置为0
  if (len % 2 == 1)
  {
    odd = 1;
    len--;
  }

  // 将每两个字符作为一个16位的数值进行异或操作
  for (uint16_t i = 0; i < len; i += 2)
  {
    sum ^= ((uint16_t)str[i] << 8) | (uint16_t)str[i + 1];
  }

  // 如果字符串长度为奇数，则还需要将最后一个字符与0xFF00异或
  if (odd)
  {
    sum ^= (uint16_t)str[len] << 8;
  }
  // 返回校验和
  return sum;
}

/*
 *  函数名：static void extract_data_from_buffer(const char* buffer, uint32_t *len_ptr, uint16_t *checkCode_ptr)
 *  输入参数：buffer字符串
 *  输出参数：json有效字符串长度len_ptr,checkCode_ptr校验码指针
 *  返回值：无
 *  函数作用:eg.   QFDWL: 621,3e23  从json信息最后端取出这段json的有效长度和校验码
 */
static void extract_data_from_buffer(const char *buffer, uint32_t *len_ptr, uint16_t *checkCode_ptr)
{
  char *start = strstr(buffer, "+QFDWL:");
  if (start != NULL)
  {
    start += 8; // 跳过"+QFDWL:"
    uint32_t len = 0;
    sscanf(start, "%u,", &len);     // 读取长度
    start = strchr(start, ',') + 1; // 跳过逗号
    uint16_t checkCode = 0;
    sscanf(start, "%hx", &checkCode); // 读取16进制数据
    // 将提取的数据存入形参
    *len_ptr = len;
    *checkCode_ptr = checkCode;
  }
}

bool WaitForUpData(char *dmaBuffer)
{
	if (UART0_RX_STAT > 0)
  	{
		UART0_RX_STAT = 0;
		uint32_t len;
		uint16_t checkCode;
			char *temp;
		extract_data_from_buffer(dmaBuffer, &len, &checkCode);
		uint16_t jsonCheck = checksum(dmaBuffer, len);
		if (checkCode == jsonCheck)
		{
			return true;
		}
		else
		{
			return false;
		}
	}
}

// 提取string字符串
void parseStringField(const char *data, const char *field, char *value)
{
    char *ptr = strstr(data, field) + strlen(field);
    sscanf(ptr, "%[^\"],", value);
}
// 提取int数据如果没有提取到数据则返回-1；提取到返回正确的值
int parseIntField(const char *data, const char *field)
{
    char *ptr = strstr(data, field) + strlen(field);
    int value;
    value = strtol(ptr, &ptr, 10);
    return value;
}

/*
 *  函数名：load_config_params(CONFIG_PARAMS *params)
 *  输入参数：无
 *  输出参数：无
 *  返回值：ota升级标志是否有效 0有效 -1无效
 *  函数作用：从w25q32中加载ota信息
 */
int load_ota_message_config_params()
{
	//检查校验码
	uint32_t BufferSize=1024;//最大获取的数据空间
	char *dmabuffer=malloc(BufferSize);
	__LOAD_CONFIG:
	// get data from UFS
	dma_config_change(dmabuffer,BufferSize);
	Delay_Ms(1000);
	EC800MSendCmd(CMD_READ_OTA_MSG_FILE, strlen(CMD_READ_OTA_MSG_FILE)); //"AT+QFDWL=otaMSG.txt\r\n"
	Delay_Ms(1000);
	dma_config();
	if(WaitForUpData(dmabuffer) == false) goto __LOAD_CONFIG;
	// W25Q32_Read((uint8_t *)&ota_message, OTA_EVENT_BLOCK*64*1024, sizeof(OTA_MESSAGE)); //从W25Q32中读取结构体数据
	// FLASH_Read(OTA_EVENT_START_ADDR,&ota_message,sizeof(OTA_MESSAGE));

	if(parseIntField(dmabuffer,"\"otaflag\":") == 1U)
	{
		ota_message.otaflag = 1;
		ota_message.XmodemByte = parseIntField(dmabuffer,"\"XmodemByte\":");
		free(dmabuffer);
		return 0;
	}
	else 
	{
		free(dmabuffer);
		return -1;
	}
}
OTA_MESSAGE *get_config_params()
{
		return &ota_message;
}
/*
 *  函数名：void clear_ota_message_config_block(void)
 *  输入参数：无
 *  输出参数：无
 *  返回值：无
 *  函数作用：清除block内包含的ota事件信息
 */
void clear_ota_message_config_block(void)
{
	// W25Q32_Erase64K(OTA_EVENT_BLOCK);//擦除一块区域的大小
	//AT+QFDEL="UFS:1.txt" 
	char string[] = "{otaflag:0,XmodemByte:0}"; 
	char OPEN_NEW_FILE[] = "AT+QFOPEN=\"otaMSG.txt\",1\r\n";
	char WRITEFILE[] = "AT+QFWRITE=1,8\r\n";
	char CLOSEFILE[] = "AT+QFCLOSE=1\r\n";
	char LOADFILE[] = "AT+QFDWL=otaMSG.txt\r\n";

	EC800MSendCmd(OPEN_NEW_FILE,strlen(OPEN_NEW_FILE));
	WaitResponse("QFOPEN:", 2000);

	EC800MSendCmd(WRITEFILE,strlen(WRITEFILE));
	WaitResponse("CONNECT", 2000);

	EC800MSendCmd(string,strlen(string));
	WaitResponse("QFWRITE", 2000);

	EC800MSendCmd(CLOSEFILE,strlen(CLOSEFILE));
	WaitResponse("OK", 2000);

	// EC800MSendCmd("AT+QFDEL=\"UFS:otaMSG.txt\r\n\"",27);	//删除文件
}