博客

在聊天系统中，获取用户聊天列表的最新的一条消息，参考了springdata mongo的文档。

TypedAggregation<ObjectClass> ag = newAggregation(ObjectClass.class,
                match(criteria),//筛选条件
                group("srcUid", "destUid")
                        .first("srcUid").as("srcUid")
                        .first("destUid").as("destUid")
                        .first("chatType").as("chatType")
                        .first("msgType").as("msgType")
                        .first("msgContent").as("msgContent")
                        .first("msgTime").as("msgTime")
                         
                        .first("collectId").as("collectId")//objectId
                ,
                sort(DESC, "msgTime"),
                project()
                        .and("collectId").previousOperation()//必须添加一个字段的 previousOperation 否则会报错
                        .and("srcUid").as("srcUid")
                        .and("destUid").as("destUid")
                        .and("chatType").as("chatType")
                        .and("msgType").as("msgType")
                        .and("msgContent").as("msgContent")
                        .and("msgTime").as("msgTime")
                        .and("msgTime2").as("msgTime2")
                        .and("fingerprint").as("fingerprint")
                ,
                sort(DESC, "msgTime")
        );
        AggregationResults<ObjectClass> r = mongo.aggregate(ag, ObjectClass.class);
        Iterable<ObjectClass> allById = r.getMappedResults();