本文详解如何在 spring data mongodb 中通过聚合管道（aggregation）高效获取去重的组织信息（organizationid + organizationname），避免 `finddistinct()` 的局限性，并解决因分组结构不匹配导致 dto 映射为空对象的问题。
在 Spring Data MongoDB 中，当需要基于多个字段（如 organizationId 和 organizationName）进行去重查询，并将结果直接映射为自定义 DTO（如 OrganizationDTO）时，单纯使用 mongoTemplate.findDistinct() 无法满足多字段联合去重需求——它仅支持单字段提取。而错误的聚合写法（如仅用 GroupOperation 但未正确投影）又会导致 AggregationResults 返回空对象，根本原因在于：MongoDB 的 $group 阶段默认将分组键封装在 _id 字段下（如 { "_id": { "organizationId": "org1", "organizationName": "Org A" } }），而 OrganizationDTO 并无对应嵌套结构，反序列化失败。
✅ 正确解法是组合使用 MatchOperation → GroupOperation → ProjectionOperation 三阶段聚合，显式将 _id 中的字段“提升”为顶层字段，使其与 DTO 字段严格对齐。
以下为完整、可运行的代码示例：
import static org.springframework.data.mongodb.core.aggregation.Aggregation.*; import static org.springframework.data.mongodb.core.aggregation.GroupOperators.*; // 注意导入 public ListfindDistinctOrganizations(Set statusList) { // 1. 匹配状态符合条件的用户 MatchOperation match = match(Criteria.where("status").in(statusList)); // 2. 按 organizationId + organizationName 联合分组（生成 _id: { organizationId: "...", organizationName: "..." }） GroupOperation group = group("organizationId", "organizationName"); // 3. 投影：将 _id 中的字段解构为顶层字段，排除 _id 自身 ProjectionOperation project = project() .and("_id.organizationId").as("organizationId") .and("_id.organizationName").as("organizationName") .andExclude("_id"); // 关键：移除原始 _id 字段，避免干扰 // 构建并执行聚合 Aggregation aggregation = newAggregation(match, group, project); AggregationResults results = mongoTemplate.aggregate(aggregation, "user", OrganizationDTO.class); // 注意：集合名建议用实际 collection 名（如 "users"） return results.getMappedResults(); }
? 关键要点说明：
- group("organizationId", "organizationName") 等价于 group().by("organizationId", "organizationName")，会自动将这两个字段作为复合 _id；
- project().and("_id.organizationId").as("organizationId") 是核心修复步骤，它从嵌套 _id 中提取值并重命名为 DTO 所需字段名；
- 必须调用 .andExclude("_id")，否则响应中仍含 _id 字段，可能引发 Jackson 反序列化冲突或字段冗余；
- 第三个参数 "user" 是 MongoDB 集合名（collection name），需与 @Document(collection = "user") 或实际存储名一致，不是实体类名 User.class（这是常见错误）；
- OrganizationDTO 必须提供无参构造函数，且字段名与 as(...) 中指定的完全一致（区分大小写），推荐使用 Lombok @Data 或手动实现 getter/setter。
? 进阶提示：
若后续需添加排序（如按 organizationName 升序），可在 project 后追加 sort(Sort.by(Sort.Direction.ASC, "organizationName"))；
若数据量极大，建议为 status、organizationId、organizationName 字段建立复合索引以加速聚合：
db.user.createIndex({ "status": 1, "organizationId": 1, "organizationName": 1 })该方案简洁、高效、类型安全，彻底规避了手动双 findDistinct() 后拼接的耦合风险与潜在数据错位问题，是 Spring MongoDB 多字段去重查询的标准实践。
