From c2efc1b0dfe76f5603dee63a917d3b7415053330 Mon Sep 17 00:00:00 2001
From: ludc
Date: 星期二, 31 十月 2023 11:30:42 +0800
Subject: [PATCH] 主数据统计功能后台接口实现

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyServiceImpl.java |   56 +++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 43 insertions(+), 13 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 66505ab..50de8a3 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
@@ -2,6 +2,7 @@
 
 import com.alibaba.nacos.common.utils.StringUtils;
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -13,6 +14,7 @@
 import com.vci.ubcs.code.enumpack.FrameworkDataLCStatus;
 import com.vci.ubcs.code.mapper.CodeClassifyMapper;
 import com.vci.ubcs.code.mapper.CodeClassifyTemplateMapper;
+import com.vci.ubcs.code.mapper.CommonsMapper;
 import com.vci.ubcs.code.po.CodeClassifyPO;
 import com.vci.ubcs.code.service.ICodeClassifyService;
 import com.vci.ubcs.code.service.ICodeKeyAttrRepeatService;
@@ -69,6 +71,7 @@
 import java.util.stream.Stream;
 
 import static com.vci.ubcs.code.constant.FrameWorkDefaultValueConstant.*;
+import static com.vci.ubcs.starter.web.util.VciBaseUtil.getTableName;
 
 @Service
 public class CodeClassifyServiceImpl extends ServiceImpl<CodeClassifyMapper, CodeClassify> implements ICodeClassifyService {
@@ -84,6 +87,9 @@
 
 	@Resource
 	private IBtmTypeClient btmTypeClient;
+
+	@Resource
+	private CommonsMapper commonsMapper;
 
 	/**
 	 * 鏃ュ織
@@ -442,7 +448,7 @@
 		List<CodeClassifyVO> voList = new ArrayList<CodeClassifyVO>();
 		if(!CollectionUtils.isEmpty(codeClassifys)){
 			for(CodeClassify s: codeClassifys){
-				CodeClassifyVO vo =  codeClassifyDO2VO(s);
+				CodeClassifyVO vo = codeClassifyDO2VO(s);
 				if(vo != null){
 					voList.add(vo);
 				}
@@ -522,20 +528,21 @@
 			lcStatus = treeQueryObject.getConditionMap().getOrDefault("lcStatus",null);
 		}
 		if(StringUtils.isNotBlank(id) || StringUtils.isNotBlank(lcStatus) ){
+			String tableName = this.getTableName(treeQueryObject.getParentOid(),treeQueryObject.getConditionMap().get("id"), treeQueryObject.getConditionMap().get("lcStatus"));
 			doList = codeClassifyMapper
-				.selectCodeClassifyDOByTree(treeQueryObject.getConditionMap().get("id"),treeQueryObject.getConditionMap().get("lcStatus"),treeQueryObject.getParentOid(), AuthUtil.getTenantId()
-					.equals(
-						NacosConfigCache
-							.getAdminUserInfo()
-							.getTenantId()
-					) ? null:AuthUtil.getTenantId());
+				.selectCodeClassifyDOByTree(
+					treeQueryObject.getConditionMap().get("id"),
+					treeQueryObject.getConditionMap().get("lcStatus"),
+					treeQueryObject.getParentOid(),
+					VciBaseUtil.checkAdminTenant() ? null:AuthUtil.getTenantId(),
+					tableName
+				);
 		}else{
-			doList =codeClassifyMapper.selectCodeClassifyVOByTree(treeQueryObject.getParentOid(), AuthUtil.getTenantId()
-				.equals(
-					NacosConfigCache
-						.getAdminUserInfo()
-						.getTenantId()
-				) ? null:AuthUtil.getTenantId());
+			// 鍙鍓嶇浼氫紶鍙傛暟杩囨潵灏变笉浼氬嚭鐜拌蛋杩欏彞鐨勬儏鍐碉紝鎵�浠ユ煡璇㈡�绘暟娌″湪杩欏効娣诲姞
+			doList =codeClassifyMapper.selectCodeClassifyVOByTree(
+				treeQueryObject.getParentOid(),
+				VciBaseUtil.checkAdminTenant() ? null:AuthUtil.getTenantId()
+			);
 		}
 		List<CodeClassifyVO> voList = codeClassifyDO2VOs(doList);
 		TreeWrapperOptions treeWrapperOptions = new TreeWrapperOptions(PARENT_FIELD_NAME);
@@ -545,6 +552,7 @@
 			return s.getId() + " " + s.getName() + (FrameworkDataLCStatus.DISABLED.getValue().equalsIgnoreCase(s
 				.getLcStatus()) ? (" 銆愬仠鐢ㄣ�� ") : "");
 		});
+
 		Iterator var6 =  tree.listIterator();
 		while(var6.hasNext()){
 			Tree trees = (Tree) var6.next();
@@ -559,6 +567,28 @@
 	}
 
 	/**
+	 * 鍒嗙被鍔犺浇鏃惰幏鍙栦笟鍔$被鍨媔d锛屾嫾鎺ヤ笟鍔$被鍨嬭〃鍚�
+	 * @return
+	 */
+	private String getTableName(String parentCodeClassifyOid,String id,String lcStatus){
+		LambdaQueryWrapper<CodeClassify> wrapper = Wrappers.<CodeClassify>query()
+			.lambda().select(CodeClassify::getBtmTypeId)
+			.eq(CodeClassify::getLcStatus, lcStatus)
+			.isNotNull(CodeClassify::getBtmTypeId)
+			.last("limit 1");
+		if(Func.isNotBlank(id)){
+			wrapper.eq(CodeClassify::getId,id).isNull(CodeClassify::getParentCodeClassifyOid);
+		}else{
+			wrapper.eq(CodeClassify::getParentCodeClassifyOid,parentCodeClassifyOid);
+		}
+		CodeClassify codeClassify = codeClassifyMapper.selectOne(wrapper);
+		if(Func.isEmpty(codeClassify) || Func.isEmpty(codeClassify.getBtmTypeId())){
+			throw new ServiceException("鏌ヨ涓绘暟鎹�绘暟鏃讹紝鏈幏鍙栦笟鍔$被鍨婭D锛�");
+		}
+		return VciBaseUtil.getTableName(codeClassify.getBtmTypeId().toLowerCase(Locale.ROOT),true);
+	}
+
+	/**
 	 * 鏍规嵁鏍戝舰鏌ヨ瀵硅薄鏉ユ煡璇㈡暟鎹璞�
 	 *
 	 * @param treeQueryObject 鏍戝舰鏌ヨ瀵硅薄

--
Gitblit v1.9.3