本文介绍如何在 spring data mongodb 中通过聚合管道（aggregation）高效获取去重的组织信息（organizationid + organizationname），避免 `finddistinct()` 的局限性，并解决因投影缺失导致 dto 映射为空对象的问题。
在 Spring Data MongoDB 中，当需要基于多个字段（如 organizationId 和 organizationName）进行去重查询，并将结果直接映射为自定义 DTO（如 OrganizationDTO）时，单纯使用 findDistinct() 无法满足需求——它仅支持单字段去重。而错误地仅使用 $group 阶段又会导致聚合结果结构与 DTO 不匹配，最终 mappedResults 返回空对象列表。
正确的做法是构建一个完整的聚合流水线，包含三阶段：匹配（Match）→ 分组（Group）→ 投影（Project），确保输出结构严格对齐 OrganizationDTO 字段。
✅ 正确的聚合实现
// 1. 构建状态匹配条件
Criteria statusCriteria = Criteria.where("status").in(statusList);
// 2. 匹配阶段：筛选指定状态的用户
MatchOperation match = Aggregation.match(statusCriteria);
// 3. 分组阶段：以 organizationId + organizationName 为联合键去重（注意：_id 设为复合对象）
GroupOperation group = Aggregation.group()
.field("organizationId").as("organizationId")
.field("organizationName").as("organizationName");
// 4. 投影阶段：显式提取字段，排除默认 _id，确保输出结构与 DTO 一致
ProjectionOperation project = Aggregation.project("organizationId", "organizationName")
.andExclude("_id"); // 确保不带 _id 字段，避免反序列化干扰
// 5. 执行聚合
Aggregation aggregation = Aggregation.newAggregation(match, group, project);
AggregationResults results =
mongoTemplate.aggregate(aggregation, "user", OrganizationDTO.class); // 建议显式指定集合名
return results.getMappedResults(); ? 关键说明： Aggregation.group() 中不使用 Fields.fields(...)，而是直接调用 .field(...).as(...)，更清晰且兼容性更好； Aggregation.project(...) 显式声明需保留的字段名（与 DTO 属性名完全一致），并排除 _id，可避免 Jackson 反序列化时因字段缺失或命名冲突导致 DTO 字段为 null； 聚合集合名建议传 "user"（实际 collection 名），而非 User.class，防止因实体类未正确映射 @Document(collection = "...") 引发意外。
⚠️ 注意事项与常见误区
- ❌ 错误写法：GroupOperation.group(Fields.fields("organizationId", "organizationName")) —— 这会将整个字段集合作为 _id 的子对象，导致后续无法直接映射到扁平 DTO；
- ❌ 忽略 project 阶段：$group 输出默认含 _id: { organizationId: "...", organizationName: "..." }，若不投影展开，OrganizationDTO 将无法绑定（字段名不匹配，且嵌套层级不符）；
- ✅ 推荐 DTO 构造：为提升反序列化鲁棒性，建议 OrganizationDTO 提供全参构造器或 Lombok @Builder + @NoArgsConstructor，并确保字段名与投影完全一致（大小写敏感）；
- ? 性能提示：若数据量大，可在 organizationId 和 status 字段上建立复合索引：
db.user.createIndex({ "organizationId": 1, "organizationName": 1, "status": 1 })
✅ 补充：纯 Java Stream 方案（小数据量备用）
若聚合调试困难，且数据集较小（如
Listusers = mongoTemplate.find( Query.query(statusCriteria), User.class, "user" ); return users.stream() .map(u -> new OrganizationDTO(u.getOrganizationId(), u.getOrganizationName())) .distinct() // 要求 OrganizationDTO 重写 equals/hashCode .collect(Collectors.toList());
但该方式不推荐用于生产环境大数据量场景——存在内存与网络开销，且失去数据库层去重效率。
综上，聚合管道 + 显式投影 是最规范、高效且可维护的解决方案。只要确保 group 输出字段被 project 准确展平并命名一致，即可稳定获得非空、结构正确的 OrganizationDTO 列表。
