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 ce353593..b249af83 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 @@ -1917,8 +1917,18 @@ public class OrderInfoServiceImpl implements OrderInfoService { List items = new ArrayList<>(); StringBuffer sb = new StringBuffer(); - + Map repeatEnding = new HashMap(); for (OrderItemInfo itemInfo : orderItemInfo) { + //存在同一物料编码 + if(repeatEnding.get(itemInfo.getZxbm()) != null){ + OrderItemInfo item = new OrderItemInfo(); + item.setId(itemInfo.getId()); + item.setZnfm(ConfigureConstant.STRING_0); + item.setZxbm(StringUtils.isNotBlank(itemInfo.getZxbm())?itemInfo.getZxbm():baseService.getGenerateShotKey()); + items.add(item); + continue; + } + try { CommodityCodeEntity commodityCodeEntity = buildCommodity(itemInfo, param, spbmMap); //判断是否已存在,同步中存在一样的是否需要过滤后期考虑 @@ -1949,7 +1959,7 @@ public class OrderInfoServiceImpl implements OrderInfoService { } items.add(item); } - + repeatEnding.put(commodityCodeEntity.getZxbm(),commodityCodeEntity); } catch (Exception e) { log.error("更新公司库物料异常{}",e); sb.append(itemInfo.getSphxh()).append(",");