From b11b45122d2b6903e8970e8d55712f7a6a657e22 Mon Sep 17 00:00:00 2001
From: ludc
Date: 星期三, 10 一月 2024 00:01:10 +0800
Subject: [PATCH] defaultReferDataGrid接口修改,实现兼容高级查询sql拼接;修改流水处理接口,增加流水处理跳出判断

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java |  100 ++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 88 insertions(+), 12 deletions(-)

diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java
index 891948a..ad4b63b 100644
--- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java
@@ -49,6 +49,7 @@
 import com.vci.ubcs.starter.web.util.LangBaseUtil;
 import com.vci.ubcs.starter.web.util.VciBaseUtil;
 import com.vci.ubcs.system.cache.NacosConfigCache;
+import com.vci.ubcs.system.feign.ISysClient;
 import org.apache.poi.hssf.util.HSSFColor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -92,7 +93,7 @@
 	private IBtmTypeClient btmTypeClient;
 
 	@Resource
-	private CommonsMapper commonsMapper;
+	private ISysClient sysClient;
 
 	/**
 	 * 鏃ュ織
@@ -582,18 +583,67 @@
 			return s.getId() + " " + s.getName() + (FrameworkDataLCStatus.DISABLED.getValue().equalsIgnoreCase(s
 				.getLcStatus()) ? (" 銆愬仠鐢ㄣ�� ") : "");
 		});
-
-		Iterator var6 =  tree.listIterator();
-		while(var6.hasNext()){
-			Tree trees = (Tree) var6.next();
-			boolean checkHasChild=codeClassifyMapper.checkHasChild(trees.getOid());
-			if(checkHasChild){
-				trees.setLeaf(false);
-			}else{
-				trees.setLeaf(true);
+		//瓒呯鏄剧ず鎵�鏈夊垎绫�
+		if(VciBaseUtil.checkAdminTenant()){
+			Iterator var6 =  tree.listIterator();
+			while(var6.hasNext()){
+				Tree trees = (Tree) var6.next();
+				boolean checkHasChild=codeClassifyMapper.checkHasChild(trees.getOid());
+				if(checkHasChild){
+					trees.setLeaf(false);
+				}else{
+					trees.setLeaf(true);
+				}
 			}
+		}else {
+			// 閭d簺鍒嗙被鍏峰鏌ョ湅鏉冮檺
+			R<List<String>> viewClassByRoleIds = sysClient.getViewClassByRoleIds(Arrays.asList(AuthUtil.getUser().getRoleId().split(",")));
+			// 璇锋眰澶辫触鎴栬�呰姹傚緱鍒扮殑鍏峰鏌ョ湅鏉冮檺鐨勫垎绫籭d闆嗗悎涓虹┖
+			if(!viewClassByRoleIds.isSuccess() && !viewClassByRoleIds.getData().isEmpty()){
+				return new ArrayList<>();
+			}
+			// 杩囨护
+			filterTreeNodes(tree,viewClassByRoleIds.getData());
 		}
 		return tree;
+	}
+
+	/**
+	 * 鍒嗙被鎺堟潈杩囨护鎺夋病鏈夋潈闄愮殑鍒嗙被
+	 * @param trees
+	 * @param classifyIds
+	 */
+	private void filterTreeNodes(List<Tree> trees, List<String> classifyIds) {
+		Iterator<Tree> iterator = trees.iterator();
+		while (iterator.hasNext()) {
+			Tree tree = iterator.next();
+			Boolean checkHasChild = codeClassifyMapper.checkHasChild(tree.getOid());
+			tree.setLeaf(!checkHasChild);
+			if (classifyIds.contains(tree.getOid())) {
+				// 濡傛灉椤跺眰鑺傜偣瀛樺湪浜� classifyIds 涓紝鐩存帴淇濈暀鍏跺瓙鑺傜偣闆嗗悎
+				continue;
+			}
+			if (tree.getChildren() != null && !tree.getChildren().isEmpty()) {
+				filterTreeNodes(tree.getChildren(), classifyIds);
+			}
+			if (!hasMatchingChild(tree, classifyIds)) {
+				iterator.remove();
+			}
+		}
+	}
+
+	private boolean hasMatchingChild(Tree tree, List<String> classifyIds) {
+		if (classifyIds.contains(tree.getOid())) {
+			return true;
+		}
+		if (tree.getChildren() != null) {
+			for (Tree child : tree.getChildren()) {
+				if (hasMatchingChild(child, classifyIds)) {
+					return true;
+				}
+			}
+		}
+		return false;
 	}
 
 	/**
@@ -688,7 +738,10 @@
 		if(codeClassifies.isEmpty()){
 			return "";
 		}
-		String oids = codeClassifies.stream().map(CodeClassify::getOid).collect(Collectors.joining(","));
+		String oids = codeClassifies.stream()
+			.map(CodeClassify::getOid)
+			.map(s -> "'" + s + "'")
+			.collect(Collectors.joining(","));;
 		return oids;
 	}
 
@@ -697,7 +750,6 @@
 	 */
 	@Override
 	public R flowingDependencyGen(String classifyOid) {
-
 		//鏌ヨ姝ゅ垎绫讳笅闈㈢殑鎵�鏈夊垎绫�
 		List<CodeClassify>  codeClassifyList=codeClassifyMapper.selectAllClassifyByOid(classifyOid,AuthUtil.getTenantId(),null);
 		//鏌ヨ鐮佸�艰〃锛岃幏鍙栨渶澶ф祦姘�
@@ -705,6 +757,17 @@
 			.map(classfiy -> classfiy.getOid()).collect(Collectors.joining("','")) + "'","'${sav}'");
 		//寰�娴佹按琛ㄩ噷闈㈠姞鏁版嵁锛屾湁鍒欐洿鏂帮紝鏃犲垯娣诲姞鏁版嵁銆�
 		for (CodeAllCode codeAllCodeVO : codeAllCodeVOS) {
+			if(Func.isEmpty(codeAllCodeVO.getSerialUnit())){
+				throw new ServiceException("缂栫爜涓猴細" + codeAllCodeVO.getId() + "鐨勭爜鍊兼暟鎹祦姘翠緷璧栦笉鑳戒负绌猴紒");
+			}
+			try {
+				CodeRuleVO codeRuleVO = codeRuleService.getObjectByOid(codeAllCodeVO.getCodeRuleOid());
+				if(Func.isEmpty(codeRuleVO)){
+					continue;
+				}
+			}catch (Exception e){
+				continue;
+			}
 			QueryWrapper<CodeBasicSec> secWrapper = new QueryWrapper<>();
 			secWrapper.eq("PKCODERULE",codeAllCodeVO.getCodeRuleOid());
 			secWrapper.eq("SECTYPE","codeserialsec");
@@ -1405,6 +1468,19 @@
 	}
 
 	/**
+	 * 鏌ヨ鎵�鏈変笂灞傜埗鑺傜偣鐨刼id
+	 * @param oid
+	 * @return
+	 */
+	@Override
+	public List<String> selectAllParentOid(String oid){
+		if(Func.isBlank(oid)){
+			return new ArrayList<>();
+		}
+		return this.codeClassifyMapper.selectAllParentOid(oid);
+	}
+
+	/**
 	 * 浣跨敤鍒嗙被涓婚敭鑾峰彇鍒嗙被鐩稿叧鐨勬墍鏈変俊鎭�
 	 *
 	 * @param codeClassifyOid 鍒嗙被鐨勪富閿�

--
Gitblit v1.9.3