4l_capital_central_control_client/src/utils/file.js

const fs = require('fs');
const path = require('path');
const {logger} = require("./logger");
const {rustConfig} = require("../config");
const http = require("./http");


// 检查目录是否存在，不存在新建
function checkPathSync(filePath) {
    // 将相对路径转换为绝对路径
    const directoryPath = path.resolve(filePath);
    // 同步检查目录是否存在
    if (!fs.existsSync(directoryPath)) {
        // 目录不存在，需要创建它
        logger.info('目录不存在，正在创建...');
        try {
            // 同步创建目录
            fs.mkdirSync(directoryPath, {recursive: true});
            logger.info('目录已成功创建');
        } catch (error) {
            // 创建目录失败
            logger.error('创建目录失败:', error);
            return false
        }
    } else {
        // 目录已存在
        logger.info('目录已存在');
    }
    return true
}

// 检查文件是否存在
function checkFilePath(filePath) {
    // 同步检查文件是否存在
    const directoryPath = path.resolve(filePath);
    if (fs.existsSync(directoryPath)) {
        logger.info('文件存在:' + filePath);
        return true
    } else {
        logger.error('文件不存在:' + filePath);
        return false
    }
}

// 创建文件
function writeFile(filePath, text, breakFun) {
    fs.writeFile(filePath, text, (err) => {
        if (err) {
            console.error('写入文件时发生错误:', err);
            breakFun(err)
        } else {
            console.log('文件已成功写入!');
            breakFun(null, true)
        }
    });
}

// 同步复制
function copyFileSync(source, destination) {
    try {
        // 同步复制文件
        fs.copyFileSync(source, destination);
        // logger.info("成功");
        return true;
    } catch (err) {
        return false;
        // logger.info("失败");
    }
}

// // 读取日志（倒叙）指定行数
// function readLastNLines(filePath, n) {
//     const content = fs.readFileSync(filePath, 'utf8');
//     const lines = content.trim().split('\n');
//     const lastNLines = lines.slice(-n).join('\n');
//
//     // 此处处理或输出最后n行的内容
//     // console.log(lastNLines);
//     return lastNLines.split("\n").reverse();
// }


// 下载文件
function dowFile(url, fileName, dowPath, headers) {
    return http.dowFile(url, fileName, dowPath, headers)
}

// 删除文件
function delFile() {
}

/***********************************/
function getLastFile(dirPath, number, callback) {
    fs.readdir(dirPath, async (err, files) => {
        if (err) {
            console.error(`Could not list the directory.`, err);
            process.exit(1);
        }
        let fileList = [];
        for (file of files) {
            const filePath = path.join(dirPath, file);
            const stats = await fs.promises.stat(filePath);
            fileList.push({name: file, time: stats.mtimeMs});
        }
        fileList.sort((a, b) => b.time - a.time);
        lastFileList = fileList.slice(0, number != -1 ? number : fileList.length);
        lastFileNameList = lastFileList.map((item) => item.name);
        callback(lastFileNameList.reverse(), lastFileList.reverse());
    });
}

// 读取日志（倒叙）指定行数
function readLastNLines(dirPath, filePathList, n) {
    const fileList = filePathList.map((item) => {
        var filepath = dirPath + "/" + item
        // 将相对路径转换为绝对路径
        const directoryPath = path.resolve(filepath);
        logger.info("日志文件:" + directoryPath)
        let lines = [""]
        if (checkFilePath(directoryPath)) {
            const content = fs.readFileSync(`${filepath}`, "utf8");
            lines = content.trim().split("\n");
        }
        return {
            filePath: item,
            lines: lines,
        };
    });
    const allFile = [].concat(...fileList.map((item) => item.lines));
    const lastNLines = allFile.slice(-n).join("\n");
    return lastNLines.split("\n").reverse();
}


module.exports = {
    dowFile,
    checkFilePath,
    checkPathSync,
    writeFile,
    copyFileSync,
    readLastNLines,
    getLastFile
}