1.增加师傅签收推送商家端作业2

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionReservationClient.java

@@ -61,6 +61,8 @@ public interface IDistributionReservationClient {
 	 */
 	@GetMapping(TOP+"/getReservationList")
     List<DistributionReservationEntity> getReservationList(@RequestParam("reservationIds") String reservationIds);
+	@GetMapping(TOP+"/getReservationByCodeAndWarehouseId")
+    DistributionReservationEntity getReservationByCodeAndWarehouseId(@RequestParam("reservationCode") String reservationCode,@RequestParam("warehouseId") String warehouseId);
 
 
 	/**

blade-service/logpm-business/src/main/java/com/logpm/business/receiver/BusinessInOrderDataQueueHandler.java

@@ -1,16 +1,23 @@
 package com.logpm.business.receiver;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.logpm.business.service.IBusinessPreOrderService;
+import com.logpm.distribution.entity.DistributionReservationEntity;
+import com.logpm.distribution.feign.IDistributionReservationClient;
 import com.rabbitmq.client.Channel;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.RabbitConstant;
+import org.springblade.core.tool.api.R;
+import org.springblade.system.entity.Tenant;
+import org.springblade.system.feign.ISysClient;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -23,7 +30,8 @@ import java.util.Map;
 public class BusinessInOrderDataQueueHandler {
 
 	private final IBusinessPreOrderService businessPreOrderService;
-
+	private final IDistributionReservationClient distributionReservationClient;
+	private final ISysClient sysClient;
 	@RabbitHandler
 	public void businessInOrderDataHandler(Map map, Message message, Channel channel) {
 		// 获取
@@ -35,7 +43,9 @@ public class BusinessInOrderDataQueueHandler {
 		String vehicleName = o.getString("vehicleName");
 		String driverName = o.getString("driverName");
 		String userName = o.getString("userName");
+		// 当前作业仓库
 		Long warehouseId = o.getLong("warehouseId");
+		// 作业
 		String tenantId = o.getString("tenantId");
 
 		//验证参数是否为null或者空串
@@ -59,9 +69,26 @@ public class BusinessInOrderDataQueueHandler {
 			log.error("driverName is null");
 			return;
 		}
+		// 判断目标租户
+		DistributionReservationEntity reservationByCodeAndWarehouseId = distributionReservationClient.getReservationByCodeAndWarehouseId(reservationCode, warehouseId.toString());
 
+		// 判断是否存在租户
+		R<List<Tenant>> tenantList = sysClient.getTenantList();
+		Tenant tenant = null;
+		if (tenantList.isSuccess()) {
+			List<Tenant> data = tenantList.getData();
+			for (Tenant datum : data) {
+				if (datum.getTenantType() == 2 && datum.getTenantName().equals(reservationByCodeAndWarehouseId.getMallName().trim())) {
+					tenant = datum;
+					break;
+				}
+			}
+		}
+		if(!ObjectUtil.isEmpty(tenant)){
 			// 如果师傅签收 以师傅签收的车次为准
-		businessPreOrderService.scanOrderPackageCodeByMaster(orderPackageCode, reservationCode, distrCarNumber, vehicleName, driverName, userName, warehouseId, tenantId);
+			businessPreOrderService.scanOrderPackageCodeByMaster(orderPackageCode, reservationCode, distrCarNumber, vehicleName, driverName, userName, warehouseId,tenant.getTenantId(),tenant.getTenantName(),tenantId);
+		}
+
 
 
 	}

blade-service/logpm-business/src/main/java/com/logpm/business/service/IBusinessPreOrderService.java

@@ -10,6 +10,7 @@ import com.logpm.trunkline.dto.InComingDTO;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BaseService;
 import org.springblade.core.tool.api.R;
+import org.springblade.system.entity.Tenant;
 
 import java.util.List;
 import java.util.Map;
@@ -88,8 +89,9 @@ public interface IBusinessPreOrderService extends BaseService<BusinessPreOrderEn
 	 * @param driverName 司机名称
 	 * @param vehicleName 车牌号码
 	 * @param warehouseId  当前作业仓库ID
-	 * @param tenantId  当前作业的租户
+	 * @param tenantId  目标租户
 	 * @param userName 作业用户
+	 * @param sourceTenantId 来源租户
 	 * @return
 	 */
 	R scanOrderPackageCodeByMaster(String orderPackageCode,
@@ -99,7 +101,9 @@ public interface IBusinessPreOrderService extends BaseService<BusinessPreOrderEn
 								   String driverName,
 								   String userName,
 								   Long warehouseId,
-								   String tenantId
+								   String tenantId,
+								   String tenantName,
+								   String sourceTenantId
 	);
 
 }

blade-service/logpm-business/src/main/java/com/logpm/business/service/impl/BusinessPreOrderServiceImpl.java

@@ -23,6 +23,7 @@ import com.logpm.trunkline.feign.IInComingClient;
 import com.logpm.trunkline.feign.ITrunklineAdvanceDetailClient;
 import lombok.AllArgsConstructor;
 import org.jetbrains.annotations.Nullable;
+import org.springblade.common.annotations.ChangeAsync;
 import org.springblade.common.constant.IncomingTypeEnum;
 import org.springblade.common.constant.RedisKeyConstant;
 import org.springblade.common.exception.CustomerException;
@@ -169,13 +170,12 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 	private R inOrderWarehourseByFeign(BusinessSanDTO businessSanDTO) {
 		InComingDTO inComingDTO = new InComingDTO();
-		BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
 		inComingDTO.setOrderPackageCode(businessSanDTO.getOrderPackageCode());
 		inComingDTO.setIncomingType(IncomingTypeEnum.LINE_INCOMING.getCode());
-		inComingDTO.setWarehouseId(myCurrentWarehouse.getId());
 		inComingDTO.setTrayCode(businessSanDTO.getTrayCode());
 		inComingDTO.setTrayType(businessSanDTO.getTrayType());
-		inComingDTO.setWarehouseName(myCurrentWarehouse.getName());
+		inComingDTO.setWarehouseName(businessSanDTO.getWarehouseName());
+		inComingDTO.setWarehouseId(businessSanDTO.getWarehouseId());
 
 		R r = inComingClient.incomingPackageByTaryCode(inComingDTO);
 		return r;
@@ -187,6 +187,9 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 
 		try {
+			BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
+			businessSanDTO.setWarehouseId(myCurrentWarehouse.getId());
+			businessSanDTO.setWarehouseName(myCurrentWarehouse.getName());
 			String orderPackageCode = businessSanDTO.getOrderPackageCode();
 			String distrCarNumber = businessSanDTO.getDistrCarNumber();
 
@@ -466,6 +469,7 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 	}
 
 
+	@ChangeAsync
 	@Override
 	public R scanOrderPackageCodeByMaster(String orderPackageCode,
 										  String reservationCode,
@@ -474,7 +478,16 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 										  String driverName,
 										  String userName,
 										  Long warehouseId,
-										  String tenantId) {
+										  String tenantId,
+										  String tenantName,
+										  String sourceTenantId) {
+
+
+		BasicdataWarehouseEntity warehouseEntity = basicdataWarehouseClient.findByName(tenantName + "仓");
+		if(ObjectUtils.isNull(warehouseEntity)){
+			return R.fail("仓库信息不存在");
+		}
+
 
 		// 判断当前的包条码是否和当前作业的车次相同
 		LambdaQueryWrapper<BusinessPreOrderEntity> queryWrapper1 = new LambdaQueryWrapper<>();
@@ -484,14 +497,22 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 		BusinessPreOrderEntity data =null;
 		if (list1.isEmpty()) {
 			// 新增改车次的预入库信息
-			DistributionParcelListEntity byPacketBarCodeAndWarehouseId = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
-			data = BeanUtil.copy(byPacketBarCodeAndWarehouseId, BusinessPreOrderEntity.class);
+			TrunklineAdvanceDetailEntity entityByOrderPackageCode = trunklineAdvanceDetailClient.findEntityByOrderPackageCode(orderPackageCode);
+
+
+			data = BeanUtil.copy(entityByOrderPackageCode, BusinessPreOrderEntity.class);
+			data.setWaybillNumber(entityByOrderPackageCode.getWaybillNo());
+			data.setFirsts(entityByOrderPackageCode.getFirstPackName());
+			data.setSecond(entityByOrderPackageCode.getSecondPackName());
+			data.setThirdProduct(entityByOrderPackageCode.getThirdPackName());
+			data.setBrandName(entityByOrderPackageCode.getBrand());
+			data.setConditions(1);
+			data.setInWarehouse(0);
 			data.setDriverName(driverName);
 			data.setVehicleName(vehicleName);
 			data.setDistrCarNumber(distrCarNumber);
-			data.setFromTenantId(tenantId);
+			data.setFromTenantId(sourceTenantId);
 			data.setOperationStatus(0);
-			data.setInWarehouse(1);
 			data.setId(null);
 			data.setTenantId(null);
 			data.setReservationCode(reservationCode);
@@ -513,9 +534,15 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
         }
 
+		// 通过目标租户确认 目标租户对应的仓库
+
 		BusinessSanDTO businessSanDTO = new BusinessSanDTO();
 		businessSanDTO.setOrderPackageCode(data.getOrderPackageCode());
-		R r = inOrderWarehourse(businessSanDTO);
+		businessSanDTO.setDistrCarNumber(distrCarNumber);
+		businessSanDTO.setInWarehouseException(0);
+		businessSanDTO.setWarehouseName(warehouseEntity.getName());
+		businessSanDTO.setWarehouseId(warehouseEntity.getId());
+		R r = inOrderWarehourseByFeign(businessSanDTO);
 
 		return r;
 	}

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java

@@ -60,6 +60,11 @@ public class DistributionReservationClient implements IDistributionReservationCl
 		return reservationService.getRetentionReservationList(reservationIds);
 	}
 
+	@Override
+	public DistributionReservationEntity getReservationByCodeAndWarehouseId(String reservationCode, String warehouseId) {
+		return reservationService.selectByReservationCode(reservationCode);
+	}
+
 	/**
 	 * @param warehouseId
 	 * @return

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

@@ -16,6 +16,8 @@
  */
 package com.logpm.distribution.service.impl;
 
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -43,6 +45,7 @@ import com.logpm.distribution.vo.app.*;
 import com.logpm.distribution.wrapper.DistributionParcelListAppWrapper;
 import com.logpm.distribution.wrapper.DistributionParcelListWrapper;
 import com.logpm.distribution.wrapper.DistributionStockArticleWrapper;
+import com.logpm.factory.comfac.dto.OrderStatusDTO;
 import com.logpm.oldproject.dto.SignPushDataContactDTO;
 import com.logpm.oldproject.dto.SignPushDataDTO;
 import com.logpm.oldproject.dto.SignPushDataUnitDTO;
@@ -2665,6 +2668,14 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 			distributionDeliveryListService.maintenanceDeliveryInfo(distrilbutionloadingscanDTO.getDeliveryId());
 
 			trunklinePackageTrackLogClient.addPackageTrackLog(aaa);
+
+			// 推送
+			sendMessage(distrilbutionloadingscanDTO.getBarcode(), distributionReservationEntity.getReservationCode(),
+				deliveryListEntity.getTrainNumber(),deliveryListEntity.getVehicleName(),deliveryListEntity.getDriverName(),
+				AuthUtil.getUserName(),myCurrentWarehouse.getId(),AuthUtil.getTenantId());
+
+
+
 			return Resp.scanSuccessWithData("签收成功", str, orderPackageCodes);
 		} catch (Exception e) {
 			log.error(">>>>> 签收异常报错", e);
@@ -2672,6 +2683,49 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		}
 	}
 
+	/**
+	 *
+	 * @param orderPackageCode
+	 * @param reservationCode
+	 * @param distrCarNumber
+	 * @param vehicleName
+	 * @param driverName
+	 * @param userName
+	 * @param warehouseId
+	 * @param tenantId 当前的租户
+	 *
+	 */
+	private void sendMessage(String orderPackageCode,
+							 String reservationCode,
+							 String distrCarNumber,
+							 String vehicleName,
+							 String driverName,
+							 String userName,
+							 Long warehouseId,
+							 String tenantId
+		){
+		try {
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("orderPackageCode",orderPackageCode);
+			jsonObject.put("reservationCode",reservationCode);
+			jsonObject.put("distrCarNumber",distrCarNumber);
+			jsonObject.put("vehicleName",vehicleName);
+			jsonObject.put("driverName",driverName);
+			jsonObject.put("userName",userName);
+			jsonObject.put("warehouseId",warehouseId);
+			jsonObject.put("tenantId",tenantId);
+			// 发送入库消息
+			Map mapState = new HashMap();
+			mapState.put("messageId", CommonUtil.getUUID());
+			mapState.put("createTime", System.currentTimeMillis());
+			Map<String, Object> map = new HashMap<>();
+			map.put("messageData", jsonObject);
+			rabbitTemplate.convertAndSend(RabbitConstant.BUSINESS_IN_CONVERSION_DATA_EXCHANGE, RabbitConstant.BUSINESS_IN_CONVERSION_DATA_ROUTING, map);
+		} catch (Exception e) {
+			log.error("签收商家推送：{}", e);
+		}
+	}
+
 	@Override
 	@Transactional(rollbackFor = Exception.class)
 	public R signforPC(DistrilbutionAppsignforDTO distrilbutionloadingscanDTO) {
@@ -3704,8 +3758,10 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 	@Override
 	public List<DistributionAppStockArticleVO> getAppDeliveryorderListPage(DistributionAppDeliveryListDTO distributionDeliveryList) {
+		List<DistributionAppStockArticleVO> orderVos = new ArrayList<>();
 		if (Func.isEmpty(distributionDeliveryList.getReservationId())) {
 			log.error("参数缺失reservationId:{}", distributionDeliveryList.getReservationId());
+			return orderVos;
 		}
 
 		//查询该客户装车
@@ -3731,32 +3787,40 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		}
 		Map<Long, List<DistributionReservationStockarticleEntity>> reservationOrderMap = reservationStockarticleEntityList.stream().collect(Collectors.groupingBy(DistributionReservationStockarticleEntity::getStockArticleId));
 		Map<Long, List<DistributionLoadscanEntity>> loadingOrderMap = distributionLoadscanEntities.stream().collect(Collectors.groupingBy(DistributionLoadscanEntity::getOrderId));
-		List<DistributionAppStockArticleVO> orderVos = new ArrayList<>();
+
 		if (Func.isNotEmpty(orderIds)) {
 			orderIds = orderIds.stream().distinct().collect(Collectors.toList());
-			for (Long orderId : orderIds) {
-				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleService.getById(orderId);
-				DistributionAppStockArticleVO distributionAppStockArticleVO = Func.copy(stockArticleEntity, DistributionAppStockArticleVO.class);
-				distributionAppStockArticleVO.setTotalNumber(stockArticleEntity.getTotalNumber());
-				distributionAppStockArticleVO.setStockArticleId(stockArticleEntity.getId());
+
+			List<DistributionStockArticleEntity> distributionStockArticleEntities = distributionStockArticleService.listByIds(orderIds);
+
+
+
+			List<DistributionReservationStockarticleEntity> reservationOrders = distributionReservationStockarticleService.list(Wrappers.<DistributionReservationStockarticleEntity>query().lambda()
+				.eq(DistributionReservationStockarticleEntity::getReservationId, distributionDeliveryList.getReservationId())
+				.in(DistributionReservationStockarticleEntity::getStockArticleId, orderIds)
+				.ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())
+			);
+
+			for (DistributionStockArticleEntity distributionStockArticleEntity : distributionStockArticleEntities) {
+
+
+//				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleService.getById(orderId);
+				DistributionAppStockArticleVO distributionAppStockArticleVO = Func.copy(distributionStockArticleEntity, DistributionAppStockArticleVO.class);
+                assert distributionAppStockArticleVO != null;
                 distributionAppStockArticleVO.setLoadingNub(0);
 				distributionAppStockArticleVO.setSignforNub(0);
 				distributionAppStockArticleVO.setReservationNum(0);
 				//查询预约该订单计划数量
-				DistributionReservationStockarticleEntity reservationOrder = distributionReservationStockarticleService.getOne(Wrappers.<DistributionReservationStockarticleEntity>query().lambda()
-					.eq(DistributionReservationStockarticleEntity::getReservationId, distributionDeliveryList.getReservationId())
-					.eq(DistributionReservationStockarticleEntity::getStockArticleId, orderId)
-					.ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())
-				);
+				DistributionReservationStockarticleEntity reservationOrder = findReservationOrders(reservationOrders, distributionStockArticleEntity.getId());
 				if (Func.isNotEmpty(reservationOrder)) {
 					distributionAppStockArticleVO.setReservationNum(reservationOrder.getReservationNum());
 				}
-				if (stockArticleEntity.getIsZero().equals(IsOrNoConstant.no.getValue())) {
+				if (distributionStockArticleEntity.getIsZero().equals(IsOrNoConstant.no.getValue())) {
 					//判断此订单是是否是异常装车
 
-					if (Func.isEmpty(reservationOrderMap.get(orderId))) {
+					if (Func.isEmpty(reservationOrderMap.get(distributionStockArticleEntity.getId()))) {
 						//不存在计划之中的订单装车
-						List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(orderId);
+						List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(distributionStockArticleEntity.getId());
 						List<Long> abnormalPackageIds = loadscanEntityList.stream().map(DistributionLoadscanEntity::getPackageId).collect(Collectors.toList());
 						List<DistributionParcelListEntity> distributionParcelListEntities = distributionParcelListService.listByIds(abnormalPackageIds);
 						List<DistributionAppParcelListVO> distributionAppParcelListVOS = DistributionParcelListAppWrapper.build().listVO(distributionParcelListEntities);
@@ -3778,7 +3842,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						//查询此预约该订单下的包件信息
 						List<DistributionReservationPackageEntity> reservationPackage = distributionReservationPackageService.list(Wrappers.<DistributionReservationPackageEntity>query().lambda()
 							.eq(DistributionReservationPackageEntity::getReservationId, distributionDeliveryList.getReservationId())
-							.eq(DistributionReservationPackageEntity::getStockArticleId, orderId)
+							.eq(DistributionReservationPackageEntity::getStockArticleId, distributionStockArticleEntity.getId())
 							.ne(DistributionReservationPackageEntity::getPacketBarStatus, ReservationPackageStatusConstant.quxiao.getValue())
 						);
 						List<Long> packageIds = new ArrayList<>();
@@ -3788,8 +3852,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						}
 
 						Map<Long, DistributionLoadscanEntity> collect = null;
-						if (Func.isNotEmpty(loadingOrderMap.get(orderId))) {
-							List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(orderId);
+						if (Func.isNotEmpty(loadingOrderMap.get(distributionStockArticleEntity.getId()))) {
+							List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(distributionStockArticleEntity.getId());
 							List<Long> loadingPackageIds = loadscanEntityList.stream().map(DistributionLoadscanEntity::getPackageId).collect(Collectors.toList());
 							packageIds.addAll(loadingPackageIds);
 							collect = loadscanEntityList.stream().collect(Collectors.toMap(DistributionLoadscanEntity::getPackageId, Function.identity(), (k1, k2) -> k2));
@@ -3801,11 +3865,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						List<DistributionAppParcelListVO> packageVOS = new ArrayList<>();
 						if (Func.isNotEmpty(packageIds)) {
 							packageIds = packageIds.stream().distinct().collect(Collectors.toList());
-							for (Long packageId : packageIds) {
-								DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(packageId);
+
+							List<DistributionParcelListEntity> parcelListEntitys = distributionParcelListService.listByIds(packageIds);
+							for (DistributionParcelListEntity parcelListEntity : parcelListEntitys) {
+//								DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(packageId);
 								DistributionAppParcelListVO distributionAppParcelListVO = DistributionParcelListAppWrapper.build().entityVO(parcelListEntity);
 								if (Func.isNotEmpty(collect)) {
-									DistributionLoadscanEntity distributionLoadscanEntity = collect.get(packageId);
+									DistributionLoadscanEntity distributionLoadscanEntity = collect.get(parcelListEntity.getId());
 									if (Func.isNotEmpty(distributionLoadscanEntity)) {
 										distributionAppParcelListVO.setMaterialName(parcelListEntity.getMaterialName());
 										if (distributionLoadscanEntity.getIsAbnormalLoading().equals(2)) {
@@ -3832,16 +3898,16 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 					List<DistributionReservationZeroPackageEntity> reservationZeroPackageEntityList = distributionReservationZeroPackageService.list(Wrappers.<DistributionReservationZeroPackageEntity>query().lambda()
 						.eq(DistributionReservationZeroPackageEntity::getReservationId, distributionDeliveryList.getReservationId())
-						.eq(DistributionReservationZeroPackageEntity::getStockArticleId, orderId)
+						.eq(DistributionReservationZeroPackageEntity::getStockArticleId, distributionStockArticleEntity.getId())
 						.ne(DistributionReservationZeroPackageEntity::getZeroPackageStatus, ReservationPackageStatusConstant.quxiao.getValue()));
 					if (Func.isNotEmpty(reservationZeroPackageEntityList)) {
 						int reservationTotal = reservationZeroPackageEntityList.stream().mapToInt(DistributionReservationZeroPackageEntity::getQuantity).sum();
 						distributionAppStockArticleVO.setReservationNum(reservationTotal);
-						List<DistributionParcelNumberVO> parcelNumberVOS = distributionReservationMapper.selectReservationZeroOrderDetail(orderId, Long.parseLong(distributionDeliveryList.getReservationId()));
+						List<DistributionParcelNumberVO> parcelNumberVOS = distributionReservationMapper.selectReservationZeroOrderDetail(distributionStockArticleEntity.getId(), Long.parseLong(distributionDeliveryList.getReservationId()));
 						distributionAppStockArticleVO.setSignforNub(0);
 						if (Func.isNotEmpty(parcelNumberVOS)) {
 							parcelNumberVOS.forEach(p -> {
-								DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getReservationId, distributionDeliveryList.getReservationId()).eq(DistributionLoadscanEntity::getOrderId, orderId).eq(DistributionLoadscanEntity::getPackageId, p.getParcelListId()).ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()));
+								DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getReservationId, distributionDeliveryList.getReservationId()).eq(DistributionLoadscanEntity::getOrderId, distributionStockArticleEntity.getId()).eq(DistributionLoadscanEntity::getPackageId, p.getParcelListId()).ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()));
 								p.setLoadingNum(0);
 								p.setSigningNum(0);
 								if (Func.isNotEmpty(loadscanEntity)) {
@@ -3866,6 +3932,16 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 	}
 
+	/**
+	 * 寻找预约单中订单
+	 * @param reservationOrders
+	 * @param id
+	 * @return
+	 */
+	private DistributionReservationStockarticleEntity findReservationOrders(List<DistributionReservationStockarticleEntity> reservationOrders , Long id) {
+		return reservationOrders.stream().filter(f -> f.getStockArticleId().equals(id)).findFirst().orElse(null);
+	}
+
 
 //			Map<Long, List<DistributionLoadscanEntity>> orderMap = distributionLoadscanEntities.stream().collect(Collectors.groupingBy(DistributionLoadscanEntity::getOrderId));
 //		List<DistributionAppStockArticleVO> distributionAppStockArticleVOS = new ArrayList<>();