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

update - 打印抄送时的日志

Browse Source
This commit is contained in:
wangli 2024-04-08 15:11:57 +08:00
parent 21260d382b
commit d7f0766ffb
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ExtTaskInstEventListener.java
View File

@ -6,6 +6,7 @@ import cn.axzo.workflow.core.engine.event.ExtTaskInstUpdateEvent;
import cn.axzo.workflow.core.engine.event.ReceiveTaskEventType;
import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst;
import cn.axzo.workflow.core.service.ExtAxHiTaskInstService;
import com.alibaba.fastjson.JSON;
import com.google.common.collect.ImmutableSet;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@ -43,6 +44,7 @@ public class ExtTaskInstEventListener extends AbstractFlowableEventListener {
@Override
public void onEvent(FlowableEvent flowableEvent) {
if (flowableEvent instanceof ExtTaskInstEvent) {
log.info("Ext Task Inst Event : {}", JSON.toJSONString(flowableEvent));
ExtTaskInstEvent event = (ExtTaskInstEvent) flowableEvent;
ReceiveTaskEventType eventType = (ReceiveTaskEventType) flowableEvent.getType();
if (SUPPORT_EVENTS.contains(eventType)) {
@ -78,19 +80,13 @@ public class ExtTaskInstEventListener extends AbstractFlowableEventListener {
private void updateExtTaskInst(ExtTaskInstUpdateEvent event) {
ExtAxHiTaskInst entity = extAxHiTaskInstService.getByTaskId(event.getTaskId(), event.getProcessInstanceId());
if (Objects.nonNull(entity)) {
if (StringUtils.hasText(event.getAssignee())) {
entity.setAssignee(event.getAssignee());
}
entity.setStatus(event.getResultEnum().getStatus());
extAxHiTaskInstService.update(entity);
} else {
// 如果一个任务,如果没有设置人,那么就不会先执行 saveExtTaskInst 方法,
// 所以,这里做一个兜底,如果没有查询到,有协助新建该对象
// ExtTaskInstCreateEvent create = new ExtTaskInstCreateEvent(event.getProcessInstanceId(),
// event.getActivityId(), event.getTaskId(), event.getAssignee(), event.getResultEnum());
// saveExtTaskInst(create);
if (Objects.isNull(entity)) {
return;
}
if (StringUtils.hasText(event.getAssignee())) {
entity.setAssignee(event.getAssignee());
}
entity.setStatus(event.getResultEnum().getStatus());
extAxHiTaskInstService.update(entity);
}
}