最近在做客服聊天系统遇到的一些小问题，记录一下。
java 项目，使用的是 MongoTemplate
1.去重
List<User> memberIds =mongoTemplate.findDistinct(query, "memberId", MSG_PREFIX, User.class);query 查询条件
memberId 去重字段
MSG_PREFIX 查询的集合
User 转换Java类型
2.分组
使用mongoDB的聚合操作 Aggregation，对 memberId 进行分组然后取 msgId 最大的一条数据
Criteria criteriaMsg = new Criteria();criteriaMsg.and("memberId").in(memberIds);AggregationResults<ModelMap> aggregate = mongoTemplate.aggregate(Aggregation.newAggregation(Aggregation.match(criteriaMsg),//按条件过滤Aggregation.sort(Sort.by(Sort.Direction.DESC,"msgId")),//排序Aggregation.group("memberId").first("msgId").as("msgId"),//按会员id分组Aggregation.limit(10)//分页//将符合条件的msgId放入列表), VENDOR_CONTACT_PREFIX, ModelMap.class);List<ModelMap> list = aggregate.getMappedResults();List<Long> msgIds = list.stream().map(map -> (Long) map.get("msgId")).collect(Collectors.toList());
