Можете да използвате $graphLookup и други полезни оператори за масиви,
$matchфилтър, който записите имат самоparent_idеnull$graphLookupза получаване на дъщерни записи и номер на дълбочина в deepFieldlevel$unwindдеконструирайтеchildrenмасив и позволява да не се премахват празни деца$sortпо ниво на дълбочина полеlevelв низходящ ред$groupотidполе и реконструираchildrenмасив
db.collection.aggregate([
{ $match: { parent_id: null } },
{
$graphLookup: {
from: "collection",
startWith: "$id",
connectFromField: "id",
connectToField: "parent_id",
depthField: "level",
as: "children"
}
},
{
$unwind: {
path: "$children",
preserveNullAndEmptyArrays: true
}
},
{ $sort: { "children.level": -1 } },
{
$group: {
_id: "$id",
parent_id: { $first: "$parent_id" },
name: { $first: "$name" },
type: { $first: "$type" },
category: { $first: 1 },
children: { $push: "$children" }
}
},
$addFieldsсега намерете децата на вложеното ниво и разпределете към неговото ниво,- $reduce to iterate цикъл на
childrenмасив. - инициализиране на полето по подразбиране
levelстойността по подразбиране е -1,presentChildе [],prevChildе [] за целта на условията $letза инициализиране на полета:prevспоред условието, ако и дветеlevelса равни, тогава връщаprevChildв противен случай връщаpresentChildcurrentспоред условието, ако и дветеlevelса равни, тогава връщаpresentChildв противен случай []
inза връщане наlevelполе иprevChildполе от инициализирани полетаpresentChild$filterchildrenотprevмасив и връщане, обединяване на текущи обекти сchildrenмасив с помощта на$mergeObjectsи concat сcurrentмасив от let с помощта на$concatArrays
- $reduce to iterate цикъл на
$addFieldsза да върне самоpresentChildмасив, защото изисквахме само този обработен масив
{
$addFields: {
children: {
$reduce: {
input: "$children",
initialValue: { level: -1, presentChild: [], prevChild: [] },
in: {
$let: {
vars: {
prev: {
$cond: [
{ $eq: ["$$value.level", "$$this.level"] },
"$$value.prevChild",
"$$value.presentChild"
]
},
current: {
$cond: [{ $eq: ["$$value.level", "$$this.level"] }, "$$value.presentChild", []]
}
},
in: {
level: "$$this.level",
prevChild: "$$prev",
presentChild: {
$concatArrays: [
"$$current",
[
{
$mergeObjects: [
"$$this",
{
children: {
$filter: {
input: "$$prev",
as: "e",
cond: { $eq: ["$$e.parent_id", "$$this.id"] }
}
}
}
]
}
]
]
}
}
}
}
}
}
}
},
{
$addFields: {
id: "$_id",
children: "$children.presentChild"
}
}
])