From f043d5d9d1919ee81d7b43e2f58cd8ac7419259a Mon Sep 17 00:00:00 2001 From: ludc Date: 星期五, 25 八月 2023 11:09:22 +0800 Subject: [PATCH] Merge branch 'master' of http://dev.vci-tech.com:1065/r/ubcs --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/DockingSystemConfigServiceImpl.java | 74 +++++++++++++++++++------------------ 1 files changed, 38 insertions(+), 36 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 c4ace0a..a256faf 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 @@ -161,56 +161,58 @@ */ @Transactional(rollbackFor = Exception.class) @Override - public boolean addSave(DockingSystemConfigDTO dockingSystemConfigDTO) { + public boolean addSave(DockingSystemConfigDTO dockingSystemConfigDTO) throws Throwable { log.info(" 澧炲姞绯荤粺闆嗘垚鐨勬帴鍙g鐞嗕俊鎭�:"+dockingSystemConfigDTO.toString()); VciBaseUtil.alertNotNull(dockingSystemConfigDTO, "闇�瑕佹坊鍔犵殑鏁版嵁瀵硅薄"); checkColumnNotNull(dockingSystemConfigDTO); String systemOid =""; - if(dockingSystemConfigDTO.getDataFlowType().equals(SysIntegrationDataFlowTypeEnum.ACCEPT.getValue())) { + if(dockingSystemConfigDTO.getDataFlowType().equals(SysIntegrationDataFlowTypeEnum.PUSH.getValue())) { systemOid = dockingSystemConfigDTO.getTargetSystemOid(); }else{ systemOid = dockingSystemConfigDTO.getSourceSystemOid(); } DockingSystem dockingSystem = dockingSystemMapper.selectById(systemOid); - dockingSystemConfigDTO.setSysBaseOid(systemOid); - dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId()); - dockingSystemConfigDTO.setSysBaseName(dockingSystem.getName()); - dockingSystemConfigDTO.setUsedFlag("true");//璁剧疆榛樿鍚敤鐘舵�� + if(dockingSystem!=null) { + dockingSystemConfigDTO.setSysBaseOid(systemOid); + dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId()); + dockingSystemConfigDTO.setSysBaseName(dockingSystem.getName()); + dockingSystemConfigDTO.setUsedFlag("true");//璁剧疆榛樿鍚敤鐘舵�� - //灏咲TO杞崲涓篋O - DockingSystemConfig dockingSystemConfig = new DockingSystemConfig(); - revisionModelUtil.copyFromDTOIgnore(dockingSystemConfigDTO,dockingSystemConfig); + //灏咲TO杞崲涓篋O + DockingSystemConfig dockingSystemConfig = new DockingSystemConfig(); + revisionModelUtil.copyFromDTOIgnore(dockingSystemConfigDTO,dockingSystemConfig); - List<DockingSysIntParamDTO> sysIntParamDTOList= dockingSystemConfigDTO.getSysIntParamDTOS(); - List<DockingSysIntParam> sysIntParamList=new ArrayList<>(); - if(!CollectionUtils.isEmpty(sysIntParamDTOList)) { - sysIntParamDTOList.stream().forEach(sysIntParamDTO -> { - DockingSysIntParam sysIntParamDO = new DockingSysIntParam(); - sysIntParamDTO.setInfoOid(dockingSystemConfigDTO.getOid()); - BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntParamDTO, sysIntParamDO); - DefaultAttrAssimtUtil.addDefaultAttrAssimt(sysIntParamDO, MdmBtmTypeConstant.SYS_INT_PARAMTERY); - sysIntParamList.add(sysIntParamDO); - }); + List<DockingSysIntParamDTO> sysIntParamDTOList= dockingSystemConfigDTO.getSysIntParamDTOS(); + List<DockingSysIntParam> sysIntParamList=new ArrayList<>(); + if(!CollectionUtils.isEmpty(sysIntParamDTOList)) { + sysIntParamDTOList.stream().forEach(sysIntParamDTO -> { + DockingSysIntParam sysIntParamDO = new DockingSysIntParam(); + sysIntParamDTO.setInfoOid(dockingSystemConfigDTO.getOid()); + BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntParamDTO, sysIntParamDO); + DefaultAttrAssimtUtil.addDefaultAttrAssimt(sysIntParamDO, MdmBtmTypeConstant.SYS_INT_PARAMTERY); + sysIntParamList.add(sysIntParamDO); + }); + } + List<DockingSysIntHeaderDTO> sysIntHeaderDTOs= dockingSystemConfigDTO.getSysIntHeaderDTOS(); + List<DockingSysIntHeader> sysIntHeaderList = new ArrayList<>(); + if(!CollectionUtils.isEmpty(sysIntHeaderDTOs)) { + sysIntHeaderDTOs.stream().forEach(sysIntHeaderDTO -> { + DockingSysIntHeader dockingSysIntHeader = new DockingSysIntHeader(); + sysIntHeaderDTO.setInfoOid(dockingSystemConfigDTO.getOid()); + BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntHeaderDTO, dockingSysIntHeader); + DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSysIntHeader,MdmBtmTypeConstant.SYS_INT_HEADER); + sysIntHeaderList.add(dockingSysIntHeader); + }); + } + dockingSysIntParamService.saveBatch(sysIntParamList); + dockingSysIntHeaderService.saveBatch(sysIntHeaderList); + DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSystemConfig,MdmBtmTypeConstant.SYS_INT_INFO); + dockingSystemConfigMapper.insert(dockingSystemConfig); + }else{ + throw new Throwable("鏍规嵁閫夋嫨鐨勯泦鎴愮郴缁熸湭鏍¢獙鍒扮郴缁熶腑瀛樺湪姝ら泦鎴愮郴缁燂紝璇锋牳瀵癸紒"); } - List<DockingSysIntHeaderDTO> sysIntHeaderDTOs= dockingSystemConfigDTO.getSysIntHeaderDTOS(); - List<DockingSysIntHeader> sysIntHeaderList = new ArrayList<>(); - if(!CollectionUtils.isEmpty(sysIntHeaderDTOs)) { - sysIntHeaderDTOs.stream().forEach(sysIntHeaderDTO -> { - DockingSysIntHeader dockingSysIntHeader = new DockingSysIntHeader(); - sysIntHeaderDTO.setInfoOid(dockingSystemConfigDTO.getOid()); - BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntHeaderDTO, dockingSysIntHeader); - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSysIntHeader,MdmBtmTypeConstant.SYS_INT_HEADER); - sysIntHeaderList.add(dockingSysIntHeader); - }); - } - dockingSysIntParamService.saveBatch(sysIntParamList); - dockingSysIntHeaderService.saveBatch(sysIntHeaderList); - DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSystemConfig,MdmBtmTypeConstant.SYS_INT_INFO); - dockingSystemConfigMapper.insert(dockingSystemConfig); - return true; - } /** -- Gitblit v1.9.3