From 7fe706118bac3a40e1122fb4bdfebf9b6bf6ca06 Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Tue, 4 Jun 2024 21:07:37 +0800 Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.0.0):=20=E9=81=BF=E5=85=8D=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E8=A6=86=E7=9B=96=E7=BB=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/web/service/impl/GroupConfigServiceImpl.java | 3 +++ .../snailjob/server/web/service/impl/JobServiceImpl.java | 2 ++ .../snailjob/server/web/service/impl/WorkflowServiceImpl.java | 2 ++ 3 files changed, 7 insertions(+) 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 d8921349..a2025340 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 @@ -138,6 +138,9 @@ public class GroupConfigServiceImpl implements GroupConfigService { groupConfig.setDescription(Optional.ofNullable(groupConfigRequestVO.getDescription()).orElse(StrUtil.EMPTY)); // 使用@TableField(value = "version", update= "%s+1") 进行更新version, 这里必须初始化一个值 groupConfig.setVersion(1); + // 不允许更新组 + groupConfig.setGroupName(null); + // 不允许更新token groupConfig.setToken(null); Assert.isTrue(tablePartitionList.contains(groupConfigRequestVO.getGroupPartition()), () -> new SnailJobServerException("分区不存在. [{}]", tablePartitionList)); diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java index 61571eab..e2f8c7a2 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java @@ -173,6 +173,8 @@ public class JobServiceImpl implements JobService { updateJob.setNextTriggerAt(DateUtils.toNowMilli()); } + // 禁止更新组 + updateJob.setGroupName(null); return 1 == jobMapper.updateById(updateJob); } diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java index d9eda892..2631beba 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowServiceImpl.java @@ -225,6 +225,8 @@ public class WorkflowServiceImpl implements WorkflowService { workflow.setVersion(version); workflow.setNextTriggerAt(calculateNextTriggerAt(workflowRequestVO, DateUtils.toNowMilli())); workflow.setFlowInfo(JsonUtil.toJsonString(GraphUtils.serializeGraphToJson(graph))); + // 不允许更新组 + workflow.setGroupName(null); Assert.isTrue( workflowMapper.update(workflow, new LambdaQueryWrapper()