From 3101218c73e3b0912fc3f670afb52422525e9fb9 Mon Sep 17 00:00:00 2001 From: Jeff Zhan <360400325@qq.com> Date: Thu, 18 Nov 2021 14:30:58 +0800 Subject: [PATCH] [Improvement][API][num-5] The workflow of the main table version is not allowed to be deleted (#6893) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * feature:deleteProcessDefinitionVersion * pref:delete duplicate enum definition Co-authored-by: 北笙 <“zhanqian@cai-inc.com”> --- .../api/service/impl/ProcessDefinitionServiceImpl.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java index 47fde6ff2f..ae1faf2757 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java @@ -1509,6 +1509,10 @@ public class ProcessDefinitionServiceImpl extends BaseServiceImpl implements Pro if (processDefinition == null) { putMsg(result, Status.PROCESS_DEFINE_NOT_EXIST, code); } else { + if (processDefinition.getVersion() == version) { + putMsg(result, Status.MAIN_TABLE_USING_VERSION); + return result; + } int deleteLog = processDefinitionLogMapper.deleteByProcessDefinitionCodeAndVersion(code, version); int deleteRelationLog = processTaskRelationLogMapper.deleteByCode(processDefinition.getCode(), processDefinition.getVersion()); if (deleteLog == 0 || deleteRelationLog == 0) {