Spring MongoDB多字段去重查询：获取唯一OrganizationDTO列表

我在Mongo集合中有一个User模型，定义如下：
User.class

@Id
private String userId;
private String userName;
private String organizationId;
private String organizationName;
private String status;

我需要获取OrganizationDTO列表返回给前端，该DTO定义如下：
OrganizationDTO.class

private String organizationId;
private String organizationName;

由于不同User可能拥有相同的organizationId和organizationName，我希望这些信息仅出现一次，且列表需包含所有状态在指定集合中的唯一组织信息。

我尝试使用mongoTemplate.findDistinct()，但不符合需求；曾用一种复杂方案分别查询去重的organizationId和organizationName再映射，但并不满意。于是尝试聚合操作：

MatchOperation match = new MatchOperation(getCriteria(statusList));  //getCriteria返回上述条件
GroupOperation group = new GroupOperation(Fields.fields("organizationId", "organizationName"));
Aggregation aggregation = Aggregation.newAggregation(match, group);
AggregationResults<OrganizationDTO> results = mongoTemplate.aggregate(aggregation, User.class, OrganizationDTO.class);
return results.getMappedResults();

目前聚合返回的是包含空对象的列表，想确认此方案是否正确，或是否有更优实现方式。

问题原因 #

你的聚合思路方向是对的，但返回空对象的核心问题是：GroupOperation默认会把分组键封装在_id字段下，而你的OrganizationDTO期望直接获取organizationId和organizationName字段，两者无法自动映射匹配。

修正后的聚合实现 #

需要在分组操作中显式保留目标字段，再通过投影操作把_id中的字段映射到DTO对应的字段名：

// 1. 过滤状态符合要求的用户
MatchOperation match = new MatchOperation(getCriteria(statusList));

// 2. 按组织ID和名称分组，同时显式保留这两个字段的值
GroupOperation group = Aggregation.group("organizationId", "organizationName")
        .first("organizationId").as("organizationId")
        .first("organizationName").as("organizationName");

// 3. 投影确保输出结构完全匹配DTO（可选，但能避免字段映射异常）
ProjectionOperation project = Aggregation.project("organizationId", "organizationName");

// 组装聚合流水线
Aggregation aggregation = Aggregation.newAggregation(match, group, project);

// 执行聚合并映射到DTO
AggregationResults<OrganizationDTO> results = mongoTemplate.aggregate(
        aggregation, 
        User.class, 
        OrganizationDTO.class
);
return results.getMappedResults();

更简洁的替代方案 #

如果使用Spring Data MongoDB 3.x及以上版本，直接用多字段distinct结合投影的方式更简洁，无需手动写聚合流水线：

Query query = new Query(getCriteria(statusList));
// 指定去重字段，直接映射到OrganizationDTO
List<OrganizationDTO> organizations = mongoTemplate.findDistinct(
        query,
        Arrays.asList("organizationId", "organizationName"),
        User.class,
        OrganizationDTO.class
);
return organizations;

注意事项 #

• 确保getCriteria(statusList)生成的过滤条件正确，能筛选出状态符合要求的User文档；
• OrganizationDTO必须有无参构造函数，Spring Data MongoDB需要通过它实例化对象；
• 如果存在organizationId或organizationName为null的情况，去重后会包含null条目，若不需要可在match阶段添加非空判断（如Criteria.where("organizationId").ne(null)）。

内容的提问来源于stack exchange，提问作者matpel42