1.优化库内作业订单上下架

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataGoodsAllocationClient.java

@@ -72,4 +72,7 @@ public interface IBasicdataGoodsAllocationClient {
 
 	@GetMapping(API_PREFIX+"/findStockUpAllocationById")
     BasicdataGoodsAllocationEntity findStockUpAllocationById(@RequestParam Long warehouseId,@RequestParam Long stockUpAllocationId);
+
+	@PostMapping(API_PREFIX+"/updateListAllocationStatus")
+    void updateListAllocationStatus(@RequestParam List<Long> updateAllocationIds, @RequestParam String allocationStatus);
 }

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataTrayClient.java

@@ -79,4 +79,7 @@ public interface IBasicdataTrayClient {
 	 */
 	@GetMapping(API_PREFIX+"/findByTrayName")
     BasicdataTrayEntity findByTrayName(@RequestParam String positions);
+
+	@PostMapping(API_PREFIX+"/updateTrayStatusByTrayIds")
+    void updateTrayStatusByTrayIds(@RequestParam List<Long> trayIds, @RequestParam int trayStatus);
 }

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

@@ -192,4 +192,9 @@ public interface IDistributionParcelListClient {
 	@PostMapping(API_PREFIX + "/findListByOrderCodesAndWarehouseId")
     List<DistributionParcelListEntity> findListByOrderCodesAndWarehouseId(@RequestParam Set<String> orderCodeSet, @RequestParam Long warehouseId);
 
+	@PostMapping(API_PREFIX + "/findListByOrderPackageCodeList")
+	List<DistributionParcelListEntity> findListByOrderPackageCodeList(@RequestParam List<String> orderPackageCodeList, @RequestParam Long warehouseId);
+
+	@PostMapping(API_PREFIX + "/findALLNoUpShelfPackageByOrderCodeList")
+	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@RequestParam List<String> orderCodeList, @RequestParam Long warehouseId);
 }

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataGoodsAllocationClient.java

@@ -114,4 +114,12 @@ public class BasicdataGoodsAllocationClient implements IBasicdataGoodsAllocation
 		return BasicdataGoodsAllocationService.findStockUpAllocationById(warehouseId,stockUpAllocationId);
 	}
 
+	@Override
+	public void updateListAllocationStatus(List<Long> updateAllocationIds, String allocationStatus) {
+		UpdateWrapper<BasicdataGoodsAllocationEntity> updateWrapper = new UpdateWrapper<>();
+		updateWrapper.set("allocation_status",allocationStatus)
+			.in("id",updateAllocationIds);
+		BasicdataGoodsAllocationService.update(updateWrapper);
+	}
+
 }

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataTrayClient.java

@@ -116,4 +116,13 @@ public class BasicdataTrayClient implements IBasicdataTrayClient {
 		).get(0);
 	}
 
+	@Override
+	public void updateTrayStatusByTrayIds(List<Long> trayIds, int trayStatus) {
+		UpdateWrapper<BasicdataTrayEntity> updateWrapper = new UpdateWrapper<>();
+		updateWrapper.set("tray_status",trayStatus)
+			.in("id",trayIds)
+			.eq("is_deleted",0);
+		basicdataTrayService.update(updateWrapper);
+	}
+
 }

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

@@ -430,4 +430,18 @@ public class DistributionParcelListClient implements IDistributionParcelListClie
 
 		return distributionParcelListService.list(queryWrapper);
 	}
+
+	@Override
+	public List<DistributionParcelListEntity> findListByOrderPackageCodeList(List<String> orderPackageCodeList, Long warehouseId) {
+		QueryWrapper<DistributionParcelListEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.in("order_package_code", orderPackageCodeList)
+			.eq("warehouse_id", warehouseId);
+
+		return distributionParcelListService.list(queryWrapper);
+	}
+
+	@Override
+	public List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(List<String> orderCodeList, Long warehouseId) {
+		return distributionParcelListService.findALLNoUpShelfPackageByOrderCodeList(orderCodeList,warehouseId);
+	}
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java

@@ -277,4 +277,6 @@ public interface DistributionParcelListMapper extends BaseMapper<DistributionPar
 	void removePakcageByAdvanceIds(@Param("advanceIds") List<Long> advanceIds, @Param("warehouseId") Long warehouseId);
 
     List<Map<String, String>> findPackageCodeByCodes(@Param("keySet") Set<String> keySet);
+
+	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@Param("orderCodeList") List<String> orderCodeList, @Param("warehouseId") Long warehouseId);
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml

@@ -1765,4 +1765,23 @@
         </foreach>
     </delete>
 
+
+
+    <select id="findALLNoUpShelfPackageByOrderCodeList"
+            resultType="com.logpm.distribution.entity.DistributionParcelListEntity">
+        select ldpl.*
+        from logpm_distribution_parcel_list ldpl
+                 left join logpm_warehouse_tray_goods lwtg on lwtg.association_value = ldpl.order_package_code
+                 left join logpm_warehouse_updown_goods lwug on lwug.association_value = ldpl.order_package_code
+        where 1 = 1
+          and ldpl.order_code in
+            <foreach collection="orderCodeList" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+          and ldpl.warehouse_id = #{warehouseId}
+          and lwtg.id is null
+          and lwug.id is null
+    </select>
+
+
 </mapper>

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java

@@ -242,4 +242,6 @@ public interface IDistributionParcelListService extends BaseService<Distribution
 	 * @return
 	 */
     Map<String, Set<String>> findPackageCodeByCodes(Set<String> keySet);
+
+	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(List<String> orderCodeList, Long warehouseId);
 }

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

@@ -1286,4 +1286,9 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl<Distribut
         return resultMap;
     }
 
+	@Override
+	public List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(List<String> orderCodeList, Long warehouseId) {
+		return baseMapper.findALLNoUpShelfPackageByOrderCodeList(orderCodeList,warehouseId);
+	}
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/mapper/WarehouseTrayGoodsMapper.java

@@ -94,4 +94,6 @@ public interface WarehouseTrayGoodsMapper extends BaseMapper<WarehouseTrayGoodsE
 	 * @return
 	 */
     List<WarehouseTrayGoodsEntity> getPackageTrayInfo(@Param("param")Map<String, Object> map);
+
+    void deleteEntityByTrayGoodsIds(@Param("trayGoodsIds") List<Long> trayGoodsIds);
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/mapper/WarehouseTrayGoodsMapper.xml

@@ -442,4 +442,12 @@
     </select>
 
 
+    <delete id="deleteEntityByTrayGoodsIds" >
+        delete from logpm_warehouse_tray_goods
+        WHERE id in
+        <foreach collection="trayGoodsIds" item="item" index="index" open="(" close=")" separator=",">
+            #{item}
+        </foreach>
+    </delete>
+
 </mapper>

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/mapper/WarehouseUpdownGoodsMapper.java

@@ -133,6 +133,11 @@ public interface WarehouseUpdownGoodsMapper extends BaseMapper<WarehouseUpdownGo
 
 
 	List<DistributionParcelListEntity> findParcelListByAllocationIdAndWarehouseId(@Param("allocationId") String allocationId, @Param("warehouseId") Long warehouseId);
+
+    List<String> findOrderPackageCodesByOrderPackageCodeList(@Param("orderPackageCodeList") List<String> orderPackageCodeList, @Param("warehouseId") Long warehouseId);
+
+	void deleteByUpdownGoodsIds(@Param("updownGoodsIds") List<Long> updownGoodsIds);
+
 //	/**
 //	 * 根据货位查询货物
 //	 *

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/mapper/WarehouseUpdownGoodsMapper.xml

@@ -537,4 +537,22 @@
           and ldpl.warehouse_id = #{warehouseId}
     </select>
 
+    <select id="findOrderPackageCodesByOrderPackageCodeList" resultType="String">
+        select association_value
+        from logpm_warehouse_updown_goods
+        where association_type = '3'
+        and association_value in
+        <foreach collection="orderPackageCodeList" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <delete id="deleteByUpdownGoodsIds">
+        delete from logpm_warehouse_updown_goods
+        where id in
+        <foreach collection="updownGoodsIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </delete>
+
 </mapper>

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/IWarehouseTrayGoodsService.java

@@ -29,6 +29,8 @@ public interface IWarehouseTrayGoodsService extends BaseService<WarehouseTrayGoo
 
 	Integer deleteByTrayGoodsId(Long trayGoodsId,Long warehouseId);
 
+	Integer deleteByTrayGoodsIds(List<Long> trayGoodsIds, Long trayTypeId,Long warehouseId);
+
 	Boolean downZeroByTrayId(Long trayGoodsId,Long orderId,Long warehouseId,Integer num,String remark);
 
 	List<TrayTypeDataListVO> getZeroListByTrayTypeId(Long trayTypeId,Long warehouseId);

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/IWarehouseTrayTypeService.java

@@ -2,6 +2,7 @@ package com.logpm.warehouse.service;
 
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.warehouse.dto.TrayTypeDTO;
 import com.logpm.warehouse.dto.ZeroOrderVO;
 import com.logpm.warehouse.entity.WarehouseTrayTypeEntity;
@@ -57,6 +58,8 @@ public interface IWarehouseTrayTypeService extends BaseService<WarehouseTrayType
 
 	void downPackageByOrderPackageCode(String orderPackageCode,String remark,Long warehouseId);
 
+	void downPackageByOrderPackageCodeList(List<String> orderPackageCodeList,String remark,Long warehouseId);
+
 	void updateEntityNumByTrayGoodsIdAndNumStock(Long trayGoodsId, Integer enterNum,String remark);
 
 	void downTrayGoodsByTrayId(Long trayId,String remark);
@@ -113,4 +116,6 @@ public interface IWarehouseTrayTypeService extends BaseService<WarehouseTrayType
 	 */
 	Integer getZeroOrderByOrderId(Long orderId, Long warehouseId);
 
+
+	void orderScanOrderPackageCodeList(WarehouseTrayTypeEntity trayTypeEntity, List<DistributionParcelListEntity> parcelListEntityList, Long warehouseId, String remark);
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/IWarehouseUpdownGoodsService.java

@@ -76,6 +76,7 @@ public interface IWarehouseUpdownGoodsService extends BaseService<WarehouseUpdow
     List<WarehouseUpdownGoodsEntity> findListByUpdownTypeIdAndOrderCode(Long updownTypeId, String orderCode);
 
 	void bindingAllocationAndPackage(WarehouseUpdownTypeEntity updownTypeEntity, DistributionParcelListEntity parcelListEntity, String bindingType,Integer isAlltrays,String remark);
+	void bindingAllocationAndPackageList(WarehouseUpdownTypeEntity updownTypeEntity, List<DistributionParcelListEntity> parcelListEntities, String bindingType,Integer isAlltrays,String remark);
 
 	Map<String, Integer> getTotalNumberAndNum(Long updownTypeId);
 
@@ -105,6 +106,7 @@ public interface IWarehouseUpdownGoodsService extends BaseService<WarehouseUpdow
 	Integer selectCountByArea(String ids);
 
     Integer deleteByUpdownGoodsId(Long updownGoodsId);
+    Integer deleteByUpdownGoodsIds(List<Long> updownGoodsIds,Long updownTypeId);
 
 	void updeteNumByUpdownGoodsId(int num, Long updownGoodsId);
 
@@ -154,4 +156,6 @@ public interface IWarehouseUpdownGoodsService extends BaseService<WarehouseUpdow
     List<String> getAllocationsByOrderPackages(List<String> orderPackageOrders, Long warehouseId);
 
 	List<String> getAllocationsByWarehouseIdAndMarketIdAndSku(Long mallId, String sku, Long warehouseId);
+
+    List<String> findOrderPackageCodesByOrderPackageCodeList(List<String> orderPackageCodeList, Long warehouseId);
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseTrayGoodsServiceImpl.java

@@ -102,6 +102,17 @@ public class WarehouseTrayGoodsServiceImpl extends BaseServiceImpl<WarehouseTray
 		return list.size();
 	}
 
+	@Override
+	public Integer deleteByTrayGoodsIds(List<Long> trayGoodsIds, Long trayTypeId,Long warehouseId) {
+		baseMapper.deleteEntityByTrayGoodsIds(trayGoodsIds);
+		QueryWrapper<WarehouseTrayGoodsEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("tray_type_id",trayTypeId);
+		List<WarehouseTrayGoodsEntity> list = baseMapper.selectList(queryWrapper);
+		return list.size();
+	}
+
+
+
 	@Override
 	public Boolean downZeroByTrayId(Long trayId,Long orderId,Long warehouseId,Integer num,String remark) {
 		WarehouseTrayGoodsEntity trayGoodsEntity = baseMapper.selectOne(Wrappers.<WarehouseTrayGoodsEntity>query().lambda()

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseTrayTypeServiceImpl.java

@@ -62,6 +62,8 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 @Log4j2
 @Service
@@ -686,6 +688,193 @@ public class WarehouseTrayTypeServiceImpl extends BaseServiceImpl<WarehouseTrayT
 		}
 	}
 
+
+
+	public void orderScanOrderPackageCodeList(WarehouseTrayTypeEntity trayTypeEntity, List<DistributionParcelListEntity> parcelListEntityList,Long warehouseId,String remark) {
+
+		String tt = trayTypeEntity.getTrayType();
+		Long filterId = trayTypeEntity.getFilterId();
+		String filterValue = trayTypeEntity.getFilterValue();
+		if(StringUtil.isBlank(filterValue)){
+			filterValue = "";
+		}
+		Long trayTypeId = trayTypeEntity.getId();
+		Long trayTypeEntityWarehouseId = trayTypeEntity.getWarehouseId();
+
+		if(!trayTypeEntityWarehouseId.equals(warehouseId)){
+			log.warn("##############orderScanOrderPackageCode: 托盘已在其他仓库打托 {}={}",trayTypeEntityWarehouseId,warehouseId);
+			throw new CustomerException(2001,"托盘已在其他仓库打托");
+		}
+
+		//把parcelListEntityList通过orderCode进行分组
+		Map<String, List<DistributionParcelListEntity>> map = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getOrderCode));
+
+		List<DistributionStockArticleEntity> stockArticleEntityList = distributionStockArticleClient.findListByOrderCodesAndWarehouseId(map.keySet(), warehouseId);
+		//把stockArticleEntityList转化成orderCode为key的Map
+		Map<String, DistributionStockArticleEntity> stockArticleEntityMap = stockArticleEntityList.stream().collect(Collectors.toMap(DistributionStockArticleEntity::getOrderCode, Function.identity()));
+
+		Map<String, Integer> orderPackageChuanMap = new HashMap<>();
+
+		String finalFilterValue = filterValue;
+		parcelListEntityList.forEach(parcelListEntity -> {
+			String orderPackageCode = parcelListEntity.getOrderPackageCode();
+			String orderCode = parcelListEntity.getOrderCode();
+			DistributionStockArticleEntity stockArticleEntity = stockArticleEntityMap.get(orderCode);
+
+			boolean chuanFlag = false;
+			String msg = "";
+			if("10".equals(tt)){//服务号
+				String serviceNumber = stockArticleEntity.getServiceNumber();
+				if(!finalFilterValue.equals(serviceNumber)){
+					chuanFlag = true;
+					msg = "服务号"+ finalFilterValue;
+				}
+			}else if("20".equals(tt)){//订单自编号
+				String oc = stockArticleEntity.getOrderCode();
+				if(!finalFilterValue.equals(oc)){
+					chuanFlag = true;
+					msg = "订单自编号"+ finalFilterValue;
+				}
+			}else if("30".equals(tt)){//商场
+				Long mallId = stockArticleEntity.getMallId();
+				String mallName = null;
+				if(!Objects.isNull(mallId)){
+					mallName = stockArticleEntity.getMallName();
+				}else{
+					String dealerName = stockArticleEntity.getDealerName();
+					String brand = stockArticleEntity.getBrand();
+					Long clientId = basicdataTripartiteMallClient.getClientIdByNameAndBrand(dealerName, brand);
+					if(!Objects.isNull(clientId)){
+						BasicdataClientEntity basicdataClientEntity = basicdataClientClient.findEntityById(clientId);
+						if(Objects.isNull(basicdataClientEntity)){
+							log.error("#############saveTrayTypeByOrderPackageCode: 未找到三方商场对应的汇通商场 clientId={}",clientId);
+							throw new CustomerException(405,"未找到三方商场对应的汇通商场");
+						}
+						mallName = basicdataClientEntity.getClientName();
+					}else{
+						mallName = dealerName;
+					}
+				}
+				if(!finalFilterValue.equals(mallName)){
+					chuanFlag = true;
+					msg = "商场"+ finalFilterValue;
+				}
+			}else if("40".equals(tt)){//门店
+				Long storeId = stockArticleEntity.getStoreId();
+				String storeName = stockArticleEntity.getStoreName();
+				if(!finalFilterValue.equals(storeName)){
+					chuanFlag = true;
+					msg = "门店"+ finalFilterValue;
+				}
+			}else if("50".equals(tt)){//客户
+				String customerName = stockArticleEntity.getCustomerName();
+				String customerTelephone = stockArticleEntity.getCustomerTelephone();
+				if(!finalFilterValue.equals(customerName+customerTelephone)){
+					chuanFlag = true;
+					msg = "客户"+ finalFilterValue;
+				}
+			}else if("60".equals(tt)){//仓库
+				String warehouse = null;
+				String waybillNumber = parcelListEntity.getWaybillNumber();
+				if(StringUtil.isBlank(waybillNumber)){
+					//如果运单为空则去找有没有对应的dealName是否有对应的维护的商场信息
+					String brand = stockArticleEntity.getBrand();
+					String dealerName = parcelListEntity.getDealerName();
+					Long clientId = basicdataTripartiteMallClient.getClientIdByNameAndBrand(dealerName, brand);
+					if(!Objects.isNull(clientId)){
+						BasicdataStorageServicesEntity storageServicesEntity = basicdataStorageServicesClient.findEntityBySendWarehouseIdAndClientId(warehouseId, clientId);
+						if(!Objects.isNull(storageServicesEntity)){
+							warehouse = storageServicesEntity.getServeWarehouseName();
+						}else{
+							warehouse = "";
+						}
+					}else{
+						warehouse = "";
+					}
+				}else{
+					WarehouseWaybillEntity waybillEntity = warehouseWaybillService.findByWaybillNo(waybillNumber);
+					if(!Objects.isNull(waybillEntity)){
+						warehouse = waybillEntity.getDestinationWarehouseName();
+					}else{
+						warehouse = "";
+					}
+				}
+				if(!finalFilterValue.equals(warehouse)){
+					chuanFlag = true;
+					msg = "仓库"+ finalFilterValue;
+				}
+			}
+			orderPackageChuanMap.put(orderPackageCode,chuanFlag?1:0);
+
+		});
+
+		List<WarehouseTrayGoodsEntity> trayGoodsEntities = new ArrayList<>();
+		List<WarehouseTrayGoodsLogEntity> trayGoodsLogEntities = new ArrayList<>();
+
+		parcelListEntityList.forEach(parcelListEntity -> {
+			String orderPackageCode = parcelListEntity.getOrderPackageCode();
+			Integer chuanFlag = orderPackageChuanMap.get(orderPackageCode);
+			if(Objects.isNull(chuanFlag)){
+				chuanFlag = 1;
+			}
+
+			Date date = new Date();
+			WarehouseTrayGoodsEntity trayGoodsEntity = new WarehouseTrayGoodsEntity();
+			BladeUser user = AuthUtil.getUser();
+			if(user==null){
+				trayGoodsEntity.setTenantId(TenantNum.HUITONGCODE);
+				trayGoodsEntity.setCreateUser(1714696768639311873L);
+				trayGoodsEntity.setUpdateUser(1714696768639311873L);
+				trayGoodsEntity.setCreateDept(1649331096241836033L);
+			}
+
+			trayGoodsEntity.setTrayId(trayTypeEntity.getTrayId());
+			trayGoodsEntity.setTrayTypeId(trayTypeEntity.getId());
+			trayGoodsEntity.setTrayCode(trayTypeEntity.getTrayCode());
+			trayGoodsEntity.setGoodsType(1);
+			trayGoodsEntity.setAssociationId(parcelListEntity.getId());
+			trayGoodsEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+			trayGoodsEntity.setAssociationType("3");
+			trayGoodsEntity.setGoodsName(parcelListEntity.getMaterialName());
+			trayGoodsEntity.setNum(1);
+			if(chuanFlag.equals(1)){
+				trayGoodsEntity.setIsFleeing("1");
+			}else{
+				trayGoodsEntity.setIsFleeing("0");
+			}
+			trayGoodsEntity.setWarehouseId(trayTypeEntity.getWarehouseId());
+			trayGoodsEntities.add(trayGoodsEntity);
+
+			WarehouseTrayGoodsLogEntity trayGoodsLogEntity = new WarehouseTrayGoodsLogEntity();
+			if(user==null){
+				trayGoodsLogEntity.setTenantId(TenantNum.HUITONGCODE);
+				trayGoodsLogEntity.setCreateUser(1714696768639311873L);
+				trayGoodsLogEntity.setUpdateUser(1714696768639311873L);
+				trayGoodsLogEntity.setCreateDept(1649331096241836033L);
+			}
+			trayGoodsLogEntity.setTrayId(trayTypeEntity.getTrayId());
+			trayGoodsLogEntity.setTrayTypeId(trayTypeEntity.getId());
+			trayGoodsLogEntity.setAssociationId(parcelListEntity.getId());
+			trayGoodsLogEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+			trayGoodsLogEntity.setAssociationType("3");
+			trayGoodsLogEntity.setBindingType("1");
+			trayGoodsLogEntity.setRemark(remark);
+			trayGoodsLogEntity.setPalletizingType("1");
+			trayGoodsLogEntity.setNum(1);
+			trayGoodsLogEntity.setWarehouseId(trayTypeEntity.getWarehouseId());
+			trayGoodsLogEntities.add(trayGoodsLogEntity);
+		});
+
+		warehouseTrayGoodsService.saveBatch(trayGoodsEntities);
+		warehouseTrayGoodsLogService.saveBatch(trayGoodsLogEntities);
+
+		//更新打托方式上的值
+		updateNumByTrayTypeId(trayTypeEntity);
+
+	}
+
+
+
 	@Override
 	public R orderScanOrderPackageCodeSync(String trayType, String trayCode, String orderPackageCode,Long warehouseId) {
 
@@ -2150,6 +2339,113 @@ public class WarehouseTrayTypeServiceImpl extends BaseServiceImpl<WarehouseTrayT
 		}
 	}
 
+
+	@Transactional(rollbackFor = Exception.class)
+	@Override
+	public void downPackageByOrderPackageCodeList(List<String> orderPackageCodeList,String remark,Long warehouseId) {
+
+//		List<DistributionParcelListEntity> distributionParcelListEntities = distributionParcelListClient.findListByOrderPackageCodeList(orderPackageCodeList,warehouseId);
+//		//把distributionParcelListEntities转化成orderPackageCode为key的Map
+//		Map<String, DistributionParcelListEntity> orderPackageCodeToParcelMap = distributionParcelListEntities.stream()
+//			.collect(Collectors.toMap(DistributionParcelListEntity::getOrderPackageCode, Function.identity(), (entity1, entity2) -> entity1));
+
+		QueryWrapper<WarehouseTrayGoodsEntity> trayGoodsQueryWrapper = new QueryWrapper<>();
+		trayGoodsQueryWrapper.eq("association_type","3")
+			.in("association_value",orderPackageCodeList);
+		List<WarehouseTrayGoodsEntity> trayGoodsEntityList = warehouseTrayGoodsService.list(trayGoodsQueryWrapper);
+
+		//把trayGoodsEntityList通过trayTypeId进行分组
+		Map<Long, List<WarehouseTrayGoodsEntity>> trayTypeIdToTrayGoodsListMap = trayGoodsEntityList.stream()
+			.collect(Collectors.groupingBy(WarehouseTrayGoodsEntity::getTrayTypeId));
+
+		Set<Long> trayTypeIds = trayTypeIdToTrayGoodsListMap.keySet();
+		List<WarehouseTrayTypeEntity> warehouseTrayTypeEntities = baseMapper.selectBatchIds(trayTypeIds);
+
+		Map<Long, WarehouseTrayTypeEntity> trayTypeMap = warehouseTrayTypeEntities.stream()
+			.collect(Collectors.toMap(WarehouseTrayTypeEntity::getId, Function.identity(), (entity1, entity2) -> entity1));
+
+		List<Long> toNullTrayTypeIds = new ArrayList<>();
+		List<Long> updateTrayTypeIds = new ArrayList<>();
+		List<Long> updateTrayIds = new ArrayList<>();
+		List<WarehouseTrayGoodsLogEntity> addTrayGoodsLogEntities = new ArrayList<>();
+
+		trayTypeIdToTrayGoodsListMap.keySet().forEach(trayTypeId -> {
+			List<WarehouseTrayGoodsEntity> warehouseTrayGoodsEntities = trayTypeIdToTrayGoodsListMap.get(trayTypeId);
+			if(!warehouseTrayGoodsEntities.isEmpty()){
+				WarehouseTrayTypeEntity trayTypeEntity = trayTypeMap.get(trayTypeId);
+				Long trayId = trayTypeEntity.getTrayId();
+
+				warehouseTrayGoodsEntities.forEach(warehouseTrayGoodsEntity -> {
+					WarehouseTrayGoodsLogEntity trayGoodsLogEntity = new WarehouseTrayGoodsLogEntity();
+					trayGoodsLogEntity.setTrayId(warehouseTrayGoodsEntity.getTrayId());
+					trayGoodsLogEntity.setTrayTypeId(trayTypeId);
+					trayGoodsLogEntity.setAssociationId(warehouseTrayGoodsEntity.getAssociationId());
+					trayGoodsLogEntity.setAssociationValue(warehouseTrayGoodsEntity.getAssociationValue());
+					trayGoodsLogEntity.setAssociationType("3");
+					trayGoodsLogEntity.setBindingType("0");
+					trayGoodsLogEntity.setRemark(remark);
+					trayGoodsLogEntity.setPalletizingType("1");
+					trayGoodsLogEntity.setNum(1);
+					trayGoodsLogEntity.setWarehouseId(warehouseId);
+					addTrayGoodsLogEntities.add(trayGoodsLogEntity);
+				});
+
+				List<Long> trayGoodsIds = warehouseTrayGoodsEntities.stream()
+					.map(WarehouseTrayGoodsEntity::getId)
+					.collect(Collectors.toList());
+				Integer residueNum = warehouseTrayGoodsService.deleteByTrayGoodsIds(trayGoodsIds, trayTypeId, warehouseId);
+				if(residueNum == 0){
+					//空置托盘
+					toNullTrayTypeIds.add(trayTypeId);
+					//更新托盘状态
+					updateTrayIds.add(trayId);
+				}else{
+					updateTrayTypeIds.add(trayTypeId);
+				}
+			}
+		});
+
+		//空置的托盘打托id
+		removeByIds(toNullTrayTypeIds);
+		//更新托盘状态
+		basicdataTrayClient.updateTrayStatusByTrayIds(updateTrayIds,1);
+		//添加下托日志
+		warehouseTrayGoodsLogService.saveBatch(addTrayGoodsLogEntities);
+		updateTrayTypeIds.forEach(trayTypeId -> {
+			WarehouseTrayTypeEntity trayTypeEntity = trayTypeMap.get(trayTypeId);
+			if(!Objects.isNull(trayTypeEntity)){
+				updateNumByTrayTypeId(trayTypeEntity);
+			}
+		});
+
+//		if (!Objects.isNull(trayGoodsEntity)){
+//			Long trayGoodsId = trayGoodsEntity.getId();
+//			Long trayTypeId = trayGoodsEntity.getTrayTypeId();
+//			Long trayId = trayGoodsEntity.getTrayId();
+//			WarehouseTrayTypeEntity trayTypeEntity = baseMapper.selectById(trayTypeId);
+//			//解除绑定
+//			Integer residueNum = warehouseTrayGoodsService.deleteByTrayGoodsId(trayGoodsId,warehouseId);
+//
+//			if(residueNum == 0){
+//				//空置托盘
+//				removeById(trayTypeId);
+//				//更新托盘状态
+//				basicdataTrayClient.updateTrayStatus(trayId,1);
+//			}
+//
+//			//添加下托日志
+//			warehouseTrayGoodsLogService.saveLogPackage(parcelListEntity,trayTypeEntity,"0",remark,"1");
+//
+//			updateNumByTrayTypeId(trayTypeEntity);
+//		}else {
+//			stringBuffer.append(orderPackageCode);
+//		}
+//		if (Func.isNotEmpty(stringBuffer)){
+//			log.error("托盘商品不存在,trayId：{}",stringBuffer.toString());
+//		}
+	}
+
+
 	@Override
 	public void updateEntityNumByTrayGoodsIdAndNumStock(Long trayGoodsId, Integer enterNum,String remark) {
 		WarehouseTrayGoodsEntity trayGoodsEntity = warehouseTrayGoodsService.getById(trayGoodsId);

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownGoodsServiceImpl.java

@@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.warehouse.entity.WarehouseUpdownGoodsEntity;
+import com.logpm.warehouse.entity.WarehouseUpdownGoodsLogEntity;
 import com.logpm.warehouse.entity.WarehouseUpdownTypeEntity;
 import com.logpm.warehouse.excel.WarehouseUpdownGoodsExcel;
 import com.logpm.warehouse.mapper.WarehouseUpdownGoodsMapper;
@@ -124,6 +125,65 @@ public class WarehouseUpdownGoodsServiceImpl extends BaseServiceImpl<WarehouseUp
 		warehouseUpdownGoodsLogService.saveAllocationAndPackage(updownTypeEntity,parcelListEntity,bindingType,isAlltrays,remark);
 	}
 
+	@Override
+	public void bindingAllocationAndPackageList(WarehouseUpdownTypeEntity updownTypeEntity, List<DistributionParcelListEntity> parcelListEntities, String bindingType,Integer isAlltrays,String remark) {
+		List<WarehouseUpdownGoodsEntity> updownGoodsEntities = new ArrayList<>();
+		List<WarehouseUpdownGoodsLogEntity> updownGoodsLogEntities = new ArrayList<>();
+		parcelListEntities.forEach(parcelListEntity -> {
+			WarehouseUpdownGoodsEntity updownGoodsEntity = new WarehouseUpdownGoodsEntity();
+			updownGoodsEntity.setCreateUser(1714696768639311873L);
+			updownGoodsEntity.setUpdateUser(1714696768639311873L);
+			updownGoodsEntity.setCreateDept(1649331096241836033L);
+			updownGoodsEntity.setTenantId(TenantNum.HUITONGCODE);
+			updownGoodsEntity.setUpdownTypeId(updownTypeEntity.getId());
+			updownGoodsEntity.setAreaId(updownTypeEntity.getAreaId());
+			updownGoodsEntity.setAreaTitle(updownTypeEntity.getAreaTitle());
+			updownGoodsEntity.setShelfId(updownTypeEntity.getShelfId());
+			updownGoodsEntity.setShelfTitle(updownTypeEntity.getShelfTitle());
+			updownGoodsEntity.setAllocationId(updownTypeEntity.getAllocationId());
+			updownGoodsEntity.setAllocationTitle(updownTypeEntity.getAllocationTitle());
+			updownGoodsEntity.setPositionCode(updownTypeEntity.getPositionCode());
+			updownGoodsEntity.setAssociationId(parcelListEntity.getId());
+			updownGoodsEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+			updownGoodsEntity.setAssociationType("3");//包件
+			updownGoodsEntity.setNum(1);
+			updownGoodsEntity.setWarehouseId(updownTypeEntity.getWarehouseId());
+			updownGoodsEntities.add(updownGoodsEntity);
+
+			WarehouseUpdownGoodsLogEntity warehouseUpdownGoodsLogEntity = new WarehouseUpdownGoodsLogEntity();
+			warehouseUpdownGoodsLogEntity.setCreateUser(1714696768639311873L);
+			warehouseUpdownGoodsLogEntity.setUpdateUser(1714696768639311873L);
+			warehouseUpdownGoodsLogEntity.setCreateDept(1649331096241836033L);
+			warehouseUpdownGoodsLogEntity.setTenantId(TenantNum.HUITONGCODE);
+			warehouseUpdownGoodsLogEntity.setUpdownTypeId(updownTypeEntity.getId());
+			warehouseUpdownGoodsLogEntity.setAreaId(updownTypeEntity.getAreaId());
+			warehouseUpdownGoodsLogEntity.setAreaTitle(updownTypeEntity.getAreaTitle());
+			warehouseUpdownGoodsLogEntity.setShelfId(updownTypeEntity.getShelfId());
+			warehouseUpdownGoodsLogEntity.setShelfTitle(updownTypeEntity.getShelfTitle());
+			warehouseUpdownGoodsLogEntity.setAllocationId(updownTypeEntity.getAllocationId());
+			warehouseUpdownGoodsLogEntity.setAllocationTitle(updownTypeEntity.getAllocationTitle());
+			warehouseUpdownGoodsLogEntity.setPositionCode(updownTypeEntity.getPositionCode());
+			warehouseUpdownGoodsLogEntity.setBindingType(bindingType);
+			warehouseUpdownGoodsLogEntity.setIsAlltrays(isAlltrays);
+			warehouseUpdownGoodsLogEntity.setAssociationId(parcelListEntity.getId());
+			warehouseUpdownGoodsLogEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+			warehouseUpdownGoodsLogEntity.setAssociationType("3");
+			warehouseUpdownGoodsLogEntity.setNum(1);
+			warehouseUpdownGoodsLogEntity.setRemark(remark);
+			warehouseUpdownGoodsLogEntity.setWarehouseId(updownTypeEntity.getWarehouseId());
+			updownGoodsLogEntities.add(warehouseUpdownGoodsLogEntity);
+
+
+			parcelListEntity.setOrderPackageGroundingStatus("20");
+
+		});
+
+		saveBatch(updownGoodsEntities);
+		warehouseUpdownGoodsLogService.saveBatch(updownGoodsLogEntities);
+	}
+
+
+
 	@Override
 	public Map<String, Integer> getTotalNumberAndNum(Long updownTypeId) {
 		return baseMapper.getTotalNumberAndNum(updownTypeId);
@@ -173,6 +233,15 @@ public class WarehouseUpdownGoodsServiceImpl extends BaseServiceImpl<WarehouseUp
 		return updownGoodsEntities.size();
 	}
 
+	@Override
+	public Integer deleteByUpdownGoodsIds(List<Long> updownGoodsIds,Long updownTypeId) {
+		baseMapper.deleteByUpdownGoodsIds(updownGoodsIds);
+		QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("updown_type_id",updownTypeId);
+		List<WarehouseUpdownGoodsEntity> updownGoodsEntities = baseMapper.selectList(queryWrapper);
+		return updownGoodsEntities.size();
+	}
+
 	@Override
 	public void updeteNumByUpdownGoodsId(int num, Long updownGoodsId) {
 		baseMapper.updeteNumByUpdownGoodsId(num,updownGoodsId);
@@ -273,4 +342,9 @@ public class WarehouseUpdownGoodsServiceImpl extends BaseServiceImpl<WarehouseUp
 		return baseMapper.getAllocationsByWarehouseIdAndMarketIdAndSku(mallId,sku,warehouseId);
 	}
 
+	@Override
+	public List<String> findOrderPackageCodesByOrderPackageCodeList(List<String> orderPackageCodeList, Long warehouseId) {
+		return baseMapper.findOrderPackageCodesByOrderPackageCodeList(orderPackageCodeList,warehouseId);
+	}
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java

@@ -32,6 +32,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.*;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 @Log4j2
@@ -828,19 +829,18 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 	public R upShelfOrder(List<UpShelfOrderDTO> upShelfOrderList, Long allocationId, Long warehouseId, String remrk) {
 		int num = 0;
 		String trayCode = null;
+		WarehouseTrayTypeEntity trayTypeEntity = null;
 		//判断货位是否有托盘
 		BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
 		String trayType = null;
 		if (!Objects.isNull(trayEntity)) {
 			trayCode = trayEntity.getPalletCode();
-			//如果有托盘
+			QueryWrapper<WarehouseTrayTypeEntity> queryWrapper = new QueryWrapper<>();
-			TrayTypeDataVO entityByTrayCode = warehouseTrayTypeService.getEntityByTrayCodeWithUpdown(trayCode);
+			queryWrapper.eq("tray_code", trayCode)
-			trayType = entityByTrayCode.getTrayType();
+				.eq("is_deleted", 0);
-//			String type = entityByTrayCode.getType();//数据类型 1订制品 2零担 3 4 库存品
+			trayTypeEntity = warehouseTrayTypeService.getOne(queryWrapper);
-//			if(!"1".equals(type)){
+			trayType = trayTypeEntity.getTrayType();
-//				log.warn("##############upShelfOrder: 库位上的托盘是定制品类型 allocationId={}",allocationId);
+
-//				return R.fail(403,"库位上的托盘是定制品类型");
-//			}
 		}
 
 
@@ -877,46 +877,27 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			return R.fail(403, "库位不属于当前仓库");
 		}
 
+		//把upShelfOrderList中的orderCode提取到一个Set集合中
+		List<String> orderCodeList = upShelfOrderList.stream().map(UpShelfOrderDTO::getOrderCode).collect(Collectors.toList());
+		List<DistributionParcelListEntity> parcelListList = distributionParcelListClient.findALLNoUpShelfPackageByOrderCodeList(orderCodeList, warehouseId);
 
-		for (UpShelfOrderDTO upShelfOrderDTO : upShelfOrderList) {
+		List<UpShelfPackageDTO> upShelfPackageList = new ArrayList<>();
-			String orderCode = upShelfOrderDTO.getOrderCode();
-			if (StringUtil.isBlank(orderCode)) {
-				log.warn("##############upShelfOrder: 订单号不存在 orderCode={}", orderCode);
-				continue;
-			}
-			//查询所有该订单号未上架的数据
-			List<DistributionParcelListEntity> parcelListList = distributionParcelListClient.findALLNoUpShelfPackageByOrderCode(orderCode, warehouseId);
-			for (DistributionParcelListEntity parcelListEntity : parcelListList) {
-				try {
-					String orderPackageCode = parcelListEntity.getOrderPackageCode();
-					Integer quantity = parcelListEntity.getQuantity();
-
-					if (StringUtil.hasLength(trayCode)) {
 
-						//存入托盘信息
+		parcelListList.forEach(parcelListEntity -> {
-						warehouseTrayTypeService.orderScanOrderPackageCode(trayType, trayCode, orderPackageCode, warehouseId, remrk + "并上架");
+			UpShelfPackageDTO upShelfPackageDTO = new UpShelfPackageDTO();
-					}
+			upShelfPackageDTO.setOrderPackageCode(parcelListEntity.getOrderPackageCode());
-					//包件级别的上架
+			upShelfPackageList.add(upShelfPackageDTO);
-					upShelfPackageNoTray(parcelListEntity, goodsAllocationEntity, goodsShelfEntity, goodsAreaEntity, warehouseId, remrk);
+		});
 
-					num = num + quantity;
+		return upShelfPackage(upShelfPackageList, allocationId, warehouseId, remrk);
-				} catch (CustomerException e) {
-					log.warn(e.message);
-					continue;
-				} catch (Exception e) {
-					log.warn(e.getMessage());
-					continue;
-				}
-			}
-		}
-		return Resp.scanSuccess("上架成功", "成功上架" + num + "条");
 	}
 
+	@Transactional(rollbackFor = Exception.class)
 	@Override
 	public R upShelfPackage(List<UpShelfPackageDTO> upShelfPackageList, Long allocationId, Long warehouseId, String remark) {
 		int num = 0;
 		String trayCode = null;
-		String trayType = null;
+		WarehouseTrayTypeEntity trayTypeEntity = null;
 		//判断货位是否有托盘
 		BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
 		if (!Objects.isNull(trayEntity)) {
@@ -925,8 +906,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			QueryWrapper<WarehouseTrayTypeEntity> queryWrapper = new QueryWrapper<>();
 			queryWrapper.eq("tray_code", trayCode)
 				.eq("is_deleted", 0);
-			WarehouseTrayTypeEntity trayTypeEntity = warehouseTrayTypeService.getOne(queryWrapper);
+			trayTypeEntity = warehouseTrayTypeService.getOne(queryWrapper);
-			trayType = trayTypeEntity.getTrayType();
 //			String type = trayTypeEntity.getType();//数据类型 1订制品 2零担 3 4 库存品
 //			if(!"1".equals(type)){
 //				log.warn("##############upShelfOrder: 库位上的托盘是定制品类型 allocationId={}",allocationId);
@@ -973,60 +953,89 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			return R.fail(403, "库位不属于本仓库");
 		}
 
+		//把upShelfPackageList中所有orderPackageCode存入一个List<String>
+		List<String> orderPackageCodeList = upShelfPackageList.stream().map(UpShelfPackageDTO::getOrderPackageCode).collect(Collectors.toList());
+		log.info("##############upShelfPackage: 当前处理的包件码 orderPackageCodeList={}", orderPackageCodeList);
+		//判断包件是否已经上架
+		List<String> hasOrderPackageCodes = warehouseUpdownGoodsService.findOrderPackageCodesByOrderPackageCodeList(orderPackageCodeList, warehouseId);
+		orderPackageCodeList.removeAll(hasOrderPackageCodes);
 
-		for (UpShelfPackageDTO upShelfPackageDTO : upShelfPackageList) {
+		//判断包件是否有绑托盘，
-			String orderPackageCode = upShelfPackageDTO.getOrderPackageCode();
+		QueryWrapper<WarehouseTrayGoodsEntity> trayGoodsQueryWrapper = new QueryWrapper<>();
-			log.info("##############upShelfPackage: 当前处理的包件码 orderPackageCode={}", orderPackageCode);
+		trayGoodsQueryWrapper.in("association_value", orderPackageCodeList);
-			try {
+		List<WarehouseTrayGoodsEntity> trayGoodsEntityList = warehouseTrayGoodsService.list(trayGoodsQueryWrapper);
-				//判断包件是否已经上架
+		if(!trayGoodsEntityList.isEmpty()){
-				QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
+			//把trayGoodsEntityList中的association_value提取出来存入一个List<String>
-				queryWrapper.eq("association_value", orderPackageCode)
+			List<String> orderPackageCodes = trayGoodsEntityList.stream().map(WarehouseTrayGoodsEntity::getAssociationValue).collect(Collectors.toList());
-					.eq("warehouse_id", warehouseId);
+			warehouseTrayTypeService.downPackageByOrderPackageCodeList(orderPackageCodes,"同步处理:包件解托",warehouseId);
-				WarehouseUpdownGoodsEntity updownGoodsEntity = warehouseUpdownGoodsService.getOne(queryWrapper);
+		}
-				if (!Objects.isNull(updownGoodsEntity)) {
+		List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(orderPackageCodeList, warehouseId);
-					log.warn("##############upShelfPackage: 包件已上架 orderPackageCode={}", orderPackageCode);
+		//排除parcelListEntityList中元素orderPackageStatus 不等于20的
-					continue;
+		parcelListEntityList = parcelListEntityList.stream().filter(parcelListEntity -> "20".equals(parcelListEntity.getOrderPackageStatus())).collect(Collectors.toList());
-				}
-				//判断包件是否有绑托盘，
-				QueryWrapper<WarehouseTrayGoodsEntity> trayGoodsQueryWrapper = new QueryWrapper<>();
-				trayGoodsQueryWrapper.eq("association_value", orderPackageCode);
-				WarehouseTrayGoodsEntity trayGoodsEntity = warehouseTrayGoodsService.getOne(trayGoodsQueryWrapper);
-				if (!Objects.isNull(trayGoodsEntity)) {
-//					log.warn("##############upShelfPackage: 包件已打托 orderPackageCode={}",orderPackageCode);
-//					continue;
-					//已打托的数据需要取消托盘绑定
-					warehouseTrayTypeService.downPackageByOrderPackageCode(orderPackageCode, "扫描上架:包件下托", warehouseId);
-				}
 
-				DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+		if (StringUtil.hasLength(trayCode)) {
-				Integer conditions = parcelListEntity.getConditions();
+			//存入托盘信息
-				Integer quantity = parcelListEntity.getQuantity();
+			warehouseTrayTypeService.orderScanOrderPackageCodeList(trayTypeEntity, parcelListEntityList, warehouseId, remark + "并打托");
-				String orderPackageStatus = parcelListEntity.getOrderPackageStatus();
-				if (!"20".equals(orderPackageStatus)) {
-					log.warn("##############upShelfPackage: 包件已不在库 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId);
-					return Resp.scanFail(403, "包件已不在库", "包件已不在库");
-				}
-//				if(conditions != 1){
-//					log.warn("##############upShelfPackage: 包件已转库存品 orderPackageCode={}",orderPackageCode);
-//					continue;
-//				}
-				if (StringUtil.hasLength(trayCode)) {
-					//存入托盘信息
-					warehouseTrayTypeService.orderScanOrderPackageCode(trayType, trayCode, orderPackageCode, warehouseId, remark + "并打托");
-				}
-				//包件级别的上架
-				upShelfPackageNoTray(parcelListEntity, goodsAllocationEntity, goodsShelfEntity, goodsAreaEntity, warehouseId, remark);
-				num = num + quantity;
-			} catch (CustomerException e) {
-				log.warn(e.message);
-				continue;
-			} catch (Exception e) {
-				log.warn(e.getMessage());
-				continue;
-			}
 		}
+		//包件级别的上架
+		upShelfPackageListNoTray(parcelListEntityList, goodsAllocationEntity, goodsShelfEntity, goodsAreaEntity, warehouseId, remark);
+		num = num + parcelListEntityList.size();
+
 		//更新货位缓存
 		warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
+
+//		for (UpShelfPackageDTO upShelfPackageDTO : upShelfPackageList) {
+//			String orderPackageCode = upShelfPackageDTO.getOrderPackageCode();
+//			log.info("##############upShelfPackage: 当前处理的包件码 orderPackageCode={}", orderPackageCode);
+//			try {
+//				//判断包件是否已经上架
+//				QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
+//				queryWrapper.eq("association_value", orderPackageCode)
+//					.eq("warehouse_id", warehouseId);
+//				WarehouseUpdownGoodsEntity updownGoodsEntity = warehouseUpdownGoodsService.getOne(queryWrapper);
+//				if (!Objects.isNull(updownGoodsEntity)) {
+//					log.warn("##############upShelfPackage: 包件已上架 orderPackageCode={}", orderPackageCode);
+//					continue;
+//				}
+//				//判断包件是否有绑托盘，
+//				QueryWrapper<WarehouseTrayGoodsEntity> trayGoodsQueryWrapper = new QueryWrapper<>();
+//				trayGoodsQueryWrapper.eq("association_value", orderPackageCode);
+//				WarehouseTrayGoodsEntity trayGoodsEntity = warehouseTrayGoodsService.getOne(trayGoodsQueryWrapper);
+//				if (!Objects.isNull(trayGoodsEntity)) {
+////					log.warn("##############upShelfPackage: 包件已打托 orderPackageCode={}",orderPackageCode);
+////					continue;
+//					//已打托的数据需要取消托盘绑定
+//					warehouseTrayTypeService.downPackageByOrderPackageCode(orderPackageCode, "扫描上架:包件下托", warehouseId);
+//				}
+//
+//				DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+//				Integer conditions = parcelListEntity.getConditions();
+//				Integer quantity = parcelListEntity.getQuantity();
+//				String orderPackageStatus = parcelListEntity.getOrderPackageStatus();
+//				if (!"20".equals(orderPackageStatus)) {
+//					log.warn("##############upShelfPackage: 包件已不在库 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId);
+//					return Resp.scanFail(403, "包件已不在库", "包件已不在库");
+//				}
+////				if(conditions != 1){
+////					log.warn("##############upShelfPackage: 包件已转库存品 orderPackageCode={}",orderPackageCode);
+////					continue;
+////				}
+//				if (StringUtil.hasLength(trayCode)) {
+//					//存入托盘信息
+//					warehouseTrayTypeService.orderScanOrderPackageCodeList(trayTypeEntity, orderPackageCodeList, warehouseId, remark + "并打托");
+//				}
+//				//包件级别的上架
+//				upShelfPackageNoTray(parcelListEntity, goodsAllocationEntity, goodsShelfEntity, goodsAreaEntity, warehouseId, remark);
+//				num = num + quantity;
+//			} catch (CustomerException e) {
+//				log.warn(e.message);
+//				continue;
+//			} catch (Exception e) {
+//				log.warn(e.getMessage());
+//				continue;
+//			}
+//		}
+
 		return Resp.scanSuccess("上架成功", "成功上架" + num + "条");
 	}
 
@@ -1405,58 +1414,133 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 	@Override
 	public R downPackage(List<UpShelfPackageDTO> upShelfPackageList, Long warehouseId, String remark) {
 		int num = 0;
-		Set<String> orderSet = new TreeSet<>();
+		Set<String> orderSet = new HashSet<>();
-		for (UpShelfPackageDTO upShelfPackageDTO : upShelfPackageList) {
+
-			String orderPackageCode = upShelfPackageDTO.getOrderPackageCode();
+		//把upShelfPackageList中的orderPackageCde提取到List中
-			//查询包件在哪个库位上
+		List<String> orderPackageCodeList = upShelfPackageList.stream().map(UpShelfPackageDTO::getOrderPackageCode).collect(Collectors.toList());
-			QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
+		QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
-			queryWrapper.eq("association_type", "3")
+		queryWrapper.eq("association_type", "3")
-				.eq("warehouse_id", warehouseId)
+			.eq("warehouse_id", warehouseId)
-				.eq("association_value", orderPackageCode);
+			.in("association_value", orderPackageCodeList);
-			WarehouseUpdownGoodsEntity updownGoodsEntity = warehouseUpdownGoodsService.getOne(queryWrapper);
+		List<WarehouseUpdownGoodsEntity> updownGoodsEntities = warehouseUpdownGoodsService.list(queryWrapper);
-			if (Objects.isNull(updownGoodsEntity)) {
+
-				log.warn("##############downPackage: 包件没有上架记录 orderPackageCode={}", orderPackageCode);
+		//把updownGoodsEntities的association_value提取到一个List中
-				continue;
+		List<String> associationValueList = updownGoodsEntities.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
-			}
+
-			Long allocationId = updownGoodsEntity.getAllocationId();
+		List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(associationValueList, warehouseId);
-			DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+		//把parcelListEntityList转化成orderPackageCode为key的Map
-			Integer quantity = parcelListEntity.getQuantity();
+		Map<String, DistributionParcelListEntity> parcelListEntityMap = parcelListEntityList.stream().collect(Collectors.toMap(DistributionParcelListEntity::getOrderPackageCode, Function.identity()));
-			String orderCode = parcelListEntity.getOrderCode();
+
-			Long updownGoodsId = updownGoodsEntity.getId();
+		//把updownGoodsEntities通过allocatiionId进行分组
-			Long updownTypeId = updownGoodsEntity.getUpdownTypeId();
+		Map<Long, List<WarehouseUpdownGoodsEntity>> map = updownGoodsEntities.stream().collect(Collectors.groupingBy(WarehouseUpdownGoodsEntity::getAllocationId));
-			WarehouseUpdownTypeEntity updownTypeEntity = baseMapper.selectById(updownTypeId);
+
+		List<Long> allocationIds = new ArrayList<>(map.keySet());
+
+		QueryWrapper<WarehouseUpdownTypeEntity> updownTypeEntityQueryWrapper = new QueryWrapper<>();
+		updownTypeEntityQueryWrapper.in("allocation_id", allocationIds)
+			.eq("is_deleted", 0);
+		List<WarehouseUpdownTypeEntity> updownTypeList = list(updownTypeEntityQueryWrapper);
+		//把updownTypeList转化成allocationId为key的Map
+		Map<Long, WarehouseUpdownTypeEntity> updownTypeMap = updownTypeList.stream().collect(Collectors.toMap(WarehouseUpdownTypeEntity::getAllocationId, Function.identity()));
+
+		List<Long> toNullUpdownTypeIds = new ArrayList<>();
+		List<Long> updateAllocationIds = new ArrayList<>();
+		List<WarehouseTaryAllocationEntity> deleteTrayAllocationList = new ArrayList<>();
+		List<WarehouseUpdownTypeEntity> updateUpdownTypeList = new ArrayList<>();
+		List<WarehouseUpdownGoodsLogEntity> updownGoodsLogEntities = new ArrayList<>();
+		List<DistributionParcelListEntity> updownParcelEntities = new ArrayList<>();
+
+		map.keySet().forEach(allocationId -> {
 			QueryWrapper<WarehouseTaryAllocationEntity> taryAllocationEntityQueryWrapper = new QueryWrapper<>();
 			taryAllocationEntityQueryWrapper.eq("allocation_id", allocationId)
 				.eq("is_deleted", 0);
 			WarehouseTaryAllocationEntity taryAllocationEntity = warehouseTaryAllocationService.getOne(taryAllocationEntityQueryWrapper);
-//			BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
+			List<WarehouseUpdownGoodsEntity> updownGoodsEntities1 = map.get(allocationId);
-			if (!Objects.isNull(taryAllocationEntity)) {
+			List<String> orderPackageCodes = updownGoodsEntities1.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
-				//有托盘，托盘下托
+			if(!Objects.isNull(taryAllocationEntity)){
-				warehouseTrayTypeService.downPackageByOrderPackageCode(orderPackageCode, remark + ":同步下托", warehouseId);
+				warehouseTrayTypeService.downPackageByOrderPackageCodeList(orderPackageCodes, remark, warehouseId);
 			}
-			Integer residue = warehouseUpdownGoodsService.deleteByUpdownGoodsId(updownGoodsId);
+			WarehouseUpdownTypeEntity updownTypeEntity = updownTypeMap.get(allocationId);
+			Long updownTypeId = updownTypeEntity.getId();
+			//把updownGoodsEntities1的id提取到List中
+			List<Long> updownGoodsIds = updownGoodsEntities1.stream().map(WarehouseUpdownGoodsEntity::getId).collect(Collectors.toList());
+
+			Integer residue = warehouseUpdownGoodsService.deleteByUpdownGoodsIds(updownGoodsIds, updownTypeEntity.getId());
 			if (residue == 0) {
 				//删除上架方式
-				removeById(updownTypeId);
+				toNullUpdownTypeIds.add(updownTypeId);
 				//修改库位状态为空闲
-				basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
+				updateAllocationIds.add(allocationId);
+//				basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
 				//如果有托盘还要删除托盘与库位的绑定
 				if (!Objects.isNull(taryAllocationEntity)) {
-					warehouseTaryAllocationService.deleteById(taryAllocationEntity);
+					deleteTrayAllocationList.add(taryAllocationEntity);
+//					warehouseTaryAllocationService.deleteById(taryAllocationEntity);
 				}
+			}else{
+				updateUpdownTypeList.add(updownTypeEntity);
 			}
-			warehouseUpdownGoodsLogService.saveAllocationAndPackage(updownTypeEntity, parcelListEntity, "2", 0, remark + ":包件下架");
+
-			updatePackageGroundingStatus(orderPackageCode, "10", warehouseId);
+			List<DistributionParcelListEntity> parcelListEntities = new ArrayList<>();
-			updateUpdownTypeNum(updownTypeEntity);
+			orderPackageCodes.forEach(orderPackageCode -> {
-			orderSet.add(orderCode);
+				DistributionParcelListEntity parcelListEntity = parcelListEntityMap.get(orderPackageCode);
-			num = num + quantity;
+				if(!Objects.isNull(parcelListEntity)){
+					parcelListEntities.add(parcelListEntity);
+				}
+			});
+
+			parcelListEntities.forEach(parcelListEntity -> {
+				orderSet.add(parcelListEntity.getOrderCode());
+				WarehouseUpdownGoodsLogEntity warehouseUpdownGoodsLogEntity = new WarehouseUpdownGoodsLogEntity();
+				warehouseUpdownGoodsLogEntity.setCreateUser(1714696768639311873L);
+				warehouseUpdownGoodsLogEntity.setUpdateUser(1714696768639311873L);
+				warehouseUpdownGoodsLogEntity.setCreateDept(1649331096241836033L);
+				warehouseUpdownGoodsLogEntity.setTenantId(TenantNum.HUITONGCODE);
+				warehouseUpdownGoodsLogEntity.setUpdownTypeId(updownTypeEntity.getId());
+				warehouseUpdownGoodsLogEntity.setAreaId(updownTypeEntity.getAreaId());
+				warehouseUpdownGoodsLogEntity.setAreaTitle(updownTypeEntity.getAreaTitle());
+				warehouseUpdownGoodsLogEntity.setShelfId(updownTypeEntity.getShelfId());
+				warehouseUpdownGoodsLogEntity.setShelfTitle(updownTypeEntity.getShelfTitle());
+				warehouseUpdownGoodsLogEntity.setAllocationId(updownTypeEntity.getAllocationId());
+				warehouseUpdownGoodsLogEntity.setAllocationTitle(updownTypeEntity.getAllocationTitle());
+				warehouseUpdownGoodsLogEntity.setPositionCode(updownTypeEntity.getPositionCode());
+				warehouseUpdownGoodsLogEntity.setBindingType("2");
+				warehouseUpdownGoodsLogEntity.setIsAlltrays(0);
+				warehouseUpdownGoodsLogEntity.setAssociationId(parcelListEntity.getId());
+				warehouseUpdownGoodsLogEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+				warehouseUpdownGoodsLogEntity.setAssociationType("3");
+				warehouseUpdownGoodsLogEntity.setNum(1);
+				warehouseUpdownGoodsLogEntity.setRemark(remark);
+				warehouseUpdownGoodsLogEntity.setWarehouseId(updownTypeEntity.getWarehouseId());
+				updownGoodsLogEntities.add(warehouseUpdownGoodsLogEntity);
+
+				parcelListEntity.setOrderPackageGroundingStatus("10");
+
+			});
+
+			updownParcelEntities.addAll(parcelListEntities);
+
+		});
+
+		removeByIds(toNullUpdownTypeIds);
+		basicdataGoodsAllocationClient.updateListAllocationStatus(updateAllocationIds,"1");
+		warehouseTaryAllocationService.removeBatchByIds(deleteTrayAllocationList);
+
+		updateUpdownTypeList.forEach(this::updateUpdownTypeNum);
+
+		warehouseUpdownGoodsLogService.saveBatch(updownGoodsLogEntities);
+
+		distributionParcelListClient.updateList(updownParcelEntities);
+
+		map.keySet().forEach(allocationId -> {
 			warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
-		}
+		});
 
 		for (String orderCode : orderSet) {
 			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
 		}
 
+		num = num + updownParcelEntities.size();
 
 		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
 	}
@@ -2961,6 +3045,37 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 
 	}
 
+
+	private void upShelfPackageListNoTray(List<DistributionParcelListEntity> parcelListEntities, BasicdataGoodsAllocationEntity goodsAllocationEntity, BasicdataGoodsShelfEntity goodsShelfEntity, BasicdataGoodsAreaEntity goodsAreaEntity, Long warehouseId, String remrk) {
+		log.info("###########upShelfPackageNoTray: 上架包件没有托盘 parcelListEntities={} allocationCode={}", parcelListEntities, goodsAllocationEntity.getGoodsAllocationName());
+		//修改上架方式的数量
+
+		QueryWrapper<WarehouseUpdownTypeEntity> updownTypeEntityQueryWrapper = new QueryWrapper<>();
+		updownTypeEntityQueryWrapper.eq("allocation_id", goodsAllocationEntity.getId())
+			.eq("is_deleted", 0);
+		WarehouseUpdownTypeEntity updownTypeEntity = baseMapper.selectOne(updownTypeEntityQueryWrapper);
+		if (Objects.isNull(updownTypeEntity)) {
+			updownTypeEntity = createUpdownType("1", goodsAllocationEntity, goodsShelfEntity, goodsAreaEntity, warehouseId);
+		}
+
+		Long wid = updownTypeEntity.getWarehouseId();
+		if (!wid.equals(warehouseId)) {
+			log.warn("##############upShelfPackageNoTray: 库位不在当前仓库 wid={}", wid);
+			throw new CustomerException(403, "库位不在当前仓库");
+		}
+
+		//货物和库位绑定
+		warehouseUpdownGoodsService.bindingAllocationAndPackageList(updownTypeEntity, parcelListEntities, "1", 0, remrk);
+
+		distributionParcelListClient.updateList(parcelListEntities);
+
+		//修改上架方式上的数据
+		updateUpdownTypeNum(updownTypeEntity);
+
+	}
+
+
+
 	private void updateUpdownTypeNum(WarehouseUpdownTypeEntity updownTypeEntity) {
 		Long updownTypeId = updownTypeEntity.getId();
 		Long warehouseId = updownTypeEntity.getWarehouseId();