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 |   24 +++++++++++++-----------
 1 files changed, 13 insertions(+), 11 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 2817e78..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());
@@ -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();
@@ -967,7 +968,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());
@@ -977,7 +978,7 @@
 								xDOs.add(x);
 							}
 						});
-					}).join();
+					//}).join();
 					resultDataObjectDetailDOs.addAll(xDOs);
 					boolean finalSuccess1 = success.get();
 					String finalMessage1 = message;
@@ -2731,7 +2732,7 @@
 							String dataValue = sourceKeyValueMap.get(sourceKey);
 							if (attrMapConfigMap.containsKey(sourceKey)) {
 								String targetKey = attrMapConfigMap.get(sourceKey);
-								log.info("xxxxx灞炴�ф槧灏勫��:sourceKey銆�"+sourceKey+"銆戔�斺�斻��+targetKey"+targetKey+":"+dataValue);
+								log.info("xxxxx灞炴�ф槧灏勫��:sourceKey銆�"+sourceKey+"銆戔�斺�斻��+targetKey---銆�"+targetKey+":"+dataValue);
 								keyValueMap.put(targetKey, StringUtils.isBlank(dataValue)?"":dataValue);
 							}
 						});
@@ -2865,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