JAVA 通过MongoTemplate管理MongoDB的统计实现

//根据投保单号（applNo）,组织层次代码(levelCode),险种代码(polCode) 查询被保人信息【GrpInsured】组织查询条件：

//1、组织查询条件：

Criteria c=Criteria.where("applNo").is("").and("levelCode").is("");

//org.springframework.data.mongodb.core.aggregation.Aggregation，用于组合一个统计需要的元素

Aggregation aggregation = Aggregation.newAggregation(
Aggregation.match(c),
//查询条件

Aggregation.unwind("subStateList"),
//需要一个文档数组，并将它们作为一个文档流返回。

//group("$subStateList.polCode"):需要根据分组的字段

//sum("subStateList.premium"):需要聚合的字段

//as("sumPremium") ：起别名

Aggregation.group("$subStateList.polCode").sum("subStateList.premium").as("sumPremium")

);

AggregationResults<GrpInsured> aggregate = 

mongoTemplate.aggregate(aggregation, 需要查询的集合名称, 集合对应Model【GrpInsured】.class);

//通过调试可知道，查询出的结果存放在aggregate.getRawResults().get("result")中；

BasicDBList bdbl =(BasicDBList) aggregate.getRawResults().get("result");
//获取子要约【SubState】中险种保费【premium】累计数
double sumPremium = 0 ;

for(int i=0;i<bdbl.size();i++){   
 BasicDBObject obj=(BasicDBObject) bdbl.get(i);   
 System.out.println("id:"+obj.getString("_id")+">>>>sumPremium:"+obj.getDouble("sumPremium"));
           

}