java8 stream 多字段分组、多个列汇总统计

Java中的类Collector的collectionAndThen(Collector下游，函数完成器)方法，该方法采用Collector，以便我们可以执行其他整理转换。

public static  
       Collector  
       collectingAndThen(Collector  downstream, 
                         Function  finisher)
                                                             

Where,

用法

• T：输入元素的类型
• A：下游Collector的中间堆积类型
• R：下游Collector的结果类型
• RR：结果Collector的结果类型

参数：此方法接受下面列出的两个参数

• downstream:它是Collector的一个实例，即我们可以在这里使用任何Collector。
• finisher:它是一个函数的实例，该函数将应用于下游Collector的最终结果。

返回值：返回一个执行下游Collector动作的Collector，然后在finisher函数的帮助下执行附加的整理步骤。

分组聚合 返回多个计算结果

  Map>  groupAndSum = result.stream().collect(Collectors.groupingBy(
            m ->m.get("type").toString(),Collectors.collectingAndThen(
               Collectors.toList(), m -> {
                 Map map = new HashMap();
                 final double   kwh=m.stream().mapToDouble(t->(Double)t.get("daykwh")).sum();
                 final BigDecimal   area=m.stream().map(a->Convert.toBigDecimal(a.get("area"))).reduce(BigDecimal.ZERO,BigDecimal::add);
                 map.put("kwh",kwh);
                 map.put("area",area);
                 return map;
        })));

分组统计 并用统计的结果在做运算

  Map sum = result.stream().collect(Collectors.groupingBy(
            m -> m.get("type").toString(), Collectors.collectingAndThen(
               Collectors.toList(), m -> {
                  
                 final BigDecimal kwh = m.stream().map(a -> Convert.toBigDecimal(a.get("daykwh"))).reduce(BigDecimal.ZERO, BigDecimal::add);
                 final BigDecimal area = m.stream().map(a -> Convert.toBigDecimal(a.get("area"))).reduce(BigDecimal.ZERO, BigDecimal::add);
                 return kwh.multiply(area).setScale(2, BigDecimal.ROUND_HALF_UP);
     })));