PHP中高效聚合多JSON文件数据并生成报表

{
    "id": "id_1638974137049",
    "weeknr": 48,
    "dayhours": 5,
    "tvt": 1.25
}

<?php

// 定义JSON文件所在的目录
$dataDirectory = 'data/*.json'; 

// 使用glob函数查找匹配指定模式的所有文件路径
// 结果是一个包含所有文件路径的数组
$files = glob($dataDirectory);

// 初始化一个空数组，用于存储所有解析后的JSON对象
$allJsonObjects = [];

// 遍历每个找到的文件
foreach ($files as $file) {
    // 读取文件内容
    $jsonContent = file_get_contents($file);

    // 将JSON字符串解码为PHP关联数组
    // 第二个参数设置为 true 表示解码为关联数组，而不是标准对象
    $decodedData = json_decode($jsonContent, true);

    // 检查解码是否成功，避免处理无效JSON
    if (json_last_error() === JSON_ERROR_NONE && is_array($decodedData)) {
        $allJsonObjects[] = $decodedData;
    } else {
        // 可以根据需要添加错误处理逻辑，例如记录日志
        error_log("Error decoding JSON from file: " . $file . " - " . json_last_error_msg());
    }
}

// 此时，$allJsonObjects 数组中包含了所有JSON文件解析后的PHP关联数组
// 例如：
// [
//     ['id' => 'id_...', 'weeknr' => 48, 'dayhours' => 5, 'tvt' => 1.25],
//     ['id' => 'id_...', 'weeknr' => 48, 'dayhours' => 6, 'tvt' => 1.50],
//     ...
// ]

?>

<?php
// 假设 $allJsonObjects 已经如上一步所示填充完毕

// 初始化一个空数组，用于存储按周聚合后的数据
// 结构将是：[weeknr => ['dayhours' => total_dayhours, 'tvt' => total_tvt]]
$weeksData = [];

// 遍历所有解析后的JSON对象
foreach ($allJsonObjects as $dataEntry) {
    // 获取当前记录的周数
    $weeknr = $dataEntry['weeknr'];

    // 确保当前周的数据结构已存在，如果不存在则初始化为0
    // 使用 null 合并运算符 (??) 是一个简洁的写法，
    // 如果 $weeksData[$weeknr]['dayhours'] 不存在或为 null，则取 0
    $weeksData[$weeknr]['dayhours'] = ($weeksData[$weeknr]['dayhours'] ?? 0) + $dataEntry['dayhours'];
    $weeksData[$weeknr]['tvt'] = ($weeksData[$weeknr]['tvt'] ?? 0) + $dataEntry['tvt'];
}

// 此时，$weeksData 数组将包含按周聚合后的数据，例如：
// [
//     48 => ['dayhours' => 18, 'tvt' => 4.5],
//     49 => ['dayhours' => 20, 'tvt' => 6.5],
//     50 => ['dayhours' => 24, 'tvt' => 5.5],
//     ...
// ]

?>

<?php

// 1. 定义JSON文件所在的目录模式
$dataDirectoryPattern = 'data/*.json'; 

// 2. 查找所有匹配的文件
$files = glob($dataDirectoryPattern);

// 3. 初始化数组用于存储所有解码后的JSON对象
$allJsonObjects = [];

// 4. 遍历文件，读取并解码JSON
foreach ($files as $file) {
    $jsonContent = file_get_contents($file);
    $decodedData = json_decode($jsonContent, true);

    if (json_last_error() === JSON_ERROR_NONE && is_array($decodedData)) {
        $allJsonObjects[] = $decodedData;
    } else {
        error_log("Error decoding JSON from file: " . $file . " - " . json_last_error_msg());
    }
}

// 5. 初始化数组用于存储按周聚合后的数据
$weeksData = [];

// 6. 遍历所有解码后的数据，进行聚合
foreach ($allJsonObjects as $dataEntry) {
    $weeknr = $dataEntry['weeknr'];

    // 累加 dayhours 和 tvt，使用 ?? 运算符处理首次出现的周数
    $weeksData[$weeknr]['dayhours'] = ($weeksData[$weeknr]['dayhours'] ?? 0) + $dataEntry['dayhours'];
    $weeksData[$weeknr]['tvt'] = ($weeksData[$weeknr]['tvt'] ?? 0) + $dataEntry['tvt'];
}

// 7. 打印聚合后的数据（可选，用于调试或验证）
echo "<pre>";
print_r($weeksData);
echo "</pre>";

// 预期输出类似：
// Array
// (
//     [48] => Array
//         (
//             [dayhours] => 18
//             [tvt] => 4.5
//         )
//     [49] => Array
//         (
//             [dayhours] => 20
//             [tvt] => 6.5
//         )
//     [50] => Array
//         (
//             [dayhours] => 24
//             [tvt] => 5.5
//         )
// )

?>

<?php
// 假设 $weeksData 已经包含聚合后的数据

echo "<table border='1'>";
echo "<thead>";
echo "<tr><th>周数 (weeknr)</th><th>总日工时 (tot dayhours)</th><th>总电视观看时间 (tot tvt hours)</th></tr>";
echo "</thead>";
echo "<tbody>";

// 遍历聚合后的数据，每一项代表一周的汇总
foreach ($weeksData as $weeknr => $totals) {
    echo "<tr>";
    echo "<td>" . htmlspecialchars($weeknr) . "</td>";
    echo "<td>" . htmlspecialchars($totals['dayhours']) . "</td>";
    echo "<td>" . htmlspecialchars($totals['tvt']) . "</td>";
    echo "</tr>";
}

echo "</tbody>";
echo "</table>";

?>