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

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

一、修改流程图

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

二、编写代码

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);
}

三、测试

1、金额小于1万元，审核通过

访问 http://localhost:8080/app/cockpit/default/#/ 查看流程详情。

可以看到这里的 Process Instances ID 与刚刚通过自定义API请求返回的实例ID是一致的。

访问 http://localhost:8080/app/tasklist/default/#/ 查看任务列表。

可以看到右上角显示该任务还未被认领，因为我们上面将 Assignee 的值置为了空，然后右下角的操作按钮是无法操作的。

接下来认领任务。

将上面请求到的流程实例ID作为任务认领的参数。

再次访问 http://localhost:8080/app/tasklist/default/#/ 查看任务列表。

可以看到右上角已经显示该任务已被 admin 认领了，并且右下角的操作按钮也已经可以操作了。

访问 http://localhost:8080/app/cockpit/default/#/ 查看任务详情。

可以看到这里的任务ID和我们请求返回的任务ID是一致的。

最后审核任务。

将上面请求到的任务ID作为任务审核的参数。

访问 http://localhost:8080/app/tasklist/default/#/ 查看任务列表。

可以看到已经没有等待执行的任务了。

再访问 http://localhost:8080/app/cockpit/default/#/ 查看实例看板。

已经没有允许中的实例了。

2、金额大于1万元，决策通过

访问 http://localhost:8080/app/cockpit/default/#/ 查看决策详情。

再访问 查看任务列表 。

可以看到又到了任务认领环节了。

最后任务审批。

再一次访问 http://localhost:8080/app/cockpit/default/#/ 查看实例看板。

已无运行中的流程实例。

更多信息访问 Camunda官网 。