在BPMN工具上面绘制会议审批的工作流，如下：

下载BPMN文件，把文件导入到SpringBoot项目的processes目录，然后启动项目执行部署。

在com.example.emos.workflow.service包创建WorkflowService接口。

public interface WorkflowService {
    public String startMeetingProcess(HashMap param);
}

在com.example.emos.workflow.service.impl包创建WorkflowServiceImpl类。

@Service
public class WorkflowServiceImpl implements WorkflowService {
    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private ProcessEngine processEngine;

    @Autowired
    private TaskService taskService;

    @Autowired
    private HistoryService historyService;

    @Autowired
    private KieSession kieSession;

    @Autowired
    private MeetingService meetingService;

    @Autowired
    private LeaveService leaveService;

    @Autowired
    private ReimService reimService;

    @Autowired
    private QuartzUtil quartzUtil;
    
    @Override
    public String startMeetingProcess(HashMap param) {
        String instanceId = runtimeService.startProcessInstanceByKey("meeting", param).getProcessInstanceId(); //启动工作流
        String uuid = param.get("uuid").toString();
        String date = param.get("date").toString();
        String start = param.get("start").toString();

        /*
         * 创建定时器，执行时间为会议开始时间。
         * 如果会议开始前，该会议还没有审批通过，定时器就把会议状态更新成2，然后关闭工作流
         * 如果会议审批通过，需要删除这个定时器任务
         */
        JobDetail jobDetail = JobBuilder.newJob(MeetingWorkflowJob.class).build();
        Map dataMap = jobDetail.getJobDataMap();
        dataMap.put("uuid", uuid);
        dataMap.put("instanceId", instanceId);

        Date executeDate = DateUtil.parse(date + " " + start, "yyyy-MM-dd HH:mm:ss");
        quartzUtil.addJob(jobDetail, uuid, "会议工作流组", executeDate); //创建定时任务，检查工作流审批状态

        return instanceId;
    }

}

在com.example.emos.workflow.controller.form包中创建StartMeetingProcessForm类。

@Data
public class StartMeetingProcessForm
 {
    @NotBlank(message = "uuid不能为空")
    private String uuid;

    @NotNull(message = "creatorId不能为空")
    @Min(value = 1, message = "creatorId不能小于1")
    private Integer creatorId;

    @NotBlank(message = "creatorName不能为空")
    @Pattern(regexp = "^[\\u4e00-\\u9fa5]{2,15}$", message = "creatorName内容不正确")
    private String creatorName;

    @NotBlank(message = "title不能为空")
    @Pattern(regexp = "^[a-zA-Z0-9\\u4e00-\\u9fa5]{2,30}$", message = "title内容不正确")
    private String title;

    @Min(value = 1, message = "gmId不能小于1")
    private Integer gmId;

    @Min(value = 1, message = "managerId不能小于1")
    private Integer managerId;

    @NotBlank(message = "url不能为空")
    private String url;

    private Boolean sameDept;

    @NotBlank(message = "code不能为空")
    private String code;

    @NotNull(message = "date不能为空")
    @Pattern(regexp = "^((((1[6-9]|[2-9]\\d)\\d{2})-(0?[13578]|1[02])-(0?[1-9]|[12]\\d|3[01]))|(((1[6-9]|[2-9]\\d)\\d{2})-(0?[13456789]|1[012])-(0?[1-9]|[12]\\d|30))|(((1[6-9]|[2-9]\\d)\\d{2})-0?2-(0?[1-9]|1\\d|2[0-8]))|(((1[6-9]|[2-9]\\d)(0[48]|[2468][048]|[13579][26])|((16|[2468][048]|[3579][26])00))-0?2-29-))$", message = "date内容不正确")
    private String date;

    @NotNull(message = "start不能为空")
    @Pattern(regexp = "^([01]?[0-9]|2[0-3]):[0-5][0-9]:[0-5][0-9]$", message = "start内容不正确")
    private String start;

    @NotBlank(message = "meetingType不能为空")
    @Pattern(regexp = "^线上会议$|^线下会议$", message = "meetingType内容不正确")
    private String meetingType;

    @NotBlank(message = "tcode不能为空")
    @Pattern(regexp = "^[0-9]{6}$",message = "tcode必须是6位数字")
    private String tcode;

}

在com.example.emos.workflow.controller包中创建WorkFlowController类。

@RestController
@RequestMapping("/workflow")
public class WorkFlowController {

    @Autowired
    private WorkflowService workflowService;

    @Autowired
    private TaskService taskService;

    @Autowired
    private ProcessEngine processEngine;

    @Autowired
    private RepositoryService repositoryService;

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private HistoryService historyService;

    @PostMapping("/startMeetingProcess")
    public R startMeetingProcess(@Valid @RequestBody StartMeetingProcessForm form) {
       
        HashMap param = JSONUtil.parse(form).toBean(HashMap.class);
        param.put("filing", false);
        param.put("type", "会议申请");
        param.put("createDate", DateUtil.today());

        param.remove("code");
        if (form.getGmId() == null) {
            //会议状态通过
            param.put("identity", "总经理");
            param.put("result", "同意");

        } else {
            param.put("identity", "员工");
        }

        String instanceId = workflowService.startMeetingProcess(param);
        return R.ok().put("instanceId", instanceId);

    }
    @PostMapping("/approvalTask")
    public R approvalTask(@Valid @RequestBody ApprovalTaskForm form) {
        HashMap param = new HashMap();
        param.put("taskId", form.getTaskId());
        param.put("approval", form.getApproval());
        workflowService.approvalTask(param);
        return R.ok();
    }
}

创建MeetingWorkflowJob.java类

/**
 * 检查工作流的会议审批任务
 */
@Slf4j
@Component
public class MeetingWorkflowJob extends QuartzJobBean {
    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private HistoryService historyService;

    @Autowired
    private MeetingService meetingService;

    @Autowired
    private WorkflowService workflowService;

    /**
     * 检查工作里的审批状态
     *
     * @param ctx
     * @throws JobExecutionException
     */
    @Override
    protected void executeInternal(JobExecutionContext ctx) throws JobExecutionException {
        Map map = ctx.getJobDetail().getJobDataMap();
        String uuid = map.get("uuid").toString();
        String instanceId = map.get("instanceId").toString();
        //判断会议审批是不是未结束
        ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId(instanceId).singleResult();
        if (instance != null) {
            map.put("processStatus", "未结束");
            workflowService.deleteProcessById(uuid, instanceId, "会议", "会议过期");
            HashMap param = new HashMap();
            param.put("uuid", uuid);
            param.put("status", 2); //更改会议状态为已拒绝
            meetingService.updateMeetingStatus(param); //更新会议状态
            log.debug("会议已失效");
        }
    }
}