Camunda流程引擎笔记(七)：自定义流程

之前的笔记中使用的流程功能都是基于Camunda官方提供的内置功能，这里简单讲述一下使用Camunda提供的API实现自定义流程。
实现自定义流程，那么我们就可以重新实现符合自己需求的流程前端页面，但是这里我们依然使用官方提供的前端页面，但是只是作为任务查看（当然也可不用，直接看json数据）。

这里还是使用上篇用到的审批流程图，然后我们使用官方提供的API实现启动流程、审批流程等功能。

一、修改流程图

将财务审批节点中的Assignee输入框中的值删除。

Camunda流程引擎笔记(七)：自定义流程

二、编写代码

1、启动流程实例

service

@Autowired
private RuntimeService runtimeService;

/**
 * 开启流程实例
 *
 * @param amount 申请金额
 * @param role 角色
 * @param useFor 资金方向
 * @return java.lang.String
 */
 public String startProcess(long amount, String role, String useFor) {
    Map<String, Object> initialVariables = new HashMap<>(1);
    initialVariables.put("amount", amount);
    if (amount >= 10000) {
      initialVariables.put("role", role);
      initialVariables.put("useFor", useFor);
    }
    Execution execution = runtimeService.startProcessInstanceByKey("approve_process", initialVariables);
    return "实例启动成功，实例ID：" + execution.getProcessInstanceId();
  }

controller

@ApiOperation("启动实例")
@PostMapping("/start")
public String startProcess(@RequestParam long amount,
                         @RequestParam(required = false) String role,
                         @RequestParam(required = false) String useFor) {
return processService.startProcess(amount, role, useFor);
}

2、任务认领

service

@Autowired
private TaskService taskService;

/**
 * 任务认领
 *
 * @param processInstanceId 流程实例ID
 * @return java.lang.String
 */
 public String assignTask(String processInstanceId) {
    List<Task> tasks = taskService.createTaskQuery().processInstanceId(processInstanceId).active().list();
    if (!CollectionUtils.isEmpty(tasks)) {
      taskService.claim(tasks.get(0).getId(), "admin");
      return "任务认领成功，任务ID：" + tasks.get(0).getId() + "，认领人：admin";
    }
    return "无任务可认领";
  }

controller

@ApiOperation("任务认领")
@PostMapping("/assign")
public String assignTask(@RequestParam String processInstanceId) {
return processService.assignTask(processInstanceId);
}

3、任务审核

service

@Autowired
private TaskService taskService;

/**
* 任务审核
*
* @param taskId 任务ID
* @return java.lang.String
*/
public String approveTask(String taskId, boolean passed) {
List<Task> tasks = taskService.createTaskQuery().taskId(taskId).taskAssignee("admin").list();
if (!CollectionUtils.isEmpty(tasks)) {
  Map<String, Object> approveVariables = new HashMap<>(1);
  approveVariables.put("passed", passed);
  taskService.complete(taskId, approveVariables);
  return "任务审核完成，审核"
    + (passed ? "通过" : "拒绝");
}
return "无任务可审核";
}

controller

@ApiOperation("任务审核")
@PostMapping("/approve")
public String approveTask(@RequestParam String taskId, @RequestParam boolean passed) {
return processService.approveTask(taskId, passed);
}