Camunda
官方提供的内置功能,这里简单讲述一下使用Camunda
提供的API实现自定义流程。
实现自定义流程,那么我们就可以重新实现符合自己需求的流程前端页面,但是这里我们依然使用官方提供的前端页面,但是只是作为任务查看(当然也可不用,直接看json数据)。
这里还是使用上篇用到的审批流程图,然后我们使用官方提供的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官网 。
原文
https://segmentfault.com/a/1190000022137289
本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Camunda流程引擎笔记(七):自定义流程