From 7aea6680aaeea2737832e19d71365da61ac31551 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Wed, 23 Oct 2024 00:14:39 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BF=E8=BF=90=E5=8D=95bug?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8D=202.=E8=A1=A5=E4=B8=81=E6=96=B0=E5=A2=9E?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E5=8C=85=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../feign/DistributionParcelListClient.java   |  6 +++--
 .../mapper/DistributionParcelListMapper.xml   | 10 +++----
 .../DistributionParcelListServiceImpl.java    |  1 +
 .../jobhandle/SyncOrderInfoToPlatform.java    | 27 +++++++++++++++++++
 .../mapper/WarehouseMappingDataMapper.java    |  2 ++
 .../mapper/WarehouseMappingDataMapper.xml     | 17 ++++++++++++
 .../patch/service/ISyncOrderInfoService.java  |  2 ++
 .../service/IWarehouseMappingDataService.java |  2 ++
 .../impl/SyncOrderInfoServiceImpl.java        | 16 +++++++++++
 .../impl/WarehouseMappingDataServiceImpl.java |  6 +++++
 10 files changed, 82 insertions(+), 7 deletions(-)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java
index aa4887bae..8813a6255 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java
@@ -386,9 +386,11 @@ public class DistributionParcelListClient implements IDistributionParcelListClie
 		distributionParcelListService.updatePackageStatus(orderPackageCodes, warehouseId, packageStatus);
 
 
-		List<DistributionParcelListEntity> list = distributionParcelListService.findListByOrderPackageCode(orderPackageCodes, warehouseId);
+//		List<DistributionParcelListEntity> list = distributionParcelListService.findListByOrderPackageCode(orderPackageCodes, warehouseId);
+		List<String> orderCodesByOrderPackageCodes = distributionParcelListService.findOrderCodesByOrderPackageCodes(orderPackageCodes, warehouseId);
+
 		//把list中的orderCode放入一个set
-		Set<String> orderCodeSet = list.stream().map(DistributionParcelListEntity::getOrderCode).collect(Collectors.toSet());
+		Set<String> orderCodeSet = new HashSet<>(orderCodesByOrderPackageCodes);
 		orderCodeSet.forEach(orderCode -> {
 			distributionStockArticleService.updateOrderInfo(orderCode, warehouseId);
 		});
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml
index 924c6d43e..07ee36790 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml
@@ -1701,9 +1701,7 @@
 
     <update id="updatePackageStatus">
         update logpm_distribution_parcel_list ldpl
-        set ldpl.order_package_status = #{packageStatus}
-        where exists(
-        select 1 from (
+        join (
         <foreach collection="orderPackageCodes" index="ind" item="item">
             <if test="ind == 0">
                 select #{item} pid
@@ -1713,8 +1711,10 @@
                 select #{item} pid
             </if>
         </foreach>
-        ) packageCodes where packageCodes.pid = ldpl.order_package_code)
-        and ldpl.warehouse_id = #{warehouseId}
+        ) t on t.pid = ldpl.order_package_code
+        set ldpl.order_package_status = #{packageStatus}
+        where ldpl.warehouse_id = #{warehouseId}
+
     </update>
 
     <select id="findListByOrderPackageCode" resultType="com.logpm.distribution.entity.DistributionParcelListEntity">
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 94ca60b08..776d3fb4f 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
@@ -1437,6 +1437,7 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl<Distribut
         return orderInfoByOrderPackageCode;
 	}
 
+	@Transactional()
 	@Override
 	public void updateEntityByOpenOrderByAdvanceIds(UpdateOrderDTO updateOrderDTO) {
 		Long waybillId = updateOrderDTO.getWaybillId();
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/SyncOrderInfoToPlatform.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/SyncOrderInfoToPlatform.java
index ea8a26518..4299689fa 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/SyncOrderInfoToPlatform.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/SyncOrderInfoToPlatform.java
@@ -39,6 +39,7 @@ import org.springblade.core.tool.utils.StringUtil;
 import org.springframework.stereotype.Component;
 
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 同步老系统订单信息到新系统
@@ -957,4 +958,30 @@ public class SyncOrderInfoToPlatform {
 	}
 
 
+	@XxlJob("dealPackageStatus")
+	public ReturnT<String>  dealPackageStatus(String param) {
+		log.info("############dealPackageStatus: 处理包件状态为出库   开始");
+
+		if(StringUtil.isBlank(param)){
+			log.warn("###########dealPackageStatus: 仓库id为空");
+			throw new CustomerException(405,"仓库id为空");
+		}
+
+		Long warehouseId = Long.parseLong(param);
+
+		List<JSONObject> ls = warehouseMappingDataService.findAllOrderPackage();
+
+		List<String> orderPackageCodes = ls.stream().map(l -> l.getStr("orderPackageCode")).collect(Collectors.toList());
+
+
+		syncOrderInfoService.updatePackageStatusList(orderPackageCodes,warehouseId,"60");
+
+
+		log.info("############dealPackageStatus: 处理包件状态为出库  完成");
+
+		return ReturnT.SUCCESS;
+	}
+
+
+
 }
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java
index ee7eba422..d927da696 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java
@@ -146,5 +146,7 @@ public interface WarehouseMappingDataMapper {
 	void updateParcelListWaybillInfo(@Param("orderCodes") List<String> orderCodes, @Param("waybillId") Long waybillId, @Param("waybillNo") String waybillNo, @Param("departureWarehouseId") Long departureWarehouseId, @Param("departureWarehouseName") String departureWarehouseName, @Param("destinationWarehouseId") Long destinationWarehouseId, @Param("destinationWarehouseName") String destinationWarehouseName);
 
 	void updateRepairParcelListWaybillById(@Param("id") Integer id, @Param("status") int status);
+
+    void updatePackageStatusList(@Param("orderPackageCodes") List<String> orderPackageCodes, @Param("warehouseId") Long warehouseId, @Param("packageStatus") String packageStatus);
 }
 
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml
index 11930acef..e90ccfe65 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml
@@ -487,4 +487,21 @@
     </update>
 
 
+    <update id="updatePackageStatusList" >
+        update logpm_distribution_parcel_list ldpl
+        join (
+        <foreach collection="orderPackageCodes" index="ind" item="item">
+            <if test="ind == 0">
+                select #{item} pid
+            </if>
+            <if test="ind != 0">
+                union all
+                select #{item} pid
+            </if>
+        </foreach>
+        ) t on t.pid = ldpl.order_package_code
+        set ldpl.order_package_status = #{packageStatus}
+        where ldpl.warehouse_id = #{warehouseId}
+    </update>
+
 </mapper>
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/ISyncOrderInfoService.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/ISyncOrderInfoService.java
index 2e7f892e0..c2e0f7ee0 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/ISyncOrderInfoService.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/ISyncOrderInfoService.java
@@ -32,4 +32,6 @@ public interface ISyncOrderInfoService {
 	void clearOrderPackageDownAndDelTray(String orderPackageCode, Long warehouseId);
 
 	void syncWaybillInfo(String waybillNo);
+
+    void updatePackageStatusList(List<String> orderPackageCodes, Long warehouseId, String number);
 }
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/IWarehouseMappingDataService.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/IWarehouseMappingDataService.java
index 430e60ee8..4e75daf17 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/IWarehouseMappingDataService.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/IWarehouseMappingDataService.java
@@ -127,4 +127,6 @@ public interface IWarehouseMappingDataService {
 	void updateParcelListWaybillInfo(List<String> orderCodes, Long waybillId, String waybillNo, Long departureWarehouseId, String departureWarehouseName, Long destinationWarehouseId, String destinationWarehouseName);
 
 	void updateRepairParcelListWaybillById(Integer id, int status);
+
+	void updatePackageStatusList(List<String> orderPackageCodes, Long warehouseId, String packageStatus);
 }
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java
index c6887dc27..eb0eadb93 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java
@@ -1,11 +1,13 @@
 package com.logpm.patch.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import com.alibaba.nacos.shaded.com.google.common.collect.Lists;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.logpm.basic.entity.BasicMaterialEntity;
 import com.logpm.basic.feign.IBasicMaterialClient;
 import com.logpm.basicdata.entity.*;
 import com.logpm.basicdata.feign.*;
+import com.logpm.distribution.dto.UpdatePackageDTO;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.distribution.entity.DistributionParcelNumberEntity;
 import com.logpm.distribution.entity.DistributionStockArticleEntity;
@@ -387,6 +389,20 @@ public class SyncOrderInfoServiceImpl implements ISyncOrderInfoService {
 
 	}
 
+	@Override
+	public void updatePackageStatusList(List<String> orderPackageCodes, Long warehouseId, String number) {
+		//把orderPackageCodes 每1000条进行分组
+		List<List<String>> partition = Lists.partition(orderPackageCodes, 1000);
+		partition.forEach(list -> {
+			UpdatePackageDTO updatePackageDTO = new UpdatePackageDTO();
+			updatePackageDTO.setOrderPackageCodes(list);
+			updatePackageDTO.setWarehouseId(warehouseId);
+			updatePackageDTO.setPackageStatus(number);
+			distributionParcelListClient.updatePackageStatus(updatePackageDTO);
+		});
+
+	}
+
 
 	@Transactional(rollbackFor = Exception.class)
 	@Override
diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/WarehouseMappingDataServiceImpl.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/WarehouseMappingDataServiceImpl.java
index 2379d9409..a5991c919 100644
--- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/WarehouseMappingDataServiceImpl.java
+++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/WarehouseMappingDataServiceImpl.java
@@ -305,4 +305,10 @@ public class WarehouseMappingDataServiceImpl implements IWarehouseMappingDataSer
 	public void updateRepairParcelListWaybillById(Integer id, int status) {
 		warehouseMappingDataMapper.updateRepairParcelListWaybillById(id,status);
 	}
+
+	@Override
+	public void updatePackageStatusList(List<String> orderPackageCodes, Long warehouseId, String packageStatus) {
+
+		warehouseMappingDataMapper.updatePackageStatusList(orderPackageCodes,warehouseId,packageStatus);
+	}
 }