From 9de3d450d394323c986f0c8d371cfc9d96de5aa0 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Wed, 7 Aug 2024 11:31:53 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/BasicdataClientMapper.xml          |  2 +
 .../service/impl/OpenOrderServiceImpl.java    | 42 +++++++++++++------
 2 files changed, 32 insertions(+), 12 deletions(-)

diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml
index df9ee3f69..395318cbd 100644
--- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml
+++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml
@@ -101,6 +101,8 @@
         from logpm_basicdata_client lbc
         left join logpm_basicdata_store_contact lbsc on lbsc.shop_id = lbc.id
         where lbc.id = #{clientId}
+        order by lbsc.default_type desc
+        limit 1
     </select>
     <select id="pageList" resultType="com.logpm.basicdata.vo.BasicdataClientVO">
         SELECT
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java
index 09467b825..ad01de271 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java
@@ -1787,18 +1787,18 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 		Set<String> importStandardOuPaiDTOSet = importStandardOuPaiDTOS.stream().map(ImportStandardOuPaiDTO::getOrderPackageCode).collect(Collectors.toSet());
 
 		//把pacakgeDetailExcelDTOS中的元素的orderPackageCode属性分组
-		Map<String, Long> orderPackageCodeCounts = importStandardOuPaiDTOS.stream()
-			.collect(Collectors.groupingBy(ImportStandardOuPaiDTO::getOrderPackageCode, Collectors.counting()));
-
-		Set<String> duplicateOrderPackageCodes = orderPackageCodeCounts.entrySet().stream()
-			.filter(entry -> entry.getValue() > 1)
-			.map(Map.Entry::getKey)
-			.collect(Collectors.toSet());
-
-		if(!duplicateOrderPackageCodes.isEmpty()){
-			log.warn("#################importStandardOuPai: 包条码重复 {}",duplicateOrderPackageCodes);
-			return R.fail(405, "包条码重复"+duplicateOrderPackageCodes);
-		}
+//		Map<String, Long> orderPackageCodeCounts = importStandardOuPaiDTOS.stream()
+//			.collect(Collectors.groupingBy(ImportStandardOuPaiDTO::getOrderPackageCode, Collectors.counting()));
+//
+//		Set<String> duplicateOrderPackageCodes = orderPackageCodeCounts.entrySet().stream()
+//			.filter(entry -> entry.getValue() > 1)
+//			.map(Map.Entry::getKey)
+//			.collect(Collectors.toSet());
+//
+//		if(!duplicateOrderPackageCodes.isEmpty()){
+//			log.warn("#################importStandardOuPai: 包条码重复 {}",duplicateOrderPackageCodes);
+//			return R.fail(405, "包条码重复"+duplicateOrderPackageCodes);
+//		}
 
 		List<String> orderPackageCodeKeys = new ArrayList<>(importStandardOuPaiDTOSet);
 
@@ -1818,6 +1818,20 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 			hasOrderPackageCodeList.addAll(hasOrderPackageCodes);
 		});
 
+		List<TrunklineAdvanceDetailEntity> updateMaterialList = new ArrayList<>();
+		//把importStandardOuPaiDTOS转化成orderPackageCode为key的Map
+		Map<String, ImportStandardOuPaiDTO> importStandardOuPaiDTOMap = importStandardOuPaiDTOS.stream().collect(Collectors.toMap(ImportStandardOuPaiDTO::getOrderPackageCode, Function.identity(), (a, b) -> a));
+		List<TrunklineAdvanceDetailEntity> hasAdvanceDetailList = advanceDetailService.findListByOrderPackageCodeList(hasOrderPackageCodeList);
+		hasAdvanceDetailList.forEach(advanceDetailEntity -> {
+			ImportStandardOuPaiDTO importStandardOuPaiDTO = importStandardOuPaiDTOMap.get(advanceDetailEntity.getOrderPackageCode());
+			TrunklineAdvanceDetailEntity updateMaterialEntity = new TrunklineAdvanceDetailEntity();
+			updateMaterialEntity.setId(advanceDetailEntity.getId());
+			updateMaterialEntity.setMaterialCode(importStandardOuPaiDTO.getMaterialCode());
+			updateMaterialEntity.setMaterialName(importStandardOuPaiDTO.getMaterialName());
+			updateMaterialList.add(updateMaterialEntity);
+		});
+
+
 		//排除importStandardOuPaiDTOS中orderPackageCode在hasOrderPackageCodeList中存在的元素
 		importStandardOuPaiDTOS = importStandardOuPaiDTOS.stream().filter(item -> !hasOrderPackageCodeList.contains(item.getOrderPackageCode())).collect(Collectors.toList());
 
@@ -2077,6 +2091,10 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 			carsLoadAsyncService.sendRabbitMessageLoadScanData(advanceEntityList);
 		}
 
+		if(CollUtil.isNotEmpty(updateMaterialList)){
+			advanceDetailService.updateBatchById(updateMaterialList);
+		}
+
 		int successNum = advanceDetailEntities.size();
 
 		return R.success("成功导入"+successNum+"条");