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

update - 调整事件中 payload 模型,新增模型对应的消息模板配置信息

Browse Source
This commit is contained in:
wangli 2023-12-07 17:19:22 +08:00
parent 1b4e681936
commit dd1abd11cf
2 changed files with 17 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessTaskServiceImpl.java
View File

@ -477,9 +477,10 @@ public class BpmnProcessTaskServiceImpl implements BpmnProcessTaskService {
runtimeService.deleteMultiInstanceExecution(task.getExecutionId(), false); runtimeService.deleteMultiInstanceExecution(task.getExecutionId(), false);
taskService.deleteTask(task.getId(), dto.getAdvice()); taskService.deleteTask(task.getId(), dto.getAdvice());
if (Objects.nonNull(currentNumberOfInstances) && currentNumberOfInstances == 1) { // FIXME 这个拒绝的功能太过于业务定制了, 根本无法使用用户节点配置的完成条件, 后续慢慢熟悉后调整
// if (Objects.nonNull(currentNumberOfInstances) && currentNumberOfInstances == 1) {
finishProcessInstance(dto, instance); finishProcessInstance(dto, instance);
} // }
} else { } else {
finishProcessInstance(dto, instance); finishProcessInstance(dto, instance);
} }

32
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -179,27 +179,23 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
variables.put(VAR_PROCESS_END_TIME, sdf.format(processInstance.getEndTime())); variables.put(VAR_PROCESS_END_TIME, sdf.format(processInstance.getEndTime()));
} }
variables.put(VAR_PROCESS_RESULT, processInstance.getResult().getDesc()); variables.put(VAR_PROCESS_RESULT, processInstance.getResult().getDesc());
if (StringUtils.hasLength(event.getTaskId())) {
if (!StringUtils.hasLength(event.getTaskId())) {
return variables;
} else {
List<HistoricTaskInstance> tasks = List<HistoricTaskInstance> tasks =
historyService.createHistoricTaskInstanceQuery().taskId(event.getTaskId()).list(); historyService.createHistoricTaskInstanceQuery().taskId(event.getTaskId()).list();
if (CollectionUtils.isEmpty(tasks)) { if (!CollectionUtils.isEmpty(tasks)) {
return variables; // 应该只有 1 个, 但是为了防止有多个, 这里只取第一个
List<BpmnTaskDelegateAssigner> assigners =
(List<BpmnTaskDelegateAssigner>) originVariables.getOrDefault(INTERNAL_TASK_RELATION_ASSIGNEE_LIST_INFO_SNAPSHOT + tasks.get(0).getTaskDefinitionKey(), Collections.emptyList());
assigners.stream().filter(i -> Objects.equals(i.buildAssigneeId(), tasks.get(0).getAssignee())).findAny()
.ifPresent(i -> {
variables.put(VAR_TASK_USER_NAME, i.getAssignerName());
});
variables.put(VAR_ACTIVITY_ID, tasks.get(0).getTaskDefinitionKey());
variables.put(VAR_ACTIVITY_NAME, tasks.get(0).getName());
variables.put(VAR_TASK_START_TIME, sdf.format(tasks.get(0).getCreateTime()));
// 操作类型 同意、驳回、加签、评论、转交等, 暂时不实现, 这里设置有很多问题
variables.put(VAR_OPERATOR_TYPE, "");
} }
// 应该只有 1 个, 但是为了防止有多个, 这里只取第一个
List<BpmnTaskDelegateAssigner> assigners =
(List<BpmnTaskDelegateAssigner>) originVariables.getOrDefault(INTERNAL_TASK_RELATION_ASSIGNEE_LIST_INFO_SNAPSHOT + tasks.get(0).getTaskDefinitionKey(), Collections.emptyList());
assigners.stream().filter(i -> Objects.equals(i.buildAssigneeId(), tasks.get(0).getAssignee())).findAny()
.ifPresent(i -> {
variables.put(VAR_TASK_USER_NAME, i.getAssignerName());
});
variables.put(VAR_ACTIVITY_ID, tasks.get(0).getTaskDefinitionKey());
variables.put(VAR_ACTIVITY_NAME, tasks.get(0).getName());
variables.put(VAR_TASK_START_TIME, sdf.format(tasks.get(0).getCreateTime()));
// 操作类型 同意、驳回、加签、评论、转交等, 暂时不实现, 这里设置有很多问题
variables.put(VAR_OPERATOR_TYPE, "");
} }
categoryService.getById(Long.valueOf(processInstance.getCategory())).ifPresent(category -> { categoryService.getById(Long.valueOf(processInstance.getCategory())).ifPresent(category -> {