Express+Mongoose商品搜索路由异常及聚合转查询方法咨询

一、聚合返回空数组的排查点 #

1. 评分过滤逻辑错误：检查聚合中评分相关的$match阶段，比如是否误将rating >= 3写成rating > 3，或者字段名拼写错误（比如把rating写成score）。
2. 聚合阶段顺序错误：如果先执行$limit再执行$match，会导致过滤前就截断数据，必须确保$match在$limit、$skip之前执行。
3. 排序字段不存在：sort=recommend对应的排序字段（比如rating、sales）是否在Schema中定义，或者字段类型不匹配（比如存的是字符串而非数字）。

二、改用Mongoose查询方法实现完整逻辑 #

1. 确保Product Schema字段正确 #

const mongoose = require('mongoose');

const productSchema = new mongoose.Schema({
  name: String,
  price: Number,
  rating: Number, // 商品评分，0-5
  tags: [String], // 标签数组
  sales: Number, // 销量，用于推荐排序
  // 其他业务字段...
});

const Product = mongoose.model('Product', productSchema);

2. 搜索路由实现（Mongoose查询版） #

const express = require('express');
const router = express.Router();
const Product = require('../models/Product');

router.get('/search', async (req, res) => {
  try {
    // 解析查询参数
    const {
      tags, // 逗号分隔的标签，如tags=electronics,phone
      minPrice,
      maxPrice,
      minRating,
      sort = 'recommend', // 默认推荐排序
      page = 1,
      limit = 10
    } = req.query;

    // 构建查询条件
    const query = {};

    // 标签筛选：匹配包含所有指定标签的商品
    if (tags) {
      const tagList = tags.split(',');
      query.tags = { $all: tagList };
    }

    // 价格范围筛选
    if (minPrice || maxPrice) {
      query.price = {};
      if (minPrice) query.price.$gte = Number(minPrice);
      if (maxPrice) query.price.$lte = Number(maxPrice);
    }

    // 评分筛选
    if (minRating) {
      query.rating = { $gte: Number(minRating) };
    }

    // 处理排序规则
    let sortOption;
    switch (sort) {
      case 'price-asc':
        sortOption = { price: 1 };
        break;
      case 'price-desc':
        sortOption = { price: -1 };
        break;
      case 'rating-desc':
        sortOption = { rating: -1 };
        break;
      case 'recommend':
        // 推荐排序：评分降序 + 销量降序
        sortOption = { rating: -1, sales: -1 };
        break;
      default:
        sortOption = { rating: -1, sales: -1 };
    }

    // 计算分页参数
    const skip = (Number(page) - 1) * Number(limit);
    const limitNum = Number(limit);

    // 并行查询数据和总条数，提升性能
    const [products, total] = await Promise.all([
      Product.find(query)
        .sort(sortOption)
        .skip(skip)
        .limit(limitNum),
      Product.countDocuments(query)
    ]);

    res.json({
      code: 0,
      data: {
        products,
        pagination: {
          page: Number(page),
          limit: limitNum,
          total,
          totalPages: Math.ceil(total / limitNum)
        }
      }
    });
  } catch (err) {
    console.error(err);
    res.status(500).json({ code: -1, message: '搜索失败' });
  }
});

module.exports = router;

3. 关键说明 #

• 标签筛选：用$all确保商品包含所有指定标签，若需匹配任意标签可改用$in。
• 排序逻辑：recommend排序结合评分和销量，符合常规推荐场景，可根据需求调整字段顺序。
• 分页优化：通过Promise.all并行执行数据查询和总数统计，避免串行请求的性能损耗。
• 参数校验：实际项目中需对数值型参数做类型校验和范围限制，比如minPrice不能为负数，避免非法值导致查询异常。

三、测试注意事项 #

测试/search?limit=5&sort=recommend时：

1. 确认数据库中存在rating和sales字段有有效值的商品。
2. 若需要默认评分过滤，可在query.rating中添加默认规则，比如query.rating = { $gte: 3 }。

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