如何使用nodejs与mongo DB的另一个集合中的数据进行排序，并进行一对二的映射？

如何解决如何使用nodejs与mongo DB的另一个集合中的数据进行排序，并进行一对二的映射？

我在mongo DB中有2个收藏集-

1. 车辆
2. 车针

在这里您可以下载集合的json- Download

我想按stockid加入，按描述计数排序，按description.type分组。 意味着，UI中有一列名为DAMAGE，如果我对此字段进行排序，则它将按最高DAMAGE计数进行排序。您的帮助将不胜感激。

输出应该像这样-

{
    "stockid": 62790,"condition": "Used","vin": "WA1C4AFY1J2153426","make": "Audi","carYear": 2018,"carBody": "SUV","model": "SQ5","series": "3.0 TFSI Prestige","mileage": 21861,"exteriorColor": "WHITE","interiorColor": "DK RED","fuelType": "Gasoline Fuel","seating": "5","listPrice": 35900,"damageCount": 5,"possibleFeatureCount": 1,"featureCount": 5
},{
    "stockid": 62852,"vin": "WAU43AFD4HN017288","carYear": 2017,"carBody": "Sedan","model": "A8 L","series": "4.0 TFSI Sport","mileage": 32427,"interiorColor": "LT GRAY","listPrice": 38900,"damageCount": 1,"featureCount": 2
},{
    "stockid": 6740,"vin": "5TDKK3DC7GS751192","make": "Toyota","carYear": 2016,"model": "Sienna","series": "5dr 7-Pass Van LE FWD","mileage": 11111,"exteriorColor": "BLACK","cylinder": "V6 Cylinder Engine","seating": "7","listPrice": 18900,"damageCount": 13,"possibleFeatureCount": 3,"featureCount": 3
}

解决方法

您可以使用Aggregation Pipeline进行计算和排序。我建立了一个符合您要求的管道。

[
{$unwind: {
  path: "$description"
}},{$group: {
  _id: "$stockId",description: {
    $push: "$description"
  }
}},{$lookup: {
  from: 'vehicles',localField: '_id',foreignField: 'stockid',as: 'vehicleInfo'
}},{$addFields: {
  damageCount: {
    $size: {
      $filter: {
        input: '$description',as: 'desc',cond: {
          $eq: [
            '$$desc.type','DAMAGE'
          ]
        }
      }
    }
  }
}},{$sort: {
  damageCount: -1
}}
]

管道要做的第一件事是展开描述数组。我这样做是因为同一个stockid可以出现多次。

然后$ group阶段根据stockid对文档进行分组。原始描述数组中的所有项目均被推送到新的描述字段。

$ lookup阶段将vehicles集合和vehicle-pins上的stockId集合加入。此阶段将来自vehicles集合的信息放入名为vehicleInfo的数组中。

$ addFields阶段向每个名为damageCount的文档中添加一个字段，该字段计算描述中有多少个元素具有等于DAMAGE的类型。

$ sort阶段按新的damageCount字段以降序对文档进行排序。

我在MongoDB Atlas中包含了以下管道的屏幕截图，以便您了解每个阶段发生的事情。

注意：当我将您的文档导入Atlas时，两个集合中的库存编号都不相同。一个stockid的类型为string类型，另一个为int32类型。在我将它们设置为相同类型之前，$ lookup阶段不起作用。如果您不想自己更新文档，则可以在管道中添加一个阶段进行转换：$toInt。