diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java index 3371d5dc..f1ed83b6 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java @@ -2016,14 +2016,19 @@ public class OrderInfoServiceImpl implements OrderInfoService { } List collect = null; if(itemList != null){ - collect = orderItemInfos.stream().filter(t -> itemList.contains(t.getId()) && StringUtils.isNotBlank(t.getSpbm())).collect(Collectors.toList()); - if(ObjectUtil.isNull(orderItemInfos)){ + collect = orderItemInfos.stream().filter(t -> itemList.contains(t.getId()) && StringUtils.isBlank(t.getSpbm())).collect(Collectors.toList()); + if(ObjectUtil.isNull(collect)){ return R.error("税收编码为空的不允许合并,请先更新税收编码"); } }else{ collect = orderItemInfos; } - Map> collect1 = collect.stream().collect(Collectors.groupingBy(t -> t.getFphxz() + t.getXmmc() + t.getXmdw() + t.getGgxh() + t.getSl() + t.getSpbm())); + Map> collect1 = collect.stream().map(t->{ + t.setXmmc(StringUtils.isBlank(t.getXmmc())?"":t.getXmmc()); + t.setXmdw(StringUtils.isBlank(t.getXmdw())?"":t.getXmdw()); + t.setGgxh(StringUtils.isBlank(t.getGgxh())?"":t.getGgxh()); + return t; + }).collect(Collectors.groupingBy(t -> t.getFphxz() + t.getXmmc() + t.getXmdw() + t.getGgxh() + t.getSl() + t.getSpbm())); List orderItemInfoList = new ArrayList<>(); List deleteItem = new ArrayList<>(); for (List value : collect1.values()) {