权限数据
This commit is contained in:
parent
87a5eb59c6
commit
6f55def466
|
|
@ -75,5 +75,10 @@ public interface AuthRoleDataMapper {
|
|||
* @param ids 主键id集合
|
||||
*/
|
||||
void deleteByIds(@Param("ids") Collection<Long> ids);
|
||||
|
||||
|
||||
/**
|
||||
* 根据角色id删除
|
||||
* @param roleId roleId
|
||||
*/
|
||||
void deleteByRoleId(Long roleId);
|
||||
}
|
||||
|
|
@ -0,0 +1,297 @@
|
|||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
||||
<mapper namespace="com.engine.salary.mapper.auth.AuthRoleDataMapper">
|
||||
<resultMap id="BaseResultMap" type="com.engine.salary.entity.auth.po.AuthRoleDataPO">
|
||||
<result column="id" property="id"/>
|
||||
<result column="role_id" property="roleId"/>
|
||||
<result column="employee_id" property="employeeId"/>
|
||||
<result column="creator" property="creator"/>
|
||||
<result column="create_time" property="createTime"/>
|
||||
<result column="update_time" property="updateTime"/>
|
||||
<result column="delete_type" property="deleteType"/>
|
||||
<result column="tenant_key" property="tenantKey"/>
|
||||
</resultMap>
|
||||
|
||||
<!-- 表字段 -->
|
||||
<sql id="baseColumns">
|
||||
t
|
||||
.
|
||||
id
|
||||
, t.role_id
|
||||
, t.employee_id
|
||||
, t.creator
|
||||
, t.create_time
|
||||
, t.update_time
|
||||
, t.delete_type
|
||||
, t.tenant_key
|
||||
</sql>
|
||||
|
||||
<!-- 查询全部 -->
|
||||
<select id="listAll" resultMap="BaseResultMap">
|
||||
SELECT
|
||||
<include refid="baseColumns"/>
|
||||
FROM hrsa_auth_role_data t
|
||||
WHERE delete_type = 0
|
||||
</select>
|
||||
|
||||
<!-- 根据主键获取单条记录 -->
|
||||
<select id="getById" resultMap="BaseResultMap" parameterType="Long">
|
||||
SELECT
|
||||
<include refid="baseColumns"/>
|
||||
FROM hrsa_auth_role_data t
|
||||
WHERE id = #{id} AND delete_type = 0
|
||||
</select>
|
||||
|
||||
<!-- 条件查询 -->
|
||||
<select id="listSome" resultMap="BaseResultMap" parameterType="com.engine.salary.entity.auth.po.AuthRoleDataPO">
|
||||
SELECT
|
||||
<include refid="baseColumns"/>
|
||||
FROM hrsa_auth_role_data t
|
||||
WHERE delete_type = 0
|
||||
<if test="id != null">
|
||||
AND id = #{id}
|
||||
</if>
|
||||
<if test="roleId != null">
|
||||
AND role_id = #{roleId}
|
||||
</if>
|
||||
<if test="employeeId != null">
|
||||
AND employee_id = #{employeeId}
|
||||
</if>
|
||||
<if test="creator != null">
|
||||
AND creator = #{creator}
|
||||
</if>
|
||||
<if test="createTime != null">
|
||||
AND create_time = #{createTime}
|
||||
</if>
|
||||
<if test="updateTime != null">
|
||||
AND update_time = #{updateTime}
|
||||
</if>
|
||||
<if test="deleteType != null">
|
||||
AND delete_type = #{deleteType}
|
||||
</if>
|
||||
<if test="tenantKey != null">
|
||||
AND tenant_key = #{tenantKey}
|
||||
</if>
|
||||
<if test="ids != null and ids.size()>0">
|
||||
AND id IN
|
||||
<foreach collection="ids" open="(" item="id" separator="," close=")">
|
||||
#{id}
|
||||
</foreach>
|
||||
</if>
|
||||
ORDER BY id DESC
|
||||
</select>
|
||||
|
||||
|
||||
<!-- 插入不为NULL的字段 -->
|
||||
<insert id="insertIgnoreNull" parameterType="com.engine.salary.entity.auth.po.AuthRoleDataPO">
|
||||
INSERT INTO hrsa_auth_role_data
|
||||
<trim prefix="(" suffix=")" suffixOverrides=",">
|
||||
|
||||
<if test="id != null">
|
||||
id,
|
||||
</if>
|
||||
<if test="roleId != null">
|
||||
role_id,
|
||||
</if>
|
||||
<if test="employeeId != null">
|
||||
employee_id,
|
||||
</if>
|
||||
<if test="creator != null">
|
||||
creator,
|
||||
</if>
|
||||
<if test="createTime != null">
|
||||
create_time,
|
||||
</if>
|
||||
<if test="updateTime != null">
|
||||
update_time,
|
||||
</if>
|
||||
<if test="deleteType != null">
|
||||
delete_type,
|
||||
</if>
|
||||
<if test="tenantKey != null">
|
||||
tenant_key,
|
||||
</if>
|
||||
</trim>
|
||||
<trim prefix="VALUES (" suffix=")" suffixOverrides=",">
|
||||
<if test="id != null">
|
||||
#{id},
|
||||
</if>
|
||||
<if test="roleId != null">
|
||||
#{roleId},
|
||||
</if>
|
||||
<if test="employeeId != null">
|
||||
#{employeeId},
|
||||
</if>
|
||||
<if test="creator != null">
|
||||
#{creator},
|
||||
</if>
|
||||
<if test="createTime != null">
|
||||
#{createTime},
|
||||
</if>
|
||||
<if test="updateTime != null">
|
||||
#{updateTime},
|
||||
</if>
|
||||
<if test="deleteType != null">
|
||||
#{deleteType},
|
||||
</if>
|
||||
<if test="tenantKey != null">
|
||||
#{tenantKey},
|
||||
</if>
|
||||
</trim>
|
||||
</insert>
|
||||
|
||||
|
||||
<insert id="batchInsert">
|
||||
|
||||
INSERT INTO hrsa_auth_role_data
|
||||
(
|
||||
id,
|
||||
role_id,
|
||||
employee_id,
|
||||
creator,
|
||||
create_time,
|
||||
update_time,
|
||||
delete_type,
|
||||
tenant_key
|
||||
)
|
||||
VALUES
|
||||
|
||||
<foreach collection="collection" item="item" separator=",">
|
||||
(
|
||||
#{item.id},
|
||||
#{item.roleId},
|
||||
#{item.employeeId},
|
||||
#{item.creator},
|
||||
#{item.createTime},
|
||||
#{item.updateTime},
|
||||
#{item.deleteType},
|
||||
#{item.tenantKey}
|
||||
)
|
||||
</foreach>
|
||||
|
||||
</insert>
|
||||
|
||||
|
||||
<insert id="batchInsert" databaseId="oracle">
|
||||
INSERT INTO hrsa_auth_role_data (
|
||||
id,
|
||||
role_id,
|
||||
employee_id,
|
||||
creator,
|
||||
create_time,
|
||||
update_time,
|
||||
delete_type,
|
||||
tenant_key
|
||||
)
|
||||
|
||||
<foreach collection="collection" item="item" separator="union all">
|
||||
select
|
||||
#{item.id,jdbcType=DOUBLE},
|
||||
#{item.roleId,jdbcType=DOUBLE},
|
||||
#{item.employeeId,jdbcType=DOUBLE},
|
||||
#{item.creator,jdbcType=DOUBLE},
|
||||
#{item.createTime,jdbcType=DATE},
|
||||
#{item.updateTime,jdbcType=DATE},
|
||||
#{item.deleteType,jdbcType=INTEGER},
|
||||
#{item.tenantKey,jdbcType=VARCHAR}
|
||||
from dual
|
||||
</foreach>
|
||||
</insert>
|
||||
|
||||
|
||||
<insert id="batchInsert" databaseId="sqlserver">
|
||||
<foreach collection="collection" item="item" separator=";">
|
||||
INSERT INTO hrsa_auth_role_data (
|
||||
id,
|
||||
role_id,
|
||||
employee_id,
|
||||
creator,
|
||||
create_time,
|
||||
update_time,
|
||||
delete_type,
|
||||
tenant_key
|
||||
)
|
||||
VALUES
|
||||
(
|
||||
#{item.id},
|
||||
#{item.roleId},
|
||||
#{item.employeeId},
|
||||
#{item.creator},
|
||||
#{item.createTime},
|
||||
#{item.updateTime},
|
||||
#{item.deleteType},
|
||||
#{item.tenantKey}
|
||||
)
|
||||
</foreach>
|
||||
</insert>
|
||||
|
||||
<!-- 更新,更新全部字段 -->
|
||||
<update id="update" parameterType="com.engine.salary.entity.auth.po.AuthRoleDataPO">
|
||||
UPDATE hrsa_auth_role_data
|
||||
<set>
|
||||
role_id=#{roleId},
|
||||
employee_id=#{employeeId},
|
||||
creator=#{creator},
|
||||
create_time=#{createTime},
|
||||
update_time=#{updateTime},
|
||||
delete_type=#{deleteType},
|
||||
tenant_key=#{tenantKey},
|
||||
</set>
|
||||
WHERE id = #{id} AND delete_type = 0
|
||||
</update>
|
||||
|
||||
|
||||
<!-- 更新不为NULL的字段 -->
|
||||
<update id="updateIgnoreNull" parameterType="com.engine.salary.entity.auth.po.AuthRoleDataPO">
|
||||
UPDATE hrsa_auth_role_data
|
||||
<set>
|
||||
<if test="roleId != null">
|
||||
role_id=#{roleId},
|
||||
</if>
|
||||
<if test="employeeId != null">
|
||||
employee_id=#{employeeId},
|
||||
</if>
|
||||
<if test="creator != null">
|
||||
creator=#{creator},
|
||||
</if>
|
||||
<if test="createTime != null">
|
||||
create_time=#{createTime},
|
||||
</if>
|
||||
<if test="updateTime != null">
|
||||
update_time=#{updateTime},
|
||||
</if>
|
||||
<if test="deleteType != null">
|
||||
delete_type=#{deleteType},
|
||||
</if>
|
||||
<if test="tenantKey != null">
|
||||
tenant_key=#{tenantKey},
|
||||
</if>
|
||||
</set>
|
||||
WHERE id = #{id} AND delete_type = 0
|
||||
</update>
|
||||
|
||||
|
||||
<!-- 根据主键删除记录 -->
|
||||
<delete id="delete">
|
||||
UPDATE hrsa_auth_role_data
|
||||
SET delete_type=1
|
||||
WHERE id = #{id}
|
||||
AND delete_type = 0
|
||||
</delete>
|
||||
|
||||
<delete id="deleteByIds">
|
||||
UPDATE hrsa_auth_role_data
|
||||
SET delete_type = 1
|
||||
WHERE delete_type = 0
|
||||
AND id IN
|
||||
<foreach collection="ids" open="(" item="id" separator="," close=")">
|
||||
#{id}
|
||||
</foreach>
|
||||
</delete>
|
||||
|
||||
<delete id="deleteByRoleId">
|
||||
UPDATE hrsa_auth_role_data
|
||||
SET delete_type=1
|
||||
WHERE role_id = #{roleId} AND delete_type = 0
|
||||
</delete>
|
||||
</mapper>
|
||||
|
|
@ -1,24 +1,26 @@
|
|||
package com.engine.salary.service.auth;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.engine.core.impl.Service;
|
||||
import com.engine.salary.constant.SalaryDefaultTenantConstant;
|
||||
import com.engine.salary.entity.auth.param.AuthDataSaveParam;
|
||||
import com.engine.salary.entity.auth.po.*;
|
||||
import com.engine.salary.entity.auth.po.AuthDataPO;
|
||||
import com.engine.salary.entity.auth.po.AuthRoleDataPO;
|
||||
import com.engine.salary.entity.auth.po.AuthRolePO;
|
||||
import com.engine.salary.enums.auth.DataLinkEnum;
|
||||
import com.engine.salary.enums.auth.DataTargetTypeEnum;
|
||||
import com.engine.salary.enums.auth.MemberTargetTypeEnum;
|
||||
import com.engine.salary.exception.SalaryRunTimeException;
|
||||
import com.engine.salary.mapper.auth.AuthDataMapper;
|
||||
import com.engine.salary.mapper.auth.AuthRoleDataMapper;
|
||||
import com.engine.salary.mapper.auth.AuthRoleEmpMapper;
|
||||
import com.engine.salary.mapper.auth.AuthRoleMapper;
|
||||
import com.engine.salary.util.SalaryEntityUtil;
|
||||
import com.engine.salary.util.db.IdGenerator;
|
||||
import com.engine.salary.util.db.MapperProxyFactory;
|
||||
import com.google.common.collect.Lists;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.Date;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
public class AuthDataServiceImpl extends Service implements AuthDataService {
|
||||
|
|
@ -35,6 +37,7 @@ public class AuthDataServiceImpl extends Service implements AuthDataService {
|
|||
private AuthRoleEmpMapper getAuthRoleEmpMapper() {
|
||||
return MapperProxyFactory.getProxy(AuthRoleEmpMapper.class);
|
||||
}
|
||||
|
||||
private AuthRoleDataMapper getAuthRoleDataMapper() {
|
||||
return MapperProxyFactory.getProxy(AuthRoleDataMapper.class);
|
||||
}
|
||||
|
|
@ -78,49 +81,10 @@ public class AuthDataServiceImpl extends Service implements AuthDataService {
|
|||
|
||||
@Override
|
||||
public void sync(Long roleId) {
|
||||
|
||||
|
||||
AuthRolePO rolePO = getAuthRoleMapper().getById(roleId);
|
||||
if (rolePO == null) {
|
||||
throw new SalaryRunTimeException("角色不存在！");
|
||||
}
|
||||
|
||||
//1、获取成员
|
||||
List<AuthMemberPO> members = getAuthMemberMapper().listSome(AuthMemberPO.builder().roleId(roleId).build());
|
||||
Map<Integer, Set<String>> targetTypeMap = SalaryEntityUtil.group2Map(members, AuthMemberPO::getTargetType, AuthMemberPO::getTarget);
|
||||
|
||||
//2、获取人员
|
||||
Set<Long> empIds = new HashSet<>();
|
||||
for (Integer targetType : targetTypeMap.keySet()) {
|
||||
Set<String> targetIds = targetTypeMap.get(targetType);
|
||||
List<Long> ids = MemberTargetTypeEnum.parseByValue(targetType).getEmpIds(targetIds);
|
||||
empIds.addAll(ids);
|
||||
}
|
||||
|
||||
//3、更新成员关系
|
||||
getAuthRoleEmpMapper().deleteByRoleId(roleId);
|
||||
Date now = new Date();
|
||||
List<AuthRoleEmpPO> roleEmpPOS = empIds.stream()
|
||||
.map(empId -> AuthRoleEmpPO.builder()
|
||||
.id(IdGenerator.generate())
|
||||
.employeeId(empId)
|
||||
.roleId(roleId)
|
||||
.creator((long) user.getUID())
|
||||
.createTime(now)
|
||||
.updateTime(now)
|
||||
.deleteType(0)
|
||||
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
||||
.build())
|
||||
.collect(Collectors.toList());
|
||||
if (CollUtil.isNotEmpty(roleEmpPOS)) {
|
||||
List<List<AuthRoleEmpPO>> partition = Lists.partition(roleEmpPOS, 100);
|
||||
partition.forEach(list -> getAuthRoleEmpMapper().batchInsert(list));
|
||||
}
|
||||
|
||||
|
||||
List<AuthDataPO> list = list(roleId);
|
||||
|
||||
Set<Long> ids = null;
|
||||
Set<Long> ids = new HashSet<>();
|
||||
for (int i = 0; i < list.size(); i++) {
|
||||
AuthDataPO dataPO = list.get(i);
|
||||
DataTargetTypeEnum dataTargetTypeEnum = DataTargetTypeEnum.parseByValue(dataPO.getTargetType());
|
||||
|
|
@ -133,22 +97,22 @@ public class AuthDataServiceImpl extends Service implements AuthDataService {
|
|||
}
|
||||
}
|
||||
|
||||
getAuthDataMapper().deleteByRoleId(roleId);
|
||||
getAuthRoleDataMapper().deleteByRoleId(roleId);
|
||||
|
||||
List<AuthRoleDataPO> collect = ids.stream().map(empId -> AuthRoleDataPO.builder()
|
||||
.id(IdGenerator.generate())
|
||||
.employeeId(empId)
|
||||
.roleId(roleId)
|
||||
.creator((long) user.getUID())
|
||||
.createTime(now)
|
||||
.updateTime(now)
|
||||
.deleteType(0)
|
||||
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
||||
.build())
|
||||
List<AuthRoleDataPO> collect = ids.stream().map(empId ->
|
||||
AuthRoleDataPO.builder()
|
||||
.id(IdGenerator.generate())
|
||||
.roleId(roleId)
|
||||
.employeeId(empId)
|
||||
.creator((long) user.getUID())
|
||||
.createTime(now)
|
||||
.updateTime(now)
|
||||
.deleteType(0)
|
||||
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
||||
.build())
|
||||
.collect(Collectors.toList());
|
||||
|
||||
List<List<AuthRoleDataPO>> partition = Lists.partition(collect, 100);
|
||||
partition.forEach(list -> getAuthRoleDataMapper().batchInsert(list));
|
||||
|
||||
partition.forEach(pos -> getAuthRoleDataMapper().batchInsert(pos));
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue