MongoDB聚合$project中同时访问lookup与主集合嵌套字段方案咨询

首先明确：完全可以在$project阶段同时访问主集合嵌套字段和lookup关联返回的字段，不需要额外合并数组，你遇到的无法访问问题是由两处逻辑错误导致的：

• 错误1：$addFields阶段提取外键错误：你需要将unwind后子文档的$users._id转为字符串作为关联外键，而非不存在的顶层字段$userId，这会导致lookup关联结果异常
• 错误2：示例中的users数组子文档不存在你筛选用的field1字段，若为实际业务自定义字段可保留，否则需要调整筛选规则

修正后的聚合管道 #

$pipeline = [
    [
        '$match' => [
            'users' => [
                '$elemMatch' => [
                    'field1' => $field1,
                ],
            ]
        ]
    ],
    ['$unwind' => '$users'],
    [
        '$match' => [
            'users.field1' => $field1,
        ]
    ],
    // 修正：提取users子文档的_id转为字符串作为关联外键
    ['$addFields' => ['userId' => ['$toString' => '$users._id']]],
    [
        '$lookup' => [
            'from' => 'comments',
            'localField' => 'userId',
            'foreignField' => 'userId',
            'as' =>  'userComments'
        ]
    ],
    // 如果允许无评论的用户保留，建议加preserveNullAndEmptyArrays参数避免数据丢失
    ['$unwind' => ['path' => '$userComments', 'preserveNullAndEmptyArrays' => true]],
    [
        '$project' => [
            'comments'  => [
                '$switch'   => [
                    'branches'  => [
                        [ 
                            'case' => ['$eq' => ['$userComments.status','verified']],
                            'then'  => 1
                        ],
                        [ 
                            'case' => ['$lte' => ['$userComments.status', '']],
                            'then'  => 1
                        ],
                    ],
                    'default'   => 0
                ]
            ],
            'status' => [
                // 这里如果要把active转为1、passive转为0用于求和，建议加转换逻辑
                '$cond' => [['$eq' => ['$users.status', 'active']], 1, 0]
            ],
            // 修正：统计总条数赋值为1
            'total' => 1,
        ]
    ],
    [
        '$group' => [
            '_id' => $groupBy,
            'text' => ['$sum' => '$comments'],
            'total' => ['$sum' => '$total'],
            'completed' => ['$sum' => '$status'],
        ]
    ],
];

逻辑说明 #

$unwind操作只会拆分你指定的数组字段，文档内的其他所有字段（包括主集合的顶层字段、嵌套字段、lookup返回的关联字段）都会完整保留在拆分后的每一条文档中，只要字段路径书写正确，就可以在$project、$group等任意后续阶段同时调用。

内容的提问来源于stack exchange，提问作者Victor