From e48a53698ce25f9523429e4b86f4dce5083c283a Mon Sep 17 00:00:00 2001 From: dhb52 Date: Fri, 10 May 2024 11:44:56 +0800 Subject: [PATCH] style: cs-fix --- .../web/service/impl/WorkflowServiceImpl.java | 21 +++++++++++-------- 1 file changed, 12 insertions(+), 9 deletions(-) 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 232af5226..6c6d7dc44 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 @@ -133,8 +133,8 @@ public class WorkflowServiceImpl implements WorkflowService { workflowRequestVO.getGroupName(), workflow.getId(), nodeConfig, graph, workflow.getVersion()); - log.info("图构建完成. graph:[{}]", graph); + // 保存图信息 workflow.setVersion(null); workflow.setFlowInfo(JsonUtil.toJsonString(GraphUtils.serializeGraphToJson(graph))); @@ -250,10 +250,12 @@ public class WorkflowServiceImpl implements WorkflowService { workflow.setVersion(version); workflow.setNextTriggerAt(calculateNextTriggerAt(workflowRequestVO, DateUtils.toNowMilli())); workflow.setFlowInfo(JsonUtil.toJsonString(GraphUtils.serializeGraphToJson(graph))); - Assert.isTrue(workflowMapper.update(workflow, new LambdaQueryWrapper() - .eq(Workflow::getId, workflow.getId()) - .eq(Workflow::getVersion, version) - ) > 0, () -> new SnailJobServerException("更新失败")); + Assert.isTrue( + workflowMapper.update(workflow, + new LambdaQueryWrapper() + .eq(Workflow::getId, workflow.getId()) + .eq(Workflow::getVersion, version)) > 0, + () -> new SnailJobServerException("更新失败")); return Boolean.TRUE; } @@ -288,10 +290,11 @@ public class WorkflowServiceImpl implements WorkflowService { Workflow workflow = workflowMapper.selectById(id); Assert.notNull(workflow, () -> new SnailJobServerException("workflow can not be null.")); - long count = accessTemplate.getGroupConfigAccess().count(new LambdaQueryWrapper() - .eq(GroupConfig::getGroupName, workflow.getGroupName()) - .eq(GroupConfig::getNamespaceId, workflow.getNamespaceId()) - .eq(GroupConfig::getGroupStatus, StatusEnum.YES.getStatus()) + long count = accessTemplate.getGroupConfigAccess().count( + new LambdaQueryWrapper() + .eq(GroupConfig::getGroupName, workflow.getGroupName()) + .eq(GroupConfig::getNamespaceId, workflow.getNamespaceId()) + .eq(GroupConfig::getGroupStatus, StatusEnum.YES.getStatus()) ); Assert.isTrue(count > 0, () -> new SnailJobServerException("组:[{}]已经关闭，不支持手动执行.", workflow.getGroupName()));