Bạn có thể sử dụng $ graphLookup và các toán tử mảng hữu ích khác,
-
$match
lọc các bản ghi chỉ cósponsor
là""
-
$graphLookup
để lấy các bản ghi con và số chiều sâu ở cấp độ DeepFieldlevel
-
$unwind
giải mãdownline
mảng và cho phép không xóa phần con trống -
$sort
theo trường cấp độ sâulevel
theo thứ tự giảm dần -
$group
bởiid
trường và cấu trúc lạidownline
mảng -
$addFields
bây giờ tìm cấp độ con lồng nhau và phân bổ cho cấp độ của nó,-
$reduce
để lặp lại vòng lặp củadownline
mảng. - khởi tạo trường mặc định
level
giá trị mặc định là -1,presentChild
là [],prevChild
là [] cho mục đích điều kiện -
$let
để khởi tạo các trường:-
prev
theo điều kiện nếu cảlevel
bằng nhau thì trả vềprevChild
nếu không thì trả vềpresentChild
-
current
theo điều kiện nếu cảlevel
bằng nhau thì trả vềpresentChild
nếu không thì []
-
-
in
để trả vềlevel
trường vàprevChild
trường từ các trường đã khởi tạo-
presentChild
$filter
downline
từprev
mảng và trả về, hợp nhất các đối tượng hiện tại vớidownline
mảng sử dụng$mergeObjects
và nối vớicurrent
mảng let sử dụng$concatArrays
-
-
-
$addFields
để chỉ trả lạipresentChild
mảng vì chúng tôi chỉ yêu cầu mảng đã xử lý đó
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" } }
])