wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'hotfix/timer_alter' into feature/REQ-4624

Browse Source
This commit is contained in:
wangli 2025-08-06 18:04:40 +08:00
commit b42ed0b38c
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncTermNodeAlterJobHandler.java
View File

@ -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();