diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java index 154a89a52..53671c876 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/GroupConfigServiceImpl.java @@ -478,11 +478,14 @@ public class GroupConfigServiceImpl implements GroupConfigService { .eq(GroupConfig::getGroupName, groupName)), () -> new SnailJobServerException("删除组失败, 请检查状态是否关闭状态")); - Assert.isTrue(1 == sequenceAllocMapper.delete(new LambdaQueryWrapper() + //-----解决issues-IBTAFZ 删除之前查询一下避免sj_sequence_alloc表为空仍然删除 + LambdaQueryWrapper sequenceAllocQueryWrapper = new LambdaQueryWrapper() .eq(SequenceAlloc::getNamespaceId, namespaceId) - .eq(SequenceAlloc::getGroupName, groupName)), - () -> new SnailJobServerException("删除分布式Id表数据失败")); - + .eq(SequenceAlloc::getGroupName, groupName); + if (!sequenceAllocMapper.selectList(sequenceAllocQueryWrapper).isEmpty()) { + Assert.isTrue(sequenceAllocMapper.delete(sequenceAllocQueryWrapper) >= 1, + () -> new SnailJobServerException("删除分布式Id表数据失败")); + } return Boolean.TRUE; }