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

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java |   50 +++++++++++++++++---------------------------------
 1 files changed, 17 insertions(+), 33 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 1e7ecf0..b21309c 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
@@ -6,7 +6,6 @@
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.thoughtworks.xstream.XStream;
 import com.thoughtworks.xstream.io.xml.DomDriver;
-import com.vci.ubcs.code.applyjtcodeservice.feign.IMdmInterJtClient;
 import com.vci.ubcs.code.bo.CodeClassifyFullInfoBO;
 import com.vci.ubcs.code.constant.MdmDuckingConstant;
 import com.vci.ubcs.code.dto.CodeOrderDTO;
@@ -131,8 +130,6 @@
 	@Autowired
 	private ICodeClassifyValueService codeClassifyValueService;
 
-	@Resource
-	private IMdmInterJtClient mdmInterJtClient;
 	/***
 	 * 闆嗘垚鎺ュ彛鏃ュ織鏈嶅姟鐨勯厤缃�
 	 */
@@ -285,13 +282,6 @@
 					resultClassfyVO.setObjects(resultDataObjectDetailDOs);
 					resultClassfyVOList.add(resultClassfyVO);
 				}
-				//鏄惁璋冪敤闆嗗洟鎺ュ彛鐢宠鎺ュ彛
-				if(isCodeOrGroupCode){
-					 List<String> IdList=resultDataObjectDetailDOs.stream().filter(xMLResultDataObjectDetailDO->StringUtils.isNotBlank(xMLResultDataObjectDetailDO.getId())).map(XMLResultDataObjectDetailDO::getId).distinct().collect(Collectors.toList());
-					 if(!CollectionUtils.isEmpty(IdList)) {
-						this.sendApplyGroupcode(IdList, libray,sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue());
-					}
-				}
 			});
 
 			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
@@ -344,19 +334,7 @@
 		return resultStr;
 	}
 
-	/***
-	 * 鐢宠闆嗗洟缂栫爜
-	 * @param idList
-	 * @param btmName
-	 */
-	private void sendApplyGroupcode(List<String> idList,String btmName,String operationType){
-		String oids=VciBaseUtil.array2String(idList.toArray(new String[]{}));
-		if(operationType.equals(sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue())) {
-			mdmInterJtClient.applyGroupCode(oids,btmName);
-		}else if(operationType.equals(sysIntegrationPushTypeEnum.ACCPET_EDITCODE)){
-			mdmInterJtClient.receiveEditApply(oids,btmName);
-		}
-	}
+
 	/***
 	 * 缁熶竴鏇存柊鎺ュ彛锛堟洿鏀圭姸鎬侊紝鏇存敼灞炴�т俊鎭級鎺ュ彛
 	 * @param data
@@ -400,13 +378,6 @@
 			}
 			ClassfysVO classfysVO = interParameterVO.getData().getClassifys();
 			systemId = interParameterVO.getData().getSystemId();
-
-			//鏍¢獙鏄惁閰嶇疆
-			boolean checkPass = checkIspass(systemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getValue());
-			if (!checkPass) {
-				errorid = "101";
-				throw new Throwable("绯荤粺鏍囪瘑涓恒��" + systemId + "銆�," + sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getText() + "鎺ュ彛閰嶇疆宸插仠鐢ㄦ垨鑰呮湭閰嶇疆锛岃鑱旂郴缂栫爜绠$悊鍛橈紒");
-			}
 			UserVO userVo = interParameterVO.getData().getUser();
 			List<ClassfyVO> classVOList = classfysVO.getClassify();
 			InterParameterVO finalInterParameterVO = interParameterVO;
@@ -419,16 +390,30 @@
 			String finalSystemId = systemId;
 			classVOList.stream().forEach(classVO->{
 				log.info("鍙傛暟锛氬垎绫籆Ode:" + classVO.getClassCode());
+				boolean isCodeOrGroupCode=false;
 				LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
+				String libray ="";
 				//鑾峰彇鍒嗙被淇℃伅
 				try {
-					String libray = classVO.getLibrary();
+					libray = classVO.getLibrary();
 					CodeClassifyVO codeClassifyVO = getClassfy(classVO,libray);
 					if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){
 						objerrorCode="100";
 						throw  new  Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙栧埌鍒嗙被淇℃伅");
 					}
 					log.info("end锛氬垎绫绘煡璇㈠畬姣�");
+
+					String operation="";
+					if(CODE_CHECKCONFIG) {
+						//鏍¢獙鏄惁閰嶇疆
+						DockingSystemConfig dockingSystemConfig= checkIspass(finalSystemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getValue(),codeClassifyVO.getOid());
+						if(dockingSystemConfig==null){
+							objerrorCode ="101";
+							throw new Throwable("绯荤粺鏍囪瘑涓恒��"+ finalSystemId +"銆戯紝闆嗘垚鍒嗙被涓恒��"+codeClassifyVO.getName()+"銆戜互涓婂垎绫伙紝"+sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getText()+"鎺ュ彛閰嶇疆宸插仠鐢ㄦ垨鑰呮湭閰嶇疆锛岃鑱旂郴缂栫爜绠$悊鍛橈紒");
+						}
+						isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false;
+					}
+
 					//鑾峰彇鍒嗙被妯℃澘淇℃伅
 					CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid());
 					if(templateVO==null||StringUtils.isBlank(templateVO.getOid())){
@@ -444,7 +429,7 @@
 					this.getConfigDatas(finalSystemId, libray, applyDatasVO, attrVOS, dataObjectVO);
 					log.info("end锛氭暟鎹瀯寤哄畬姣�");
 					log.info("start锛氫慨鏀规暟鎹墽琛屽畬姣�");
-					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs);
+					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,isCodeOrGroupCode);
 					log.info("end锛氫慨鏀规暟鎹墽琛屽畬姣�");
 				} catch (Throwable e) {
 					XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO=new XMLResultDataObjectDetailDO();
@@ -462,7 +447,6 @@
 					resultClassfyVO.setObjects(resultDataObjectDetailDOs);
 					resultClassfyVOList.add(resultClassfyVO);
 				}
-
 			});
 		}catch (Throwable e){
 			e.printStackTrace();;

--
Gitblit v1.9.3