2.1.3 重复拼接字符串

  1. String str = StringUtils.repeat("ab", 2);
  2. System.out.println(str); // 输出abab

2.1.4 格式化日期

再也不用手写SimpleDateFormat格式化了

  1. // Date类型转String类型
  2. String date = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");
  3. System.out.println(date); // 输出 2021-05-01 01:01:01
  4. // String类型转Date类型
  5. Date date = DateUtils.parseDate("2021-05-01 01:01:01", "yyyy-MM-dd HH:mm:ss");
  6. // 计算一个小时后的日期
  7. Date date = DateUtils.addHours(new Date(), 1);

2.1.5 包装临时对象

当一个方法需要返回两个及以上字段时,我们一般会封装成一个临时对象返回,现在有了Pair和Triple就不需要了

  1. // 返回两个字段
  2. ImmutablePair<Integer, String> pair = ImmutablePair.of(1, "yideng");
  3. System.out.println(pair.getLeft() + "," + pair.getRight()); // 输出 1,yideng
  4. // 返回三个字段
  5. ImmutableTriple<Integer, String, Date> triple = ImmutableTriple.of(1, "yideng", new Date());
  6. System.out.println(triple.getLeft() + "," + triple.getMiddle() + "," + triple.getRight()); // 输出 1,yideng,Wed Apr 07 23:30:00 CST 2021

2.2 commons-collections 集合工具类

Maven依赖是:

  1. <dependency>
  2. <groupId>org.apache.commons</groupId>
  3. <artifactId>commons-collections4</artifactId>
  4. <version>4.4</version>
  5. </dependency>

2.2.1 集合判空

封装了集合判空的方法,以下是源码:

  1. public static boolean isEmpty(final Collection<?> coll) {
  2. return coll == null || coll.isEmpty();
  3. }
  4. public static boolean isNotEmpty(final Collection<?> coll) {
  5. return !isEmpty(coll);
  6. }
  7. // 两个集合取交集
  8. Collection<String> collection = CollectionUtils.retainAll(listA, listB);
  9. // 两个集合取并集
  10. Collection<String> collection = CollectionUtils.union(listA, listB);
  11. // 两个集合取差集
  12. Collection<String> collection = CollectionUtils.subtract(listA, listB);

2.3 common-beanutils 操作对象

Maven依赖:

  1. <dependency>
  2. <groupId>commons-beanutils</groupId>
  3. <artifactId>commons-beanutils</artifactId>
  4. <version>1.9.4</version>
  5. </dependency>
  6. public class User {
  7. private Integer id;
  8. private String name;
  9. }

设置对象属性

  1. User user = new User();
  2. BeanUtils.setProperty(user, "id", 1);
  3. BeanUtils.setProperty(user, "name", "yideng");
  4. System.out.println(BeanUtils.getProperty(user, "name")); // 输出 yideng
  5. System.out.println(user); // 输出 {"id":1,"name":"yideng"}

对象和map互转

  1. // 对象转map
  2. Map<String, String> map = BeanUtils.describe(user);
  3. System.out.println(map); // 输出 {"id":"1","name":"yideng"}
  4. // map转对象
  5. User newUser = new User();
  6. BeanUtils.populate(newUser, map);
  7. System.out.println(newUser); // 输出 {"id":1,"name":"yideng"}

2.4 commons-io 文件流处理

Maven依赖:

  1. <dependency>
  2. <groupId>commons-io</groupId>
  3. <artifactId>commons-io</artifactId>
  4. <version>2.8.0</version>
  5. </dependency>

文件处理

  1. File file = new File("demo1.txt");
  2. // 读取文件
  3. List<String> lines = FileUtils.readLines(file, Charset.defaultCharset());
  4. // 写入文件
  5. FileUtils.writeLines(new File("demo2.txt"), lines);
  6. // 复制文件
  7. FileUtils.copyFile(srcFile, destFile);

3. Google Guava 工具类库

Maven依赖:

  1. <dependency>
  2. <groupId>com.google.guava</groupId>
  3. <artifactId>guava</artifactId>
  4. <version>30.1.1-jre</version>
  5. </dependency>

3.1 创建集合

  1. List<String> list = Lists.newArrayList();
  2. List<Integer> list = Lists.newArrayList(1, 2, 3);
  3. // 反转list
  4. List<Integer> reverse = Lists.reverse(list);
  5. System.out.println(reverse); // 输出 [3, 2, 1]
  6. // list集合元素太多,可以分成若干个集合,每个集合10个元素
  7. List<List<Integer>> partition = Lists.partition(list, 10);
  8. Map<String, String> map = Maps.newHashMap();
  9. Set<String> set = Sets.newHashSet();

3.2 黑科技集合

3.2.1 Multimap 一个key可以映射多个value的HashMap

  1. Multimap<String, Integer> map = ArrayListMultimap.create();
  2. map.put("key", 1);
  3. map.put("key", 2);
  4. Collection<Integer> values = map.get("key");
  5. System.out.println(map); // 输出 {"key":[1,2]}
  6. // 还能返回你以前使用的臃肿的Map
  7. Map<String, Collection<Integer>> collectionMap = map.asMap();

多省事,多简洁,省得你再创建 Map

3.2.2 BiMap 一种连value也不能重复的HashMap

  1. BiMap<String, String> biMap = HashBiMap.create();
  2. // 如果value重复,put方法会抛异常,除非用forcePut方法
  3. biMap.put("key","value");
  4. System.out.println(biMap); // 输出 {"key":"value"}
  5. // 既然value不能重复,何不实现个翻转key/value的方法,已经有了
  6. BiMap<String, String> inverse = biMap.inverse();
  7. System.out.println(inverse); // 输出 {"value":"key"}

这其实是双向映射,在某些场景还是很实用的。

3.2.3 Table 一种有两个key的HashMap

  1. // 一批用户,同时按年龄和性别分组
  2. Table<Integer, String, String> table = HashBasedTable.create();
  3. table.put(18, "男", "yideng");
  4. table.put(18, "女", "Lily");
  5. System.out.println(table.get(18, "男")); // 输出 yideng
  6. // 这其实是一个二维的Map,可以查看行数据
  7. Map<String, String> row = table.row(18);
  8. System.out.println(row); // 输出 {"男":"yideng","女":"Lily"}
  9. // 查看列数据
  10. Map<Integer, String> column = table.column("男");
  11. System.out.println(column); // 输出 {18:"yideng"}

3.2.4 Multiset 一种用来计数的Set

  1. Multiset<String> multiset = HashMultiset.create();
  2. multiset.add("apple");
  3. multiset.add("apple");
  4. multiset.add("orange");
  5. System.out.println(multiset.count("apple")); // 输出 2
  6. // 查看去重的元素
  7. Set<String> set = multiset.elementSet();
  8. System.out.println(set); // 输出 ["orange","apple"]
  9. // 还能查看没有去重的元素
  10. Iterator<String> iterator = multiset.iterator();
  11. while (iterator.hasNext()) {
  12. System.out.println(iterator.next());
  13. }
  14. // 还能手动设置某个元素出现的次数
  15. multiset.setCount("apple", 5);

https://www.cnblogs.com/liyihua/p/12286086.html

  1. @Override
  2. public Map<String, ?> executeCancel(OdoOperateVo vo) {
  3. return operate(vo, null, o -> o.setOperateType(JdiTransactionOperateTypeEnum.ODO_HOLD_CANCEL.type));
  4. }
  5. @Override
  6. public Map<String, ?> executeConfirm(OdoOperateVo vo) {
  7. return operate(vo, o -> {
  8. // 检查是否有商品没有销售价
  9. JdiSaleOrderQueryVo queryVo = new JdiSaleOrderQueryVo();
  10. queryVo.setShopId(vo.getShopId());
  11. queryVo.setStoreId(vo.getStoreId());
  12. queryVo.setSaleOrderNo(o.getOriginOrderNo());
  13. // 返回true表示有无价格商品
  14. RemoteResultBean<Boolean> r = saleOrderManService.hasNullSalePriceGoods(queryVo);
  15. if (!r.isSuccess() || r.getContent()) {
  16. throw new UnsupportedOperationException("销售单[" + o.getOriginOrderNo() + "]存在商品无销售价的情况");
  17. }
  18. return true;
  19. }, o -> {
  20. o.setOperateType(JdiTransactionOperateTypeEnum.ODO_NORMAL.type);
  21. o.setChangedQuantity(o.getHoldQuantity());
  22. });
  23. }
  24. /**
  25. * operate
  26. * @param vo
  27. * @param filter
  28. * @param consumer
  29. * @return
  30. */
  31. private Map<String, ?> operate(OdoOperateVo vo, Predicate<JdiOdoHeader> filter, Consumer<JdiStockChangeDto> consumer) {
  32. JdiOdoHeader odoHeader = odoHeaderService.findByOdoNo(vo.getOdoNo(), vo.getWarehouseNo(), vo.getShopId());
  33. if (odoHeader == null) {
  34. throw new EntityNotFoundException("JdiOutboundService.exec", vo.getWarehouseNo() + ": 查询的出库单[" + vo.getOdoNo() + "]不存在");
  35. }
  36. // 状态检查
  37. if (odoHeader.getOdoStatus() == null || JdiOdoStatusEnum.OUTING.getValue() != odoHeader.getOdoStatus()) {
  38. throw new UnsupportedOperationException("发货单[" + vo.getOdoNo() + "]当前状态不是“待发货确认”无法执行关单操作!");
  39. }
  40. // 特殊检查
  41. if (filter != null && !filter.test(odoHeader)) {
  42. return Collections.emptyMap();
  43. }
  44. List<JdiOdoDetail> list = odoDetailService.queryByOdoNo(vo.getOdoNo(), vo.getWarehouseNo(), vo.getShopId());
  45. JdiStockTransactionLog queryVo = new JdiStockTransactionLog();
  46. queryVo.setShopId(vo.getShopId());
  47. queryVo.setStoreId(vo.getStoreId());
  48. queryVo.setWarehouseNo(vo.getWarehouseNo());
  49. queryVo.setDocNo(odoHeader.getOdoNo());
  50. queryVo.setOperateType(JdiTransactionOperateTypeEnum.ODO_HOLD.type);
  51. JdiStockQueryVo stockQueryVo = new JdiStockQueryVo();
  52. stockQueryVo.setShopId(vo.getShopId());
  53. stockQueryVo.setStoreId(vo.getStoreId());
  54. JdiOdoVo odoVo = AgileConvert.convert(vo, JdiOdoVo.class);
  55. boolean hasConsumer = consumer != null;
  56. // 修改时间
  57. Date date = new Date();
  58. // 实际发货数量
  59. BigDecimal totalShipped = BigDecimal.ZERO;
  60. // 状态
  61. int status = vo.getOperate() == OdoOperateVo.Operate.CONFIRM ? JdiOdoStatusEnum.FINISHED.getValue()
  62. : JdiOdoStatusEnum.CANCEL.getValue();
  63. List<JdiStockTransactionLog> logList = new ArrayList<>();
  64. List<JdiStockAveragePriceChangeVo> priceChangeVoList = new ArrayList<>();
  65. for (JdiOdoDetail detail : list) {
  66. queryVo.setDocDetailNo(detail.getOdoDetailNo());
  67. queryVo.setSkuId(detail.getSkuId());
  68. List<JdiStockTransactionLog> logs = logService.queryLogList(queryVo);
  69. // 实际发货数量
  70. BigDecimal shipped = BigDecimal.ZERO;
  71. for (JdiStockTransactionLog log : logs) {
  72. stockQueryVo.setWarehouseNo(log.getWarehouseNo());
  73. stockQueryVo.setPartitionNo(log.getPartitionNo());
  74. stockQueryVo.setLocationNo(log.getLocationNo());
  75. stockQueryVo.setBatchNo(log.getBatchNo());
  76. stockQueryVo.setSkuId(log.getSkuId());
  77. List<JdiStock> stocks = stockService.findJdiStock(stockQueryVo);
  78. odoVo.setOriginOrderNo(log.getBusinessCode());
  79. for (JdiStock stock : stocks) {
  80. shipped = shipped.add(log.getHoldQuantity());
  81. JdiStockChangeDto changeDto = makeStockChangeDto(odoVo, odoHeader.getOdoNo(), stock, BigDecimal.ZERO.subtract(log.getHoldQuantity()), detail.getOdoDetailNo());
  82. if (hasConsumer) {
  83. consumer.accept(changeDto);
  84. }
  85. // 扣减库存不抛异常为成功
  86. logList.add(stockOperateService.executeDirectStockIO(changeDto));
  87. priceChangeVoList.add(AgileConvert.convert(changeDto, JdiStockAveragePriceChangeVo.class));
  88. }
  89. }
  90. // 修改详情单状态
  91. JdiOdoDetail newDetail = AgileConvert.convert(detail, JdiOdoDetail.class);
  92. newDetail.setStatus(status);
  93. newDetail.setUpdatedId(vo.getOperatorId());
  94. newDetail.setUpdatedBy(vo.getOperatorName());
  95. newDetail.setUpdateDate(date);
  96. newDetail.setOrderNo(date.getTime());
  97. if (status == JdiOdoStatusEnum.FINISHED.getValue()) {
  98. newDetail.setShippedTime(date);
  99. newDetail.setShippedQuantity(shipped);
  100. totalShipped = totalShipped.add(shipped);
  101. }
  102. odoDetailService.updateStatus(newDetail);
  103. }
  104. // 修改单头状态
  105. JdiOdoHeader newOdoHeader = AgileConvert.convert(odoHeader, JdiOdoHeader.class);
  106. newOdoHeader.setOdoStatus(status);
  107. newOdoHeader.setUpdatedId(vo.getOperatorId());
  108. newOdoHeader.setUpdatedBy(vo.getOperatorName());
  109. newOdoHeader.setUpdateDate(date);
  110. newOdoHeader.setOrderNo(date.getTime());
  111. newOdoHeader.setShippedQuantity(totalShipped);
  112. odoHeaderService.updateStatus(newOdoHeader);
  113. return new HashMap<String, Object>() {
  114. {
  115. put("logList", logList);
  116. put("changed", priceChangeVoList);
  117. put("originOrderNo", odoHeader.getOriginOrderNo());
  118. put("timestamp", date.getTime());
  119. put("odoType", odoHeader.getOdoType());
  120. }
  121. };
  122. }
  123. }

java8 实现集合分页

  1. list.stream().skip(n * DEFAULT_MAX_BATCH_SIZE).limit(DEFAULT_MAX_BATCH_SIZE).parallel().collect(Collectors.toList())

java8 map收集两个键的情况,高频写法

  1. customerMap.put(String.format("%s-%s", customerDto.getCustomerType().name(), customerDto.getCustomerName()), customerDto);