From cce94fbdfc824fbddc3136cf3308753e7620ea88 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Thu, 26 Dec 2024 11:37:06 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E7=BB=84=E5=90=88?= =?UTF-8?q?=E5=B7=A5=E5=85=B7=E6=B7=BB=E5=8A=A0=E5=BC=95=E7=94=A8=E5=88=97?= =?UTF-8?q?=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1318905102958592]组合工具添加引用列表 http://192.168.0.96:8090/demo/rdm.html#/task-detail/939050947543040/939050947543050/1318905102958592 --- ...ecCombop2ProcessStepDependencyHandler.java | 143 ++++++++---------- 1 file changed, 64 insertions(+), 79 deletions(-) diff --git a/src/main/java/neatlogic/module/autoexec/dependency/AutoexecCombop2ProcessStepDependencyHandler.java b/src/main/java/neatlogic/module/autoexec/dependency/AutoexecCombop2ProcessStepDependencyHandler.java index 878b1225..799e38cf 100644 --- a/src/main/java/neatlogic/module/autoexec/dependency/AutoexecCombop2ProcessStepDependencyHandler.java +++ b/src/main/java/neatlogic/module/autoexec/dependency/AutoexecCombop2ProcessStepDependencyHandler.java @@ -15,95 +15,80 @@ along with this program. If not, see .*/ package neatlogic.module.autoexec.dependency; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; -import neatlogic.framework.asynchronization.threadlocal.TenantContext; import neatlogic.framework.autoexec.constvalue.AutoexecFromType; -import neatlogic.framework.crossover.CrossoverServiceFactory; import neatlogic.framework.dependency.core.DefaultDependencyHandlerBase; import neatlogic.framework.dependency.core.IFromType; import neatlogic.framework.dependency.dto.DependencyInfoVo; import neatlogic.framework.dependency.dto.DependencyVo; -import neatlogic.framework.process.crossover.IProcessCrossoverMapper; -import neatlogic.framework.process.dto.ProcessVo; -import neatlogic.module.autoexec.process.dto.CreateJobConfigConfigVo; -import neatlogic.module.autoexec.process.dto.CreateJobConfigVo; -import org.apache.commons.collections4.CollectionUtils; -import org.apache.commons.collections4.MapUtils; -import org.springframework.stereotype.Component; -import java.util.ArrayList; -import java.util.List; -import java.util.Objects; - -@Component +//@Component public class AutoexecCombop2ProcessStepDependencyHandler extends DefaultDependencyHandlerBase { @Override protected DependencyInfoVo parse(DependencyVo dependencyVo) { - JSONObject config = dependencyVo.getConfig(); - if (MapUtils.isEmpty(config)) { - return null; - } - String stepUuid = dependencyVo.getTo(); - String processUuid = config.getString("processUuid"); - IProcessCrossoverMapper processCrossoverMapper = CrossoverServiceFactory.getApi(IProcessCrossoverMapper.class); - ProcessVo processVo = processCrossoverMapper.getProcessBaseInfoByUuid(processUuid); - if (processVo == null) { - return null; - } - JSONObject processConfig = processVo.getConfig(); - if (MapUtils.isEmpty(processConfig)) { - return null; - } - JSONObject processObj = processConfig.getJSONObject("process"); - if (MapUtils.isEmpty(processObj)) { - return null; - } - JSONArray stepList = processObj.getJSONArray("stepList"); - if (CollectionUtils.isEmpty(stepList)) { - return null; - } - for (int i = 0; i < stepList.size(); i++) { - JSONObject stepObj = stepList.getJSONObject(i); - if (MapUtils.isEmpty(stepObj)) { - continue; - } - String uuid = stepObj.getString("uuid"); - if (!Objects.equals(uuid, stepUuid)) { - continue; - } - JSONObject stepConfig = stepObj.getJSONObject("stepConfig"); - if (MapUtils.isEmpty(stepConfig)) { - return null; - } - JSONObject createJobConfig = stepConfig.getJSONObject("createJobConfig"); - if (MapUtils.isEmpty(createJobConfig)) { - return null; - } - boolean flag = false; - CreateJobConfigVo createJobConfigVo = createJobConfig.toJavaObject(CreateJobConfigVo.class); - List configList = createJobConfigVo.getConfigList(); - if (CollectionUtils.isNotEmpty(configList)) { - for (CreateJobConfigConfigVo createJobConfigConfigVo : configList) { - if (createJobConfigConfigVo.getCombopId() != null && Objects.equals(createJobConfigConfigVo.getCombopId().toString(), dependencyVo.getFrom())) { - flag = true; - break; - } - } - } - if (!flag) { - return null; - } - JSONObject dependencyInfoConfig = new JSONObject(); - dependencyInfoConfig.put("processUuid", processUuid); - dependencyInfoConfig.put("stepUuid", stepUuid); - List pathList = new ArrayList<>(); - pathList.add("流程管理"); - pathList.add(processVo.getName()); - String urlFormat = "/" + TenantContext.get().getTenantUuid() + "/process.html#/flow-edit?uuid=${DATA.processUuid}&stepUuid=${DATA.stepUuid}"; - return new DependencyInfoVo(stepUuid, dependencyInfoConfig, stepObj.getString("name"), pathList, urlFormat, this.getGroupName()); - } +// JSONObject config = dependencyVo.getConfig(); +// if (MapUtils.isEmpty(config)) { +// return null; +// } +// String stepUuid = dependencyVo.getTo(); +// String processUuid = config.getString("processUuid"); +// IProcessCrossoverMapper processCrossoverMapper = CrossoverServiceFactory.getApi(IProcessCrossoverMapper.class); +// ProcessVo processVo = processCrossoverMapper.getProcessBaseInfoByUuid(processUuid); +// if (processVo == null) { +// return null; +// } +// JSONObject processConfig = processVo.getConfig(); +// if (MapUtils.isEmpty(processConfig)) { +// return null; +// } +// JSONObject processObj = processConfig.getJSONObject("process"); +// if (MapUtils.isEmpty(processObj)) { +// return null; +// } +// JSONArray stepList = processObj.getJSONArray("stepList"); +// if (CollectionUtils.isEmpty(stepList)) { +// return null; +// } +// for (int i = 0; i < stepList.size(); i++) { +// JSONObject stepObj = stepList.getJSONObject(i); +// if (MapUtils.isEmpty(stepObj)) { +// continue; +// } +// String uuid = stepObj.getString("uuid"); +// if (!Objects.equals(uuid, stepUuid)) { +// continue; +// } +// JSONObject stepConfig = stepObj.getJSONObject("stepConfig"); +// if (MapUtils.isEmpty(stepConfig)) { +// return null; +// } +// JSONObject createJobConfig = stepConfig.getJSONObject("createJobConfig"); +// if (MapUtils.isEmpty(createJobConfig)) { +// return null; +// } +// boolean flag = false; +// CreateJobConfigVo createJobConfigVo = createJobConfig.toJavaObject(CreateJobConfigVo.class); +// List configList = createJobConfigVo.getConfigList(); +// if (CollectionUtils.isNotEmpty(configList)) { +// for (CreateJobConfigConfigVo createJobConfigConfigVo : configList) { +// if (createJobConfigConfigVo.getCombopId() != null && Objects.equals(createJobConfigConfigVo.getCombopId().toString(), dependencyVo.getFrom())) { +// flag = true; +// break; +// } +// } +// } +// if (!flag) { +// return null; +// } +// JSONObject dependencyInfoConfig = new JSONObject(); +// dependencyInfoConfig.put("processUuid", processUuid); +// dependencyInfoConfig.put("stepUuid", stepUuid); +// List pathList = new ArrayList<>(); +// pathList.add("流程管理"); +// pathList.add(processVo.getName()); +// String urlFormat = "/" + TenantContext.get().getTenantUuid() + "/process.html#/flow-edit?uuid=${DATA.processUuid}&stepUuid=${DATA.stepUuid}"; +// return new DependencyInfoVo(stepUuid, dependencyInfoConfig, stepObj.getString("name"), pathList, urlFormat, this.getGroupName()); +// } return null; } -- Gitee