From f6de710d9492cc165211becc7d9e7c27f5724012 Mon Sep 17 00:00:00 2001
From: xiejun <xj@2023>
Date: 星期五, 25 八月 2023 14:52:46 +0800
Subject: [PATCH] 统一接口配置保存bug修复

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java |   27 +++++++++++++++++----------
 1 files changed, 17 insertions(+), 10 deletions(-)

diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java
index eaf4e1f..30ddb67 100644
--- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java
@@ -59,7 +59,8 @@
 import javax.annotation.Resource;
 import java.util.*;
 import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.Collectors;
 
 import static com.vci.ubcs.code.constant.MdmEngineConstant.DEFAULT_SYNC_ATTR_LIST;
@@ -204,7 +205,7 @@
 				//鑾峰彇鍒嗙被淇℃伅
 				try {
 					libray = classVO.getLibrary();
-					CodeClassifyVO codeClassifyVO = getClassfy(classVO);
+					CodeClassifyVO codeClassifyVO = getClassfy(classVO,libray);
 					log.info("end锛氬垎绫绘煡璇㈠畬姣�");
 					//鑾峰彇鍒嗙被妯℃澘淇℃伅
 					if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){
@@ -217,7 +218,7 @@
 						DockingSystemConfig dockingSystemConfig= checkIspass(finalSystemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue(),codeClassifyVO.getOid());
 						if(dockingSystemConfig==null){
 							errorid[0] ="101";
-							throw new Throwable("绯荤粺鏍囪瘑涓恒��"+ finalSystemId +"銆戯紝闆嗘垚鍒嗙被涓恒��+codeClassifyVO.getName()銆戜互涓婂垎绫伙紝"+sysIntegrationPushTypeEnum.ACCPET_APPCODE.getText()+"鎺ュ彛閰嶇疆宸插仠鐢ㄦ垨鑰呮湭閰嶇疆锛岃鑱旂郴缂栫爜绠$悊鍛橈紒");
+							throw new Throwable("绯荤粺鏍囪瘑涓恒��"+ finalSystemId +"銆戯紝闆嗘垚鍒嗙被涓恒��"+codeClassifyVO.getName()+"銆戜互涓婂垎绫伙紝"+sysIntegrationPushTypeEnum.ACCPET_APPCODE.getText()+"鎺ュ彛閰嶇疆宸插仠鐢ㄦ垨鑰呮湭閰嶇疆锛岃鑱旂郴缂栫爜绠$悊鍛橈紒");
 						}
 						isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false;
 					}
@@ -421,7 +422,7 @@
 				//鑾峰彇鍒嗙被淇℃伅
 				try {
 					String libray = classVO.getLibrary();
-					CodeClassifyVO codeClassifyVO = getClassfy(classVO);
+					CodeClassifyVO codeClassifyVO = getClassfy(classVO,libray);
 					if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){
 						objerrorCode="100";
 						throw  new  Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙栧埌鍒嗙被淇℃伅");
@@ -1327,7 +1328,7 @@
 	 * 鏌ヨ鏍¢獙鍒嗙被淇℃伅
 	 * @param classfyVO
 	 */
-	private  CodeClassifyVO getClassfy(ClassfyVO classfyVO) throws Throwable{
+	private  CodeClassifyVO getClassfy(ClassfyVO classfyVO,String libray) throws Throwable{
 		CodeClassifyVO classifyVO = new CodeClassifyVO();
 		try {
 			String classCode = classfyVO.getClassCode();
@@ -1336,13 +1337,19 @@
 			if (StringUtils.isNotBlank(classfyVO.getClassCode())) {
 				Map<String, String> conditionMap = new HashMap<>();
 				List<CodeClassify> codeClassifyList = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId, classCode));
+				final CodeClassify[] newCodeClassify = {new CodeClassify()};
 				if (!CollectionUtils.isEmpty(codeClassifyList)) {
-					CodeClassify classifyDO = codeClassifyList.get(0);
-					//灏咲TO杞崲涓篋O
+					codeClassifyList.stream().forEach(codeClassify -> {
+						CodeClassifyVO codeClassifyVO=  classifyService.getTopClassifyVO(codeClassify.getOid());
+						if(codeClassifyVO.getId().equals(libray)){
+							newCodeClassify[0] =codeClassify;
+						}
+					});
 					classifyVO = new CodeClassifyVO();
-					BeanUtilForVCI.copyPropertiesIgnoreCase(classifyDO, classifyVO);
+					BeanUtilForVCI.copyPropertiesIgnoreCase(newCodeClassify[0], classifyVO);
+					//灏咲TO杞崲涓篋O
 					if(StringUtils.isBlank(classifyVO.getOid())){
-						throw new  Throwable("鏍规嵁鍒嗙被浠e彿鏈煡璇㈠埌鐩稿簲鐨勫垎绫讳俊鎭�");
+						throw new  Throwable("鐢宠缂栫爜鐨勫垎绫伙細銆�"+classCode+"銆戜笉灞炰簬搴撹妭鐐广��"+libray+"銆戯紝璇锋鏌ュ弬鏁板垎绫昏妭鐐�/搴撹妭鐐逛俊鎭槸鍚﹀尮閰�");
 					}
 				}else{
 					throw new  Throwable("鏍规嵁鍒嗙被浠e彿鏈煡璇㈠埌鐩稿簲鐨勫垎绫讳俊鎭�");
@@ -1355,7 +1362,7 @@
 			}
 		}catch (Throwable e){
 			objerrorCode="100";
-			new  Throwable("鑾峰彇鍒嗙被淇℃伅澶辫触:"+e.getMessage());
+			throw 	new  Throwable("鑾峰彇鍒嗙被淇℃伅澶辫触:"+e.getMessage());
 		}
 		return classifyVO;
 	}

--
Gitblit v1.9.3