MongoDB原生聚合转Spring Data MongoDB聚合及扩展MongoItemReader报错求助

1. 启动异常An implementation of MongoOperations is required 根因 #

自定义的CustomMongoItemReader直接继承了MongoItemReader，父类在初始化执行afterPropertiesSet方法时，会强制校验自身持有的MongoOperations实例是否存在，不存在就抛出这个异常。
目前虽然在自定义类里声明了MongoTemplate template字段，但没有把这个实例回传给父类要求的MongoOperations属性，相当于父类自己持有的Mongo操作类始终为null，自然校验失败。

修复方式 #

在自定义Reader的初始化逻辑中，显式将持有的MongoTemplate实例赋值给父类对应的属性，同时把父类运行需要的目标类型、集合名参数同步传入：

@PostConstruct
public void initReader() {
    // 给父类赋值要求的MongoOperations
    super.setMongoOperations(this.template);
    // 同步父类需要的目标类型、集合名配置
    super.setTargetType(this.type);
    super.setCollection(this.collection);
}

2. Spring聚合查询写法和原生Mongo逻辑不匹配的问题 #

对照可正常运行的原生聚合脚本，目前编写的Spring Data Mongo聚合逻辑存在三处核心偏差，完全对应不上原生的执行流程：

• Group阶段逻辑错误：之前写的Aggregation.group(fields).sum("orderUnts").as("_id")和原生逻辑完全相反——原生命令是按四个字段组合作为分组id，对每个分组下的文档计数，把计数结果存在orderUnts字段；而当前代码是对orderUnts字段求和，把求和结果塞到_id下，完全搞混了字段映射。
• Project阶段映射错误：group执行完成后，四个分组字段是嵌套在_id子文档下的，之前直接按同名字段投影的方式读不到嵌套值，而且还漏了node字段的映射。
• 字段取值错误：原生命令的$sum:1是计数逻辑，不需要对现有字段求和，直接用Spring Data Mongo提供的count()方法实现即可。

正确的聚合实现 #

// Match阶段：和原生命令的匹配规则完全对齐
MatchOperation matchOp = Aggregation.match(
    Criteria.where("orderDate").gt(startDate)
        .lt(endDate)
        .and("status").in("GREEN", "YELLOW")
);

// Group阶段：按四个字段组合分组，对组内文档计数
GroupOperation groupOp = Aggregation.group("orderDate", "node", "code1", "code2")
    .count()
    .as("orderUnts");

// Project阶段：把_id下的字段平铺到结果根节点，去掉冗余的_id结构
ProjectionOperation projectOp = Aggregation.project()
    .and("_id.orderDate").as("orderDate")
    .and("_id.node").as("node")
    .and("_id.code1").as("code1")
    .and("_id.code2").as("code2")
    .and("orderUnts")
    .andExclude("_id");

// 排序逻辑保留原有写法即可
SortOperation sortOp = Aggregation.sort(Sort.by(Sort.Direction.ASC, "orderDate"));

补充说明 #

在doPageRead方法里拼接skip、limit实现分页的逻辑是正确的，因为父类MongoItemReader已经内置维护了分页页码、页大小的状态流转，不需要额外自己实现分页追踪。只要把聚合的基础操作按上面修正后，和分页操作拼接后传给MongoTemplate执行即可。

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