From f3f8ed503e24c61f0d7e1b70aa00a2365e10fff0 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Fri, 1 Aug 2025 16:15:52 +0800 Subject: [PATCH 1/2] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=90=8E=E7=AB=AF-?= =?UTF-8?q?=E7=BB=84=E5=90=88=E5=B7=A5=E5=85=B7=E5=88=9B=E5=BB=BA=E4=BD=9C?= =?UTF-8?q?=E4=B8=9A=E9=A1=B5=E9=9D=A2=E5=A6=82=E6=9E=9C=E6=89=80=E6=9C=89?= =?UTF-8?q?runner=E9=98=B6=E6=AE=B5=E9=83=BD=E8=AE=BE=E7=BD=AE=E4=BA=86?= =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E7=BB=84=EF=BC=8C=E5=88=99=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E4=BD=9C=E4=B8=9A=E7=9A=84=E6=97=B6=E5=80=99=E6=97=A0?= =?UTF-8?q?=E9=9C=80=E8=AE=BE=E7=BD=AE=E6=89=A7=E8=A1=8C=E5=99=A8=E7=BB=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1478301363699712]后端-组合工具创建作业页面如果所有runner阶段都设置了执行器组,则创建作业的时候无需设置执行器组 http://192.168.0.96:8090/demo/rdm.html#/task-detail/939050947543040/939050947543050/1478301363699712 --- .../autoexec/api/combop/AutoexecCombopDetailGetApi.java | 1 + .../autoexec/service/AutoexecCombopServiceImpl.java | 8 ++++++++ 2 files changed, 9 insertions(+) diff --git a/src/main/java/neatlogic/module/autoexec/api/combop/AutoexecCombopDetailGetApi.java b/src/main/java/neatlogic/module/autoexec/api/combop/AutoexecCombopDetailGetApi.java index 1a102bac..ad343acd 100644 --- a/src/main/java/neatlogic/module/autoexec/api/combop/AutoexecCombopDetailGetApi.java +++ b/src/main/java/neatlogic/module/autoexec/api/combop/AutoexecCombopDetailGetApi.java @@ -121,6 +121,7 @@ public class AutoexecCombopDetailGetApi extends PrivateApiComponentBase { autoexecCombopVo.setNeedExecuteUser(autoexecCombopVersionVo.getNeedExecuteUser()); autoexecCombopVo.setNeedProtocol(autoexecCombopVersionVo.getNeedProtocol()); autoexecCombopVo.setNeedRoundCount(autoexecCombopVersionVo.getNeedRoundCount()); + autoexecCombopVo.setNeedRunnerGroup(autoexecCombopVersionVo.getNeedRunnerGroup()); AutoexecCombopConfigVo config = autoexecCombopVo.getConfig(); config.setExecuteConfig(versionConfig.getExecuteConfig()); config.setCombopGroupList(versionConfig.getCombopGroupList()); diff --git a/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java b/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java index 1c79f548..4e00ca20 100644 --- a/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java +++ b/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java @@ -901,6 +901,7 @@ public class AutoexecCombopServiceImpl implements AutoexecCombopService, IAutoex boolean needProtocol = autoexecCombopVersionVo.getNeedProtocol(); boolean needExecuteNode = autoexecCombopVersionVo.getNeedExecuteNode(); boolean needRoundCount = autoexecCombopVersionVo.getNeedRoundCount(); + boolean needRunnerGroup = autoexecCombopVersionVo.getNeedRunnerGroup(); AutoexecCombopExecuteConfigVo executeConfigVo = null; if (Objects.equals(AutoexecJobGroupPolicy.GRAYSCALE.getName(), autoexecCombopGroupVo.getPolicy())) { AutoexecCombopGroupConfigVo autoexecCombopGroupConfigVo = autoexecCombopGroupVo.getConfig(); @@ -947,11 +948,18 @@ public class AutoexecCombopServiceImpl implements AutoexecCombopService, IAutoex needRoundCount = true; } } + if (!needRunnerGroup) { + ParamMappingVo runnerGroup = executeConfigVo.getRunnerGroup(); + if (runnerGroup == null || StringUtils.isBlank((String) runnerGroup.getValue())) { + needRunnerGroup = true; + } + } } autoexecCombopVersionVo.setNeedExecuteUser(needExecuteUser); autoexecCombopVersionVo.setNeedExecuteNode(needExecuteNode); autoexecCombopVersionVo.setNeedProtocol(needProtocol); autoexecCombopVersionVo.setNeedRoundCount(needRoundCount); + autoexecCombopVersionVo.setNeedRunnerGroup(needRunnerGroup); } @Override -- Gitee From 8e280d40303f3ff74adb47e1625a2f66c1dfbb0d Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Fri, 1 Aug 2025 17:23:57 +0800 Subject: [PATCH 2/2] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=90=8E=E7=AB=AF-?= =?UTF-8?q?=E7=BB=84=E5=90=88=E5=B7=A5=E5=85=B7=E5=88=9B=E5=BB=BA=E4=BD=9C?= =?UTF-8?q?=E4=B8=9A=E9=A1=B5=E9=9D=A2=E5=A6=82=E6=9E=9C=E6=89=80=E6=9C=89?= =?UTF-8?q?runner=E9=98=B6=E6=AE=B5=E9=83=BD=E8=AE=BE=E7=BD=AE=E4=BA=86?= =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E7=BB=84=EF=BC=8C=E5=88=99=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E4=BD=9C=E4=B8=9A=E7=9A=84=E6=97=B6=E5=80=99=E6=97=A0?= =?UTF-8?q?=E9=9C=80=E8=AE=BE=E7=BD=AE=E6=89=A7=E8=A1=8C=E5=99=A8=E7=BB=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1478301363699712]后端-组合工具创建作业页面如果所有runner阶段都设置了执行器组,则创建作业的时候无需设置执行器组 http://192.168.0.96:8090/demo/rdm.html#/task-detail/939050947543040/939050947543050/1478301363699712 --- .../service/AutoexecCombopServiceImpl.java | 76 +++++++++---------- 1 file changed, 38 insertions(+), 38 deletions(-) diff --git a/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java b/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java index 4e00ca20..bb64dfa3 100644 --- a/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java +++ b/src/main/java/neatlogic/module/autoexec/service/AutoexecCombopServiceImpl.java @@ -884,19 +884,14 @@ public class AutoexecCombopServiceImpl implements AutoexecCombopService, IAutoex @Override public void needExecuteConfig(AutoexecCombopVersionVo autoexecCombopVersionVo, AutoexecCombopPhaseVo autoexecCombopPhaseVo, AutoexecCombopGroupVo autoexecCombopGroupVo) { String execMode = autoexecCombopPhaseVo.getExecMode(); - if (ExecMode.RUNNER.getValue().equals(execMode)) { + if (ExecMode.RUNNER.getValue().equals(execMode) || ExecMode.SQL.getValue().equals(execMode)) { if (autoexecCombopVersionVo.getAllPhasesAreRunnerOrSqlExecMode() == null) { autoexecCombopVersionVo.setAllPhasesAreRunnerOrSqlExecMode(true); } - return; - } - if (ExecMode.SQL.getValue().equals(execMode)) { - if (autoexecCombopVersionVo.getAllPhasesAreRunnerOrSqlExecMode() == null) { - autoexecCombopVersionVo.setAllPhasesAreRunnerOrSqlExecMode(true); - } - return; + } else { + autoexecCombopVersionVo.setAllPhasesAreRunnerOrSqlExecMode(false); } - autoexecCombopVersionVo.setAllPhasesAreRunnerOrSqlExecMode(false); + boolean needExecuteUser = autoexecCombopVersionVo.getNeedExecuteUser(); boolean needProtocol = autoexecCombopVersionVo.getNeedProtocol(); boolean needExecuteNode = autoexecCombopVersionVo.getNeedExecuteNode(); @@ -915,43 +910,48 @@ public class AutoexecCombopServiceImpl implements AutoexecCombopService, IAutoex needProtocol = true; needExecuteNode = true; needRoundCount = true; + needRunnerGroup = true; } else { - if (!needProtocol) { - Long protocolId = executeConfigVo.getProtocolId(); - if (protocolId == null) { - needProtocol = true; + if (Objects.equals(execMode, ExecMode.TARGET.getValue()) || Objects.equals(execMode, ExecMode.RUNNER_TARGET.getValue())) { + if (!needProtocol) { + Long protocolId = executeConfigVo.getProtocolId(); + if (protocolId == null) { + needProtocol = true; + } } - } - if (!needExecuteUser) { - ParamMappingVo executeUser = executeConfigVo.getExecuteUser(); - if (executeUser == null || StringUtils.isBlank((String) executeUser.getValue())) { - needExecuteUser = true; + if (!needExecuteUser) { + ParamMappingVo executeUser = executeConfigVo.getExecuteUser(); + if (executeUser == null || StringUtils.isBlank((String) executeUser.getValue())) { + needExecuteUser = true; + } } - } - if (!needExecuteNode) { - AutoexecCombopExecuteNodeConfigVo executeNodeConfigVo = executeConfigVo.getExecuteNodeConfig(); - if (executeNodeConfigVo == null) { - needExecuteNode = true; - } else { - List paramList = executeNodeConfigVo.getParamList(); - List selectNodeList = executeNodeConfigVo.getSelectNodeList(); - List inputNodeList = executeNodeConfigVo.getInputNodeList(); - List preOutputList = executeNodeConfigVo.getPreOutputList(); - JSONObject filter = executeNodeConfigVo.getFilter(); - if (CollectionUtils.isEmpty(paramList) && CollectionUtils.isEmpty(selectNodeList) && CollectionUtils.isEmpty(inputNodeList) && CollectionUtils.isEmpty(preOutputList) && MapUtils.isEmpty(filter)) { + if (!needExecuteNode) { + AutoexecCombopExecuteNodeConfigVo executeNodeConfigVo = executeConfigVo.getExecuteNodeConfig(); + if (executeNodeConfigVo == null) { needExecuteNode = true; + } else { + List paramList = executeNodeConfigVo.getParamList(); + List selectNodeList = executeNodeConfigVo.getSelectNodeList(); + List inputNodeList = executeNodeConfigVo.getInputNodeList(); + List preOutputList = executeNodeConfigVo.getPreOutputList(); + JSONObject filter = executeNodeConfigVo.getFilter(); + if (CollectionUtils.isEmpty(paramList) && CollectionUtils.isEmpty(selectNodeList) && CollectionUtils.isEmpty(inputNodeList) && CollectionUtils.isEmpty(preOutputList) && MapUtils.isEmpty(filter)) { + needExecuteNode = true; + } } } - } - if (!needRoundCount) { - if (executeConfigVo.getRoundCount() == null) { - needRoundCount = true; + if (!needRoundCount) { + if (executeConfigVo.getRoundCount() == null) { + needRoundCount = true; + } } } - if (!needRunnerGroup) { - ParamMappingVo runnerGroup = executeConfigVo.getRunnerGroup(); - if (runnerGroup == null || StringUtils.isBlank((String) runnerGroup.getValue())) { - needRunnerGroup = true; + if (Objects.equals(execMode, ExecMode.RUNNER.getValue())) { + if (!needRunnerGroup) { + ParamMappingVo runnerGroup = executeConfigVo.getRunnerGroup(); + if (runnerGroup == null || runnerGroup.getValue() == null) { + needRunnerGroup = true; + } } } } -- Gitee