From 3534b13391b2a6152d0f91b72fda343b13a947cb Mon Sep 17 00:00:00 2001
From: ludc <ludc@vci-tech.com>
Date: 星期三, 22 一月 2025 15:55:27 +0800
Subject: [PATCH] 分类码段码值管理查询去除null的情况,分类码段生成编码时去除码值为null的情况

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/UniversalInterfaceImpl.java |   58 ++++++++++++++++++++++++++++++----------------------------
 1 files changed, 30 insertions(+), 28 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 e47f645..0996090 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
@@ -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());
@@ -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();
@@ -940,34 +941,34 @@
 								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 ");
-								sqlsb.append(tableName);
-								sqlsb.append(" where 1=1 ");
-								sqlsb.append(" and lastr=1 and lastv=1");
-								sqlsb.append(" and id in (");
-								sqlsb.append(VciBaseUtil.toInSql(code));
-								sqlsb.append(")");
-								List<Map<String, String>> newDataMapList = commonsMapper.queryByOnlySqlForMap(sqlsb.toString());
-								if (!CollectionUtils.isEmpty(newDataMapList)) {
-									String oid = StringUtils.isBlank(newDataMapList.get(0).get("OID")) ? "" : newDataMapList.get(0).get("OID");
-									List<String> oidList = new ArrayList<>();
-									oidList.add(oid);
-									//濡傛灉鏈夌敵璇峰氨鍘昏皟鐢ㄧ敵璇烽泦鍥㈢爜
-									if (isPersonApplyGroupCode) {
-										mdmIOService.sendApplyGroupcode(oidList, templateVO.getBtmTypeId(), sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue());
-										success.set(true);
-										mesg = "鏁版嵁淇濆瓨鎴愬姛锛岀瓑寰呯敵璇烽泦鍥㈢爜";
+								/*if(StringUtils.isNotBlank(code)) {
+									//rowData.setCode(code);
+									StringBuffer sqlsb = new StringBuffer();
+									sqlsb.append(" select * from ");
+									sqlsb.append(tableName);
+									sqlsb.append(" where 1=1 ");
+									sqlsb.append(" and lastr=1 and lastv=1");
+									sqlsb.append(" and id in (");
+									sqlsb.append(VciBaseUtil.toInSql(code));
+									sqlsb.append(")");
+									List<Map<String, String>> newDataMapList = commonsMapper.queryByOnlySqlForMap(sqlsb.toString());
+									if (!CollectionUtils.isEmpty(newDataMapList)) {
+										String oid = StringUtils.isBlank(newDataMapList.get(0).get("OID")) ? "" : newDataMapList.get(0).get("OID");
+										List<String> oidList = new ArrayList<>();
+										oidList.add(oid);
+										//濡傛灉鏈夌敵璇峰氨鍘昏皟鐢ㄧ敵璇烽泦鍥㈢爜
+										if (isPersonApplyGroupCode) {
+											mdmIOService.sendApplyGroupcode(oidList, templateVO.getBtmTypeId(), sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue());
+											success.set(true);
+											mesg = "鏁版嵁淇濆瓨鎴愬姛锛岀瓑寰呯敵璇烽泦鍥㈢爜";
+										}
 									}
-								}
-							}*/
+								}*/
 							} 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());
@@ -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