I have a mongo collection which has many documents containing information about credits / gifts given to our users.

I would like to be able to run an Aggregated Query to get all the users who have received a credit / gift within the last x number of days and sum the total value of those credits for each user.

I think I have the correct Aggregation, group and sum code but I'm getting back more than one object per user, which shouldn't be the case since I'm grouping and then summing the values(?)

Here is what my document structure looks like:

    _id: ObjectId("61c36a8a21047124c4181271"),
    transactionId: UUID("6fbf536e-7a53-442c-9615-53e32362608b"),
    userId: 'xxxxx',
    transactionMessage: 'Account credited with: 1',
    transactionType: 'CREDIT',
    transactionAction: 'GIFT',
    inComingPaymentFromUserId: 'xxxx',
    transactionAmount: Decimal128("1"),
    customMessage: "blah'",
    createdDate: ISODate("2021-12-22T18:12:26.812Z"),
    lastUpdatedAt: ISODate("2021-12-22T18:12:26.812Z"),
And here is my query code:
    @Override
    public List<RecentlyRewardedUsers> findRecentlyRewardedUsers(Integer range, Pageable pageable) {
        Aggregation agg = Aggregation.newAggregation(
                match(Criteria.where("createdDate").gt(LocalDate.now().minusDays(range))
                        .andOperator(Criteria.where("transactionAction").is("GIFT"))), sort(Sort.Direction.DESC, "createdDate"),
                group("userId", "_id").sum("transactionAmount").as("totalValueAwarded"),
                project("userId", "totalValueAwarded"),
                skip((long) pageable.getPageNumber() * pageable.getPageSize()),
                limit(pageable.getPageSize()));
        try {
            return mongoTemplate.aggregate(agg, "Transactions", RecentlyRewardedUsers.class).getMappedResults();
        } catch (Exception ex) {
            throw new ServiceUnavailableException("Unable to perform Mongo Operation {" + ex.getLocalizedMessage() + "}", "User");
Here is also my mapped class:
@Getter
@Setter
public class RecentlyRewardedUsers {
    @Field("userId")
    private String userId;
    private String totalValueAwarded;
    private String userDisplayName;
    private String profilePicUrl;
Like I said above, when the the results of the query are mapped to the RecentlyRewardedUsers class, I see multiple entries for the same userId (see image below). I would have thought it should be all rolled up / summed up into one entry for that userId
If anyone can shed some light on what I've done wrong that would be great!!
Thank you
** EDIT **
Based on the answer below from
user Eskandar Abedini, I've updated my code to be the following:
Criteria operator = new Criteria();
operator.andOperator(
        Criteria.where("createdDate").gt(LocalDate.now().minusDays(2))
                .andOperator(Criteria.where("transactionAction").is("GIFT")));
MatchOperation matchOperation = Aggregation.match(operator);
GroupOperation groupOperation = Aggregation.group("userId").sum("transactionAmount").as("totalValueAwarded");
List<String> sortOptions = new ArrayList<>();
sortOptions.add("createdDate");
Sort sort = new Sort(Sort.Direction.DESC, sortOptions);
SortOperation sortOperation = Aggregation.sort(sort);
Aggregation aggregation = Aggregation.newAggregation(Transaction.class, matchOperation, groupOperation, sortOperation);
AggregationResults<RecentlyRewardedUsers> aggregationResults = mongoTemplate.aggregate(aggregation, Transaction.class, RecentlyRewardedUsers.class);
When I now execute the above I get this error:
java.lang.IllegalArgumentException: Invalid reference 'createdDate'!
If for the moment I remove the sort options. The code will execute. However I'm not getting the userId mapped into my RecentlyRewarded class.
Criteria operator = new Criteria();
operator.andOperator(
        Criteria.where("createdDate").gt(LocalDate.now().minusDays(2))
                .andOperator(Criteria.where("transactionAction").is("GIFT")));
MatchOperation matchOperation = Aggregation.match(operator);
GroupOperation groupOperation = Aggregation.group("userId").sum("transactionAmount").as("totalValueAwarded");
Aggregation aggregation = Aggregation.newAggregation(Transaction.class, matchOperation, groupOperation);
AggregationResults<RecentlyRewardedUsers> aggregationResults = mongoTemplate.aggregate(aggregation, Transaction.class, RecentlyRewardedUsers.class);
Any help would be amazing.
Thank you
Adding image to show what I mean by userId not being mapped in the MappedResponse. However in the Raw response of the query the userId is getting mapped to the documentId _id

Answers
Remove _id from group("userId", "_id")
This is somehow similar to yours, its implementation is clear too.
public BaseResponse getErrorLogGroupByAppName() throws BaseException {
    Criteria operator = new Criteria();
    operator.andOperator(
            Criteria.where("execDate").is(DateUtil.today())
    MatchOperation matchOperation = Aggregation.match(operator);
    GroupOperation groupOperation = Aggregation.group("serUrl", "serPort", "appName", "appSer", "reqUrl", "execDate").count().as("count");
    Sort sort = new Sort(new Sort.Order(Sort.Direction.DESC, "count"));
    SortOperation sortOperation = Aggregation.sort(sort);
    Aggregation aggregation = Aggregation.newAggregation(ErrorInfo.class, matchOperation, groupOperation, sortOperation);
    AggregationResults<Map> aggregationResults = template.aggregate(aggregation, ErrorInfo.class, Map.class);
    return new BaseResponse(aggregationResults.getMappedResults());
GitHub Source
  
# rxjava# spring boot# mongodb
 
 
  
MongoDB
 
MongoDB社区为您提供最前沿的新闻资讯和知识内容
 
  加入社区
 
  
更多推荐
 

          如何克隆 GitHub 存储库(并为 CRUD 应用程序设置自己的数据库)

          带Express Js的酒店预订系统

          为什么要学习 Node 和 ExpressJs
 
 
如何克隆 GitHub 存储库(并为 CRUD 应用程序设置自己的数据库)
 
如果您不熟悉从 GitHub 克隆公共存储库,或者需要一份有关步骤的备忘单,我有(太多)屏幕截图向您展示并提醒自己如何操作。 :) 步骤 1. 从 GitHub 复制链接。 Step 2. 设置目录并在VS Code中打开。 打开终端,创建一个您计划将代码文件克隆到的文件夹,使用命令“code”。在 VS Code 中打开文件夹。 第三步,克隆代码。 在 VS Code 中打开一个新终端。单击终端
 
 MongoDB
 
 
带Express Js的酒店预订系统
 
直到上一个项目,我一直在创建网页并只处理页面的前端部分,但这次我决定创建一个全栈酒店预订系统,该系统将连接一个数据库来跟踪所有预订和活动发生在网页上。 问题陈述:首先,如果我们看到我开发这个的原因以及我正在解决什么问题。我需要了解当有人在页面上触发事件时如何从数据库中进行创建、读取、更新和删除操作,并且还想创建一个任何酒店都可以使用的预订系统。 如果您想查看代码,这里是github 存储库链接。 
 
 MongoDB
 
 
为什么要学习 Node 和 ExpressJs
 
在 Youtube 上观看完整的 Nodejs 和 ExpressJsTutorial Nodejs介绍 所以 node.js 首先不是一种语言,它不是一个框架,它是一个免费和开源的 JavaScript 运行时。现在什么是运行时以及它与 javascript 引擎的不同之处,所以 javascript 引擎只是执行代码,但运行时环境就像 node.js 一样在 node.js 中有一些额外的服务
 
 MongoDB
 
 
 273
 
 0
 
 0
 
 0
 
 
  
 
扫一扫分享内容
    点击复制链接
 
 分享
 
所有评论(0)