
本文详解如何在 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' => '2022-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 已被截断为小时精度,如 "2022-02-01T01:00:00Z"):
{
"Category A Total Price": 100,
"Category B Total Price": 350,
"created_at": "2022-02-01T01:00:00.000Z"
}⚠️ 注意事项与最佳实践
- 时间字段类型:确保 created_at 在 MongoDB 中为字符串格式(如 "2022-02-01 01:05:00")。若已是 Date 类型,可省略 $toDate 转换。
- Laravel 版本兼容性:$dateTrunc 需 MongoDB ≥ 5.0;低版本请改用 $dateFromParts 或 $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 层手动合并,完全由数据库高效完成动态透视聚合,兼顾可读性与执行性能。










