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.info("\"获取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.info("计算码段码值出现异常,原因:***********:"+e);
                           new Throwable("计算码段码值出现异常:"+e.getMessage());
                        }
                     }
@@ -463,6 +471,7 @@
                     }
                  }
               } catch (Exception e) {
                  log.info("集成系统：【"+systemCode+"】申请编码失败:，原因:***********:"+e);
                  mesg="集成系统：【"+systemCode+"】申请编码失败:" + e.getMessage();
                  mesg = e.getMessage();
                  e.printStackTrace();
@@ -495,6 +504,8 @@
            log.info("end：申请获取完毕");
         }
      } catch (Throwable e) {
         e.printStackTrace();
         log.info("错误信息***********:"+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.info("保存日志出错,原因:***********:"+e);
         e.printStackTrace();
      }
      return mdmResultData;
@@ -580,6 +592,7 @@
         }
      }catch (Throwable e){
         objerrorCode="100";
         log.info("错误信息***********:"+e);
         throw    new  Throwable("获取分类信息失败:"+e.getMessage());
      }
      return classifyVO;
@@ -602,6 +615,7 @@
         } catch (Throwable e) {
            objerrorCode = "1";
            e.printStackTrace();
            log.info("集成系统标识为：【" + 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.info("组织数据映射值失败"+e);
         throw new   Throwable("组织数据映射值失败"+e);
      }
   }
   /*private void codeValueList(List<CodeBasicSecVO> secVOList,String codeseclengthfield ){