From 6cfff55d44314e88fefd6e3adb290ec16b303f89 Mon Sep 17 00:00:00 2001
From: 黎星凯 <13949086503@163.com>
Date: 星期五, 05 一月 2024 10:42:53 +0800
Subject: [PATCH] 1、供产品导数据临时用(用户，机构，部门，仓库，库管员 可删) 2、选择库管员增加过滤参数
---
consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java | 94 +++++++++++++++++++++++++++++++++--------------
1 files changed, 66 insertions(+), 28 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java
index 7551184..a612b3f 100644
--- a/consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java
@@ -1,14 +1,19 @@
package com.consum.base.service.impl;
-import com.consum.base.service.FinSysTenantUserService;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import org.apache.commons.compress.utils.Lists;
import org.springframework.stereotype.Service;
+import com.consum.base.core.utils.MapUtils;
+import com.consum.base.core.utils.MapperUtil;
+import com.consum.base.core.utils.PageUtil;
import com.consum.base.pojo.FinSysTenantUserSearchParam;
+import com.consum.base.pojo.response.FinSysTenantUserVO;
+import com.consum.base.service.FinSysTenantUserService;
import com.consum.model.po.FinSysTenantUser;
import com.iplatform.base.util.PlatformRSAUtils;
import com.iplatform.core.util.AESUtils;
@@ -24,7 +29,9 @@
private static final String SQL_GET_USER =
"SELECT * FROM fin_sys_tenant_user WHERE IS_DELETE = 0 AND `STATUS` = 1 AND TENANT_ID = ?";
private static final String SQL_QH_PAGE_USER_PREFIX =
- "select fstu.* from FIN_SYS_TENANT_USER fstu where fstu.IS_DELETE = 0 ";
+ "select fstu.id,fstu.USER_CODE,fstu.USER_NAME,fstu.USER_PHONE,fst.name tenantName,fstd.name sysDeptName,fstu.STATUS from FIN_SYS_TENANT_USER fstu "
+ + "left join fin_sys_tenant fst on fst.id =fstu.TENANT_ID "
+ + "left join fin_sys_tenant_department fstd on fstd.id = fstu.SYS_DEPT_ID where fstu.IS_DELETE = 0 ";
private static final String SQL_TENANT_USER =
"select fstu.*, fst.TENANT_NAME, fst.LV from FIN_SYS_TENANT_USER fstu\n"
@@ -36,13 +43,7 @@
private static final String SQL_DELETE_ROLE_USER = "DELETE FROM S_ROLE_USER WHERE USER_ID =?";
- /**
- * 鏍规嵁鐢ㄦ埛id鍜岃鑹瞚d鍒犻櫎瑙掕壊
- */
- private static final String SQL_DELETE_ROLE_BY_USER_ID_AND_ROLE_ID =
- "DELETE FROM S_ROLE_USER WHERE USER_ID =? AND role_id =?";
-
- private static final String SQL_SELECT_USER_CODE = "SELECT * FROM FIN_SYS_TENANT_USER where 1 = 1 ";
+ private static final String SQL_SELECT_USER_CODE = "SELECT * FROM FIN_SYS_TENANT_USER where STATUS =1 ";
private static final String SQL_SELECT_USER_ID = "SELECT * FROM S_ROLE where 1=1 ";
private static final String SQL_DEPT_ROLES = "select * from s_dept where status=0 and del_flag=0";
@@ -53,8 +54,8 @@
* @Date 2023/7/17 14:26
*/
@Override
- public GenericPager<FinSysTenantUser> queryAllPageUser(FinSysTenantUserSearchParam param) {
- Map<String, Object> parameter = new HashMap<>(5);
+ public PageUtil<FinSysTenantUserVO> queryAllPageUser(FinSysTenantUserSearchParam param) {
+ Map<String, Object> parameter = new HashMap<>(10);
StringBuilder sql = new StringBuilder(SQL_QH_PAGE_USER_PREFIX);
if (param.getTenantCode() > 0) {
sql.append(" and fstu.TENANT_CODE =:tenantCode");
@@ -72,19 +73,11 @@
sql.append(" and USER_CODE like :USER_CODE");
parameter.put("USER_CODE", StringUtils.CHAR_PERCENT + param.getUserCode() + StringUtils.CHAR_PERCENT);
}
- // if(StringUtils.isNotEmpty(param.getUserCode())){
- // sql.append(" and user_code like :user_code");
- // parameter.put("user_code", StringUtils.CHAR_PERCENT + param.getUserCode() + StringUtils.CHAR_PERCENT);
- // }
+
if (param.getStatus() != null) {
- sql.append(" and status =:status");
+ sql.append(" and fstu.status =:status");
parameter.put("status", param.getStatus());
}
-
- // if(param.getRoleId()!=null &&!param.getRoleId().equals("")){
- // sql.append(" and fstu.SYS_USER_ID in (select user_id from s_role_user where role_id = :role_id)");
- // parameter.put("role_id", param.getRoleId());
- // }
if (StringUtils.isNotEmpty(param.getUserPhone())) {
sql.append(" and USER_PHONE =:userPhone");
@@ -117,8 +110,19 @@
sql.append(" and fstu.AGENT_JID is null ");
}
}
- sql.append(" ORDER BY SEQ asc ,CREATE_TIME desc");
- return this.selectSplit(sql.toString(), parameter, new FinSysTenantUser());
+ sql.append(" ORDER BY SEQ asc ,fstu.CREATE_TIME desc");
+
+ GenericPager<Map<String, Object>> mapGenericPager =
+ this.selectSplit(sql.toString(), parameter, param.getPageNum(), param.getPageSize(), new MapperUtil());
+ PageUtil pageUtil = new PageUtil(mapGenericPager);
+
+ List<FinSysTenantUserVO> result = Lists.newArrayList();
+ mapGenericPager.getDatas().forEach(map -> {
+ FinSysTenantUserVO finSysTenantUserVO = MapUtils.convertMapToObj(map, FinSysTenantUserVO.class);
+ result.add(finSysTenantUserVO);
+ });
+ pageUtil.setDatas(result);
+ return pageUtil;
}
@Override
@@ -201,8 +205,6 @@
this.execBatchUpdate(SQL_DELETE_ROLE_USER, parameters);
}
-
-
/**
* 鏍规嵁userCode鏌ヨ閲嶅銆�
*
@@ -226,10 +228,10 @@
* @return
*/
@Override
- public List<S_role> getByUserId(Long userId) {
+ public List<S_role> getRoleBySysUserId(Long userId) {
Map<String, Object> parameter = new HashMap<>();
- StringBuilder sql = new StringBuilder(SQL_SELECT_USER_ID);
- sql.append("and ROLE_ID IN (SELECT DISTINCT(ROLE_ID) FROM S_ROLE_USER WHERE USER_ID= :userId )");
+ StringBuilder sql = new StringBuilder("SELECT * FROM S_ROLE where ");
+ sql.append("ROLE_ID IN (SELECT DISTINCT(ROLE_ID) FROM S_ROLE_USER WHERE USER_ID= :userId )");
parameter.put("userId", userId);
List<S_role> select = this.select(sql.toString(), parameter, new S_role());
return select;
@@ -267,4 +269,40 @@
public List<FinSysTenantUser> getByOrgId(Long orgId) {
return this.select(SQL_GET_USER, new Object[] {orgId}, new FinSysTenantUser());
}
+
+ @Override
+ public GenericPager<S_role> queryPageRoleList(Long orgId, Integer status, String roleName, Integer dataScope,
+ Integer pageNum, Integer pageSize) {
+ Map<String, Object> parameters = new HashMap();
+ StringBuilder sql = new StringBuilder("select * from s_role where org_id=:orgId");
+ parameters.put("orgId", orgId);
+ if (status >= 0) {
+ sql.append(" and status=:status");
+ parameters.put("status", status);
+ }
+
+ if (dataScope != null) {
+ sql.append(" and data_scope >=:dataScope");
+ parameters.put("dataScope", dataScope);
+ }
+
+ if (com.walker.infrastructure.utils.StringUtils.isNotEmpty(roleName)) {
+ sql.append(" and role_name like :roleName");
+ parameters.put("roleName", "%" + roleName + "%");
+ }
+
+ return this.selectSplit(sql.toString(), parameters, pageNum, pageSize, new S_role());
+ }
+
+ @Override
+ public FinSysTenantUser getByTenaniId(String tenantId,String userCode) {
+ Map<String, Object> parameter = new HashMap<>();
+ StringBuilder sql = new StringBuilder(SQL_SELECT_USER_CODE);
+ sql.append(" and TENANT_ID= :tenantId");
+ parameter.put("tenantId", tenantId);
+ sql.append(" and USER_CODE= :userCode");
+ parameter.put("userCode", userCode);
+ FinSysTenantUser finSysTenantUser = this.get(sql.toString(), parameter, new FinSysTenantUser());
+ return finSysTenantUser;
+ }
}
--
Gitblit v1.9.1