From b109c194249087fc851b4e2c534c8bcf9eee3a39 Mon Sep 17 00:00:00 2001 From: zjh <17611416079@163.com> Date: Fri, 14 Mar 2025 10:58:08 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=201.4.0-beta2=20=E7=BB=84?= =?UTF-8?q?=E7=AE=A1=E7=90=86=E5=88=A0=E9=99=A4=E5=87=BA=E9=94=99BUG=20htt?= =?UTF-8?q?ps://gitee.com/aizuda/snail-job/issues/IBTAFZ=20=E5=A4=84?= =?UTF-8?q?=E7=90=86=E6=96=B9=E6=A1=88=EF=BC=9A=20=E8=A1=A8=E5=9C=A8delete?= =?UTF-8?q?=E7=9A=84=E6=97=B6=E5=80=99=E6=B2=A1=E6=9C=89=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=EF=BC=8C=E5=85=88=E6=9F=A5=E8=AF=A2=E4=B8=80=E4=B8=8B=E5=86=8D?= =?UTF-8?q?=E5=88=A0=E9=99=A4=EF=BC=8C=E9=81=BF=E5=85=8D=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../web/service/impl/GroupConfigServiceImpl.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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; }