diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncTermNodeAlterJobHandler.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncTermNodeAlterJobHandler.java index 326f24169..a241684b7 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncTermNodeAlterJobHandler.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncTermNodeAlterJobHandler.java @@ -8,7 +8,6 @@ import cn.axzo.workflow.core.conf.SupportRefreshProperties; import cn.axzo.workflow.core.listener.Alter; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; import org.flowable.common.engine.impl.interceptor.CommandContext; import org.flowable.engine.RuntimeService; @@ -50,11 +49,11 @@ public class AsyncTermNodeAlterJobHandler extends AbstractJobHandler implements public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) { log.warn("AsyncTermNodeAlterJobHandler exec start..."); ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration(commandContext); - JSONObject jsonObject = JSON.parseObject(job.getJobHandlerConfiguration()); - if (!jsonObject.containsKey("activityId")) { - return; - } - String activityId = jsonObject.getString("activityId"); +// JSONObject jsonObject = JSON.parseObject(job.getJobHandlerConfiguration()); +// if (!jsonObject.containsKey("activityId")) { +// return; +// } + String activityId = job.getJobHandlerConfiguration(); RuntimeService runtimeService = processEngineConfiguration.getRuntimeService(); TermNodePausingDTO dto = runtimeService.getVariable(job.getProcessInstanceId(), BIZ_NODE_ALTER + activityId, TermNodePausingDTO.class); TaskService taskService = processEngineConfiguration.getTaskService();