异常审核加入计划消息推送

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java

@@ -6806,6 +6806,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 				distributionLoadscanService.updateById(loadscanEntity);
 			}
 
+
+
 			//单个审核
 		} else {
 			//过滤出未审核的异常包件
@@ -6877,6 +6879,10 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 	private void extractedBuildNewPackage(DistributionReservationEntity reservationEntity, DistributionLoadscanAbnormalEntity distributionLoadscanAbnormalEntity, BasicdataWarehouseEntity warehouse) {
 		DistributionReservationPackageEntity reservationPackageEntity = getDistributionReservationPackageEntity(reservationEntity, distributionLoadscanAbnormalEntity);
 		distributionReservationPackageService.save(reservationPackageEntity);
+		Map<String, List> map = new HashMap<>();
+		map.put("1", Collections.singletonList(reservationPackageEntity));
+		NodeFanoutMsg<ReservationVO> nodeFanoutMsg = distributionReservationService.buildNodeFanoutMsgByReservation(reservationEntity, map, BizOperationEnums.MODIFY);
+		distributionNodeWorkService.planReservation(nodeFanoutMsg,AuthUtil.getUser());
 		//维护包件的预约状态
 		DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(distributionLoadscanAbnormalEntity.getPackageId());
 		parcelListEntity.setOrderPackageReservationStatus(OrderPackageReservationStatusConstant.yiyueyue.getValue());