Можете да използвате $graphLookup и други полезни оператори за масиви,
$match
филтър, който записва самоsponsor
е""
$graphLookup
за получаване на дъщерни записи и номер на дълбочина в deepFieldlevel
$unwind
деконструирайтеdownline
масив и позволява да не се премахват празни деца$sort
по ниво на дълбочина полеlevel
в низходящ ред$group
отid
поле и реконструирайтеdownline
масив$addFields
сега намерете децата на вложеното ниво и разпределете към неговото ниво,$reduce
за итериране на цикъл наdownline
масив.- инициализиране на полето по подразбиране
level
стойността по подразбиране е -1,presentChild
е [],prevChild
е [] за целта на условията $let
за инициализиране на полета:prev
според условието, ако и дветеlevel
са равни, тогава връщаprevChild
в противен случай връщаpresentChild
current
според условието, ако и дветеlevel
са равни, тогава връщаpresentChild
в противен случай []
in
за връщане наlevel
поле иprevChild
поле от инициализирани полетаpresentChild
$filter
downline
отprev
масив и връщане, обединяване на текущи обекти сdownline
масив с помощта на$mergeObjects
и concat сcurrent
масив от let с помощта на$concatArrays
$addFields
за да върне самоpresentChild
масив, защото изисквахме само този обработен масив
db.collection.aggregate([
{ $match: { sponsor: "" } },
{
$graphLookup: {
from: "collection",
startWith: "$_id",
connectFromField: "_id",
connectToField: "sponsor",
depthField: "level",
as: "downline"
}
},
{
$unwind: {
path: "$downline",
preserveNullAndEmptyArrays: true
}
},
{ $sort: { "downline.level": -1 } },
{
$group: {
_id: "$_id",
sponsor: { $first: "$sponsor" },
companyname: { $first: "$companyname" },
downline: { $push: "$downline" }
}
},
{
$addFields: {
downline: {
$reduce: {
input: "$downline",
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",
{
downline: {
$filter: {
input: "$$prev",
as: "e",
cond: { $eq: ["$$e.sponsor", "$$this._id"] }
}
}
}
]
}
]
]
}
}
}
}
}
}
}
},
{ $addFields: { downline: "$downline.presentChild" } }
])