flowable实现节点超时自动跳过

星痕

发布于 2019-05-05 11:32:36

9.3K5

发布于 2019-05-05 11:32:36

文章被收录于专栏：JAVA后端开发

不论是flowable还是activiti,都可以快速的实现节点超时自动跳过，主要是使用边缘事件

启动定时任务在初始化时,启动定时job,写在配置文件如下

flowable:
  #启动定时任务JOB
    async-executor-activate: true
    check-process-definitions: false
    rest-api-enabled: false
    database-schema-update: true
    idm:
     enabled: false

注意: async-executor-activate就是开关

使用边缘事件生成流程定义如下:

<userTask id="N5" name="审批" flowable:async="true" flowable:assignee="1,2,3">
      <multiInstanceLoopCharacteristics isSequential="false" flowable:collection="{starmark_emptycollection}" flowable:elementVariable="starmark_atuser"></multiInstanceLoopCharacteristics>
    </userTask>
    <boundaryEvent id="BoundaryEvent_N5" name="审批" attachedToRef="N5" cancelActivity="true">
      <extensionElements>
        <flowable:executionListener event="end" class="com.starmark.oa.workflow.activiti.listener.ProcessDueTimeListener"></flowable:executionListener>
      </extensionElements>
      <timerEventDefinition>
        <timeDate>PT1H</timeDate>
      </timerEventDefinition>
    </boundaryEvent>

上述就配置了1个小时自动跳过

实现监听器从上述定义,可以看到,我配置了一个监听器. 为什么配一个监听器呢,主要是为了让自动跳过时,生成一条日记记录,不然自动跳过了,啥都不知道了. 当然,如果不考虑加日志,上面的配置已经可以定时跳过了

/**
 * 流程节点超时自动跳过
 */
public class ProcessDueTimeListener implements ExecutionListener {

    private IActHiCommentService actHiCommentService=null;

    private IActHiCommentService getActHiCommentService(){
        if(actHiCommentService==null){
            actHiCommentService=SpringContextUtils.getBean(IActHiCommentService.class);
        }
        return actHiCommentService;
    }

    @Override
    public void notify(DelegateExecution execution) {
        CommentEntity comment = new CommentEntityImpl();
        comment.setId(IdWorker.getIdStr());
        comment.setProcessInstanceId(execution.getProcessInstanceId());
        comment.setType("comment");
        comment.setAction(execution.getCurrentFlowElement().getName()+"超时自动跳过");
        comment.setTime(new Date());
        comment.setUserId("system");
        comment.setMessage("");
       System.out.println(execution.getProcessInstanceId());
        System.out.println( execution.getCurrentActivityId());
        getActHiCommentService().insert(comment);

    }
}