QingYu-Club/QingYu-club
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 角色权限模块

Browse Source
This commit is contained in:
landaiqing
2024-02-19 17:44:10 +08:00
parent 04af7fca2a
commit 1ac0ec5313
45 changed files with 834 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/constants/AuthConstant.java Normal file
View File

@@ -0,0 +1,13 @@
package com.landaiqing.auth.domain.constants;
/**
* auth服务常量
*
* @author: landaiqing
* @date: 2024/2/19
*/
public class AuthConstant {
public static final String NORMAL_USER = "normal_user";
}

2
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/entity/AuthPermissionBO.java
View File

@@ -8,7 +8,7 @@ import java.io.Serializable;
* 权限dto
*
* @author: landaiqing
* @date: 2023/11/3
* @date: 2024/2/19
*/
@Data
public class AuthPermissionBO implements Serializable {

1
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/entity/AuthRoleBO.java
View File

@@ -8,7 +8,6 @@ import java.io.Serializable;
* 角色bo
*
* @author: landaiqing
* @date: 2023/11/2
*/
@Data
public class AuthRoleBO implements Serializable {

1
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/entity/AuthRolePermissionBO.java
View File

@@ -9,7 +9,6 @@ import java.util.List;
* (AuthRolePermission)实体类
*
* @author landaiqing
* @since 2023-11-04 22:16:00
*/
@Data
public class AuthRolePermissionBO implements Serializable {

1
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/entity/AuthUserBO.java
View File

@@ -8,7 +8,6 @@ import java.io.Serializable;
* 用戶信息dto
*
* @author: landaiqing
* @date: 2023/11/1
*/
@Data
public class AuthUserBO implements Serializable {

46
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/redis/RedisConfig.java Normal file
View File

@@ -0,0 +1,46 @@
package com.landaiqing.auth.domain.redis;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
/**
* Redis的config处理
*
* @author: landaiqing
*/
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
redisTemplate.setConnectionFactory(redisConnectionFactory);
redisTemplate.setKeySerializer(redisSerializer);
redisTemplate.setHashKeySerializer(redisSerializer);
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer());
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer());
return redisTemplate;
}
private Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer() {
Jackson2JsonRedisSerializer<Object> jsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
jsonRedisSerializer.setObjectMapper(objectMapper);
return jsonRedisSerializer;
}
}

107
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/redis/RedisUtil.java Normal file
View File

@@ -0,0 +1,107 @@
package com.landaiqing.auth.domain.redis;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* RedisUtil工具类
*
* @author: landaiqing
* @date: 2024/2/19
*/
@Component
@Slf4j
public class RedisUtil {
@Resource
private RedisTemplate redisTemplate;
private static final String CACHE_KEY_SEPARATOR = ".";
/**
* 构建缓存key
*/
public String buildKey(String... strObjs) {
return Stream.of(strObjs).collect(Collectors.joining(CACHE_KEY_SEPARATOR));
}
/**
* 是否存在key
*/
public boolean exist(String key) {
return redisTemplate.hasKey(key);
}
/**
* 删除key
*/
public boolean del(String key) {
return redisTemplate.delete(key);
}
/**
* set(不带过期)
*/
public void set(String key, String value) {
redisTemplate.opsForValue().set(key, value);
}
/**
* set(带过期)
*/
public boolean setNx(String key, String value, Long time, TimeUnit timeUnit) {
return redisTemplate.opsForValue().setIfAbsent(key, value, time, timeUnit);
}
/**
* 获取string类型缓存
*/
public String get(String key) {
return (String) redisTemplate.opsForValue().get(key);
}
public Boolean zAdd(String key, String value, Long score) {
return redisTemplate.opsForZSet().add(key, value, Double.valueOf(String.valueOf(score)));
}
public Long countZset(String key) {
return redisTemplate.opsForZSet().size(key);
}
public Set<String> rangeZset(String key, long start, long end) {
return redisTemplate.opsForZSet().range(key, start, end);
}
public Long removeZset(String key, Object value) {
return redisTemplate.opsForZSet().remove(key, value);
}
public void removeZsetList(String key, Set<String> value) {
value.stream().forEach((val) -> redisTemplate.opsForZSet().remove(key, val));
}
public Double score(String key, Object value) {
return redisTemplate.opsForZSet().score(key, value);
}
public Set<String> rangeByScore(String key, long start, long end) {
return redisTemplate.opsForZSet().rangeByScore(key, Double.valueOf(String.valueOf(start)), Double.valueOf(String.valueOf(end)));
}
public Object addScore(String key, Object obj, double score) {
return redisTemplate.opsForZSet().incrementScore(key, obj, score);
}
public Object rank(String key, Object obj) {
return redisTemplate.opsForZSet().rank(key, obj);
}
}

22
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthPermissionDomainService.java Normal file
View File

@@ -0,0 +1,22 @@
package com.landaiqing.auth.domain.service;
import com.landaiqing.auth.domain.entity.AuthPermissionBO;
import java.util.List;
/**
* 权限领域service
*
* @author: landaiqing
* @date: 2024/2/19
*/
public interface AuthPermissionDomainService {
Boolean add(AuthPermissionBO authPermissionBO);
Boolean update(AuthPermissionBO authPermissionBO);
Boolean delete(AuthPermissionBO authPermissionBO);
List<String> getPermission(String userName);
}

23
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthRoleDomainService.java Normal file
View File

@@ -0,0 +1,23 @@
package com.landaiqing.auth.domain.service;
import com.landaiqing.auth.domain.entity.AuthRoleBO;
/**
* 角色领域service
*
* @author: landaiqing
* @date: 2024/2/19
*/
public interface AuthRoleDomainService {
/**
* 注册
*/
Boolean add(AuthRoleBO authRoleBO);
Boolean update(AuthRoleBO authRoleBO);
Boolean delete(AuthRoleBO authRoleBO);
}

14
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthRolePermissionDomainService.java Normal file
View File

@@ -0,0 +1,14 @@
package com.landaiqing.auth.domain.service;
import com.landaiqing.auth.domain.entity.AuthRolePermissionBO;
/**
* 角色领域service
*
* @author: landaiqing
*/
public interface AuthRolePermissionDomainService {
Boolean add(AuthRolePermissionBO authRolePermissionBO);
}

5
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthUserDomainService.java
View File

@@ -16,6 +16,11 @@ public interface AuthUserDomainService {
*/
Boolean register(AuthUserBO authUserBO);
/**
* 更新用户信息
*/
Object update(AuthUserBO authUserBO);
Object delete(AuthUserBO authUserBO);
}

71
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthPermissionDomainServiceImpl.java Normal file
View File

@@ -0,0 +1,71 @@
package com.landaiqing.auth.domain.service.impl;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.landaiqing.auth.common.enums.IsDeletedFlagEnum;
import com.landaiqing.auth.domain.convert.AuthPermissionBOConverter;
import com.landaiqing.auth.domain.entity.AuthPermissionBO;
import com.landaiqing.auth.domain.redis.RedisUtil;
import com.landaiqing.auth.domain.service.AuthPermissionDomainService;
import com.landaiqing.auth.infra.basic.entity.AuthPermission;
import com.landaiqing.auth.infra.basic.service.AuthPermissionService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
@Service
@Slf4j
public class AuthPermissionDomainServiceImpl implements AuthPermissionDomainService {
@Resource
private AuthPermissionService authPermissionService;
@Resource
private RedisUtil redisUtil;
private String authPermissionPrefix = "auth.permission";
@Override
public Boolean add(AuthPermissionBO authPermissionBO) {
AuthPermission authPermission = AuthPermissionBOConverter.INSTANCE.convertBOToEntity(authPermissionBO);
authPermission.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode());
Integer count = authPermissionService.insert(authPermission);
return count > 0;
}
@Override
public Boolean update(AuthPermissionBO authPermissionBO) {
AuthPermission authPermission = AuthPermissionBOConverter.INSTANCE.convertBOToEntity(authPermissionBO);
Integer count = authPermissionService.update(authPermission);
return count > 0;
}
@Override
public Boolean delete(AuthPermissionBO authPermissionBO) {
AuthPermission authPermission = new AuthPermission();
authPermission.setId(authPermissionBO.getId());
authPermission.setIsDeleted(IsDeletedFlagEnum.DELETED.getCode());
Integer count = authPermissionService.update(authPermission);
return count > 0;
}
@Override
public List<String> getPermission(String userName) {
String permissionKey = redisUtil.buildKey(authPermissionPrefix, userName);
String permissionValue = redisUtil.get(permissionKey);
if (StringUtils.isBlank(permissionValue)) {
return Collections.emptyList();
}
List<AuthPermission> permissionList = new Gson().fromJson(permissionValue,
new TypeToken<List<AuthPermission>>() {
}.getType());
List<String> authList = permissionList.stream().map(AuthPermission::getPermissionKey).collect(Collectors.toList());
return authList;
}
}

44
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthRoleDomainServiceImpl.java Normal file
View File

@@ -0,0 +1,44 @@
package com.landaiqing.auth.domain.service.impl;
import com.landaiqing.auth.common.enums.IsDeletedFlagEnum;
import com.landaiqing.auth.domain.convert.AuthRoleBOConverter;
import com.landaiqing.auth.domain.entity.AuthRoleBO;
import com.landaiqing.auth.domain.service.AuthRoleDomainService;
import com.landaiqing.auth.infra.basic.entity.AuthRole;
import com.landaiqing.auth.infra.basic.service.AuthRoleService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
@Slf4j
public class AuthRoleDomainServiceImpl implements AuthRoleDomainService {
@Resource
private AuthRoleService authRoleService;
@Override
public Boolean add(AuthRoleBO authRoleBO) {
AuthRole authRole = AuthRoleBOConverter.INSTANCE.convertBOToEntity(authRoleBO);
authRole.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode());
Integer count = authRoleService.insert(authRole);
return count > 0;
}
@Override
public Boolean update(AuthRoleBO authRoleBO) {
AuthRole authRole = AuthRoleBOConverter.INSTANCE.convertBOToEntity(authRoleBO);
int count = authRoleService.update(authRole);
return count > 0;
}
@Override
public Boolean delete(AuthRoleBO authRoleBO) {
AuthRole authRole = new AuthRole();
authRole.setId(authRoleBO.getId());
authRole.setIsDeleted(IsDeletedFlagEnum.DELETED.getCode());
int count = authRoleService.update(authRole);
return count > 0;
}
}

38
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthRolePermissionDomainServiceImpl.java Normal file
View File

@@ -0,0 +1,38 @@
package com.landaiqing.auth.domain.service.impl;
import com.landaiqing.auth.common.enums.IsDeletedFlagEnum;
import com.landaiqing.auth.domain.entity.AuthRolePermissionBO;
import com.landaiqing.auth.domain.service.AuthRolePermissionDomainService;
import com.landaiqing.auth.infra.basic.entity.AuthRolePermission;
import com.landaiqing.auth.infra.basic.service.AuthRolePermissionService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.LinkedList;
import java.util.List;
@Service
@Slf4j
public class AuthRolePermissionDomainServiceImpl implements AuthRolePermissionDomainService {
@Resource
private AuthRolePermissionService authRolePermissionService;
@Override
public Boolean add(AuthRolePermissionBO authRolePermissionBO) {
List<AuthRolePermission> rolePermissionList = new LinkedList<>();
Long roleId = authRolePermissionBO.getRoleId();
authRolePermissionBO.getPermissionIdList().forEach(permissionId -> {
AuthRolePermission authRolePermission = new AuthRolePermission();
authRolePermission.setRoleId(roleId);
authRolePermission.setPermissionId(permissionId);
authRolePermission.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode());
rolePermissionList.add(authRolePermission);
});
int count = authRolePermissionService.batchInsert(rolePermissionList);
return count > 0;
}
}

48
jc-club-auth/jc-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthUserDomainServiceImpl.java
View File

@@ -1,14 +1,22 @@
package com.landaiqing.auth.domain.service.impl;
import cn.dev33.satoken.secure.SaSecureUtil;
import com.landaiqing.auth.common.enums.AuthUserStatusEnum;
import com.landaiqing.auth.common.enums.IsDeletedFlagEnum;
import com.landaiqing .auth.domain.convert.AuthUserBOConverter;
import com.landaiqing.auth.domain.constants.AuthConstant;
import com.landaiqing.auth.domain.convert.AuthUserBOConverter;
import com.landaiqing.auth.domain.entity.AuthUserBO;
import com.landaiqing.auth.domain.service.AuthUserDomainService;
import com.landaiqing.auth.infra.basic.entity.AuthRole;
import com.landaiqing.auth.infra.basic.entity.AuthUser;
import com.landaiqing.auth.infra.basic.entity.AuthUserRole;
import com.landaiqing.auth.infra.basic.service.AuthRoleService;
import com.landaiqing.auth.infra.basic.service.AuthUserRoleService;
import com.landaiqing.auth.infra.basic.service.AuthUserService;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
@@ -19,13 +27,51 @@ public class AuthUserDomainServiceImpl implements AuthUserDomainService {
@Resource
private AuthUserService authUserService;
@Resource
private AuthUserRoleService authUserRoleService;
@Resource
private AuthRoleService authRoleService;
private String salt="landaiqing";
@Override
@SneakyThrows
@Transactional(rollbackFor = Exception.class)
public Boolean register(AuthUserBO authUserBO) {
AuthUser authUser = AuthUserBOConverter.INSTANCE.convertBOToEntity(authUserBO);
authUser.setPassword(SaSecureUtil.md5BySalt(authUser.getPassword(),salt));
authUser.setStatus(AuthUserStatusEnum.OPEN.getCode());
authUser.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode());
Integer count = authUserService.insert(authUser);
// 用户和角色关联
AuthRole authRole=new AuthRole();
authRole.setRoleKey(AuthConstant.NORMAL_USER);
AuthRole roleResult = authRoleService.queryByCondition(authRole);
Long roleId = roleResult.getId();
Long userId = authUser.getId();
AuthUserRole authUserRole=new AuthUserRole();
authUserRole.setUserId(userId);
authUserRole.setRoleId(roleId);
authUserRole.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode());
authUserRoleService.insert(authUserRole);
return count > 0;
}
@Override
public Object update(AuthUserBO authUserBO) {
AuthUser authUser = AuthUserBOConverter.INSTANCE.convertBOToEntity(authUserBO);
Integer count = authUserService.update(authUser);
return count > 0;
}
@Override
public Object delete(AuthUserBO authUserBO) {
AuthUser authUser = new AuthUser();
authUser.setId(authUserBO.getId());
authUser.setIsDeleted(IsDeletedFlagEnum.DELETED.getCode());
Integer count = authUserService.update(authUser);
return count > 0;
}
}