From 7d5a938f72fc359644958b2b3853f79c5f15f9cf Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Wed, 5 Feb 2025 14:49:31 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=95=86=E5=AE=B6=E7=AB=AF?=
 =?UTF-8?q?=E6=8E=A8=E9=80=81=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/DistributionReservationServiceImpl.java  | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java
index df24db68b..b8d2376fe 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java
@@ -498,6 +498,10 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 			}
 
 		}
+		Map<String,List> map = new HashMap<>();
+		List<DistributionReservationPackageEntity> reservationPackageEntityList = new ArrayList<>();
+		List<DistributionReservationZeroPackageEntity> reservationZeroPackageEntityList = new ArrayList<>();
+		List<DistributionReservationStocklistEntity> reservationStocklistEntityList = new ArrayList<>();
 		//构建预约单
 		DistributionReservationEntity reservationEntity = new DistributionReservationEntity();
 		Func.copy(distributionReservationDTO, reservationEntity);
@@ -620,6 +624,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 									distributionReservationPackageEntity.setParceListId(dp.getId());
 									distributionReservationPackageEntity.setStockArticleId(s.getId());
 									distributionReservationPackageEntity.setPacketBarCode(dp.getOrderPackageCode());
+									reservationPackageEntityList.add(distributionReservationPackageEntity);
 									//维护订单下包件信息
 									distributionReservationPackageService.save(distributionReservationPackageEntity);
 									//此时订单下的所有包件都处于预约状态，可用数为0
@@ -652,6 +657,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 									distributionReservationPackageEntity.setParceListId(p.getId());
 									distributionReservationPackageEntity.setStockArticleId(s.getId());
 									distributionReservationPackageEntity.setPacketBarCode(p.getOrderPackageCode());
+									reservationPackageEntityList.add(distributionReservationPackageEntity);
 									distributionReservationPackageService.save(distributionReservationPackageEntity);
 									packageNum.getAndAdd(p.getQuantity());
 									p.setOrderPackageReservationStatus(OrderPackageReservationStatusConstant.yiyueyue.getValue());
@@ -725,6 +731,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 								distributionReservationZeroPackageEntity.setParcelListId(p.getParcelListId());
 								distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue());
 								distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue());
+								reservationZeroPackageEntityList.add(distributionReservationZeroPackageEntity);
 								distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity);
 								//统计数量
 								zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity());
@@ -751,6 +758,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 								distributionReservationZeroPackageEntity.setCategoryName(l.getFirsts());
 								distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue());
 								distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue());
+								reservationZeroPackageEntityList.add(distributionReservationZeroPackageEntity);
 								distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity);
 								//统计数量
 								zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity());
@@ -826,6 +834,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 				distributionReservationStocklistEntity.setStockListStatus("1");
 				distributionReservationStocklistEntity.setLoadingStatus(ReservationInventoryLoadingStatusConstant.weizhuangche.getValue());
 				distributionReservationStocklistEntity.setSigningStatus(ReservationInventorySigningStatusConstant.weiqianshou.getValue());
+				reservationStocklistEntityList.add(distributionReservationStocklistEntity);
 				distributionReservationStocklistService.save(distributionReservationStocklistEntity);
 				stockListCount.getAndAdd(distributionReservationStocklistEntity.getReservationNum());
 				List<DisStockListDetailEntity> detailEntities = new ArrayList<>();
@@ -898,6 +907,12 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 		reservationEntity.setSigningStatus(ReservationSigningStatusConstant.daiqianshou.getValue());
 		reservationEntity.setWarehouseId(reservationEntity.getWarehouseId());
 		distributionReservationMapper.updateById(reservationEntity);
+		map.put("1",reservationPackageEntityList);
+		map.put("2",reservationZeroPackageEntityList);
+		map.put("3",reservationStocklistEntityList);
+		NodeFanoutMsg<ReservationVO> nodeFanoutMsg = buildNodeFanoutMsgByReservation(reservationEntity,map,BizOperationEnums.ADD);
+		distributionNodeWorkService.planReservation(nodeFanoutMsg,AuthUtil.getUser());
+		handleCreatedReservationPlanLog(reservationEntity,AuthUtil.getUser(),myCurrentWarehouse);
 		return R.status(true);
 	}