SpringBoot整合Camunda(二)

一、绘制bpmn流程图

1、下载流程图绘制工具

https://camunda.com/download/…

2、创建bpmn流程图

SpringBoot整合Camunda(二)

这里我们创建一个简单的流程,该流程中只有一个审核节点,并且不需要判断审核是同意还是拒绝。并且在审核节点我们设置了一个属性,将该节点的任务归属到 camunda-admin 这个组。

SpringBoot整合Camunda(二)

二、编写代码

1、保存流程图

将我们绘制好的 bpmn 文件拷贝到上一文创建的项目的 resources 目录下,这里我们在 resources 下创建一个子目录 bpmn 用于放置我们的流程图。

SpringBoot整合Camunda(二)

2、编写基础接口

(1)流程发起接口

/**
 * 发起流程
 *
 * @param param ProcessStartParam
 * @return ResultBean
 */
@ApiOperation("发起流程")
@PostMapping("/process/start")
public ResultBean<?> startProcess(@Valid @RequestBody ProcessStartParam param) {
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(param.getProcessDefinitionId());
    Map<String, Object> map = new HashMap<>();
    map.put("processDefinitionId", processInstance.getProcessDefinitionId());
    map.put("processInstanceId", processInstance.getProcessInstanceId());
    map.put("businessKey", processInstance.getBusinessKey());
    map.put("caseInstanceId", processInstance.getCaseInstanceId());
    map.put("rootProcessInstanceId", processInstance.getRootProcessInstanceId());
    return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", map);
}

(2)自己的任务列表

/**
 * 自己的任务列表
 *
 * @param assignee 任务所属者
 * @return ResultBean
 */
@ApiOperation("查询自己的任务列表")
@GetMapping("/self/tasks")
public ResultBean<?> selfTaskList(@RequestParam("assignee") String assignee) {
    List<Task> tasks = taskService.createTaskQuery().taskAssignee(assignee).list();
    if (tasks != null && !tasks.isEmpty()) {
        List<Map<String, Object>> resultList = new ArrayList<>(tasks.size());
        tasks.forEach(task -> {
            Map<String, Object> map = new HashMap<>(3);
            map.put("processDefinitionId", task.getProcessDefinitionId());
            map.put("processInstanceId", task.getProcessInstanceId());
            map.put("taskId", task.getId());
            resultList.add(map);
        });
        return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", resultList);
    } else {
        return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", "未查询到任务列表");
    }
}

(3)可用任务列表

/**
 * 可用任务列表
 *
 * @param username 用户名称
 * @return ResultBean
 */
@ApiOperation("可用任务列表")
@GetMapping("/available/tasks")
public ResultBean<?> availableTaskList(@RequestParam("username") String username) {
    //1、根据用户名查询所在组
    List<Group> list = identityService.createGroupQuery().groupMember(username).list();
    if (list != null && !list.isEmpty()) {
        //2、获取所有组名
        //这里我配置错了,错把id当name了。
        List<String> collect = list.stream().map(Group::getId).collect(Collectors.toList());
        //3、根据组名查询所有任务
        List<Task> tasks = taskService.createTaskQuery().taskCandidateGroupIn(collect).list();
        if (tasks != null && !tasks.isEmpty()) {
            List<Map<String, Object>> resultList = new ArrayList<>(tasks.size());
            tasks.forEach(task -> {
                Map<String, Object> map = new HashMap<>(3);
                map.put("processDefinitionId", task.getProcessDefinitionId());
                map.put("processInstanceId", task.getProcessInstanceId());
                map.put("taskId", task.getId());
                resultList.add(map);
            });
            return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", resultList);
        } else {
            return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", "未查询到任务列表");
        }
    } else {
        return new ResultBean<>(HttpServletResponse.SC_NOT_FOUND, "ERROR", "未查询到所属组");
    }
}

(4)任务领取

/**
 * 任务领取
 *
 * @param param TaskClaimParam
 * @return ResultBean
 */
@ApiOperation("任务领取")
@PostMapping("/claim/task")
public ResultBean<String> claimTask(@Valid @RequestBody TaskClaimParam param) {
    //1、查询组名
    List<Group> list = identityService.createGroupQuery().groupMember(param.getUsername()).list();
    if (list != null && !list.isEmpty()) {
        List<String> collect = list.stream().map(Group::getId).collect(Collectors.toList());
        //2、查询任务
        Task task = taskService.createTaskQuery().taskCandidateGroupIn(collect).processInstanceId(param.getProcessInstanceId()).singleResult();
        if (task != null) {
            //3、判断该任务是否被领取
            if (StringUtils.isBlank(task.getAssignee())) {
                taskService.claim(task.getId(), param.getUsername());
                return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", "任务领取成功");
            } else {
                return new ResultBean<>(HttpServletResponse.SC_FOUND, "SUCCESS", "任务已被他人领取");
            }
        } else {
            return new ResultBean<>(HttpServletResponse.SC_NOT_FOUND, "ERROR", "未查询到任务");
        }
    } else {
        return new ResultBean<>(HttpServletResponse.SC_NOT_FOUND, "ERROR", "未查询到所属组");
    }
}

(5)任务审核

/**
 * 任务审核
 *
 * @param param TaskReviewParam
 * @return ResultBean
 */
@ApiOperation("任务审核")
@PostMapping("/review/task")
public ResultBean<String> review(@Valid @RequestBody TaskReviewParam param) {
    //1、查询任务
    Task task = taskService.createTaskQuery().taskId(param.getTaskId()).taskAssignee(param.getUsername()).singleResult();
    if (task != null) {
        taskService.complete(param.getTaskId());
        return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCESS", "任务审核成功");
    } else {
        return new ResultBean<>(HttpServletResponse.SC_NOT_FOUND, "ERROR", "未查询到任务");
    }
}

(6)流程历史记录

/**
 * 流程历史记录
 *
 * @param processInstanceId 流程实例id
 * @return ResultBean
 */
@ApiOperation("流程历史记录")
@GetMapping("/histories")
public ResultBean<?> processHistories(@RequestParam("processInstanceId") String processInstanceId) {
    List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).list();
    if (list != null && !list.isEmpty()) {
        return new ResultBean<>(HttpServletResponse.SC_OK, "SUCCCESS", list);
    } else {
        return new ResultBean<>(HttpServletResponse.SC_NOT_FOUND, "ERROR", "未查询到流程历史");
    }
}

测试

懒得写

  • runtimeService: 该service提供跟流程相关的方法,例如开始一个流程,删除一个流程等。
  • identityService: 该service提供跟身份相关的方法,例如增加一个用户,增加一个组等。
  • taskService: 该service提供跟任务相关的方法,例如领取任务,审核任务等。
  • historyService: 该service提供跟历史记录相关的方法,例如流程历史记录,任务历史记录等。

原文 

https://segmentfault.com/a/1190000020201213

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » SpringBoot整合Camunda(二)

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址