阅读数:439 评论数:0

一、前言

使用边界计时器，对没有审批的任务提前进行提醒，如果用户借阅了图书，在归还时间前一天的时候，对用户进行提醒。

二、流程设计

在提醒事件上设置开始时间${startTime}

三、事件监听器

自定义监听器，实现FlowableEventListener接口。

@Component
@Slf4j
public class FlowableEventListenerTest implements FlowableEventListener {
    @Override
    public void onEvent(FlowableEvent event) {
        try {
            //FlowableEntityEventImpl 事件
            if (event instanceof FlowableEntityEventImpl) {
                FlowableEntityEventImpl engineEvent = (FlowableEntityEventImpl) event;
                JobEntityImpl job = (JobEntityImpl) engineEvent.getEntity();
                //获取任务详情
                String name = job.getElementName();
                String processInstanceId = job.getProcessInstanceId();

                System.out.println(name);
                System.out.println(processInstanceId);

            } else {
                //其他事件
            }
        } catch (Exception e) {
            log.error("执行事件监听器出错，error{}", e);
        }
    }

    @Override
    public boolean isFailOnException() {
        return false;
    }

    @Override
    public boolean isFireOnTransactionLifecycleEvent() {
        return false;
    }

    @Override
    public String getOnTransaction() {
        return null;
    }
}

四、注册监听器

@Configuration
public class GlobalEventListenerConfig {
    @Autowired
    private RuntimeService runtimeService;

    @PostConstruct
    public void addListener() {
        //第二个参数表示只处理任务执行成功的事件,没有第二个参数则表示处理 FlowableEngineEventType 的所有事件
        runtimeService.addEventListener(new FlowableEventListenerTest(), FlowableEngineEventType.JOB_EXECUTION_SUCCESS);
    }
}

五、测试

1、加载流程

	@Test
    public void createDeploymentTest() {
        Deployment deployment = repositoryService.createDeployment()
                .addClasspathResource("测试定时提醒.bpmn20.xml")
                .deploy();
        System.out.println(deployment.getId());
    }

2、启动流程

	@Test
    public void startOneTimejobProcessDefinition() {
        Map<String, Object> variables = new HashMap<String, Object>();
        //定时任务启动时间
        variables.put("startTime", "2022-06-26T22:40:00");
        //通过流程的key启动实例
        ProcessInstance processInstance =
                runtimeService.startProcessInstanceByKey("oneTimejob-process", variables);
        System.out.println(processInstance.getName());
    }

在定时任务启动时间到来时，如果任务还没有审批，则会触发监听器的逻辑。