From db5ed49b5473b63bf08c4e0c7ffa752ed35a3a95 Mon Sep 17 00:00:00 2001
From: xiejun <xj@2023>
Date: 星期三, 30 八月 2023 18:46:02 +0800
Subject: [PATCH] 关于接口配置管理模块更改/统一接口涉及集团码申请功能需求bug修复

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java |  137 ++++++++++++++++++++++++---------------------
 1 files changed, 73 insertions(+), 64 deletions(-)

diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java
index 21c60ed..9c18cdd 100644
--- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java
@@ -222,76 +222,85 @@
 	 */
 	@Transactional(rollbackFor = Exception.class)
 	@Override
-	public boolean editSave(DockingSystemConfigDTO dockingSystemConfigDTO) {
+	public boolean editSave(DockingSystemConfigDTO dockingSystemConfigDTO) throws Throwable {
 		VciBaseUtil.alertNotNull(dockingSystemConfigDTO,"鏁版嵁瀵硅薄",dockingSystemConfigDTO.getOid(),"绯荤粺闆嗘垚鍩虹淇℃伅涓婚敭");
-		String sourcesystemoid = dockingSystemConfigDTO.getSourceSystemOid();//.getSourcesystemoid();
-		DockingSystem dockingSystem = dockingSystemMapper.selectById(sourcesystemoid);
-		dockingSystemConfigDTO.setSysBaseOid(sourcesystemoid);
-		dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId());
-		dockingSystemConfigDTO.setBtmname(dockingSystem.getName());
-		//灏咲TO杞崲涓篋O
-		DockingSystemConfig dockingSystemConfig = dockingSystemConfigMapper.selectById(dockingSystemConfigDTO.getOid());
-		revisionModelUtil.copyFromDTOIgnore(dockingSystemConfigDTO,dockingSystemConfig);
-		String sysInfoOid=dockingSystemConfigDTO.getOid();
-		List<DockingSysIntParamDTO> dockingSysIntParamDTOS=  dockingSystemConfigDTO.getSysIntParamDTOS();
-		List<DockingSysIntParam> dockingSysIntParamList=new ArrayList<>();
-		if(!CollectionUtils.isEmpty(dockingSysIntParamDTOS)) {
-			dockingSysIntParamDTOS.stream().forEach(dockingSysIntParamDTO -> {
-				DockingSysIntParam dockingSysIntParam = new DockingSysIntParam();
-				BeanUtilForVCI.copyPropertiesIgnoreCase(dockingSysIntParamDTO, dockingSysIntParam);
-				dockingSysIntParamList.add(dockingSysIntParam);
-			});
+		String systemOid ="";
+		if(dockingSystemConfigDTO.getDataFlowType().equals(SysIntegrationDataFlowTypeEnum.PUSH.getValue())) {
+			systemOid = dockingSystemConfigDTO.getTargetSystemOid();
+		}else{
+			systemOid = dockingSystemConfigDTO.getSourceSystemOid();
 		}
-		List<DockingSysIntHeaderDTO> dockingSysIntHeaderDTOS= dockingSystemConfigDTO.getSysIntHeaderDTOS();
-		List<DockingSysIntHeader> dockingSysIntHeaderList = new ArrayList<>();
-		if(!CollectionUtils.isEmpty(dockingSysIntHeaderDTOS)) {
-			dockingSysIntHeaderDTOS.stream().forEach(dockingSysIntHeaderDTO -> {
-				DockingSysIntHeader dockingSysIntHeader = new DockingSysIntHeader();
-				BeanUtilForVCI.copyPropertiesIgnoreCase(dockingSysIntHeaderDTO, dockingSysIntHeader);
-				dockingSysIntHeaderList.add(dockingSysIntHeader);
-			});
-		}
+		DockingSystem dockingSystem = dockingSystemMapper.selectById(systemOid);
+		if(dockingSystem!=null) {
+			dockingSystemConfigDTO.setSysBaseOid(dockingSystem.getOid());
+			dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId());
+			dockingSystemConfigDTO.setSysBaseName(dockingSystem.getName());
+			//灏咲TO杞崲涓篋O
+			DockingSystemConfig dockingSystemConfig = dockingSystemConfigMapper.selectById(dockingSystemConfigDTO.getOid());
+			revisionModelUtil.copyFromDTOIgnore(dockingSystemConfigDTO, dockingSystemConfig);
+			String sysInfoOid = dockingSystemConfigDTO.getOid();
+			List<DockingSysIntParamDTO> dockingSysIntParamDTOS = dockingSystemConfigDTO.getSysIntParamDTOS();
+			List<DockingSysIntParam> dockingSysIntParamList = new ArrayList<>();
+			if (!CollectionUtils.isEmpty(dockingSysIntParamDTOS)) {
+				dockingSysIntParamDTOS.stream().forEach(dockingSysIntParamDTO -> {
+					DockingSysIntParam dockingSysIntParam = new DockingSysIntParam();
+					BeanUtilForVCI.copyPropertiesIgnoreCase(dockingSysIntParamDTO, dockingSysIntParam);
+					dockingSysIntParamList.add(dockingSysIntParam);
+				});
+			}
+			List<DockingSysIntHeaderDTO> dockingSysIntHeaderDTOS = dockingSystemConfigDTO.getSysIntHeaderDTOS();
+			List<DockingSysIntHeader> dockingSysIntHeaderList = new ArrayList<>();
+			if (!CollectionUtils.isEmpty(dockingSysIntHeaderDTOS)) {
+				dockingSysIntHeaderDTOS.stream().forEach(dockingSysIntHeaderDTO -> {
+					DockingSysIntHeader dockingSysIntHeader = new DockingSysIntHeader();
+					BeanUtilForVCI.copyPropertiesIgnoreCase(dockingSysIntHeaderDTO, dockingSysIntHeader);
+					dockingSysIntHeaderList.add(dockingSysIntHeader);
+				});
+			}
 
-		//鎵归噺澶勭悊淇濆瓨header瀵硅薄
-		if(!CollectionUtils.isEmpty(dockingSysIntHeaderList)) {
-			List<String> idList=new ArrayList<>();
-			List<DockingSysIntHeader> headers_old =this.dockingSysIntHeaderService.list(Wrappers.<DockingSysIntHeader>query().lambda().eq(DockingSysIntHeader::getInfoOid,sysInfoOid));;
-			for (DockingSysIntHeader sysIntHeader:headers_old){
-				sysIntHeader.setUsedFlag(FLAG_FAIL);
-				idList.add(sysIntHeader.getOid());
-			}
-			if(idList.size()!=0){
-				boolean res=dockingSysIntHeaderService.removeBatchByIds(idList);
-			}
-			//鍐嶆柊澧瀐eaders
-			for(DockingSysIntHeader sysIntHeader:dockingSysIntHeaderList){
-				sysIntHeader.setUsedFlag(FLAG_TRUE);
-				sysIntHeader.setInfoOid(dockingSystemConfig.getOid());
+			//鎵归噺澶勭悊淇濆瓨header瀵硅薄
+			if (!CollectionUtils.isEmpty(dockingSysIntHeaderList)) {
+				List<String> idList = new ArrayList<>();
+				List<DockingSysIntHeader> headers_old = this.dockingSysIntHeaderService.list(Wrappers.<DockingSysIntHeader>query().lambda().eq(DockingSysIntHeader::getInfoOid, sysInfoOid));
+				;
+				for (DockingSysIntHeader sysIntHeader : headers_old) {
+					sysIntHeader.setUsedFlag(FLAG_FAIL);
+					idList.add(sysIntHeader.getOid());
+				}
+				if (idList.size() != 0) {
+					boolean res = dockingSysIntHeaderService.removeBatchByIds(idList);
+				}
+				//鍐嶆柊澧瀐eaders
+				for (DockingSysIntHeader sysIntHeader : dockingSysIntHeaderList) {
+					sysIntHeader.setUsedFlag(FLAG_TRUE);
+					sysIntHeader.setInfoOid(dockingSystemConfig.getOid());
 
+				}
+				boolean res = dockingSysIntHeaderService.saveBatch(dockingSysIntHeaderList);
 			}
-			boolean res= dockingSysIntHeaderService.saveBatch(dockingSysIntHeaderList);
+			//鎵归噺澶勭悊淇濆瓨Param瀵硅薄
+			if (!CollectionUtils.isEmpty(dockingSysIntParamList)) {
+				//鍏堝垹闄arams_old
+				List<String> idList = new ArrayList<>();
+				List<DockingSysIntParam> params_old = this.dockingSysIntParamService.list(Wrappers.<DockingSysIntParam>query().lambda().eq(DockingSysIntParam::getInfoOid, sysInfoOid));
+				for (DockingSysIntParam sysIntParamDO : params_old) {
+					sysIntParamDO.setUsedFlag(FLAG_FAIL);
+					idList.add(sysIntParamDO.getOid());
+				}
+				if (idList.size() != 0) {
+					boolean res = dockingSysIntParamService.removeBatchByIds(idList);
+				}
+				//鍐嶆柊澧瀙arams
+				for (DockingSysIntParam sysIntParamDOi : dockingSysIntParamList) {
+					sysIntParamDOi.setUsedFlag(FLAG_TRUE);
+					sysIntParamDOi.setInfoOid(dockingSystemConfig.getOid());
+				}
+				dockingSysIntParamService.saveBatch(dockingSysIntParamList);
+			}
+			this.dockingSystemConfigMapper.updateById(dockingSystemConfig);
+		}else{
+			throw new Throwable("鏍规嵁閫夋嫨鐨勯泦鎴愮郴缁熸湭鏍¢獙鍒扮郴缁熶腑瀛樺湪姝ら泦鎴愮郴缁燂紝璇锋牳瀵癸紒");
 		}
-		//鎵归噺澶勭悊淇濆瓨Param瀵硅薄
-		if(!CollectionUtils.isEmpty(dockingSysIntParamList)) {
-			//鍏堝垹闄arams_old
-			List<String> idList=new ArrayList<>();
-			List<DockingSysIntParam> params_old =this.dockingSysIntParamService.list(Wrappers.<DockingSysIntParam>query().lambda().eq(DockingSysIntParam::getInfoOid,sysInfoOid));
-			for (DockingSysIntParam sysIntParamDO:params_old){
-				sysIntParamDO.setUsedFlag(FLAG_FAIL);
-				idList.add(sysIntParamDO.getOid());
-			}
-			if(idList.size()!=0){
-				boolean res= dockingSysIntParamService.removeBatchByIds(idList);
-			}
-			//鍐嶆柊澧瀙arams
-			for(DockingSysIntParam sysIntParamDOi:dockingSysIntParamList){
-				sysIntParamDOi.setUsedFlag(FLAG_TRUE);
-				sysIntParamDOi.setInfoOid(dockingSystemConfig.getOid());
-			}
-			dockingSysIntParamService.saveBatch(dockingSysIntParamList);
-		}
-		this.dockingSystemConfigMapper.updateById(dockingSystemConfig);
-		//return changeoDckingSystemEntityVOs(dockingSystemConfig,dockingSysIntHeaderList,dockingSysIntParamList);
 		return true;
 	}
 	/***

--
Gitblit v1.9.3