MongoDB聚合：$lookup后仍返回关联非活跃产品问题排查

核心问题 #

你的聚合管道仅完成了筛选活跃订单和关联符合条件的产品两步，但没有过滤掉没有匹配到任何productStatus=1产品的订单——这类订单的productData字段会是空数组，但依然会出现在结果中，看起来像是关联了非活跃产品；另外如果订单关联多个产品，当前lookup仅返回符合条件的产品，但订单本身仍会被保留，若你期望订单关联的所有产品都必须活跃，当前逻辑也不满足。

针对“仅保留关联至少一个活跃产品的订单”的修正方案 #

在$lookup后新增一个$match阶段，过滤掉productData为空的订单：

[
  {
    '$match': {
      'isActive': true
    }
  },
  {
    '$lookup': {
      'from': 'product_masters', 
      'as': 'productData', 
      'let': {
        'isinNo': '$isinNo'
      }, 
      'pipeline': [
        {
          '$match': {
            '$expr': {
              '$and': [
                {
                  '$eq': ['$isinNo', '$$isinNo']
                },
                {
                  '$eq': ['$productStatus', 1]
                }
              ]
            }
          }
        }
      ]
    }
  },
  // 过滤无合格关联产品的订单
  {
    '$match': {
      'productData': { '$ne': [] }
    }
  }
]

针对“订单关联的所有产品必须都是活跃状态”的修正方案 #

如果你的需求是订单关联的所有产品productStatus都等于1，需要先获取所有关联产品，再过滤掉存在非活跃产品的订单：

[
  {
    '$match': {
      'isActive': true
    }
  },
  {
    '$lookup': {
      'from': 'product_masters', 
      'as': 'allProductData', 
      'localField': 'isinNo',
      'foreignField': 'isinNo'
    }
  },
  {
    '$match': {
      'allProductData.productStatus': { '$all': [1] }
    }
  }
]

原管道问题详解 #

原$lookup的子管道仅会将符合productStatus=1的产品存入productData，但不会自动排除那些没有匹配到合格产品的订单——只要订单isActive=true，无论是否有合格关联产品，都会被保留在结果集中，这就是你看到不符合预期结果的原因。

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