Merge branch 'refs/heads/1.3.1-SNAPSHOT' into 1.3.2-SNAPSHOT
# Conflicts: # workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ExtTaskInstEventListener.java
This commit is contained in:
commit
1fda37d058
@ -123,6 +123,7 @@ public class BpmnTaskDelegateAssigner implements Serializable {
|
||||
* @return true 是同一人
|
||||
*/
|
||||
public final boolean comparePersonIdToOther(String assignee) {
|
||||
log.info("comparePersonIdToOther: {}, current PersonId: {}", assignee, personId);
|
||||
if (!StringUtils.hasText(assignee)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
@ -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;
|
||||
@ -44,6 +45,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)) {
|
||||
|
||||
@ -127,6 +127,7 @@ public class AutoOperatorEvent_103_Listener extends AbstractBpmnEventListener<Ta
|
||||
.findActivityInstancesByProcessInstanceId(delegateTask.getProcessInstanceId(), false)
|
||||
.stream()
|
||||
.filter(i -> !Objects.equals(i.getActivityId(), userTask.getId()))
|
||||
.filter(i -> !Objects.equals(i.getActivityType(), "exclusiveGateway"))
|
||||
.filter(i -> !Objects.equals(i.getActivityType(), "sequenceFlow"))
|
||||
.max(Comparator.comparing(ActivityInstanceEntity::getStartTime))
|
||||
.ifPresent(i -> {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user