From d9183aa80ae17d36b79dda48c6b1d7fa22a80ee3 Mon Sep 17 00:00:00 2001
From: xiejun <xiejun@vci-tech.com>
Date: 星期三, 22 一月 2025 11:20:41 +0800
Subject: [PATCH] 现场型号代号/人员/组织接口调试

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java |   52 +++++++++++++++++++++++++++++-----------------------
 1 files changed, 29 insertions(+), 23 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 70b78a1..1921a91 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
@@ -559,7 +559,7 @@
 						object.setOperate("create");
 						applyDataVOList.add(object);
 					}
-					codeList.add(personMasterData.getLm_code());
+					codeList.add(object.getCode());
 				});
 
 				R<BtmTypeVO> r = btmTypeClient.getAllAttributeByBtmId(templateVO.getBtmTypeId());
@@ -614,8 +614,8 @@
 					DataObjectVO dataObjectVO = new DataObjectVO();
 					this.getConfigDatas(systemCode, personLibrary, editDatasVO, attrVOS, dataObjectVO);
 					log.info("start锛氫慨鏀规暟鎹墽琛屽畬姣�");
-					boolean  personApplyGroupCode =personAndDeptConfig.isPersonApplyGroupCode();
-					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,personApplyGroupCode);
+				//	boolean  personApplyGroupCode =personAndDeptConfig.isPersonApplyGroupCode();
+					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,isPersonApplyGroupCode);
 					log.info("end锛氫慨鏀规暟鎹墽琛屽畬姣�");
 				}
 				if(applyDatasVO.getObject()!=null&&applyDatasVO.getObject().size()>0) {
@@ -680,7 +680,7 @@
 							log.error("鏁版嵁淇濆瓨澶辫触:",e);
 							mesg=e.getMessage();
 							e.printStackTrace();
-							throw new ServiceException(e.getMessage());
+						//	throw new ServiceException(e.getMessage());
 						}finally {
 							XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO();
 							x.setId(rowData.getOid());
@@ -806,10 +806,10 @@
 				List<ApplyDataVO> deleteDataVOList=new ArrayList<>();
 				orgMasterDataList.stream().forEach(orgMasterData -> {
 					ApplyDataVO object=new ApplyDataVO();
-					object.setCode(orgMasterData.getMdm_code());//缂栫爜
+					object.setCode(orgMasterData.getDepartment_code());//缂栫爜
 					object.setCreator(orgMasterData.getCreator());//鍒涘缓鑰�
 					object.setEditor(orgMasterData.getModifier());//淇敼鑰�
-					object.setId(orgMasterData.getDepartment_code());//涓婚敭
+					object.setId(orgMasterData.getId());//涓婚敭
 					object.setStatus(CodeDefaultLC.RELEASED.getValue());//鐘舵�佸垯闇�瑕佸垽鏂�
 					Map<String,String> dataMap= VciBaseUtil.objectToMapString(orgMasterData);
 					List<ProppertyVO> proppertyVOList = new ArrayList<>();
@@ -844,7 +844,7 @@
 						object.setOperate("create");
 						applyDataVOList.add(object);
 					}
-					codeList.add(orgMasterData.getMdm_code());
+					codeList.add(object.getCode());
 				});
 
 				R<BtmTypeVO> r = btmTypeClient.getAllAttributeByBtmId(templateVO.getBtmTypeId());
@@ -899,7 +899,7 @@
 					DataObjectVO dataObjectVO = new DataObjectVO();
 					this.getConfigDatas(systemCode, deptLibrary, editDatasVO, attrVOS, dataObjectVO);
 					log.info("start锛氫慨鏀规暟鎹墽琛屽畬姣�");
-					boolean personApplyGroupCode = personAndDeptConfig.isPersonApplyGroupCode();
+					boolean personApplyGroupCode = false;//personAndDeptConfig.isPersonApplyGroupCode();
 					mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,personApplyGroupCode);
 					log.info("end锛氫慨鏀规暟鎹墽琛屽畬姣�");
 				}
@@ -914,8 +914,9 @@
 					}
 					List<XMLResultDataObjectDetailDO> xDOs=new CopyOnWriteArrayList<>();
 					//闄愬埗绾跨▼骞惰鏁伴噺
-					customForkJoinPool.submit(()->{
-						dataObjectVO.getRowData().parallelStream().forEach(rowData->{
+					//customForkJoinPool.submit(()->{
+					//	dataObjectVO.getRowData().parallelStream().forEach(rowData->{
+					dataObjectVO.getRowData().forEach(rowData->{
 							String mesg="";
 							try {
 								CodeOrderDTO orderDTO = new CodeOrderDTO();
@@ -931,7 +932,7 @@
 											//瑙勫垯涔嬪畾涔変负鍙彉鐮佹瀛樺偍涓绘暟鎹紶閫掕繃鏉ョ殑鏁版嵁
 											CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO();
 											CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid());
-											CodeOrderSecDTO.setSecValue(rowData.getOid());
+											CodeOrderSecDTO.setSecValue(rowData.getCode());
 											codeOrderSecDTOList.add(CodeOrderSecDTO);
 										}
 									});
@@ -964,9 +965,10 @@
 								}
 							}*/
 							} catch (Exception e) {
+								log.error( "閮ㄩ棬鏁版嵁鎺ユ敹澶辫触:",e);
 								mesg=e.getMessage();
 								e.printStackTrace();
-								throw new ServiceException(e.getMessage());
+							//	throw new ServiceException(e.getMessage());
 							}finally {
 								XMLResultDataObjectDetailDO x=new XMLResultDataObjectDetailDO();
 								x.setId(rowData.getOid());
@@ -976,7 +978,7 @@
 								xDOs.add(x);
 							}
 						});
-					}).join();
+					//}).join();
 					resultDataObjectDetailDOs.addAll(xDOs);
 					boolean finalSuccess1 = success.get();
 					String finalMessage1 = message;
@@ -2474,17 +2476,21 @@
 						String buildSqlwhere="";
 						List<CodeSectionValueVO> codeSectionValueVOList=new ArrayList<>();
 						if(coderefersecSearchVO!=null) {
+							Map<String, Object> condtionMap = new HashMap<>();
+							String valueField= coderefersecSearchVO.getValueField();
+							if(StringUtils.isNotBlank(valueField)){
+								condtionMap.put(valueField,sectypeValue);
+							}
 							if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.DEFAULT.getValue()) || coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.GRID.getValue())) {//榛樿鏍峰紡/鍒楄〃
-								Map<String, Object> condtionMap = new HashMap<>();
 								List<CodeSrchCondConfigVO> codeSrchCondConfigVOList = coderefersecSearchVO.getCodeSrchCondConfigVOS();
-
 								if (!CollectionUtils.isEmpty(codeSrchCondConfigVOList)) {
 									codeSrchCondConfigVOList.stream().forEach(codeSrchCondConfigVO -> {
 										condtionMap.put(codeSrchCondConfigVO.getFilterField() + codeSrchCondConfigVO.getFilterType(), codeSrchCondConfigVO.getFilterValue());
 									});
+								}
+								if(!CollectionUtils.isEmpty(condtionMap)) {
 									buildSqlwhere = UBCSSqlKeyword.buildSqlwhere(condtionMap);
 								}
-
 								//浣跨敤浼犲叆鐨勪笟鍔$被鍨嬫煡璇㈣〃
 								R<List<BtmTypeVO>> listR = btmTypeClient.selectByIdCollection(Collections.singletonList(referBtmId));
 								if (!listR.isSuccess() || listR.getData().size() == 0) {
@@ -2499,7 +2505,7 @@
 									sb.append(buildSqlwhere);
 								}
 								List<Map> ListMap = commonsMapper.selectBySql(sb.toString());
-								String valueField = coderefersecSearchVO.getValueField();
+								//String valueField = coderefersecSearchVO.getValueField();
 								String textField = coderefersecSearchVO.getTextField();
 								final int[] num = {0};
 								if (!CollectionUtils.isEmpty(ListMap)) {
@@ -2514,8 +2520,6 @@
 									});
 								}
 							}else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.TREE.getValue())) {//鏍戝舰
-								Map<String, Object> condtionMap = new HashMap<>();
-
 								//浣跨敤浼犲叆鐨勪笟鍔$被鍨嬫煡璇㈣〃
 								R<List<BtmTypeVO>> listR = btmTypeClient.selectByIdCollection(Collections.singletonList(referBtmId));
 								if (!listR.isSuccess() || listR.getData().size() == 0) {
@@ -2532,9 +2536,10 @@
 									codeSrchCondConfigVOList.stream().forEach(codeSrchCondConfigVO -> {
 										condtionMap.put(codeSrchCondConfigVO.getFilterField() + codeSrchCondConfigVO.getFilterType(), codeSrchCondConfigVO.getFilterValue());
 									});
+								}
+								if(!CollectionUtils.isEmpty(condtionMap)) {
 									buildSqlwhere = UBCSSqlKeyword.buildSqlwhere(condtionMap);
 								}
-
 								//if("all".equals(coderefersecSearchVO.getLoadType())) {
 								String parentOidSql = "";
 								if(StringUtils.isNotBlank(parentValue)){
@@ -2581,7 +2586,6 @@
 									sb.append(buildSqlwhere);
 								}
 								List<Map> ListMap = commonsMapper.selectBySql(sb.toString());
-								String valueField = coderefersecSearchVO.getValueField();
 								String textField = coderefersecSearchVO.getTextField();
 								final int[] num = {0};
 								if (!CollectionUtils.isEmpty(ListMap)) {
@@ -2601,11 +2605,11 @@
 						if(!CollectionUtils.isEmpty(codeSectionValueVOList)){
 							Map<String, CodeSectionValueVO> codeSectionValueVOMap = codeSectionValueVOList.stream().collect(Collectors.toMap(s -> s.getValue(), t -> t, (o1, o2) -> o2));
 							if(!codeSectionValueVOMap.containsKey(sectypeValue)){
-								message="浼犲叆鐨勭紪鐮佽鍒欑爜娈�:銆�"+name+"銆戜负"+CODE_REFER_SEC.getText()+",鍏跺搴旂殑鍊硷紝鍦ㄧ紪鐮佺郴缁熶笉瀛樺湪";
+								message="浼犲叆鐨勭紪鐮佽鍒欑爜娈�:銆�"+name+"銆戜负"+CODE_REFER_SEC.getText()+",鍏跺搴旂殑鍊笺��"+sectypeValue+"銆戯紝鍦ㄧ紪鐮佺郴缁熶笉瀛樺湪";
 								errorMap.put("error",errorMap.getOrDefault("error","")+";"+message);
 							}
 						}else{
-							message="浼犲叆鐨勭紪鐮佽鍒欑爜娈�:銆�"+name+"銆戜负"+CODE_REFER_SEC.getText()+",鍏跺搴旂殑鍊硷紝鍦ㄧ紪鐮佺郴缁熶笉瀛樺湪";
+							message="浼犲叆鐨勭紪鐮佽鍒欑爜娈�:銆�"+name+"銆戜负"+CODE_REFER_SEC.getText()+",鍏跺搴旂殑鍊笺��"+sectypeValue+"銆戯紝鍦ㄧ紪鐮佺郴缁熶笉瀛樺湪";
 							errorMap.put("error",errorMap.getOrDefault("error","")+";"+message);
 						}
 					}
@@ -2728,6 +2732,7 @@
 							String dataValue = sourceKeyValueMap.get(sourceKey);
 							if (attrMapConfigMap.containsKey(sourceKey)) {
 								String targetKey = attrMapConfigMap.get(sourceKey);
+								log.info("xxxxx灞炴�ф槧灏勫��:sourceKey銆�"+sourceKey+"銆戔�斺�斻��+targetKey---銆�"+targetKey+":"+dataValue);
 								keyValueMap.put(targetKey, StringUtils.isBlank(dataValue)?"":dataValue);
 							}
 						});
@@ -2861,6 +2866,7 @@
 							String dataValue = sourceKeyValueMap.get(sourceKey);
 							if (attrMapConfigMap.containsKey(sourceKey)) {
 								String targetKey = attrMapConfigMap.get(sourceKey);
+								log.info("xxxxx灞炴�ф槧灏勫��:sourceKey銆�"+sourceKey+"銆戔�斺�斻��+targetKey---銆�"+targetKey+":"+dataValue);
 								keyValueMap.put(targetKey, StringUtils.isBlank(dataValue)?"":dataValue);
 							}
 						});

--
Gitblit v1.9.3