改进聚合查询以获得不同的结果

Improve aggregation query to get distinct results

我有这个聚合查询,returns Operation 字段 amount:BigDecimal 高于 minAmount 且在日期 range.I 内的对象只想获取不同的结果(每个 Operation 对象都有一个 operationId:String),基于 operationId.

我在这里找到了一个相关的例子,但它并没有帮助我解决我的问题:

我知道可以使用 addToSetgroup,但我不清楚如何将它准确地合并到查询的其余部分中

    private List<OperationDataVO> getInfoFromDB(BigDecimal minAmount,
                                                     Instant startDate, Instant endDate) {
        Criteria criterias = new Criteria()
            .andOperator(Criteria.where(WinningOperation.AMOUNT)
                    .gte(minAmount)
                    .and(Operation.TYPE).is(OperationTypeEnum.WINNING_TYPE)
                    .and("createdAt").gte(startDate).lte(endDate));

        MatchOperation matchOperation = Aggregation.match(criterias);

        ProjectionOperation projectionOperation = 
                Aggregation.project("amount", "operationId");

        Aggregation aggregation = Aggregation.newAggregation(matchOperation,
                projectionOperation, sort(direction, "amount"));

        AggregationResults<OperationDataVO> aggregate = mongoTemplate
                .aggregate(aggregation, COLLECTION, OperationDataVO.class);

        return aggregate.getMappedResults();
    }

此外,我尝试在 Aggregation 管道中添加一个组操作,但是当我这样做时,我得到一个 OperationDataVO 列表,其中每个对象的两个字段都是 null

(Aggregation aggregation = Aggregation.newAggregation(matchOperation, projectionOperation, sort(direction, "amount"), group("operationId")); )

在进行分组之前,您需要按 amount 降序排列。 应该使用“$first”累加器进行分组。我们使用 $$ROOT 保留整个文档。 然后您可以用组中的文档替换根文档。

分组不保留任何顺序,因为您想对最终结果进行排序,您需要重新排序。

实现此目的的 mongo shell 代码如下所示:

db.getCollection('operationData').aggregate([
{ $match: ... } ,
{ $project: { amount: 1, operationId: 1 } },
{ $sort: { amount: -1 } },
{ $group: { _id: '$operationId', g: { $first: {data: '$$ROOT'} }} },
{ $replaceRoot: { newRoot: '$g.data' }},
{ $sort: { amount: 1 } }
])

这需要翻译成Spring数据Mongo(也许我以后有时间自己试试)。