parent
33c1ae8751
commit
68c531b3dc
@ -478,11 +478,14 @@ public class GroupConfigServiceImpl implements GroupConfigService {
|
||||
.eq(GroupConfig::getGroupName, groupName)),
|
||||
() -> new SnailJobServerException("删除组失败, 请检查状态是否关闭状态"));
|
||||
|
||||
Assert.isTrue(1 == sequenceAllocMapper.delete(new LambdaQueryWrapper<SequenceAlloc>()
|
||||
//-----解决issues-IBTAFZ 删除之前查询一下避免sj_sequence_alloc表为空仍然删除
|
||||
LambdaQueryWrapper<SequenceAlloc> sequenceAllocQueryWrapper = new LambdaQueryWrapper<SequenceAlloc>()
|
||||
.eq(SequenceAlloc::getNamespaceId, namespaceId)
|
||||
.eq(SequenceAlloc::getGroupName, groupName)),
|
||||
.eq(SequenceAlloc::getGroupName, groupName);
|
||||
if (!sequenceAllocMapper.selectList(sequenceAllocQueryWrapper).isEmpty()) {
|
||||
Assert.isTrue(sequenceAllocMapper.delete(sequenceAllocQueryWrapper) >= 1,
|
||||
() -> new SnailJobServerException("删除分布式Id表数据失败"));
|
||||
|
||||
}
|
||||
return Boolean.TRUE;
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user