转载

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

之前的笔记中使用的流程功能都是基于 Camunda 官方提供的内置功能,这里简单讲述一下使用 Camunda

提供的API实现自定义流程。

实现自定义流程,那么我们就可以重新实现符合自己需求的流程前端页面,但是这里我们依然使用官方提供的前端页面,但是只是作为任务查看(当然也可不用,直接看json数据)。

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

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

一、修改流程图

财务审批 节点中的 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);
}

三、测试

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

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

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

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

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

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

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

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

接下来认领任务。

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

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

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

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

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

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

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

最后审核任务。

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

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

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

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

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

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

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

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

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

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

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

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

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

再访问 查看任务列表

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

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

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

最后任务审批。

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

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

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

已无运行中的流程实例。

更多信息访问 Camunda官网 。

原文  https://segmentfault.com/a/1190000022137289
正文到此结束
Loading...