如何在Express.js MongoDB API中实现产品Filter属性的精确匹配查询

你的问题核心在于当前查询用了$or逻辑——只要产品的filters匹配传入的任意一个filter项就会被返回，这和你需要的所有传入filter项都必须匹配的需求完全不符。另外，当前的aggregate流程先过滤匹配的filter条目再判断长度，也无法保证所有条件都被满足。

下面是两种不同程度的精确匹配方案，你可以根据实际需求选择：

方案1：产品包含所有传入的Filter项（允许产品有额外Filter） #

如果你的需求是「产品必须包含传入的每一个filter项，但可以有其他额外的filter」，可以用$allElementsTrue配合$map和$filter实现：

修改后的完整查询代码：

const { ObjectId } = require('mongoose'); // 确保导入ObjectId

filter: async (req, res) => {
  try {
    // 注意：请求体里是"category"单数，这里要和请求字段对应，否则拿不到值！
    const { category, filters } = req.body;
    let products;
    
    if (filters && filters.length > 0) {
      const targ_cat = category;
      products = await Product.aggregate([
        {
          $match: {
            categories: new ObjectId(targ_cat),
            $expr: {
              // 检查所有传入的filter都能在产品的filters中找到匹配项
              $allElementsTrue: {
                $map: {
                  input: filters,
                  as: 'f',
                  in: {
                    $gt: [
                      {
                        $size: {
                          $filter: {
                            input: '$filters',
                            cond: {
                              $and: [
                                { $eq: ['$$this.name', '$$f.name'] },
                                { $eq: ['$$this.value', '$$f.value'] }
                              ]
                            }
                          }
                        }
                      },
                      0
                    ]
                  }
                }
              }
            }
          }
        }
      ]);
    } else {
      // 同样注意字段名和请求体保持一致
      products = await Product.find({ categories: category });
    }
    
    res.status(200).json(products);
  } catch (err) {
    console.log(err);
    res.status(500).json(err);
  }
}

方案2：产品Filters和传入参数完全一致（不允许额外Filter） #

如果你的需求是产品的filters数组必须和传入的数组完全匹配（数量一致，且每个name/value都对应），只需要在方案1的基础上加上数组长度判断：

// 替换方案1中的$expr部分
$expr: {
  $and: [
    {
      $allElementsTrue: {
        $map: {
          input: filters,
          as: 'f',
          in: {
            $gt: [
              {
                $size: {
                  $filter: {
                    input: '$filters',
                    cond: {
                      $and: [
                        { $eq: ['$$this.name', '$$f.name'] },
                        { $eq: ['$$this.value', '$$f.value'] }
                      ]
                    }
                  }
                }
              },
              0
            ]
          }
        }
      }
    },
    // 确保产品的filters数量和传入的完全一致
    { $eq: [{ $size: '$filters' }, filters.length] }
  ]
}

关键逻辑解释 #

• $map：遍历传入的每个filter项，生成一个布尔值数组，每个值代表当前filter项是否能在产品的filters中找到匹配的name+value。
• $filter：针对产品的filters数组，筛选出和当前传入filter项name、value都匹配的条目，再用$size判断是否存在匹配（长度>0）。
• $allElementsTrue：检查布尔数组的所有元素都是true，也就是所有传入的filter项都在产品中存在。
• 长度判断（方案2）：确保产品的filters数量和传入的一致，避免产品有额外的filter项被误匹配。

重要注意事项 #

• 你的请求体里用的是"category"单数，但原代码里解构的是categories复数，这会导致查询时categories为undefined，必须修改字段名保持一致！
• 必须确保ObjectId已正确导入，否则new ObjectId(targ_cat)会抛出错误。

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