wangli/tyr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:(REQ-2750) 收口roleUserRelation删除的接口

Browse Source
This commit is contained in:
lilong 2024-09-24 17:33:32 +08:00
parent c4e37637da
commit 7b08981945
2 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tyr-server/src/main/java/cn/axzo/tyr/server/repository/dao/SaasRoleUserRelationDao.java
View File

@ -21,13 +21,6 @@ import java.util.stream.Collectors;
@Repository @Repository
public class SaasRoleUserRelationDao extends ServiceImpl<SaasRoleUserRelationMapper, SaasRoleUserRelation> { public class SaasRoleUserRelationDao extends ServiceImpl<SaasRoleUserRelationMapper, SaasRoleUserRelation> {
public void deleteByRoleId(List<Long> roleId) {
lambdaUpdate()
.in(SaasRoleUserRelation::getRoleId,roleId)
.set(BaseEntity::getIsDelete,TableIsDeleteEnum.DELETE.value)
.update();
}
public void deleteById(List<Long> ids) { public void deleteById(List<Long> ids) {
if (CollUtil.isEmpty(ids)) { if (CollUtil.isEmpty(ids)) {
return; return;

6
tyr-server/src/main/java/cn/axzo/tyr/server/service/impl/RoleServiceImpl.java
View File

@ -988,11 +988,13 @@ public class RoleServiceImpl extends ServiceImpl<SaasRoleMapper, SaasRole>
saasRoleDao.delete(deleteRoleParam.getRoleIds()); saasRoleDao.delete(deleteRoleParam.getRoleIds());
// 收口remove接口，通过id更新不会出现死锁，并补发mq // 收口remove接口，通过id更新不会出现死锁，并补发mq
// 因为角色用户数据量巨大，应该是角色删除后发送mq，异步解耦去删除相关数据，但是得等角色的写接口收口后才能做 // 因为角色用户数据量巨大，应该是角色删除后发送mq，异步解耦去删除相关数据，但是得等角色的写接口收口后才能做
saasRoleUserRelationService.listV2(ListRoleUserRelationParam.builder() List<SaasRoleUserV2DTO> saasRoleUsers = saasRoleUserRelationService.listV2(ListRoleUserRelationParam.builder()
.roleIds(deleteRoleParam.getRoleIds()) .roleIds(deleteRoleParam.getRoleIds())
.build()); .build());
roleUserRelationDao.deleteByRoleId(deleteRoleParam.getRoleIds()); saasRoleUserRelationService.batchRemove(SaasRoleUserRelationService.BatchRemoveParam.builder()
.ids(saasRoleUsers.stream().map(SaasRoleUserV2DTO::getId).collect(Collectors.toSet()))
.build());
roleGroupRelationDao.deleteGroupRelation(deleteRoleParam.getRoleIds()); roleGroupRelationDao.deleteGroupRelation(deleteRoleParam.getRoleIds());
saasPgroupRoleRelationDao.deleteByRoleId(deleteRoleParam.getRoleIds()); saasPgroupRoleRelationDao.deleteByRoleId(deleteRoleParam.getRoleIds());
} }