17370845950

本文详解如何在 laravel + mongodb 环境中，使用聚合管道（aggregation pipeline）对 `created_at` 字段按小时截断分组，同时按 `category` 动态键名（如 "category a total price"）汇总价格，并将结果扁平化为单行结构。

在 Laravel 项目中集成 MongoDB（常用 jenssegers/mongodb 包）时，若需实现「按时间粒度分组 + 按分类动态键名聚合」的复杂报表需求（如每小时各商品类目销售额汇总），原生 Eloquent 不支持动态字段名聚合，必须借助 MongoDB 原生聚合管道（aggregate()）完成。

以下聚合流程精准匹配你的目标输出格式：
✅ 按 created_at 截断到小时级（非天级；原文示例中 unit: "day" 应修正为 "hour"）
✅ 先按 category + hour 两级分组求和
✅ 再次分组，将各分类汇总结果转为键值对数组（k/v 形式）
✅ 使用 $arrayToObject 动态生成字段，再通过 $mergeObjects 合并 created_at 字段

✅ 正确聚合管道（Laravel 调用示例）

use Jenssegers\Mongodb\Collection;

$collection = (new YourModel)->getCollection(); // 获取原生 Collection 实例

$result = $collection->aggregate([
    [
        '$match' => [
            // 可选：添加时间范围等过滤条件，如 'created_at' => ['$gte' => '2025-02-01']
        ]
    ],
    [
        '$group' => [
            '_id' => [
                'category' => '$category',
                'hour' => [
                    '$dateTrunc' => [
                        'date' => ['$toDate' => '$created_at'],
                        'unit' => 'hour', // ⚠️ 关键：改为 'hour' 实现小时级分组
                    ]
                ]
            ],
            'total' => ['$sum' => '$price']
        ]
    ],
    [
        '$group' => [
            '_id' => '$_id.hour',
            'entries' => [
                '$push' => [
                    'k' => ['$concat' => ['$_id.category', ' Total Price']],
                    'v' => '$total'
                ]
            ]
        ]
    ],
    [
        '$replaceWith' => [
            '$mergeObjects' => [
                ['$arrayToObject' => '$entries'],
                ['created_at' => '$_id']
            ]
        ]
    ]
])->toArray();

? 输出结构说明

执行后将得到类似如下文档（注意：created_at 已被截断为小时精度，如 "2025-02-01T01:00:00Z"）：

{
  "Category A Total Price": 100,
  "Category B Total Price": 350,
  "created_at": "2025-02-01T01:00:00.000Z"
}

⚠️ 注意事项与最佳实践

• 时间字段类型：确保 created_at 在 MongoDB 中为字符串格式（如 "2025-02-01 01:05:00"）。若已是 Date 类型，可省略 $toDate 转换。
• Laravel 版本兼容性：$dateTrunc 需 MongoDB ≥ 5.0；低版本请改用 $dateF

  

  romParts 或 $substr 手动截取（不推荐）。
• 性能优化：在 created_at 和 category 字段上创建复合索引：

  db.collection.createIndex({ "created_at": 1, "category": 1 })

• 空值防护：生产环境建议在 $match 阶段排除 null/空字符串的 category 或 price，避免聚合异常：

  '$match' => [
      'category' => ['$ne' => null],
      'price' => ['$ne' => null, '$type' => 'number']
  ]

该方案无需为每个分类编写独立查询，也无需 PHP 层手动合并，完全由数据库高效完成动态透视聚合，兼顾可读性与执行性能。