最近公司有工作流审批相关业务，于是学习起了Camunda。

首先是工具传送门

IDEA安装camunda-modeler工具
安装了工具才能好好画图啊

合同审核简易流程图

合同审核流程图

常用操作

部署工作流

Deployment deployment=repositoryService.createDeployment()
                .name(name)
                .addClasspathResource("process/"+name)
                .deploy();
##部署路径根据项目实际路径填写

开启流程实例

 Map<String, Object> params=new HashMap<>();
 params.put("key","contract_create");
 params.put("manager","LI1,LI2");
 params.put("leader","Z3");
 Execution execution = runtimeService.startProcessInstanceByKey(params.get("key").toString(), params);
## 根据key启动流程实例 key是bpmn中定义的，Map<String, Object> params是传入流程的参数
## demo中使用的是 camunda:candidateUsers="${manager}" 审核人通过params传入,逗号分隔。一人审核流程即可通过

查询我的待办任务

List<Task> tasks = taskService.createTaskQuery()
                .taskCandidateUser(assignee)
                .orderByTaskCreateTime().asc()
                .active().list();

查询我的已办任务

List<HistoricTaskInstance> historicTaskInstances = historyService.createHistoricTaskInstanceQuery()
                .taskAssignee(assignee)
                .orderByHistoricActivityInstanceStartTime().desc()
                .finished().list();

审批通过

 Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
        if (!ObjectUtils.isEmpty(task)) {
            Map<String, Object> approveVariables = new HashMap<>(1);
            approveVariables.put("passed", passed);
            approveVariables.put("comment",comment);
            this.taskService.claim(taskId, assignee);
            taskService.createComment(taskId, task.getProcessInstanceId(), comment);
            taskService.complete(taskId, approveVariables);
            System.out.println("任务审核完成，审核"
                    + (passed ? "通过" : "拒绝"));
            return "任务审核完成，审核"
                    + (passed ? "通过" : "拒绝");
        }
## 审批时添加审核意见和审核结果

撤回流程

 ActivityInstance activity = runtimeService.getActivityInstance(processInstanceId);
            runtimeService.createProcessInstanceModification(processInstanceId)
                    //关闭相关任务
                    .cancelActivityInstance(activity.getId())
                    .setAnnotation("发起人撤回")
                    //启动目标活动节点
                    .startBeforeActivity("root")
                    .execute();

查询 流程历史

 List<HistoricActivityInstance> activityInstanceList= historyService.createHistoricActivityInstanceQuery()
                .processInstanceId(instanceId).orderByHistoricActivityInstanceStartTime().asc().list();
        for (HistoricActivityInstance hi : activityInstanceList) {
            HistoricActivityInstanceEntity entity=(HistoricActivityInstanceEntity) hi;
                System.out.println("");
                System.out.println("===================-===============");
                System.out.println(hi.getStartTime());
                System.out.println(hi.getAssignee());
                System.out.println(hi.getActivityId());
                System.out.println(hi.getActivityName());
                System.out.println(entity.getActivityInstanceState());
                 List<Comment> taskComments = taskService.getTaskComments(hi.getTaskId());
                taskComments.stream().forEach(e->{
                    System.out.println("comment:"+e.getFullMessage());
                });
                System.out.println(hi.getTaskId());
                System.out.println(hi.getProcessDefinitionId());
                System.out.println(hi.getProcessInstanceId());
                System.out.println("===================-===============");
                System.out.println("");
        }

源码传送门

camunda springboot例子