应用jdk1.8新特性stream并自定义方法对BigDecimal类型分组求和排序

前言

今天想用下jdk1.8的新特性,对记账流水进行按照账户id进行统计汇总金额,查找jdk1.8的新特性发现没有实现对BigDecimal的求和方法。一开始用下面的方式搞定的,比较土鳖。另外还有个需求,更新账户余额的时候,为了避免死锁,要按照账户号顺序进行更新,这就涉及到汇总后按账户号排序的问题,这里用的是TreeMap。

第一版实现

TreeMap<Long, List<AccountingDetailVo>> resultList222 = voList.stream().collect(
        Collectors.groupingBy(AccountingDetailVo::getAcctNo,TreeMap::new,Collectors.toList()));

    TreeMap<Long, BigDecimal> acctMap = new TreeMap<>();
    for (Entry<Long, List<AccountingDetailVo>> entry:resultList222.entrySet()) {
      acctMap.put(entry.getKey(),
          entry.getValue().stream().map(AccountingDetailVo::getAmtByBalDir).reduce(BigDecimal.ZERO, BigDecimal::add));
    }

后来从网上查了查,可以自定义实现,参考文章我给关了,这里就不引用了,具体实现如下:

自定义个Function

@FunctionalInterface
public interface ToBigDecimalFunction <T> {

  BigDecimal applyAsBigDecimal(T value);

}

自定义个CollectorsUtils

public class CollectorsUtils {

  static final Set<Characteristics> CH_NOID = Collections.emptySet();

  private CollectorsUtils() {
  }

  @SuppressWarnings("unchecked")
  private static <I, R> Function<I, R> castingIdentity() {
    return i -> (R) i;
  }

  //自定义个Collector实现类
  static class CollectorImpl<T, A, R> implements Collector<T, A, R> {
    private final Supplier<A> supplier;
    private final BiConsumer<A, T> accumulator;
    private final BinaryOperator<A> combiner;
    private final Function<A, R> finisher;
    private final Set<Characteristics> characteristics;

    CollectorImpl(Supplier<A> supplier, BiConsumer<A, T> accumulator, BinaryOperator<A> combiner,
        Function<A, R> finisher, Set<Characteristics> characteristics) {
      this.supplier = supplier;
      this.accumulator = accumulator;
      this.combiner = combiner;
      this.finisher = finisher;
      this.characteristics = characteristics;
    }

    CollectorImpl(Supplier<A> supplier, BiConsumer<A, T> accumulator, BinaryOperator<A> combiner,
        Set<Characteristics> characteristics) {
      this(supplier, accumulator, combiner, castingIdentity(), characteristics);
    }

    @Override
    public BiConsumer<A, T> accumulator() {
      return accumulator;
    }

    @Override
    public Supplier<A> supplier() {
      return supplier;
    }

    @Override
    public BinaryOperator<A> combiner() {
      return combiner;
    }

    @Override
    public Function<A, R> finisher() {
      return finisher;
    }

    @Override
    public Set<Characteristics> characteristics() {
      return characteristics;
    }
  }

  // 创建个汇总的方法
  public static <T> Collector<T, ?, BigDecimal> summingBigDecimal(ToBigDecimalFunction<? super T> mapper) {
    return new CollectorImpl<>(() -> new BigDecimal[1], (a, t) -> {
      if (a[0] == null) {
        a[0] = BigDecimal.ZERO;
      }
      a[0] = a[0].add(mapper.applyAsBigDecimal(t));
    }, (a, b) -> {
      a[0] = a[0].add(b[0]);
      return a;
    }, a -> a[0], CH_NOID);
  }

}

要计算的bean

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class AccountingDetailVo implements Serializable{


  private static final long serialVersionUID = 6226733035919673733L;

  @ApiModelProperty(value = "资金类型")
  private Long amtType;

  @ApiModelProperty(value = "账户")
  private Long acctNo;

  @ApiModelProperty(value = "账户类型")
  private Long acctType;

  @ApiModelProperty(value = "客户")
  private Long custNo;

  @ApiModelProperty(value = "发生方向")
  private String balDir;

  @ApiModelProperty(value = "金额")
  private BigDecimal amt;

  /**
   * 根据资金方向取得金额
   */
  public double getAmtByBalDirToDouble() {
    return this.getBalDir().equals(BalDirEnum.ADD.getValue()) ? this.getAmt().doubleValue() : this.getAmt().negate().doubleValue();
  }

  public BigDecimal getAmtByBalDir() {
    return this.getBalDir().equals(BalDirEnum.ADD.getValue()) ? this.getAmt() : this.getAmt().negate();
  }

}

测试用例

public class ListGroupTest2 {
  public static void main(String[] args) {

    List<AccountingDetailVo> voList = new ArrayList<>();
    AccountingDetailVo vo1 = AccountingDetailVo.builder().acctNo(1L).balDir("-").amt(BigDecimal.valueOf(500.22)).build();
    AccountingDetailVo vo2 = AccountingDetailVo.builder().acctNo(2L).balDir("+").amt(BigDecimal.valueOf(500.33)).build();
    AccountingDetailVo vo3 = AccountingDetailVo.builder().acctNo(1L).balDir("-").amt(BigDecimal.valueOf(500.44)).build();
    AccountingDetailVo vo4 = AccountingDetailVo.builder().acctNo(2L).balDir("+").amt(BigDecimal.valueOf(500.55)).build();
    AccountingDetailVo vo5 = AccountingDetailVo.builder().acctNo(3L).balDir("+").amt(BigDecimal.valueOf(500.66)).build();
    voList.add(vo1);
    voList.add(vo2);
    voList.add(vo3);
    voList.add(vo4);
    voList.add(vo5);
    TreeMap<Long, BigDecimal> resultList333 = voList.stream().collect(
        Collectors.groupingBy(AccountingDetailVo::getAcctNo,TreeMap::new, CollectorsUtils.summingBigDecimal(AccountingDetailVo::getAmtByBalDir)));

    System.out.println(JSON.toJSONString(resultList333, SerializerFeature.PrettyFormat));

  }
}

如果是多个字段要进行group by呢?

可以看下groupingBy的参数信息,第一个传入的是Function,可以在要计算的bean里面增加个get方法就好,把要group by的字段拼串吧。

Collector<T, ?, M> groupingBy(Function<? super T, ? extends K> classifier,
                                  Supplier<M> mapFactory,
                                  Collector<? super T, A, D> downstream)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,772评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,458评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,610评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,640评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,657评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,590评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,962评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,631评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,870评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,611评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,704评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,386评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,969评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,944评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,179评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,742评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,440评论 2 342

推荐阅读更多精彩内容