$graphLookup を使用できます およびその他の便利な配列演算子
-
$ match
レコードにスポンサー
しかないフィルター""
です -
$graphLookup
子レコードと深度番号をdepthFieldlevel
で取得するには -
$ unwind
downline
を分解します 配列し、空の子を削除しないようにします -
$ sort
深度レベルフィールドlevel
降順 -
$ group
id
による フィールドを作成し、downline
を再構築します 配列 -
$ addFields
次に、ネストされたレベルの子を見つけて、そのレベルに割り当てます。-
$ reduce
downline
のループを繰り返す 配列。 - デフォルトフィールドの
level
を初期化します デフォルト値は-1、presentChild
は[]、prevChild
条件の目的で[]です -
$ let
フィールドを初期化するには:前へ
両方のlevel
の場合、条件に従って 等しい場合はprevChild
を返します それ以外の場合は、presentChild
を返します現在
両方のlevel
の場合、条件に従って 等しい場合はpresentChild
を返します それ以外の場合[]
-
in
level
を返す フィールドとprevChild
初期化されたフィールドからのフィールド-
presentChild
$ filter
ダウンラインコード>
prev
から 配列して戻り、現在のオブジェクトをdownline
とマージします$ mergeObjects
を使用した配列current
と連結します$ concatArrays
を使用したletの配列
-
-
-
$ 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" } }
])