/* USER CODE BEGIN Header */
/**
******************************************************************************
* @file : main.c
* @brief : Main program body
******************************************************************************
* @attention
*
* © Copyright (c) 2019 STMicroelectronics.
* All rights reserved.
*
* This software component is licensed by ST under BSD 3-Clause license,
* the "License"; You may not use this file except in compliance with the
* License. You may obtain a copy of the License at:
* opensource.org/licenses/BSD-3-Clause
*
******************************************************************************
*/
/* USER CODE END Header */
#include "main.h"
#if USE_FATFS_RECORD==1
/* Includes ------------------------------------------------------------------*/
#include
#include
#include
#include
#include "func_fatfs.h"
#include "dev_spi_sdcard.h"
#include "func_spi_w25qxx.h"
#include "func_fatfs_record.h"
#include "func_queue_record.h"
#include "Data_deal.h"
/* Private includes ----------------------------------------------------------*/
/* USER CODE BEGIN Includes */
/* USER CODE END Includes */
/* Private typedef -----------------------------------------------------------*/
#define MAX_FILE_COUNT 20
#define NUM_FILE_SET 10
/* Private define ------------------------------------------------------------*/
/* USER CODE BEGIN PD */
/* USER CODE END PD */
/* Private macro -------------------------------------------------------------*/
/* USER CODE BEGIN PM */
/* USER CODE END PM */
/* Private variables ---------------------------------------------------------*/
/* USER CODE BEGIN PV */
/* USER CODE END PV */
const char FILE_START[] = "20";
const char FILE_END[] = ".TXT";
const char FILE_FOLD[] = "JLRECORD";
/* Private function prototypes -----------------------------------------------*/
typedef struct fs_record_struct
{
int8_t fs_stat;
const char *fold; //操作路径
int8_t * path[32]; //操作路径
int8_t name_new[32]; //最新的文件名
int8_t name_send[32]; //最老的文件名
FIL opt_file; //当前操作的文件
FATFS fs;
DIR dir; //操作的文件名
uint32_t opt_len;
uint32_t items_num;
int8_t read_buf[512];
uint32_t read_len;
int8_t write_buf[512];
uint32_t write_len;
uint32_t file_num;
int8_t file_list[MAX_FILE_COUNT][32];//保存文件名
int8_t link_ok;
uint32_t free_size;
}fs_record_OBJ;
fs_record_OBJ fs_record_obj = {
.fs_stat = true,
.fold = FILE_FOLD,
.items_num= 0,
.file_num = 0,
.link_ok = false,
};
//add boly 20221020
//uint8_t data_buf[16*1024] = {0};
//end boly
void func_record_Get_Capacity(void);
void func_record_files_update(char * path);
void func_record_dir_qsort(size_t fcount);
extern SDateTime m_datetime;
/* Private user code ---------------------------------------------------------*/
uint8_t func_record_fatfs_isOK(void)
{
return fs_record_obj.fs_stat;
}
uint8_t func_record_fatfs_set_OK(uint8_t stat)
{
fs_record_obj.fs_stat = stat;
return fs_record_obj.fs_stat;
}
void func_record_mk_fileName(char *buf)
{
//fs_record_obj.path[12] = 0;
#if 0
sprintf(buf,"%s/%04d%02d%02d.TXT",fs_record_obj.fold,
m_datetime.year%100 + 2000,
m_datetime.month%100,
m_datetime.day%100
);
#elif 0
sprintf(buf,"%s/%04d%02d%02d.TXT",fs_record_obj.fold,
m_datetime.day%100 + 2000,
m_datetime.hour%100,
m_datetime.min%100
);
#else
sprintf(buf,"%s/%04d%02d%02d.TXT",fs_record_obj.fold,
m_datetime.hour%100 + 2000,
m_datetime.min%100,
m_datetime.sec%100
);
#endif
return;
}
/**
* @brief 指定长度len,buf内容写入文件
* @retval int
*/
uint32_t func_record_write(uint8_t *buf ,uint32_t len)
{
FRESULT res;
UINT write_len = 0;
//根据日期生成文件名，用于文件写入
func_record_mk_fileName((char *)fs_record_obj.name_new);
//打开当前存在的文件；
res = f_open(&fs_record_obj.opt_file,(char *)fs_record_obj.name_new , FA_WRITE| FA_OPEN_EXISTING);
if(FR_OK != res)
{
//检查文件个数是否超限
func_record_files_update((char *)fs_record_obj.fold);
if(FR_NO_FILE == res)
{
//创建文件并写入
res = f_open(&fs_record_obj.opt_file, (char*)fs_record_obj.name_new, FA_WRITE| FA_CREATE_NEW);
if(FR_OK != res)
{
fs_record_obj.fs_stat = false;
return 0;
}
}
else
{
return 0;
}
}
//将当前发送文件更新为当前写入文件
strcpy((char *)fs_record_obj.name_send,(char *)fs_record_obj.name_new);
fs_record_obj.opt_len = f_size(&fs_record_obj.opt_file);
//操作指针移动到文件末尾
res = f_lseek(&fs_record_obj.opt_file, fs_record_obj.opt_len);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_write(&fs_record_obj.opt_file, buf, len, &write_len);
res = f_close(&fs_record_obj.opt_file); //关闭文件
taskEXIT_CRITICAL(); /* 临界保护关闭 */
return write_len;
}
void func_record_get_NameSend(void)
{
//发送文件是否存在
if(strlen((char*)fs_record_obj.name_send) > 0)
{
return;
}
//检查文件个数是否超限
func_record_files_update((char *)fs_record_obj.fold);
}
/**
* @brief The application entry point.
* @retval int
*/
uint32_t func_record_read(uint8_t *buf, uint32_t len)
{
FRESULT res;
//uint32_t file_len = 0;
uint32_t read_len = 0;
func_record_get_NameSend();
if(strlen((char *)fs_record_obj.name_send) <= 0)
{
return 0;
}
res = f_open(&fs_record_obj.opt_file, (char*)fs_record_obj.name_send, FA_READ | FA_OPEN_EXISTING);
if(FR_OK != res)
{
return 0;
}
fs_record_obj.opt_len = f_size(&fs_record_obj.opt_file);
//如果文件小于数据长度，则删除文件
if(fs_record_obj.opt_len < len)
{
res = f_close(&fs_record_obj.opt_file);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_unlink((char*)fs_record_obj.name_send);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
if(res == FR_OK)
{
memset((char*)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
}
return 0;
};
res = f_lseek(&fs_record_obj.opt_file, fs_record_obj.opt_len - len);
res = f_read(&fs_record_obj.opt_file, buf, len, &read_len);
res = f_close(&fs_record_obj.opt_file);
return read_len;
}
uint32_t func_record_remove(uint8_t *buf, uint32_t len)
{
FRESULT res;
uint32_t read_len = 0;
func_record_get_NameSend();
if(strlen((char *)fs_record_obj.name_send) <= 0)
{
return 0;
}
res = f_open(&fs_record_obj.opt_file, (char*)fs_record_obj.name_send, FA_WRITE| FA_READ| FA_OPEN_EXISTING);
if(FR_OK != res)
{
memset((char*)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
return 0;
}
fs_record_obj.opt_len = f_size(&fs_record_obj.opt_file);
//如果文件小于数据长度，则删除文件
if(fs_record_obj.opt_len < len)
{
res = f_close(&fs_record_obj.opt_file);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_unlink((char*)fs_record_obj.name_send);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
if(res == FR_OK)
{
memset((char*)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
}
return 0;
};
res = f_lseek(&fs_record_obj.opt_file, fs_record_obj.opt_len - len);
res = f_read(&fs_record_obj.opt_file, buf, len, &read_len);
res = f_lseek(&fs_record_obj.opt_file, fs_record_obj.opt_len - len);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_truncate(&fs_record_obj.opt_file ); //截断后面的文件
res = f_close(&fs_record_obj.opt_file);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
return read_len;
}
uint32_t func_record_delete(uint8_t *buf,uint32_t len)
{
FRESULT res;
//uint32_t file_len = 0;
if(strlen((char *)fs_record_obj.name_send) <= 0)
{
return 0;
}
//打开文件
res = f_open(&fs_record_obj.opt_file, (char*)fs_record_obj.name_send, FA_WRITE | FA_OPEN_EXISTING );
if ( res != FR_OK )
{
if(res == FR_NO_FILE )
{
memset((char*)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
memset((char*)fs_record_obj.name_new, 0x00,sizeof(fs_record_obj.name_new));
}
return res;
}
fs_record_obj.opt_len = f_size(&fs_record_obj.opt_file);
//如果文件小于数据长度，则删除文件
if(fs_record_obj.opt_len <= len)
{
res = f_close(&fs_record_obj.opt_file);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_unlink((char*)fs_record_obj.name_send);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
if(res == FR_OK)
{
memset((char*)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
}
return 0;
};
res = f_lseek(&fs_record_obj.opt_file, fs_record_obj.opt_len - len);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_truncate(&fs_record_obj.opt_file ); //截断后面的文件
taskEXIT_CRITICAL(); /* 临界保护关闭 */
res = f_close(&fs_record_obj.opt_file);
return res;
}
/**
* 文件信息获取
*/
FRESULT func_record_file_check(void)
{
FRESULT f_res; /* 文件操作结果 */
static FILINFO finfo;
/* 获取文件信息 */
f_res=f_stat("TestDir/testdir.txt",&finfo);
if(f_res==FR_OK)
{
printf("“testdir.txt”文件信息：\n");
printf("》文件大小: %ld(字节)\n", finfo.fsize);
printf("》时间戳: %u/%02u/%02u, %02u:%02u\n",
(finfo.fdate >> 9) + 1980, finfo.fdate >> 5 & 15, finfo.fdate & 31,finfo.ftime >> 11, finfo.ftime >> 5 & 63);
printf("》属性: %c%c%c%c%c\n\n",
(finfo.fattrib & AM_DIR) ? 'D' : '-', // 是一个目录
(finfo.fattrib & AM_RDO) ? 'R' : '-', // 只读文件
(finfo.fattrib & AM_HID) ? 'H' : '-', // 隐藏文件
(finfo.fattrib & AM_SYS) ? 'S' : '-', // 系统文件
(finfo.fattrib & AM_ARC) ? 'A' : '-'); // 档案文件
}
return f_res;
}
/**
* @brief scan_files 递归扫描FatFs内的文件
* @param path:初始扫描路径
* @retval result:文件系统的返回值
*/
FRESULT func_record_scan_files (char* path)
{
FRESULT res; //部分在递归过程被修改的变量，不用全局变量
FILINFO fno;
DIR dir;
int i;
char *fn; // 文件名
#if _USE_LFN
/* 长文件名支持 */
/* 简体中文需要2个字节保存一个“字”*/
static char lfn[_MAX_LFN*2 + 1];
fno.fname = lfn;
fno.fsize = sizeof(lfn);
#endif
//打开目录
res = f_opendir(&dir, path);
if (res == FR_OK)
{
i = strlen(path);
for (;;)
{
//读取目录下的内容，再读会自动读下一个文件
res = f_readdir(&dir, &fno);
//为空时表示所有项目读取完毕，跳出
if (res != FR_OK || fno.fname[0] == 0) break;
#if _USE_LFN
fn = *fno.lfname ? fno.lfname : fno.fname;
#else
fn = fno.fname;
#endif
//点表示当前目录，跳过
if (*fn == '.') continue;
//目录，递归读取
if (fno.fattrib & AM_DIR)
{
//合成完整目录名
sprintf(&path[i], "/%s", fn);
//递归遍历
res = func_record_scan_files(path);
path[i] = 0;
//打开失败，跳出循环
if (res != FR_OK)
break;
}
else
{
printf("%s/%s\n", path, fn); //输出文件名
/* 可以在这里提取特定格式的文件路径 */
}//else
} //for
}
return res;
}
/*------------------------------------------------------
读取指定目录下所有的文件
说明:
f_readdir 按顺序读取目录内文件，
重复调用此函数可读取目录内所有文件；
---------------------------------------------------------*/
void func_record_files_update(char * path)
{
char file_name[32] = {0};
FRESULT res; //部分在递归过程被修改的变量，不用全局变量
FILINFO fno = {0};
fs_record_obj.items_num = 0;
fs_record_obj.file_num = 0;
memset((void *)fs_record_obj.file_list, 0x00,sizeof(fs_record_obj.file_list));
memset((void *)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
//获取fatfs文件系统
fs_record_obj.free_size = func_fatfs_get_free();
#if _USE_LFN//如果使能支持长文件名 先对下面两项初始化
fileinfo.lfsize=_MAX_LFN * 2 + 1;//
fileinfo.lfname=(TCHAR*)FileName;//
#endif
if(f_opendir(&fs_record_obj.dir,(const char*)path) != FR_OK)/* 打开文件夹目录成功，目录信息已经在dir结构体中保存 */
{
res = f_mkdir((const char*)path);
if(res == FR_OK)
{
fs_record_obj.fs_stat = true;
return;
}
else
{
return;
}
}
fs_record_obj.fs_stat = true;
//打开日志路径正常,获取路文件夹内的文件列表
while(f_readdir(&fs_record_obj.dir, &fno) == FR_OK) //读文件信息到文件状态结构体中
{
fs_record_obj.items_num++;
//判定的顺序不能变
if(!fno.fname[0]) break; //如果文件名为‘\0'，说明读取完成结束
if (fno.fattrib & AM_DIR) continue; //表示目录，跳过
if (fno.fname[0] == '.') continue; //点表示当前目录，跳过
if( (fs_record_obj.file_num < MAX_FILE_COUNT)
&&(strstr(fno.fname,FILE_START) == fno.fname)
&&((strstr(fno.fname,FILE_END) != 0))
)
{
sprintf((char *)fs_record_obj.file_list[fs_record_obj.file_num], "%s/%s", fs_record_obj.fold,fno.fname);//将文件名存入列表中
fs_record_obj.file_num ++;
}
else
{
/* 如果目录已经存在，关闭它 */
res = f_closedir(&fs_record_obj.dir);
sprintf((char *)file_name,"%s/%s",fs_record_obj.fold, fno.fname); //输出文件名
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_unlink(file_name);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
if(FR_OK != res)
{
fs_record_obj.fs_stat = false;
return;
}
}
}
/* 如果目录已经存在，关闭它 */
res = f_closedir(&fs_record_obj.dir);
if(fs_record_obj.file_num > 0)
{
}
else
{
memset((void *)fs_record_obj.name_send, 0x00,sizeof(fs_record_obj.name_send));
return;
}
//按文件名最小到大排序；
if(fs_record_obj.file_num > 1)
{
func_record_dir_qsort(fs_record_obj.file_num);
}
//获取最新的文件；
uint8_t max_idx = fs_record_obj.file_num - 1;
sprintf((char *)fs_record_obj.name_send,"%s", fs_record_obj.file_list[max_idx]);
//如果文件个数超限，
if((fs_record_obj.file_num > NUM_FILE_SET)
||(fs_record_obj.free_size < 500))
{
//删除日期最早的文件
sprintf((char *)file_name,"%s", fs_record_obj.file_list[0]);
taskENTER_CRITICAL(); /* 临界保护开启 */
res = f_unlink(file_name);
taskEXIT_CRITICAL(); /* 临界保护关闭 */
if(FR_OK != res)
{
fs_record_obj.fs_stat = false;
return;
}
}
UNUSED(res);
return;
}
int qsort_cmp(const void *a,const void *b)
{
return strcmp(( char * ) a, (const char* )b);
}
//(void * /*base*/, size_t /*nmemb*/, size_t /*size*/, int (* /*compar*/)(const void *, const void *)) __attribute__((__nonnull__(1,4)));
void func_record_dir_qsort(size_t fcount)
{
qsort((void *)fs_record_obj.file_list, fcount, sizeof(fs_record_obj.file_list[0]), qsort_cmp);
}
void func_record_init(void)
{
memset(fs_record_obj.file_list, 0x00,sizeof(fs_record_obj.file_list)); //清空文件列表
fs_record_obj.file_num = 0;
fs_record_obj.fs_stat = true;
func_record_files_update((char *)fs_record_obj.fold);
}
void func_record_fs_test(void)
{
record_test_obj.cnts++;
sprintf(record_test_obj.buf,"XX%08xXX",record_test_obj.cnts);
switch(record_test_obj.test_flag)
{
case 0:
{
func_record_write((uint8_t *)record_test_obj.buf ,strlen(record_test_obj.buf));
}break;
case 1:
{
func_record_read((uint8_t *)record_test_obj.buf ,sizeof(record_test_obj.buf));
func_record_delete((uint8_t *)record_test_obj.buf ,sizeof(record_test_obj.buf));
func_record_read((uint8_t *)record_test_obj.buf ,sizeof(record_test_obj.buf));
}break;
default:
{
func_record_read((uint8_t *)record_test_obj.buf ,sizeof(record_test_obj.buf));
}break;
}
}
char* pstr = 0;
char* pidx = 0;
void func_record_str(void)
{
char str_name[] ="20221112.TXT" ;
while(1)
{
pstr = strstr(str_name,FILE_START);
pidx = strstr(str_name,FILE_END);
UNUSED(pstr);
UNUSED(pidx);
}
}
char path_buf[512] = {0};
void func_record_fatfs_main(void const *argument)
{
//func_record_str();
//add boly 20221014 SD卡 FATFS组件初始化
#if USE_SPI_SD
SDCARD_GPIO_Init();
SDCARD_SPI_Init();
#endif
#if USE_SPI_FLASH
func_w25q_init();
func_w25q_test();
#endif
#if USE_FATFS_RECORD
taskENTER_CRITICAL();
func_fatfs_init();
func_fatfs_main();
taskEXIT_CRITICAL();
func_record_queue_init();
func_record_queue_update();
//while(1)
{
osDelay(1000);
};
//end boly
#endif
osDelay(1000);//
func_record_init();
while(1)
{
strcpy(path_buf,fs_record_obj.fold);
//func_fatfs_scan_files(path_buf);
//func_record_fs_test();
func_record_queue_test();
func_record_work();
osDelay(1000);
}
}
#endif //---------------------------USE_FATFS_RECORD----------------------------
/************************ (C) COPYRIGHT STMicroelectronics *****END OF FILE****/