manager/orion-visor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

⚡ 批量删除后端服务.

Browse Source
This commit is contained in:
lijiahang
2024-06-03 10:19:48 +08:00
parent 285f0532d3
commit 11606e25bb
46 changed files with 705 additions and 199 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
orion-visor-module-infra/orion-visor-module-infra-provider/src/main/java/com/orion/visor/module/infra/api/DataExtraApi.java
View File

@@ -139,19 +139,28 @@ public interface DataExtraApi {
Integer deleteByRelId(DataExtraTypeEnum type, Long relId);
/**
* 删除主机密钥
* 通过 relId 删除
*
* @param keyId keyId
* @param type type
* @param relIdList relIdList
* @return effect
*/
int deleteHostKeyExtra(Long keyId);
Integer deleteByRelIdList(DataExtraTypeEnum type, List<Long> relIdList);
/**
* 删除主机密钥
*
* @param keyIdList keyIdList
* @return effect
*/
int deleteHostKeyExtra(List<Long> keyIdList);
/**
* 删除主机身份
*
* @param identityId identityId
* @param identityIdList identityIdList
* @return effect
*/
int deleteHostIdentityExtra(Long identityId);
int deleteHostIdentityExtra(List<Long> identityIdList);
}

9
orion-visor-module-infra/orion-visor-module-infra-provider/src/main/java/com/orion/visor/module/infra/api/DataPermissionApi.java
View File

@@ -76,4 +76,13 @@ public interface DataPermissionApi {
*/
int deleteByRelId(DataPermissionTypeEnum type, Long relId);
/**
* 通过 relId 删除
*
* @param type type
* @param relIdList relIdList
* @return effect
*/
int deleteByRelIdList(DataPermissionTypeEnum type, List<Long> relIdList);
}

17
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/api/impl/DataExtraApiImpl.java
View File

@@ -134,15 +134,20 @@ public class DataExtraApiImpl implements DataExtraApi {
}
@Override
public int deleteHostKeyExtra(Long keyId) {
Valid.notNull(keyId);
return dataExtraDAO.deleteHostKey(keyId);
public Integer deleteByRelIdList(DataExtraTypeEnum type, List<Long> relIdList) {
return dataExtraService.deleteByRelIdList(type.name(), relIdList);
}
@Override
public int deleteHostIdentityExtra(Long identityId) {
Valid.notNull(identityId);
return dataExtraDAO.deleteHostIdentity(identityId);
public int deleteHostKeyExtra(List<Long> keyIdList) {
Valid.notEmpty(keyIdList);
return dataExtraDAO.deleteHostKey(keyIdList);
}
@Override
public int deleteHostIdentityExtra(List<Long> identityIdList) {
Valid.notEmpty(identityIdList);
return dataExtraDAO.deleteHostIdentity(identityIdList);
}
}

5
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/api/impl/DataPermissionApiImpl.java
View File

@@ -75,4 +75,9 @@ public class DataPermissionApiImpl implements DataPermissionApi {
return dataPermissionService.deleteByRelId(type.name(), relId);
}
@Override
public int deleteByRelIdList(DataPermissionTypeEnum type, List<Long> relIdList) {
return dataPermissionService.deleteByRelIdList(type.name(), relIdList);
}
}

10
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/controller/SystemUserController.java
View File

@@ -150,6 +150,16 @@ public class SystemUserController {
return systemUserService.deleteSystemUserById(id);
}
@DemoDisableApi
@OperatorLog(SystemUserOperatorType.DELETE)
@DeleteMapping("/batch-delete")
@Operation(summary = "批量删除用户")
@Parameter(name = "idList", description = "idList", required = true)
@PreAuthorize("@ss.hasPermission('infra:system-user:delete')")
public Integer batchDeleteSystemUser(@RequestParam("idList") List<Long> idList) {
return systemUserService.deleteSystemUserByIdList(idList);
}
@IgnoreLog(IgnoreLogMode.RET)
@GetMapping("/session/list")
@Operation(summary = "获取用户会话列表")

38
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/dao/DataExtraDAO.java
View File

@@ -6,6 +6,8 @@ import com.orion.visor.module.infra.entity.domain.DataExtraDO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 数据拓展信息 Mapper 接口
*
@@ -28,6 +30,18 @@ public interface DataExtraDAO extends IMapper<DataExtraDO> {
return this.delete(wrapper);
}
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
default int deleteByUserIdList(List<Long> userIdList) {
LambdaQueryWrapper<DataExtraDO> wrapper = this.lambda()
.in(DataExtraDO::getUserId, userIdList);
return this.delete(wrapper);
}
/**
* 通过 relId 删除
*
@@ -43,19 +57,33 @@ public interface DataExtraDAO extends IMapper<DataExtraDO> {
}
/**
* 删除主机密钥
* 通过 relId 删除
*
* @param keyId keyId
* @param type type
* @param relIdList relIdList
* @return effect
*/
int deleteHostKey(@Param("keyId") Long keyId);
default int deleteByRelIdList(String type, List<Long> relIdList) {
LambdaQueryWrapper<DataExtraDO> wrapper = this.lambda()
.eq(DataExtraDO::getType, type)
.in(DataExtraDO::getRelId, relIdList);
return this.delete(wrapper);
}
/**
* 删除主机密钥
*
* @param keyIdList keyIdList
* @return effect
*/
int deleteHostKey(@Param("keyIdList") List<Long> keyIdList);
/**
* 删除主机身份
*
* @param identityId identityId
* @param identityIdList identityIdList
* @return effect
*/
int deleteHostIdentity(@Param("identityId") Long identityId);
int deleteHostIdentity(@Param("identityIdList") List<Long> identityIdList);
}

14
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/dao/OperatorLogDAO.java
View File

@@ -5,6 +5,8 @@ import com.orion.visor.framework.mybatis.core.mapper.IMapper;
import com.orion.visor.module.infra.entity.domain.OperatorLogDO;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* 操作日志 Mapper 接口
*
@@ -27,4 +29,16 @@ public interface OperatorLogDAO extends IMapper<OperatorLogDO> {
return this.delete(wrapper);
}
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
default int deleteByUserIdList(List<Long> userIdList) {
LambdaQueryWrapper<OperatorLogDO> wrapper = this.wrapper()
.in(OperatorLogDO::getUserId, userIdList);
return this.delete(wrapper);
}
}

12
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/dao/PreferenceDAO.java
View File

@@ -5,6 +5,8 @@ import com.orion.visor.framework.mybatis.core.query.Conditions;
import com.orion.visor.module.infra.entity.domain.PreferenceDO;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* 用户偏好 Mapper 接口
*
@@ -25,4 +27,14 @@ public interface PreferenceDAO extends IMapper<PreferenceDO> {
return this.delete(Conditions.eq(PreferenceDO::getUserId, userId));
}
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
default int deleteByUserIdList(List<Long> userIdList) {
return this.delete(Conditions.in(PreferenceDO::getUserId, userIdList));
}
}

12
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/dao/SystemUserRoleDAO.java
View File

@@ -76,6 +76,18 @@ public interface SystemUserRoleDAO extends IMapper<SystemUserRoleDO> {
return this.delete(wrapper);
}
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
default int deleteByUserIdList(List<Long> userIdList) {
LambdaQueryWrapper<SystemUserRoleDO> wrapper = this.wrapper()
.in(SystemUserRoleDO::getUserId, userIdList);
return this.delete(wrapper);
}
/**
* 通过 roleId 删除
*

17
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/DataExtraService.java
View File

@@ -119,6 +119,14 @@ public interface DataExtraService {
*/
Integer deleteByUserId(Long userId);
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
Integer deleteByUserIdList(List<Long> userIdList);
/**
* 通过 relId 删除
*
@@ -128,4 +136,13 @@ public interface DataExtraService {
*/
Integer deleteByRelId(String type, Long relId);
/**
* 通过 relId 删除
*
* @param type type
* @param relIdList relIdList
* @return effect
*/
Integer deleteByRelIdList(String type, List<Long> relIdList);
}

8
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/DataGroupService.java
View File

@@ -84,4 +84,12 @@ public interface DataGroupService {
*/
Integer deleteDataGroupByUserId(Long userId);
/**
* 通过 userId 删除数据分组
*
* @param userIdList userIdList
* @return effect
*/
Integer deleteDataGroupByUserIdList(List<Long> userIdList);
}

17
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/DataPermissionService.java
View File

@@ -73,6 +73,15 @@ public interface DataPermissionService {
*/
int deleteByRelId(String type, Long relId);
/**
* 通过 relId 删除
*
* @param type type
* @param relIdList relIdList
* @return effect
*/
int deleteByRelIdList(String type, List<Long> relIdList);
/**
* 通过 userId 删除
*
@@ -81,6 +90,14 @@ public interface DataPermissionService {
*/
int deleteByUserId(Long userId);
/**
* 通过 userId 删除
*
* @param userIdList userIdList
* @return effect
*/
int deleteByUserIdList(List<Long> userIdList);
/**
* 通过 roleId 删除
*

7
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/PreferenceService.java
View File

@@ -66,4 +66,11 @@ public interface PreferenceService {
*/
void deletePreferenceByUserId(Long userId);
/**
* 删除用户偏好
*
* @param userIdList userIdList
*/
void deletePreferenceByUserIdList(List<Long> userIdList);
}

15
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/SystemUserService.java
View File

@@ -71,12 +71,19 @@ public interface SystemUserService {
Integer deleteSystemUserById(Long id);
/**
* 删除 id 删除用户拓展信息
* 通过 id 批量删除用户
*
* @param id id
* @param username username
* @param idList idList
* @return effect
*/
void deleteSystemUserRelAsync(Long id, String username);
Integer deleteSystemUserByIdList(List<Long> idList);
/**
* 通过 idList 删除用户拓展信息
*
* @param idList idList
*/
void deleteSystemUserListRelAsync(List<Long> idList);
/**
* 重置密码

48
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/DataExtraServiceImpl.java
View File

@@ -192,32 +192,56 @@ public class DataExtraServiceImpl implements DataExtraService {
@Override
public Integer deleteByUserId(Long userId) {
List<DataExtraDO> list = this.getCacheSelectWrapper()
.eq(DataExtraDO::getUserId, userId)
.then()
.list();
if (list.isEmpty()) {
return Const.N_0;
if (userId == null) {
return 0;
}
// 删除
return this.deleteByUserIdList(Lists.singleton(userId));
}
@Override
public Integer deleteByUserIdList(List<Long> userIdList) {
if (Lists.isEmpty(userIdList)) {
return 0;
}
// 删除数据
int effect = dataExtraDAO.deleteByUserId(userId);
// 删除缓存
this.deleteCache(list);
return effect;
return dataExtraDAO.deleteByUserIdList(userIdList);
// // 查询数据
// List<DataExtraDO> list = this.getCacheSelectWrapper()
// .in(DataExtraDO::getUserId, userIdList)
// .then()
// .list();
// if (list.isEmpty()) {
// return Const.N_0;
// }
// // 删除缓存 让其自动过期
// this.deleteCache(list);
}
@Override
public Integer deleteByRelId(String type, Long relId) {
if (relId == null) {
return 0;
}
// 删除
return this.deleteByRelIdList(type, Lists.singleton(relId));
}
@Override
public Integer deleteByRelIdList(String type, List<Long> relIdList) {
if (Lists.isEmpty(relIdList)) {
return 0;
}
List<DataExtraDO> list = this.getCacheSelectWrapper()
.eq(DataExtraDO::getType, type)
.eq(DataExtraDO::getRelId, relId)
.in(DataExtraDO::getRelId, relIdList)
.then()
.list();
if (list.isEmpty()) {
return Const.N_0;
}
// 删除数据
int effect = dataExtraDAO.deleteByRelId(type, relId);
int effect = dataExtraDAO.deleteByRelIdList(type, relIdList);
// 删除缓存
this.deleteCache(list);
return effect;

18
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/DataGroupServiceImpl.java
View File

@@ -250,15 +250,27 @@ public class DataGroupServiceImpl implements DataGroupService {
@Override
public Integer deleteDataGroupByUserId(Long userId) {
if (userId == null) {
return 0;
}
// 删除
return this.deleteDataGroupByUserIdList(Lists.singleton(userId));
}
@Override
public Integer deleteDataGroupByUserIdList(List<Long> userIdList) {
if (Lists.isEmpty(userIdList)) {
return 0;
}
// 删除分组
LambdaQueryWrapper<DataGroupDO> deleteGroup = dataGroupDAO.wrapper()
.eq(DataGroupDO::getUserId, userId);
.in(DataGroupDO::getUserId, userIdList);
int effect = dataGroupDAO.delete(deleteGroup);
// 删除分组引用
LambdaQueryWrapper<DataGroupRelDO> deleteRel = dataGroupRelDAO.wrapper()
.eq(DataGroupRelDO::getUserId, userId);
.in(DataGroupRelDO::getUserId, userIdList);
effect += dataGroupRelDAO.delete(deleteRel);
// 不删除缓存 自动过期
// 不删除缓存 让其自动过期
return effect;
}

35
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/DataPermissionServiceImpl.java
View File

@@ -182,9 +182,21 @@ public class DataPermissionServiceImpl implements DataPermissionService {
@Override
public int deleteByRelId(String type, Long relId) {
if (relId == null) {
return 0;
}
// 删除
return this.deleteByRelIdList(type, Lists.singleton(relId));
}
@Override
public int deleteByRelIdList(String type, List<Long> relIdList) {
if (Lists.isEmpty(relIdList)) {
return 0;
}
LambdaQueryWrapper<DataPermissionDO> wrapper = dataPermissionDAO.wrapper()
.eq(DataPermissionDO::getType, type)
.eq(DataPermissionDO::getRelId, relId);
.in(DataPermissionDO::getRelId, relIdList);
// 查询
List<DataPermissionDO> rows = dataPermissionDAO.selectList(wrapper);
// 删除
@@ -204,12 +216,23 @@ public class DataPermissionServiceImpl implements DataPermissionService {
@Override
public int deleteByUserId(Long userId) {
LambdaQueryWrapper<DataPermissionDO> wrapper = Conditions.eq(DataPermissionDO::getUserId, userId);
if (userId == null) {
return 0;
}
// 删除
int effect = dataPermissionDAO.delete(wrapper);
// 删除缓存
this.deleteCache(null, Lists.singleton(userId), null);
return effect;
return this.deleteByUserIdList(Lists.singleton(userId));
}
@Override
public int deleteByUserIdList(List<Long> userIdList) {
if (Lists.isEmpty(userIdList)) {
return 0;
}
LambdaQueryWrapper<DataPermissionDO> wrapper = Conditions.in(DataPermissionDO::getUserId, userIdList);
// 删除
return dataPermissionDAO.delete(wrapper);
// 删除缓存 让其自动过期
// this.deleteCache(null, userIdList, null);
}
@Override

18
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/DictKeyServiceImpl.java
View File

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.orion.lang.define.wrapper.DataGrid;
import com.orion.lang.utils.Objects1;
import com.orion.lang.utils.Strings;
import com.orion.lang.utils.collect.Lists;
import com.orion.lang.utils.collect.Maps;
import com.orion.visor.framework.biz.operator.log.core.utils.OperatorLogs;
import com.orion.visor.framework.common.constant.Const;
@@ -176,24 +177,13 @@ public class DictKeyServiceImpl implements DictKeyService {
}
@Override
@Transactional(rollbackFor = Exception.class)
public Integer deleteDictKeyById(Long id) {
log.info("DictKeyService-deleteDictKeyById id: {}", id);
// 检查数据是否存在
DictKeyDO record = dictKeyDAO.selectById(id);
Valid.notNull(record, ErrorMessage.CONFIG_ABSENT);
OperatorLogs.add(OperatorLogs.KEY_NAME, record.getKeyName());
// 删除配置项
int effect = dictKeyDAO.deleteById(id);
// 删除配置值
dictValueService.deleteDictValueByKeyId(id);
// 删除缓存
RedisMaps.delete(DictCacheKeyDefine.DICT_KEY, id);
RedisUtils.delete(DictCacheKeyDefine.DICT_SCHEMA.format(record.getKeyName()));
log.info("DictKeyService-deleteDictKeyById id: {}, effect: {}", id, effect);
return effect;
return this.deleteDictKeyByIdList(Lists.singleton(id));
}
@Override
@Transactional(rollbackFor = Exception.class)
public Integer deleteDictKeyByIdList(List<Long> idList) {
log.info("DictKeyService-deleteDictKeyByIdList idList: {}", idList);
// 检查数据是否存在

27
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/FavoriteServiceImpl.java
View File

@@ -20,8 +20,6 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
@@ -118,13 +116,8 @@ public class FavoriteServiceImpl implements FavoriteService {
if (userId == null) {
return;
}
// 删除库
favoriteDAO.deleteFavoriteByUserId(userId);
// 删除缓存
List<String> favoriteKeyList = Arrays.stream(FavoriteTypeEnum.values())
.map(s -> FavoriteCacheKeyDefine.FAVORITE.format(s, userId))
.collect(Collectors.toList());
redisTemplate.delete(favoriteKeyList);
// 删除
this.deleteFavoriteByUserIdList(Lists.singleton(userId));
}
@Override
@@ -134,14 +127,14 @@ public class FavoriteServiceImpl implements FavoriteService {
}
// 删除库
favoriteDAO.deleteFavoriteByUserIdList(userIdList);
// 删除缓存
List<String> favoriteKeyList = new ArrayList<>();
for (Long userId : userIdList) {
Arrays.stream(FavoriteTypeEnum.values())
.map(s -> FavoriteCacheKeyDefine.FAVORITE.format(s, userId))
.forEach(favoriteKeyList::add);
}
redisTemplate.delete(favoriteKeyList);
// 缓存自动过期
// List<String> favoriteKeyList = new ArrayList<>();
// for (Long userId : userIdList) {
// Arrays.stream(FavoriteTypeEnum.values())
// .map(s -> FavoriteCacheKeyDefine.FAVORITE.format(s, userId))
// .forEach(favoriteKeyList::add);
// }
// redisTemplate.delete(favoriteKeyList);
}
/**

30
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/PreferenceServiceImpl.java
View File

@@ -21,7 +21,6 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
@@ -164,14 +163,29 @@ public class PreferenceServiceImpl implements PreferenceService {
@Override
public void deletePreferenceByUserId(Long userId) {
if (userId == null) {
return;
}
// 删除
int effect = preferenceDAO.deleteByUserId(userId);
log.info("PreferenceService-deletePreferenceById userId: {}, effect: {}", userId, effect);
// 删除缓存
List<String> deleteKeys = Arrays.stream(PreferenceTypeEnum.values())
.map(s -> PreferenceCacheKeyDefine.PREFERENCE.format(userId, s))
.collect(Collectors.toList());
RedisMaps.delete(deleteKeys);
this.deletePreferenceByUserIdList(Lists.singleton(userId));
}
@Override
public void deletePreferenceByUserIdList(List<Long> userIdList) {
if (Lists.isEmpty(userIdList)) {
return;
}
// 删除
int effect = preferenceDAO.deleteByUserIdList(userIdList);
log.info("PreferenceService-deletePreferenceByUserIdList userIdList: {}, effect: {}", userIdList, effect);
// 删除缓存 让他自动过期
// List<String> deleteKeys = new ArrayList<>();
// for (Long userId : userIdList) {
// Arrays.stream(PreferenceTypeEnum.values())
// .map(s -> PreferenceCacheKeyDefine.PREFERENCE.format(userId, s))
// .forEach(deleteKeys::add);
// }
// RedisMaps.delete(deleteKeys);
}
/**

96
orion-visor-module-infra/orion-visor-module-infra-service/src/main/java/com/orion/visor/module/infra/service/impl/SystemUserServiceImpl.java
View File

@@ -3,9 +3,11 @@ package com.orion.visor.module.infra.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.orion.lang.define.wrapper.DataGrid;
import com.orion.lang.utils.collect.Lists;
import com.orion.lang.utils.crypto.Signatures;
import com.orion.spring.SpringHolder;
import com.orion.visor.framework.biz.operator.log.core.utils.OperatorLogs;
import com.orion.visor.framework.common.constant.Const;
import com.orion.visor.framework.common.constant.ErrorCode;
import com.orion.visor.framework.common.constant.ErrorMessage;
import com.orion.visor.framework.common.security.LoginUser;
@@ -38,7 +40,9 @@ import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Comparator;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
/**
@@ -212,58 +216,55 @@ public class SystemUserServiceImpl implements SystemUserService {
@Override
public Integer deleteSystemUserById(Long id) {
if (id.equals(SecurityUtils.getLoginUserId())) {
return this.deleteSystemUserByIdList(Lists.singleton(id));
}
@Override
public Integer deleteSystemUserByIdList(List<Long> idList) {
if (idList.contains(SecurityUtils.getLoginUserId())) {
throw ErrorCode.UNSUPPOETED.exception();
}
// 查询用户
SystemUserDO record = systemUserDAO.selectById(id);
Valid.notNull(record, ErrorMessage.USER_ABSENT);
// 查询用户列表
List<SystemUserDO> userList = systemUserDAO.selectBatchIds(idList);
Valid.notEmpty(userList, ErrorMessage.USER_ABSENT);
// 添加日志参数
OperatorLogs.add(OperatorLogs.USERNAME, record.getUsername());
idList = userList.stream()
.map(SystemUserDO::getId)
.collect(Collectors.toList());
String username = userList.stream()
.map(SystemUserDO::getUsername)
.collect(Collectors.joining(Const.COMMA));
OperatorLogs.add(OperatorLogs.USERNAME, username);
// 删除用户
int effect = systemUserDAO.deleteById(id);
log.info("SystemUserService-deleteSystemUserById id: {}, effect: {}", id, effect);
// 删除用户信息缓存
RedisUtils.delete(UserCacheKeyDefine.USER_INFO.format(id));
// 删除 token 缓存
RedisUtils.scanKeysDelete(
// 登录 token
UserCacheKeyDefine.LOGIN_TOKEN.format(id, "*"),
// 刷新 token
UserCacheKeyDefine.LOGIN_REFRESH.format(id, "*")
);
int effect = systemUserDAO.deleteBatchIds(idList);
log.info("SystemUserService-deleteSystemUserByIdList idList: {}, effect: {}", idList, effect);
// 删除缓存 其他的缓存自动过期
this.deleteUserCacheKey(userList);
// 异步删除额外信息
SpringHolder.getBean(SystemUserService.class).deleteSystemUserRelAsync(id, record.getUsername());
SpringHolder.getBean(SystemUserService.class)
.deleteSystemUserListRelAsync(idList);
return effect;
}
@Override
@Async("asyncExecutor")
public void deleteSystemUserRelAsync(Long id, String username) {
log.info("SystemUserService-deleteSystemUserRel id: {}", id);
// 删除用户列表缓存
RedisMaps.delete(UserCacheKeyDefine.USER_LIST, id);
// 删除用户缓存 其他的 key 让其自动过期
RedisUtils.delete(
// 登录失败次数
UserCacheKeyDefine.LOGIN_FAILED_COUNT.format(username),
// 用户提示
TipsCacheKeyDefine.TIPS.format(id)
);
public void deleteSystemUserListRelAsync(List<Long> idList) {
log.info("SystemUserService-deleteSystemUserListRelAsync idList: {}", idList);
// 删除角色关联
systemUserRoleDAO.deleteByUserId(id);
systemUserRoleDAO.deleteByUserIdList(idList);
// 删除操作日志
operatorLogDAO.deleteByUserId(id);
operatorLogDAO.deleteByUserIdList(idList);
// 删除用户收藏
favoriteService.deleteFavoriteByUserId(id);
favoriteService.deleteFavoriteByUserIdList(idList);
// 删除用户偏好
preferenceService.deletePreferenceByUserId(id);
preferenceService.deletePreferenceByUserIdList(idList);
// 删除用户数据权限
dataPermissionService.deleteByUserId(id);
dataPermissionService.deleteByUserIdList(idList);
// 删除用户拓展数据
dataExtraService.deleteByUserId(id);
dataExtraService.deleteByUserIdList(idList);
// 删除分组数据
dataGroupService.deleteDataGroupByUserId(id);
dataGroupService.deleteDataGroupByUserIdList(idList);
// TODO snippet
}
@Override
@@ -327,4 +328,29 @@ public class SystemUserServiceImpl implements SystemUserService {
Valid.isFalse(present, ErrorMessage.NICKNAME_PRESENT);
}
/**
* 删除主要用户缓存 其他的缓存自动过期
*
* @param userList
*/
private void deleteUserCacheKey(List<SystemUserDO> userList) {
Set<String> deleteKeys = new HashSet<>();
// 用户列表缓存
deleteKeys.add(UserCacheKeyDefine.USER_LIST.getKey());
userList.forEach(s -> {
Long id = s.getId();
// 用户提示
deleteKeys.add(TipsCacheKeyDefine.TIPS.format(id));
// 用户信息缓存
deleteKeys.add(UserCacheKeyDefine.USER_INFO.format(id));
// 登录失败次数
deleteKeys.add(UserCacheKeyDefine.LOGIN_FAILED_COUNT.format(s.getUsername()));
// 登录 token
deleteKeys.addAll(RedisUtils.scanKeys(UserCacheKeyDefine.LOGIN_TOKEN.format(id, "*")));
// 刷新 token
deleteKeys.addAll(RedisUtils.scanKeys(UserCacheKeyDefine.LOGIN_REFRESH.format(id, "*")));
});
RedisUtils.delete(deleteKeys);
}
}

46
orion-visor-module-infra/orion-visor-module-infra-service/src/main/resources/mapper/DataExtraMapper.xml
View File

@@ -26,30 +26,44 @@
UPDATE data_extra
SET value = JSON_REPLACE(value,
"$.keyId", NULL,
"$.authType", IF(
JSON_EXTRACT(value, "$.authType") = 'CUSTOM_KEY',
'DEFAULT',
JSON_EXTRACT(value, "$.authType")
))
"$.authType",
REPLACE(
IF(JSON_EXTRACT(value, "$.authType") = 'CUSTOM_KEY',
'DEFAULT',
JSON_EXTRACT(value, "$.authType")
),
'"',
''
)
)
WHERE deleted = 0
AND type = 'HOST'
AND item = 'ssh'
AND JSON_CONTAINS(value, JSON_OBJECT('keyId', #{keyId}))
AND type = 'HOST'
AND item = 'ssh'
<foreach collection="keyIdList" item="item" separator="OR" open="AND (" close=")">
JSON_CONTAINS(value, JSON_OBJECT('keyId', #{item}))
</foreach>
</delete>
<delete id="deleteHostIdentity">
UPDATE data_extra
SET value = JSON_REPLACE(value,
"$.identityId", NULL,
"$.authType", IF(
JSON_EXTRACT(value, "$.authType") = 'CUSTOM_IDENTITY',
'DEFAULT',
JSON_EXTRACT(value, "$.authType")
))
"$.authType",
REPLACE(
IF(JSON_EXTRACT(value, "$.authType") = 'CUSTOM_IDENTITY',
'DEFAULT',
JSON_EXTRACT(value, "$.authType")
),
'"',
''
)
)
WHERE deleted = 0
AND type = 'HOST'
AND item = 'ssh'
AND JSON_CONTAINS(value, JSON_OBJECT('identityId', #{identityId}))
AND type = 'HOST'
AND item = 'ssh'
<foreach collection="identityIdList" item="item" separator="OR" open="AND (" close=")">
JSON_CONTAINS(value, JSON_OBJECT('identityId', #{item}))
</foreach>
</delete>
</mapper>