问使用多标准mongodb java聚合的$lookup

EN

[{
    $match: {
        category: "Development",
        published: false
    }
}, {
    $lookup: {
        from: 'user',
        localField: 'userId',
        foreignField: 'userId',
        as: 'joinUser'
    }
}, {
    $unwind: {
        path: "$joinUser",
        preserveNullAndEmptyArrays: true
    }
}, {
    $match: {
        "joinUser.status": "active"
    }
}, {
    $addFields: {
        "status": "$joinUser.status"
    }
}, {
    $project: {
        _id: 0,
        userId: 1,
        category: 1,
        published: 1,
        status: 1
    }
}]

import static org.springframework.data.mongodb.core.aggregation.Aggregation.match;
import static org.springframework.data.mongodb.core.aggregation.Aggregation.lookup;
import static org.springframework.data.mongodb.core.aggregation.Aggregation.unwind;
import static org.springframework.data.mongodb.core.aggregation.Aggregation.project;

public Object findAllwithVideos() {
    Aggregation aggregation=Aggregation.newAggregation(
        match(Criteria.where("category").is("Development").and("published").is(false)),
        lookup("user","userId","userId","joinUser"),
        unwind("joinUser",true),
        new AggregationOperation(){
            @Override
            public Document toDocument(AggregationOperationContext aggregationOperationContext){
                return new Document("$addFields",
                    new Document("status","$joinUser.status")
                );
            }
        },
        project("userId","category","published","status")
    ).withOptions(AggregationOptions.builder().allowDiskUse(Boolean.TRUE).build());

    return mongoTemplate.aggregate(aggregation, mongoTemplate.getCollectionName(Document.class), Object.class);
}