diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java index 06da8f08e..f41084709 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java @@ -917,7 +917,7 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl p.getClientId() != null); + boolean flag = packageEntityList.stream().anyMatch(p -> p.getClientId() == null); if (flag) { String str = packageEntityList.stream().filter(p -> p.getClientId() != null).map(DistributionAddvaluePackageDTO::getOrderPackageCode).collect(Collectors.joining(",")); return R.fail(str + "无客户信息"); @@ -989,7 +989,8 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl priceDispatchAddClientVOS = basicdataPriceClient.dispatchAddPrice(BasicdatPriceApiVO.builder().clientId(distributionAddvaluePackageDTO.getClientId().toString()).brandId(distributionAddvaluePackageDTO.getClientId().toString()).build()); - if (!priceDispatchAddClientVOS.isEmpty()) { + + if (Func.isEmpty(priceDispatchAddClientVOS)){ //TODO 结算品类 } //查询价格模板 diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java index e7f392a7f..888c38026 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java @@ -62,6 +62,7 @@ import org.springblade.common.constant.order.OrderStockupStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageLoadingStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageReservationStatusConstant; import org.springblade.common.constant.orderpackage.OrderPackageStatusConstant; +import org.springblade.common.constant.reservation.ReservationPackageStatusConstant; import org.springblade.common.exception.CustomerException; import org.springblade.common.node.PackageNode; import org.springblade.common.utils.CommonUtil; @@ -375,6 +376,7 @@ public class DistributionParcelListServiceImpl extends BaseServiceImplquery().lambda().eq(DistributionParcelNumberEntity::getParcelListId, parcelListEntity.getId())); //进行预约数量的扣减 - int i = distributionParcelNumberEntity.getDeliveryQuantity() - distributionParcelNumberEntity.getQuantity(); + int i = distributionParcelNumberEntity.getDeliveryQuantity() - reservationZeroPackageEntity.getQuantity(); distributionParcelNumberEntity.setDeliveryQuantity(i); if (i == 0){ parcelListEntity.setOrderPackageReservationStatus(OrderPackageReservationStatusConstant.daiyuyue.getValue()); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 1c7fda3f2..6e1a5e337 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -2625,7 +2625,6 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl jsonObjects = new ArrayList<>(); JSONObject jsonObject = new JSONObject(); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java index 9de2e4fb5..1e38aac1d 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java @@ -218,6 +218,7 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl selectDistrilbutionBillLadingPage(IPage page, DistrilbutionBillLadingVO distrilbutionBillLading) { return page.setRecords(baseMapper.selectDistrilbutionBillLadingPage(page, distrilbutionBillLading)); @@ -1829,6 +1830,9 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl packageEntityList = new ArrayList<>(); if (Func.isNotEmpty(parcelLisList)){ @@ -1837,25 +1841,27 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImplupdate().lambda() + .setSql("delivery_quantity = delivery_quantity +"+zeroPackageEntity.getQuantity()) + .eq(DistributionParcelNumberEntity::getParcelListId,zeroPackageEntity.getParcelListId()) + .eq(DistributionParcelNumberEntity::getStockArticleId,zeroPackageEntity.getStockArticleId()) + ); }); - } - if (!packageEntityList.isEmpty()) { distributionZeroPackageService.saveBatch(packageEntityList); + }else { + log.warn("没有品类数据"); + return 0; } - - } else { - log.warn("没有品类数据"); - return 0; } - return 1; } @@ -1937,6 +1943,25 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl reservationZeroPackageEntities = distributionZeroPackageService.list(Wrappers.query().lambda() + .eq(DistributionReservationZeroPackageEntity::getReservationId, distrilbutionBillStock.getBillLadingId()) + .eq(DistributionReservationZeroPackageEntity::getStockArticleId, distrilbutionBillStock.getStockArticleId()) + .ne(DistributionReservationZeroPackageEntity::getZeroPackageStatus, ReservationPackageStatusConstant.quxiao.getValue()) + ); + if (!reservationZeroPackageEntities.isEmpty()) { + for (DistributionReservationZeroPackageEntity reservationZeroPackageEntity : reservationZeroPackageEntities) { + //进行预约数量回退 + distributionParcelNumberService.update(Wrappers.update().lambda() + .setSql("delivery_quantity = delivery_quantity -"+ reservationZeroPackageEntity.getQuantity()) + .eq(DistributionParcelNumberEntity::getId,reservationZeroPackageEntity.getParcelListId()) + .eq(DistributionParcelNumberEntity::getStockArticleId,reservationZeroPackageEntity.getStockArticleId()) + ); + + + } + } + } } distrilbutionBillStock.setOrderStatus("2");