开发日志25120809

//==========总览
const root = 'LOG';
const today = new Date().toISOString().slice(0, 10); // YYYY-MM-DD
const path = `HOST/${today}.json`;

// 读取文件
let summary = {};
try {
    const resHost = await fetch(`/api/file/read?root=${encodeURIComponent(root)}&path=${encodeURIComponent(path)}`);
    if (resHost.ok || resHost.status === 404) {
        summary = await resHost.json();
        if (JSON.stringify(summary) === '{}') {
            summary = { summary: {}, devices: [] };
        }
    } else {
        throw new Error(`HTTP ${resHost.status}: ${resHost.statusText}`);
    }
} catch (error) {
    // 网络错误或其他异常，也使用空数组
    console.warn('获取文件失败，使用空数组:', error.message);
}

//总览
let summaryHost = summary.summary;
//找到对应项
let summaryDevice = summary.devices.find(item => item.deviceId === deviceId);

if (!summaryDevice) {
    summaryDevice = { deviceId }
    summary.devices.push(summaryDevice);
};

//如果返回脚本执行成功
let updparam = ['totalRuns'];//需要+1的参数
if (result) {
    updparam.push('successCount');
    if (returns.likeVideo) updparam.push('likeVideo');
    if (returns.commentVideo) updparam.push('commentVideo');
} else {
    updparam.push('failureCount');
}
updSummary(updparam, summaryHost, summaryDevice);

post(`/api/file/write`, {
    root,
    path,
    content: JSON.stringify(summary, null, 4)
});

function updSummary(keys, objs) {
    if (!keys || !objs) return;

    // 确保传入是数组（兼容字符串和数组两种传参方式）
    const keyList = Array.isArray(keys) ? keys : [keys];
    const objList = Array.isArray(objs) ? objs : [objs];

    //对每个对象的对应键值+1
    keyList.forEach(key => {
        objList.forEach(obj => {
            if (key in obj) {
                obj[key]++;//次数+1
            } else {
                obj[key] = 1;//置为1
            }
        });
    });
}

//====================执行结果记录
const root = 'SUMMARY';
const today = new Date().toISOString().slice(0, 10); // YYYY-MM-DD
const hostPath = `HOST/${today}.json`;
const devicePath = `设备${deviceNo} - ${deviceId}/${today}.json`;

// 读取文件
let summary = {};
let record = {};

//执行总数记录
try {
    const resHost = await fetch(`/api/file/read?root=${encodeURIComponent(root)}&path=${encodeURIComponent(hostPath)}`);
    if (resHost.ok) {
        summary = await resHost.json();
        if (Object.keys(summary).length === 0) {
            summary = { summary: {}, devices: [] };
        }
    } else if (resHost.status === 404) {
        summary = { summary: {}, devices: [] };
    } else {
        throw new Error(`HTTP ${resHost.status}: ${resHost.statusText}`);
    }
} catch (error) {
    // 网络错误或其他异常，也使用空数组
    console.warn('获取文件失败，使用空数组:', error.message);
}

//单台设备详细记录
try {
    const resDevice = await fetch(`/api/file/read?root=${encodeURIComponent(root)}&path=${encodeURIComponent(devicePath)}`);
    if (resDevice.ok) {
        record = await resDevice.json();
        if (Object.keys(record).length === 0) {
            record = { summary: {}, runs: [] };//若空则初始化
        }
    } else if (resDevice.status === 404) {
        record = { summary: {}, runs: [] };//若空则初始化
    } else {
        throw new Error(`HTTP ${resDevice.status}: ${resDevice.statusText}`);
    }
} catch (error) {
    // 网络错误或其他异常，也使用空数组
    console.warn('获取文件失败，使用空数组:', error.message);
}

//执行总数记录
let summaryHost = summary.summary;
//找到设备对应对象
let summaryDevice = summary.devices.find(item => item.deviceId === deviceId);
//为空时push到数组中
if (!summaryDevice) {
    summaryDevice = { deviceId }
    summary.devices.push(summaryDevice);
};

//设备执行记录
let recordSummary = record.summary;

//如果返回脚本执行成功
let keys = ['totalRuns'];//总运行次数+1
let updObj = [summaryHost, summaryDevice, recordSummary]
//...         所有设备总计数  单设备计数     单设备详细记录
if (result) {
    //更新到summary
    keys.push('successCount');//如果成功运行+1
} else {
    keys.push('failureCount');//如果失败运行+1
}
updSummary(keys, updObj);

//分平台结果分别储存
keys = [];
summaryDevice[platform] = summaryDevice[platform] || {};
recordSummary[platform] = recordSummary[platform] || {};
updObj = [summaryDevice[platform], recordSummary[platform]];
//后期可能需要自动判断
if (returns.likeVideo) keys.push('likeVideo');//如果点赞了+1
if (returns.myComment) keys.push('commentVideo');//如果评论了+1
updSummary(keys, updObj);
//固定运行记录
let currentRecord = {
    task: task.name,
    platform,
    success: result,
    returns
}
//push到数组
record.runs.push(currentRecord);

//写入总记录
post(`/api/file/write`, {
    root,
    path: hostPath,
    content: JSON.stringify(summary, null, 4)
});
//写入详细记录
post(`/api/file/write`, {
    root,
    path: devicePath,
    content: JSON.stringify(record, null, 4)
});