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

Merge branch 'hotfix/node-alter' into test

Browse Source
This commit is contained in:
wangli 2025-09-12 10:22:30 +08:00
commit c1c801f813
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/NodeAlterJobHandler.java
View File

@ -69,16 +69,16 @@ public class NodeAlterJobHandler extends IJobHandler {
jobs.forEach(e -> { jobs.forEach(e -> {
XxlJobHelper.log("start execution of job: {}", JSON.toJSONString(e)); XxlJobHelper.log("start execution of job: {}", JSON.toJSONString(e));
ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(e.getProcessInstanceId()).singleResult(); ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(e.getProcessInstanceId()).singleResult();
if (Objects.isNull(processInstance)) {
executedJobs.add(e);
return;
}
if (!refreshProperties.getAlterAllDefinitionKey()) { if (!refreshProperties.getAlterAllDefinitionKey()) {
if (!ListUtils.emptyIfNull(refreshProperties.getAlterDefinitionKeys()).contains(processInstance.getProcessDefinitionKey())) { if (!ListUtils.emptyIfNull(refreshProperties.getAlterDefinitionKeys()).contains(processInstance.getProcessDefinitionKey())) {
XxlJobHelper.log("skip alter by config"); XxlJobHelper.log("skip alter by config");
return; return;
} }
} }
if (Objects.isNull(processInstance)) {
executedJobs.add(e);
return;
}
List<Task> tasks = taskService.createTaskQuery() List<Task> tasks = taskService.createTaskQuery()
.processInstanceId(e.getProcessInstanceId()) .processInstanceId(e.getProcessInstanceId())
.taskDefinitionKey(e.getActivityId()) .taskDefinitionKey(e.getActivityId())