From 0496aed6e04c5084f05ce1035ba9ec38e3d4e9c7 Mon Sep 17 00:00:00 2001
From: xiejun <xiejun@vci-tech.com>
Date: 星期五, 01 十一月 2024 15:17:41 +0800
Subject: [PATCH] 集成获取mdm分发通用数据格式接口集成

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java |  365 +++++++++++++++++++++++++++++----------------------
 1 files changed, 209 insertions(+), 156 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 8cb5f04..4690e47 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
@@ -69,10 +69,9 @@
 import javax.servlet.http.HttpServletRequest;
 import javax.xml.ws.WebServiceContext;
 import javax.xml.ws.handler.MessageContext;
-import java.io.PrintWriter;
-import java.io.StringWriter;
 import java.util.*;
 import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.ForkJoinPool;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -86,7 +85,7 @@
 @Service
 @Slf4j
 @VciWebservice(path = "/universalInterface")
-public class UniversalInterfaceImpl<IDockingLogeServiceing> implements UniversalInterfaceI {
+public class UniversalInterfaceImpl implements UniversalInterfaceI {
 
 	/***
 	 * 鎿嶄綔绫诲瀷
@@ -114,11 +113,13 @@
 	 */
 	@Value("${bzApply.seriesFlow:seriesFlow}")
 	private String seriesFlow;
+
 	/***
 	 * 鏄惁鍙樻洿绯诲垪
 	 */
 	@Value("${bzApply.isEditSeries:isEditSeries}")
 	private String isEditSeries;
+
 	/***
 	 * 鎺у埗鏄惁鍐欏叆鍊肩殑鐮佹鍚嶇О
 	 */
@@ -130,7 +131,6 @@
 	 */
 	@Value("${bzApply.yearSecName:骞翠唬鍙穧")
 	private String yearSecName;
-
 
 	@Value("${code.universalinterface.checkSystemConfig:true}")
 	public boolean CODE_CHECKCONFIG;
@@ -203,8 +203,14 @@
 	 */
 	@Resource
 	private IDockingLogeService dockingLogeService;
+
 	@Resource
 	private IPasswordFreeLoginService passwordFreeLoginService;
+
+	/**
+	 * 鑷畾涔夊苟鍙慒orkJoinPool
+	 */
+	private static final ForkJoinPool customForkJoinPool = new ForkJoinPool(Runtime.getRuntime().availableProcessors() - 1);
 
 	private  static String separator="##VCI##";
 	private  String errorid="0";
@@ -287,20 +293,20 @@
 				passwordFreeLoginService.pwdFreeLoginByBoolean(systemId.toLowerCase(Locale.ROOT), this.getRequest());
 			}catch (Throwable e){
 				errorid[0] ="1";
-				throw new Throwable("鐢ㄦ埛閴存潈澶辫触.");
+				throw new Throwable("鐢ㄦ埛閴存潈澶辫触锛屽師鍥狅細"+e.getMessage());
 			}
 			List<ClassfyVO> classVOList = classfysVO.getClassify();
-			InterParameterVO finalInterParameterVO = interParameterVO;
+			//InterParameterVO finalInterParameterVO = interParameterVO;
 			//杩欐槸璐﹀彿淇℃伅
 			SessionInfo sessionInfo = new SessionInfo();
 			sessionInfo.setUserId(userVo.getUserName());
 			sessionInfo.setUserName(userVo.getTrueName());
 			sessionInfo.setIp(userVo.getIp());
 			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
-//			List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>();
+			//List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>();
 			String finalSystemId = systemId;
 			classVOList.stream().forEach(classVO -> {
-				log.info("鍙傛暟锛氬垎绫籆Ode:" + classVO.getClassCode());
+				log.info("鍙傛暟锛氬垎绫籆ode:" + classVO.getClassCode());
 				boolean isCodeOrGroupCode=false;
 				LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
 				String libray ="";
@@ -372,7 +378,6 @@
 							resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
 						});
 					}else{
-
 						XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO();
 						xmlResultDataObjectDetailDO.setCode("");
 						xmlResultDataObjectDetailDO.setId("");
@@ -381,6 +386,7 @@
 						resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
 					}
 					e.printStackTrace();
+					log.error(e.getMessage());
 				}finally {
 					XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO();
 					resultClassfyVO.setClassCode(classVO.getClassCode());
@@ -399,6 +405,7 @@
 		}catch (Throwable e){
 			e.printStackTrace();
 			msg="鐢宠缂栫爜澶辫触:"+e.getMessage();
+			log.error(msg);
           /*  XMLResultSystemVO XMLResultSystemVO=new XMLResultSystemVO();
             XMLResultSystemVO.setErrorid(errorid);
             XMLResultSystemVO.setMsg("鐢宠缂栫爜澶辫触锛�->"+e.getMessage());
@@ -434,6 +441,7 @@
 				this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "applyCode");
 			}catch (Throwable e){
 				e.printStackTrace();
+				log.error(e.getMessage());
 			}
 		}
 		log.info("杩斿洖鍙傛暟:"+resultStr);
@@ -449,7 +457,6 @@
 	 */
 	@Override
 	public ResultOrgData syncDataForPerson(PersonData personData) {
-
 		boolean isUsedFlag= personAndDeptConfig.isUsedFlag();
 		ResultOrgData resultOrgData=new ResultOrgData();
 
@@ -460,7 +467,7 @@
 		if(isUsedFlag){
 			AtomicBoolean success= new AtomicBoolean(true);
 			List<PersonMasterData> masterDataList=new ArrayList<>();
-			List<String> fields= VciBaseUtil.str2List(personAndDeptConfig.getPersonFields());
+			List<String> fields = Func.toStrList(personAndDeptConfig.getPersonFields());
 			try {
 				if(personData==null){
 					throw new Throwable("浼犲叆鍙傛暟涓簄ull");
@@ -481,7 +488,7 @@
 				ClassfyVO classfyVO = new ClassfyVO();
 				classfyVO.setLibrary(personLibrary);
 				classfyVO.setClassCode(personClassCode);
-				CodeClassifyVO  codeClassifyVO=this.getClassfy(classfyVO,personLibrary);
+				CodeClassifyVO codeClassifyVO=this.getClassfy(classfyVO,personLibrary);
 				log.info("end锛氬垎绫绘煡璇㈠畬姣�");
 				//鑾峰彇鍒嗙被妯℃澘淇℃伅
 				if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){
@@ -499,8 +506,7 @@
 				).collect(Collectors.toList());
 
 				List<PersonMasterData> personMasterDataList= personData.getMasterData();
-				List<Map> dataList=new ArrayList<>();
-
+				//List<Map> dataList=new ArrayList<>();
 				List<String> codeList=new ArrayList<>();
 
 				List<ApplyDataVO> applyDataVOList=new ArrayList<>();
@@ -519,7 +525,7 @@
 					 */
 					fields.stream().forEach(field->{
 						if(dataMap.containsKey(field)){
-							String enumFiled= dataMap.get(field);
+							String enumFiled = dataMap.get(field);
 							EnumerableData enumerableData=JSONObject.toJavaObject(JSONObject.parseObject(enumFiled),EnumerableData.class);
 							String enumCode=enumerableData.getCode();
 							//String enumCodeValue=enumerableData.getName();
@@ -539,11 +545,11 @@
 
 					object.setProp(proppertyVOList);
 					if(personMasterData.getDr()==1){
-						object.setOperate("delete");//鎿嶄綔绫诲瀷
+						//鎿嶄綔绫诲瀷
+						object.setOperate("delete");
 						deleteDataVOList.add(object);
 					}else{
-						String worker_category=personMasterData.getWorker_category();
-
+						//String worker_category=personMasterData.getWorker_category();
 						object.setOperate("create");
 						applyDataVOList.add(object);
 					}
@@ -571,12 +577,12 @@
 				sb.append(VciBaseUtil.toInSql(codeList.toArray(new String[0])));
 				sb.append(")");
 				List<Map<String,String>> dataMapList=commonsMapper.queryByOnlySqlForMap(sb.toString());
-
+				DefaultAttrAssimtUtil.mapToLowerCase(dataMapList,true);
 				List<ClientBusinessObject> cboList=	ChangeMapTOClientBusinessObjects(dataMapList);
 				ApplyDatasVO applyDatasVO=new ApplyDatasVO();
 				ApplyDatasVO editDatasVO=new ApplyDatasVO();
 				if(!CollectionUtils.isEmpty(cboList)){
-				Map<String,ClientBusinessObject> oldpplyDataVOMap=	cboList.stream().filter(data -> data != null && StringUtils.isNotBlank(data.getId())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
+				Map<String,ClientBusinessObject> oldpplyDataVOMap =	cboList.stream().filter(data -> data != null && StringUtils.isNotBlank(data.getId())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
 					//鏁版嵁搴撲笉瀛樺湪鐨�
 					List<ApplyDataVO> applyApplyDataVOList = applyDataVOList.stream().filter(cbo -> {
 						String code =cbo.getCode();
@@ -616,7 +622,8 @@
 						throw  new Throwable("缂栫爜瑙勫垯");
 					}
 					List<XMLResultDataObjectDetailDO> xDOs=new CopyOnWriteArrayList<>();
-					dataObjectVO.getRowData().parallelStream().forEach(rowData->{
+					final List<RowDatas> rowDatas = dataObjectVO.getRowData();
+					rowDatas.parallelStream().forEach(rowData->{
 						String mesg="";
 						try {
 							CodeOrderDTO orderDTO = new CodeOrderDTO();
@@ -666,6 +673,7 @@
 						} catch (Exception e) {
 							mesg=e.getMessage();
 							e.printStackTrace();
+							throw new ServiceException(e.getMessage());
 						}finally {
 							XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO();
 							x.setId(rowData.getOid());
@@ -678,21 +686,25 @@
 					resultDataObjectDetailDOs.addAll(xDOs);
 					boolean finalSuccess1 = success.get();
 					String finalMessage1 = message;
-					resultDataObjectDetailDOs.stream().forEach(resultDataObjectDetailDO->{
-						ResultMdMapping resultMdMapping=new ResultMdMapping();
-						resultMdMapping.setBusiDataId(resultDataObjectDetailDO.getId());
-						resultMdMapping.setSuccess(finalSuccess1);
-						resultMdMapping.setEntityCode(" ");
-						resultMdMapping.setMdmCode(resultDataObjectDetailDO.getCode());
-						resultMdMapping.setMessage(finalMessage1);
-						resultMdMapping.setSubMdMappings(null);
-						resultMdMappingList.add(resultMdMapping);
-					});
+					// 闄愬埗绾跨▼骞惰鏁伴噺
+					customForkJoinPool.submit(()->{
+						resultDataObjectDetailDOs.stream().forEach(resultDataObjectDetailDO->{
+							ResultMdMapping resultMdMapping=new ResultMdMapping();
+							resultMdMapping.setBusiDataId(resultDataObjectDetailDO.getId());
+							resultMdMapping.setSuccess(finalSuccess1);
+							resultMdMapping.setEntityCode(" ");
+							resultMdMapping.setMdmCode(resultDataObjectDetailDO.getCode());
+							resultMdMapping.setMessage(finalMessage1);
+							resultMdMapping.setSubMdMappings(null);
+							resultMdMappingList.add(resultMdMapping);
+						});
+					}).join();
 					log.info("end锛氱敵璇疯幏鍙栧畬姣�");
 				}
 			}catch (Throwable e){
 				success.set(false);
-				message="浜哄憳鏁版嵁鎺ュ彈澶辫触:"+e.getMessage();
+				message = "浜哄憳鏁版嵁鎺ユ敹澶辫触:"+e.getMessage();
+				msg = "浜哄憳鏁版嵁鎺ユ敹澶辫触:"+e.getMessage();
 				//缁勭粐杩斿洖缁撴灉
 				boolean finalSuccess = success.get();
 				String finalMessage = message;
@@ -709,7 +721,7 @@
 				resultOrgData.setMessage(message);
 				resultOrgData.setSuccess(success.get());
 				resultOrgData.setMdMappings(resultMdMappingList);
-				Object object = JSONObject.toJSON(resultOrgData);
+				//Object object = JSONObject.toJSON(resultOrgData);
 			}
 			String resultStr = JSONObject.toJSONString(resultOrgData);
 			String data = JSONObject.toJSONString(personData);
@@ -734,14 +746,14 @@
 	public ResultOrgData syncDataForOrg(OrgData orgData) {
 		boolean isUsedFlag= personAndDeptConfig.isUsedFlag();
 		ResultOrgData resultOrgData=new ResultOrgData();
-		boolean isPersonApplyGroupCode= personAndDeptConfig.isPersonApplyGroupCode();
+		// boolean isPersonApplyGroupCode= personAndDeptConfig.isDeptApplyGroupCode();
 		List<ResultMdMapping> resultMdMappingList=new ArrayList<>();
 		AtomicBoolean success= new AtomicBoolean(true);
 		String message="";
 		String systemCode="";
 		if(isUsedFlag){
-			List<OrgMasterData> orgMasterDataList=new ArrayList<>();
-			List<String> fields= VciBaseUtil.str2List(personAndDeptConfig.getPersonFields());
+			List<OrgMasterData> orgMasterDataList = new ArrayList<>();
+			List<String> fields = Func.toStrList(personAndDeptConfig.getDeptFields());
 			try {
 				if(orgData==null){
 					throw new Throwable("浼犲叆鍙傛暟涓簄ull");
@@ -753,17 +765,17 @@
 					throw new Throwable("鐢ㄦ埛閴存潈澶辫触");
 				}
 				orgMasterDataList = orgData.getMasterData();
-				String personLibrary = personAndDeptConfig.getPersonLibrary();
-				if (StringUtils.isBlank(personLibrary)) {
+				String deptLibrary = personAndDeptConfig.getDeptLibrary();
+				if (StringUtils.isBlank(deptLibrary)) {
 					success.set(false);
-					log.info("闆嗘垚閰嶇疆缂哄皯浜哄憳搴撹妭鐐逛俊鎭�,personLibrary->" + personLibrary);
-					throw  new Throwable("闆嗘垚閰嶇疆缂哄皯浜哄憳搴撹妭鐐逛俊鎭�,personLibrary->" + personLibrary);
+					log.info("闆嗘垚閰嶇疆缂哄皯閮ㄩ棬搴撹妭鐐逛俊鎭�,deptLibrary->" + deptLibrary);
+					throw  new Throwable("闆嗘垚閰嶇疆缂哄皯閮ㄩ棬搴撹妭鐐逛俊鎭�,deptLibrary->" + deptLibrary);
 				}
-				String personClassCode = personAndDeptConfig.getPersonClassCode();
+				String deptClassCode = personAndDeptConfig.getDeptClassCode();
 				ClassfyVO classfyVO = new ClassfyVO();
-				classfyVO.setLibrary(personLibrary);
-				classfyVO.setClassCode(personClassCode);
-				CodeClassifyVO  codeClassifyVO=this.getClassfy(classfyVO,personLibrary);
+				classfyVO.setLibrary(deptLibrary);
+				classfyVO.setClassCode(deptClassCode);
+				CodeClassifyVO codeClassifyVO = this.getClassfy(classfyVO,deptLibrary);
 				log.info("end锛氬垎绫绘煡璇㈠畬姣�");
 				//鑾峰彇鍒嗙被妯℃澘淇℃伅
 				if(codeClassifyVO==null || StringUtils.isBlank(codeClassifyVO.getOid())){
@@ -773,13 +785,12 @@
 				CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid());
 				if(templateVO==null||StringUtils.isBlank(templateVO.getOid())){
 					success.set(false);
-					throw  new  Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙朚DM绯荤粺涓搴旀ā鏉�");
+					throw new Throwable ("鏍规嵁浼犺緭鐨勫垎绫伙紝鏈幏鍙朚DM绯荤粺涓搴旀ā鏉�");
 				}
 
 				List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) &&
 					((Func.isNotEmpty(s.getClassifyInvokeAttr()) || Func.isNotEmpty(s.getClassifyInvokeAttrName())) || VciBaseUtil.getBoolean(s.getFormDisplayFlag()))
 				).collect(Collectors.toList());
-				List<Map> dataList=new ArrayList<>();
 				List<String> codeList=new ArrayList<>();
 				List<ApplyDataVO> applyDataVOList=new ArrayList<>();
 				List<ApplyDataVO> deleteDataVOList=new ArrayList<>();
@@ -788,10 +799,10 @@
 					object.setCode(orgMasterData.getMdm_code());//缂栫爜
 					object.setCreator(orgMasterData.getCreator());//鍒涘缓鑰�
 					object.setEditor(orgMasterData.getModifier());//淇敼鑰�
-					object.setId(orgMasterData.getPk_mdm());//涓婚敭
+					object.setId(orgMasterData.getDepartment_code());//涓婚敭
 					object.setStatus(CodeDefaultLC.RELEASED.getValue());//鐘舵�佸垯闇�瑕佸垽鏂�
 					Map<String,String> dataMap= VciBaseUtil.objectToMapString(orgMasterData);
-					List<ProppertyVO> proppertyVOList=new ArrayList<>();
+					List<ProppertyVO> proppertyVOList = new ArrayList<>();
 					/***
 					 * 鏍规嵁閰嶇疆鏂囦欢鑾峰彇鏋氫妇鍊�
 					 */
@@ -820,7 +831,6 @@
 						object.setOperate("delete");//鎿嶄綔绫诲瀷
 						deleteDataVOList.add(object);
 					}else{
-
 						object.setOperate("create");
 						applyDataVOList.add(object);
 					}
@@ -836,10 +846,10 @@
 					throw new Throwable("鏍规嵁涓氬姟绫诲瀷鏈煡璇㈠埌涓氬姟绫诲瀷瀵硅薄锛�");
 				}
 				String tableName = btmTypeVO.getTableName();
-				if (com.alibaba.nacos.common.utils.StringUtils.isBlank(tableName)) {
+				if (StringUtils.isBlank(tableName)) {
 					throw new Throwable("鏍规嵁涓氬姟绫诲瀷鏈煡璇㈠埌涓氬姟绫诲瀷鐩稿叧鑱旂殑琛�");
 				}
-				StringBuffer sb=new StringBuffer();
+				StringBuffer sb = new StringBuffer();
 				sb.append(" select * from ");
 				sb.append(tableName);
 				sb.append(" where 1=1 ");
@@ -847,15 +857,16 @@
 				sb.append(" and id in (");
 				sb.append(VciBaseUtil.toInSql(codeList.toArray(new String[0])));
 				sb.append(")");
-				List<Map<String,String>> dataMapList=commonsMapper.queryByOnlySqlForMap(sb.toString());
-				List<ClientBusinessObject> cboList=	ChangeMapTOClientBusinessObjects(dataMapList);
+				List<Map<String,String>> dataMapList = commonsMapper.queryByOnlySqlForMap(sb.toString());
+				DefaultAttrAssimtUtil.mapToLowerCase(dataMapList,true);
+				List<ClientBusinessObject> cboList = ChangeMapTOClientBusinessObjects(dataMapList);
 				ApplyDatasVO applyDatasVO=new ApplyDatasVO();
 				ApplyDatasVO editDatasVO=new ApplyDatasVO();
 				if(!CollectionUtils.isEmpty(cboList)){
-					Map<String,ClientBusinessObject> oldpplyDataVOMap=	cboList.stream().filter(data -> data != null && StringUtils.isNotBlank(data.getId())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
+					Map<String,ClientBusinessObject> oldpplyDataVOMap =	cboList.stream().filter(data -> data != null && StringUtils.isNotBlank(data.getId())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
 					//鏁版嵁搴撲笉瀛樺湪鐨�
 					List<ApplyDataVO> applyApplyDataVOList = applyDataVOList.stream().filter(cbo -> {
-						String code =cbo.getCode();
+						String code = cbo.getCode();
 						return !oldpplyDataVOMap.containsKey(code);
 					}).collect(Collectors.toList());
 					applyDatasVO.setObject(applyApplyDataVOList);
@@ -876,15 +887,15 @@
 				LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs=new LinkedList<>();
 				if(editDatasVO.getObject()!=null&&editDatasVO.getObject().size()>0){
 					DataObjectVO dataObjectVO = new DataObjectVO();
-					this.getConfigDatas(systemCode, personLibrary, editDatasVO, attrVOS, dataObjectVO);
+					this.getConfigDatas(systemCode, deptLibrary, editDatasVO, attrVOS, dataObjectVO);
 					log.info("start锛氫慨鏀规暟鎹墽琛屽畬姣�");
-					boolean  personApplyGroupCode =personAndDeptConfig.isPersonApplyGroupCode();
+					boolean personApplyGroupCode = personAndDeptConfig.isPersonApplyGroupCode();
 					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,personApplyGroupCode);
 					log.info("end锛氫慨鏀规暟鎹墽琛屽畬姣�");
 				}
 				if(applyDatasVO.getObject()!=null&&applyDatasVO.getObject().size()>0) {
 					DataObjectVO dataObjectVO = new DataObjectVO();
-					this.getConfigDatas(systemCode, personLibrary, applyDatasVO, attrVOS, dataObjectVO);
+					this.getConfigDatas(systemCode, deptLibrary, applyDatasVO, attrVOS, dataObjectVO);
 
 					CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(codeClassifyVO.getOid());
 					CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo);
@@ -892,32 +903,34 @@
 						throw  new Throwable("缂栫爜瑙勫垯");
 					}
 					List<XMLResultDataObjectDetailDO> xDOs=new CopyOnWriteArrayList<>();
-					dataObjectVO.getRowData().parallelStream().forEach(rowData->{
-						String mesg="";
-						try {
-							CodeOrderDTO orderDTO = new CodeOrderDTO();
-							List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>();
-							orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//鍒嗙被涓婚敭
-							orderDTO.setTemplateOid(templateVO.getOid());
-							orderDTO.setCreator(rowData.getCreator());
-							orderDTO.setLastModifier(rowData.getEditor());
-							orderDTO.setLcStatus(rowData.getStatus());
-							if(!CollectionUtils.isEmpty(ruleVO.getSecVOList())) {
-								ruleVO.getSecVOList().stream().forEach(codeBasicSecVO -> {
-									if (codeBasicSecVO.getSecType().equals("codevariablesec")) {//瑙勫垯涔嬪畾涔変负鍙彉鐮佹瀛樺偍涓绘暟鎹紶閫掕繃鏉ョ殑鏁版嵁
-										CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO();
-										CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid());
-										CodeOrderSecDTO.setSecValue(rowData.getCode());
-										codeOrderSecDTOList.add(CodeOrderSecDTO);
-
-									}
-								});
-							}
-							orderDTO.setCodeRuleOid(ruleVO.getOid());
-							orderDTO.setSecDTOList(codeOrderSecDTOList);//瀛樺偍缂栫爜
-							orderDTO.setData(rowData.getFiledValue());
-							String code=engineService.addSaveCodeNotauthUser(orderDTO,false);
-							if(StringUtils.isNotBlank(code)) {
+					//闄愬埗绾跨▼骞惰鏁伴噺
+					customForkJoinPool.submit(()->{
+						dataObjectVO.getRowData().parallelStream().forEach(rowData->{
+							String mesg="";
+							try {
+								CodeOrderDTO orderDTO = new CodeOrderDTO();
+								List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>();
+								orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//鍒嗙被涓婚敭
+								orderDTO.setTemplateOid(templateVO.getOid());
+								orderDTO.setCreator(rowData.getCreator());
+								orderDTO.setLastModifier(rowData.getEditor());
+								orderDTO.setLcStatus(rowData.getStatus());
+								if(!CollectionUtils.isEmpty(ruleVO.getSecVOList())) {
+									ruleVO.getSecVOList().stream().forEach(codeBasicSecVO -> {
+										if (codeBasicSecVO.getSecType().equals("codevariablesec")) {
+											//瑙勫垯涔嬪畾涔変负鍙彉鐮佹瀛樺偍涓绘暟鎹紶閫掕繃鏉ョ殑鏁版嵁
+											CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO();
+											CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid());
+											CodeOrderSecDTO.setSecValue(rowData.getOid());
+											codeOrderSecDTOList.add(CodeOrderSecDTO);
+										}
+									});
+								}
+								orderDTO.setCodeRuleOid(ruleVO.getOid());
+								orderDTO.setSecDTOList(codeOrderSecDTOList);//瀛樺偍缂栫爜
+								orderDTO.setData(rowData.getFiledValue());
+								String code = engineService.addSaveCodeNotauthUser(orderDTO,false);
+							/*if(StringUtils.isNotBlank(code)) {
 								//rowData.setCode(code);
 								StringBuffer sqlsb = new StringBuffer();
 								sqlsb.append(" select * from ");
@@ -939,20 +952,21 @@
 										mesg = "鏁版嵁淇濆瓨鎴愬姛锛岀瓑寰呯敵璇烽泦鍥㈢爜";
 									}
 								}
+							}*/
+							} catch (Exception e) {
+								mesg=e.getMessage();
+								e.printStackTrace();
+								throw new ServiceException(e.getMessage());
+							}finally {
+								XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO();
+								x.setId(rowData.getOid());
+								x.setCode(rowData.getCode());
+								x.setMsg(mesg);
+								x.setErrorid("1");
+								xDOs.add(x);
 							}
-						} catch (Exception e) {
-							mesg=e.getMessage();
-							e.getMessage();
-							e.printStackTrace();
-						}finally {
-							XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO();
-							x.setId(rowData.getOid());
-							x.setCode(rowData.getCode());
-							x.setMsg(mesg);
-							x.setErrorid("1");
-							xDOs.add(x);
-						}
-					});
+						});
+					}).join();
 					resultDataObjectDetailDOs.addAll(xDOs);
 					boolean finalSuccess1 = success.get();
 					String finalMessage1 = message;
@@ -970,7 +984,8 @@
 				}
 			}catch (Throwable e){
 				success.set(false);
-				message="浜哄憳鏁版嵁鎺ュ彈澶辫触:"+e.getMessage();
+				message = "閮ㄩ棬鏁版嵁鎺ユ敹澶辫触:"+e.getMessage();
+				msg = "閮ㄩ棬鏁版嵁鎺ユ敹澶辫触:"+e.getMessage();
 				//缁勭粐杩斿洖缁撴灉
 				boolean finalSuccess = success.get();
 				String finalMessage = message;
@@ -1054,7 +1069,7 @@
 				throw new Throwable("鐢ㄦ埛閴存潈澶辫触");
 			}
 			List<ClassfyVO> classVOList = classfysVO.getClassify();
-			InterParameterVO finalInterParameterVO = interParameterVO;
+			//InterParameterVO finalInterParameterVO = interParameterVO;
 			//杩欐槸璐﹀彿淇℃伅
 			SessionInfo sessionInfo = new SessionInfo();
 			sessionInfo.setUserId(userVo.getUserName());
@@ -1199,7 +1214,7 @@
 		log.info("鏌ヨ鍒嗙被鐨勬暟鎹被鍨�:->"+dataType);
 		ResultClassifyVO resultClassifyVO =new ResultClassifyVO();
 		List<ClassifyVO> classifyVOList=new ArrayList<>();
-		com.vci.ubcs.code.vo.webserviceModel.classify.ResultData resultData=new com.vci.ubcs.code.vo.webserviceModel.classify.ResultData();
+		ResultData resultData=new ResultData();
 		try {
 			if (StringUtils.isBlank(data)) {
 				errorid = "101";
@@ -1496,7 +1511,8 @@
 					sb.append(" and lastr=1 and lastv=1" );
 					sb.append(" and codeclsfid in (" + VciBaseUtil.toInSql(oidCodeclassifyDOMap.keySet().toArray(new String[0])) +")");
 					sb.append(" and Lcstatus in (" + VciBaseUtil.toInSql(statusList.toArray(new String[]{})) +")");
-					List<Map<String,String>>  newDataList= commonsMapper.queryByOnlySqlForMap(sb.toString());
+					List<Map<String,String>> newDataList = commonsMapper.queryByOnlySqlForMap(sb.toString());
+					DefaultAttrAssimtUtil.mapToLowerCase(newDataList,true);
 					List<ClientBusinessObject> clientBusinessObjects=	ChangeMapTOClientBusinessObjects(newDataList);
 					List<com.vci.ubcs.code.vo.webserviceModel.data.DataObjectVO> dataObjectVOS=new ArrayList<>();
 					if(!CollectionUtils.isEmpty(clientBusinessObjects)){
@@ -2178,6 +2194,7 @@
 					codeBZApplyDTO.setLastModifier(applyBZDataVO.getEditor());
 					codeBZApplyDTO.setLcStatus(applyBZDataVO.getStatus());
 					ApplyBZDatasVO newApplyBZDatasVO=new ApplyBZDatasVO();
+					applyBZDataVO.setProp(proppertyVOList);
 					newApplyBZDatasVO.setObject(Arrays.asList(applyBZDataVO));
 					log.info("end锛氭暟鎹粍缁囧畬姣�");
 					this.getConfigDatas(finalSystemId, finalLibray, newApplyBZDatasVO, attrVOS, dataObjectVO);
@@ -2244,6 +2261,7 @@
 		//璋冪敤闆嗗洟鐢宠鎺ュ彛鐢宠闆嗗洟鐮�
 		return resultStr;
 	}
+
 	private void setPropertyValue(String key,String value,List<ProppertyVO> proppertyVOList){
 		ProppertyVO proppertyVO=new ProppertyVO();
 		proppertyVO.setKey(key);
@@ -2251,6 +2269,7 @@
 		proppertyVOList.add(proppertyVO);
 
 	}
+
 	/***
 	 * 鏌ヨ鏍¢獙鍒嗙被淇℃伅
 	 * @param classfyVO
@@ -2293,6 +2312,7 @@
 		}
 		return classifyVO;
 	}
+
 	/***
 	 * 鏌ヨ鏍¢獙鍒嗙被淇℃伅
 	 * @param classfyVO
@@ -2352,7 +2372,6 @@
 		return clientBusinessObjectList;
 	}
 
-
 	private List<CodeOrderSecDTO> getRuleCodeOrderSecDTOsBZ(CodeRuleVO ruleVO,CodeClassifyFullInfoBO classifyFullInfo){
 		List<CodeBasicSecVO>  codeBasicSecVOS= ruleVO.getSecVOList();
 		List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>();
@@ -2364,7 +2383,6 @@
 		}
 		return codeOrderSecDTOList;
 	}
-
 
 	/***
 	 * 鏍规嵁浼犲叆鐨勫弬鏁颁俊鎭牎楠岀爜娈佃鍒�
@@ -2429,41 +2447,60 @@
 		return codeOrderSecDTOList;
 	}
 
+	/***
+	 * 璇诲彇灞炴�ф槧灏勯厤缃俊鎭�
+	 * @param systemId
+	 * @param libray
+	 * @param applyDatasVO
+	 * @param codeClassifyTemplateAttrVOList
+	 * @param dataObjectVO
+	 * @throws Throwable
+	 */
 	public void getConfigDatas(String systemId,String libray, ApplyBZDatasVO applyDatasVO,List<CodeClassifyTemplateAttrVO> codeClassifyTemplateAttrVOList,DataObjectVO dataObjectVO) throws Throwable {
 
-		LinkedHashMap<String,LinkedHashMap<String,String>> dataKeyValueMap=new LinkedHashMap<>();
+		// LinkedHashMap<String,LinkedHashMap<String,String>> dataKeyValueMap=new LinkedHashMap<>();
 		//濡傛灉灏嗘暟鎹浆鎹㈡垚鎵�闇�瑕佺殑鏁版嵁瀵硅薄
 		Map<String, String> attrMapConfigMap=new HashMap<>();
 		Map<String, String> propMaps=new HashMap<>();
-		try {
-			log.info("寮�濮嬭鍙栫郴缁熼厤缃枃浠� start");
-			Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
-			log.info("闆嗘垚绯荤粺灞炴�ф槧灏勯厤缃枃浠舵潯鐩暟-銆�"+stringStringMap.size());
-			//stringStringMap.put("RLM","D:\\RLM.xml");
-			if(!CollectionUtils.isEmpty(stringStringMap)) {
+		log.info("寮�濮嬭鍙栫郴缁熼厤缃枃浠� start");
+		Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
+		log.info("闆嗘垚绯荤粺灞炴�ф槧灏勯厤缃枃浠舵潯鐩暟-銆�"+stringStringMap.size());
+		//stringStringMap.put("RLM","D:\\RLM.xml");
+		if(!CollectionUtils.isEmpty(stringStringMap)) {
+			List<LibraryClsfDO> libraryClsfDOList=new ArrayList<>();
+			try {
 				log.info("info锛氶渶瑕佽鍙栭厤缃枃浠�");
 				LibraryDO libraryDO = gennerAttrMapUtil.getNewInstance().gennerAttrMapBySystem(systemId, stringStringMap);
-				List<LibraryClsfDO> libraryClsfDOList = libraryDO.getClsf();
-				if(!CollectionUtils.isEmpty(libraryClsfDOList)) {
-					Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
-					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃�");
-					String path=stringStringMap.get(systemId);
-					if (libPropMaps.containsKey(libray.toUpperCase(Locale.ROOT))) {
-						log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�");
-						List<ClsfAttrMappingDO> clsfAttrMappingDOList = libPropMaps.get(libray.toUpperCase(Locale.ROOT));
-						propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
-						log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�,灞炴�ф槧灏勬潯鐩暟+" + clsfAttrMappingDOList.size());
-					}else{
-						throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�"+systemId+"銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�"+path+"銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��"+libray+"銆戝睘鎬ф槧灏勪俊鎭厤缃�");
-					}
-				}
+				libraryClsfDOList = libraryDO.getClsf();
+			} catch (Throwable e) {
+				objerrorCode = "1";
+				e.printStackTrace();
+				throw new Throwable("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�" + systemId + "銆戯紝鍒嗙被搴撲负:銆�" + libray + "銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�");
 			}
-			log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�"+libray+"浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃� end ");
-		}catch (Throwable e){
-			objerrorCode="1";
-			e.printStackTrace();
-			throw new Throwable("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�"+systemId+"銆戯紝鍒嗙被搴撲负:銆�"+libray+"銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�");
+			// String path = stringStringMap.get(systemId);
+			// 蹇界暐key澶у皬鍐欙紝鑾峰彇閰嶇疆鐨勬槧灏勬枃浠惰矾寰�
+			String path = VciBaseUtil.getMapStrValueIgnoreCase(stringStringMap,systemId);
+			if (!CollectionUtils.isEmpty(libraryClsfDOList)) {
+				Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
+				log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃�");
+				if (libPropMaps.containsKey(libray.toUpperCase(Locale.ROOT))) {
+					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�");
+					List<ClsfAttrMappingDO> clsfAttrMappingDOList = libPropMaps.get(libray.toUpperCase(Locale.ROOT));
+					propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
+					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�,灞炴�ф槧灏勬潯鐩暟+" + clsfAttrMappingDOList.size());
+				} else {
+					objerrorCode = "1";
+					throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�" + systemId + "銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�" + path + "銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��" + libray + "銆戝睘鎬ф槧灏勪俊鎭厤缃�");
+				}
+			}else{
+				objerrorCode = "1";
+				throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�" + systemId + "銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�" + path + "銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��" + libray + "銆戝睘鎬ф槧灏勪俊鎭厤缃�");
+			}
+		}else{
+			objerrorCode = "1";
+			throw new Throwable("鏈幏鍙栧埌闆嗘垚灞炴�ф槧灏勭郴缁熼厤缃俊鎭�");
 		}
+		log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�"+libray+"浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃� end ");
 		LinkedList<String> rowNameList=new LinkedList<>();
 		LinkedHashMap<String,Integer> filedIndexMap=new LinkedHashMap<>();
 		//鏍规嵁鍒嗙被妯℃澘缁勭粐鏁版嵁
@@ -2538,7 +2575,13 @@
 	}
 
 	/***
-	 * 鏍规嵁灞炴�ф槧灏勮浆鎹㈢紪鐮佹墍闇�瀛楁
+	 * 璇诲彇灞炴�ф槧灏勯厤缃俊鎭�
+	 * @param systemId
+	 * @param libray
+	 * @param applyDatasVO
+	 * @param codeClassifyTemplateAttrVOList
+	 * @param dataObjectVO
+	 * @throws Throwable
 	 */
 	public void getConfigDatas(String systemId,String libray, ApplyDatasVO applyDatasVO,List<CodeClassifyTemplateAttrVO> codeClassifyTemplateAttrVOList,DataObjectVO dataObjectVO) throws Throwable {
 
@@ -2546,35 +2589,44 @@
 		//濡傛灉灏嗘暟鎹浆鎹㈡垚鎵�闇�瑕佺殑鏁版嵁瀵硅薄
 		Map<String, String> attrMapConfigMap=new HashMap<>();
 		Map<String, String> propMaps=new HashMap<>();
-		try {
-			log.info("寮�濮嬭鍙栫郴缁熼厤缃枃浠� start");
-			Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
-			log.info("闆嗘垚绯荤粺灞炴�ф槧灏勯厤缃枃浠舵潯鐩暟-銆�"+stringStringMap.size());
-			//stringStringMap.put("RLM","D:\\RLM.xml");
-			if(!CollectionUtils.isEmpty(stringStringMap)) {
+		log.info("寮�濮嬭鍙栫郴缁熼厤缃枃浠� start");
+		Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
+		log.info("闆嗘垚绯荤粺灞炴�ф槧灏勯厤缃枃浠舵潯鐩暟-銆�"+stringStringMap.size());
+		if(!CollectionUtils.isEmpty(stringStringMap)) {
+			List<LibraryClsfDO> libraryClsfDOList=new ArrayList<>();
+			try {
 				log.info("info锛氶渶瑕佽鍙栭厤缃枃浠�");
 				LibraryDO libraryDO = gennerAttrMapUtil.getNewInstance().gennerAttrMapBySystem(systemId, stringStringMap);
-				List<LibraryClsfDO> libraryClsfDOList = libraryDO.getClsf();
-				if(!CollectionUtils.isEmpty(libraryClsfDOList)) {
-					Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
-					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃�");
-					String path=stringStringMap.get(systemId);
-					if (libPropMaps.containsKey(libray.toUpperCase(Locale.ROOT))) {
-						log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�");
-						List<ClsfAttrMappingDO> clsfAttrMappingDOList = libPropMaps.get(libray.toUpperCase(Locale.ROOT));
-						propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
-						log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�,灞炴�ф槧灏勬潯鐩暟+" + clsfAttrMappingDOList.size());
-					}else{
-						throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�"+systemId+"銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�"+path+"銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��"+libray+"銆戝睘鎬ф槧灏勪俊鎭厤缃�");
-					}
-				}
+				libraryClsfDOList = libraryDO.getClsf();
+			} catch (Throwable e) {
+				objerrorCode = "1";
+				e.printStackTrace();
+				throw new Throwable("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�" + systemId + "銆戯紝鍒嗙被搴撲负:銆�" + libray + "銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�");
 			}
-			log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�"+libray+"浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃� end ");
-		}catch (Throwable e){
-			objerrorCode="1";
-			e.printStackTrace();
-			throw new Throwable("闆嗘垚绯荤粺鏍囪瘑涓猴細銆�"+systemId+"銆戯紝鍒嗙被搴撲负:銆�"+libray+"銆戠殑闆嗘垚灞炴�ч厤缃枃浠惰鍙栧け璐�");
+			// String path = stringStringMap.get(systemId);
+			// 蹇界暐key澶у皬鍐欙紝鑾峰彇閰嶇疆鐨勬槧灏勬枃浠惰矾寰�
+			String path = VciBaseUtil.getMapStrValueIgnoreCase(stringStringMap,systemId);
+			if (!CollectionUtils.isEmpty(libraryClsfDOList)) {
+				Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
+				log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃�");
+				if (libPropMaps.containsKey(libray.toUpperCase(Locale.ROOT))) {
+					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�");
+					List<ClsfAttrMappingDO> clsfAttrMappingDOList = libPropMaps.get(libray.toUpperCase(Locale.ROOT));
+					propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
+					log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�" + libray + "鍖归厤鍒扮浉搴旂殑灞炴�ф槧灏勪俊鎭�,灞炴�ф槧灏勬潯鐩暟+" + clsfAttrMappingDOList.size());
+				} else {
+					objerrorCode = "1";
+					throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�" + systemId + "銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�" + path + "銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��" + libray + "銆戝睘鎬ф槧灏勪俊鎭厤缃�");
+				}
+			}else{
+				objerrorCode = "1";
+				throw new Throwable("鏍规嵁绯荤粺鏍囪瘑銆�" + systemId + "銆戞壘鍒板搴旂殑閰嶇疆鏂囦欢:銆�" + path + "銆戯紝浣嗘湭鑾峰彇鍒板搴旂殑搴撱��" + libray + "銆戝睘鎬ф槧灏勪俊鎭厤缃�");
+			}
+		}else{
+			objerrorCode = "1";
+			throw new Throwable("鏈幏鍙栧埌闆嗘垚灞炴�ф槧灏勭郴缁熼厤缃俊鎭�");
 		}
+		log.info("鏍规嵁鍙傛暟锛歭ibray锛�-銆�"+libray+"浠庨厤缃枃浠朵腑鎵惧搴斿睘鎬ф槧灏勯厤缃� end ");
 		LinkedList<String> rowNameList=new LinkedList<>();
 		LinkedHashMap<String,Integer> filedIndexMap=new LinkedHashMap<>();
 		//鏍规嵁鍒嗙被妯℃澘缁勭粐鏁版嵁
@@ -2652,6 +2704,7 @@
 			throw new   Throwable("缁勭粐鏁版嵁鏄犲皠鍊煎け璐�");
 		}
 	}
+
 	/***
 	 * 璁板綍鏃ュ織淇℃伅
 	 * @param systemId
@@ -2683,7 +2736,7 @@
 			dockingLoge.setInterfaceStatus("false");//鎺ュ彛闆嗘垚鐘舵��
 		}
 		dockingLogeService.save(dockingLoge);
-		log.info("闆嗘垚鎺ㄩ�佹暟鎹垚鍔�,systemId:"+systemId+",systemname:"+systemName+",operation:"+operation+",param:"+parmaData);
+		log.info("闆嗘垚鎺ㄩ�佹暟鎹�,systemId:"+systemId+",systemname:"+systemName+",operation:"+operation+",param:"+parmaData);
 	}
 
 	/***

--
Gitblit v1.9.3