From c606a7210097ca126fcf9fdb123cebf2a964f51d Mon Sep 17 00:00:00 2001 From: xiejun <xiejun@vci-tech.com> Date: 星期四, 26 十二月 2024 16:51:44 +0800 Subject: [PATCH] 集成获取mdm分发通用数据格式接口集成 日志输出到日志文件中 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeMdmInfaceImpl.java | 20 ++++++++++++++++++-- 1 files changed, 18 insertions(+), 2 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeMdmInfaceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeMdmInfaceImpl.java index 5701c22..8d26247 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeMdmInfaceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeMdmInfaceImpl.java @@ -1,6 +1,7 @@ package com.vci.ubcs.code.service.impl; import com.alibaba.cloud.commons.lang.StringUtils; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; @@ -28,6 +29,7 @@ import com.vci.ubcs.code.vo.webserviceModel.mdm.MDMParamData; import com.vci.ubcs.code.vo.webserviceModel.mdm.MdmResultData; import com.vci.ubcs.code.vo.webserviceModel.person.EnumerableData; +import com.vci.ubcs.code.vo.webserviceModel.person.PersonMasterData; import com.vci.ubcs.code.vo.webserviceModel.person.ResultMdMapping; import com.vci.ubcs.code.vo.webserviceModel.result.xml.XMLResultDataObjectDetailDO; import com.vci.ubcs.code.webService.config.AttributeMapConfig; @@ -156,6 +158,7 @@ // webservice璇锋眰鏂瑰紡鑾峰彇HttpServletRequest瀵硅薄 request = (HttpServletRequest)webServiceContext.getMessageContext().get(MessageContext.SERVLET_REQUEST); }catch (Exception e){ + log.error("鑾峰彇httpServletRequest澶辫触锛屽師鍥�:***********:",e); throw new ServiceException("鑾峰彇httpServletRequest澶辫触锛屽師鍥�:"+e.getMessage()); } }else { @@ -183,6 +186,10 @@ throw new Throwable("鐢ㄦ埛閴存潈澶辫触"); } List<ClassifyConfig> classifyConfigList=mdmInterFaceConfig.getClassifyconfigs(); + //masterDataList + String masterDataStr = mdmParamData.getMasterData(); + masterDataList = JSONArray.parseObject(masterDataStr,List.class); + if(StringUtils.isNotBlank(library)&&StringUtils.isNotBlank(classifyCode)){ String finalLibrary = library; classifyConfigList.stream().forEach(classifyConfig -> { @@ -264,7 +271,7 @@ if (com.alibaba.nacos.common.utils.StringUtils.isBlank(tableName)) { throw new Throwable("鏍规嵁涓氬姟绫诲瀷鏈煡璇㈠埌涓氬姟绫诲瀷鐩稿叧鑱旂殑琛�"); } - masterDataList = mdmParamData.getMasterData(); + List<String> codeList = new ArrayList<>(); List<ApplyDataVO> applyDataVOList = new ArrayList<>(); List<ApplyDataVO> deleteDataVOList = new ArrayList<>(); @@ -428,6 +435,7 @@ }); }catch (Throwable e){ mesg="璁$畻鐮佹鐮佸�煎嚭鐜板紓甯�:"+e.getMessage(); + log.error("璁$畻鐮佹鐮佸�煎嚭鐜板紓甯�,鍘熷洜:***********:",e); new Throwable("璁$畻鐮佹鐮佸�煎嚭鐜板紓甯�:"+e.getMessage()); } } @@ -463,6 +471,7 @@ } } } catch (Exception e) { + log.error("闆嗘垚绯荤粺锛氥��"+systemCode+"銆戠敵璇风紪鐮佸け璐�:锛屽師鍥�:***********:",e); mesg="闆嗘垚绯荤粺锛氥��"+systemCode+"銆戠敵璇风紪鐮佸け璐�:" + e.getMessage(); mesg = e.getMessage(); e.printStackTrace(); @@ -495,6 +504,8 @@ log.info("end锛氱敵璇疯幏鍙栧畬姣�"); } } catch (Throwable e) { + e.printStackTrace(); + log.error("闆嗘垚绯荤粺锛氥��"+systemCode+"銆戞墽琛岄泦鎴愬け璐�:",e); success.set(false); message = "闆嗘垚绯荤粺锛氥��"+systemCode+"銆戞墽琛岄泦鎴愬け璐�:" + e.getMessage(); msg ="闆嗘垚绯荤粺锛氥��"+systemCode+"銆戞墽琛岄泦鎴愬け璐�" + e.getMessage(); @@ -523,6 +534,7 @@ //璁板綍鏃ュ織 this.saveLogs(systemCode, systemCode, data, resultStr, success.get(), msg, "syncDataForMDM"); } catch (Throwable e) { + log.error("淇濆瓨鏃ュ織鍑洪敊,鍘熷洜:",e); e.printStackTrace(); } return mdmResultData; @@ -580,6 +592,7 @@ } }catch (Throwable e){ objerrorCode="100"; + log.error("鑾峰彇鍒嗙被淇℃伅澶辫触:",e); throw new Throwable("鑾峰彇鍒嗙被淇℃伅澶辫触:"+e.getMessage()); } return classifyVO; @@ -602,6 +615,7 @@ } catch (Throwable e) { objerrorCode = "1"; e.printStackTrace(); + log.error("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�" + systemId + "銆戯紝鍒嗙被搴撲负:銆�" + libray + "銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�",e); throw new Throwable("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�" + systemId + "銆戯紝鍒嗙被搴撲负:銆�" + libray + "銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�"); } // String path = stringStringMap.get(systemId); @@ -702,7 +716,9 @@ dataObjectVO.setRowData(rowDataList); }catch (Throwable e){ objerrorCode="1"; - throw new Throwable("缁勭粐鏁版嵁鏄犲皠鍊煎け璐�"); + e.printStackTrace(); + log.error("缁勭粐鏁版嵁鏄犲皠鍊煎け璐�",e); + throw new Throwable("缁勭粐鏁版嵁鏄犲皠鍊煎け璐�"+e); } } /*private void codeValueList(List<CodeBasicSecVO> secVOList,String codeseclengthfield ){ -- Gitblit v1.9.3