SpringBoot整合工作流引擎Activiti

  
    org.activiti.dependencies
    activiti-dependencies
    7.1.0.M6
    pom
  
  
    org.activiti
    activiti-spring-boot-starter
    7.1.0.M6
  
  
    org.springframework.boot
    spring-boot-starter-security
  
  
    org.springframework.boot
    spring-boot-starter-web
  
  
    org.mybatis.spring.boot
    mybatis-spring-boot-starter
    2.1.4
  
  
    mysql
    mysql-connector-java
    runtime
  
  
    org.springframework.boot
    spring-boot-starter-test
    test
    
      
        org.junit.vintage
        junit-vintage-engine
      
    
  

mybatis:
  mapper-locations: classpath:mapper
  public void createDeploy() {
    Deployment deployment = repositoryService.createDeployment()
        .addClasspathResource("processes/holiday.bpmn")
        .addClasspathResource("processes/holiday.png")
        .name("请假申请单流程")
        .key("holiday")
        .category("InnerP")
        .deploy();
    logger.info("流程部署id: {}", deployment.getId());
    logger.info("流程部署名称: {}", deployment.getName());
  }
  // 注意这里这个方法是当我们没有开启自动部署流程定义时，就需要手动部署。
  
  public List queryProcessDefinitionByKey(String processDefinition) {
    // 查询流程定义
    ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();
    List list = processDefinitionQuery.processDefinitionKey(processDefinition).list();
    list.forEach(pd -> {
      logger.info("------------------------------------------------");
      logger.info("流程部署id：{}", pd.getDeploymentId());
      logger.info("流程定义id：{}", pd.getId());
      logger.info("流程定义名称：{}", pd.getName());
      logger.info("流程定义key：{}", pd.getKey());
      logger.info("流程定义版本：{}", pd.getVersion());
      logger.info("------------------------------------------------");
    });
    return list ;
  }


  
  public void deleteDeployment(String deploymentId) {
    // 设置true 级联删除流程定义，即使该流程有流程实例启动也可以删除，设置为false非级别删除方式，如果流程
    repositoryService.deleteDeployment(deploymentId, true);
  }


  
  public void startProcessInstanceById(String processDefinitionId) {
    ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId) ;
    logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId());
    logger.info("流程实例ID: {}", processInstance.getId());
  }
  
  
  public void startProcessInstanceToBussinessKey(String processDefinitionId, String bussinessKey) {
    ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, bussinessKey);
    logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId());
    logger.info("流程实例ID: {}", processInstance.getId());
    logger.info("BussinessKey: {}", processInstance.getBusinessKey()) ;
  }
  
  
  public void startProcessInstanceAssignVariables(String processDefinitionId, Map variables) {
    ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);
    logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId());
    logger.info("流程实例ID: {}", processInstance.getId());
    logger.info("BussinessKey: {}", processInstance.getBusinessKey()) ;
  }
  
  
  public List queryTasks(String assignee) {
    TaskQuery query = taskService.createTaskQuery() ;
    return query.taskAssignee(assignee).orderByTaskCreateTime().asc().list() ;
  }
  
  public void executionTask(Map variables, String instanceId) {
    Task task = taskService.createTaskQuery().processInstanceId(instanceId).singleResult() ;
    if (task == null) {
      logger.error("任务【{}】不存在", instanceId) ;
      throw new RuntimeException("任务【" + instanceId + "】不存在") ;
    }
    taskService.complete(task.getId(), variables) ;
  }


}

@RestController
@RequestMapping("/holidays")
public class HolidayController {
  
  @Resource
  private HolidayService holidayService ;
  
  
  @GetMapping("")
  public R lists(String key) {
    return R.success(holidayService.queryProcessDefinitionByKey(key)) ;
  }
  
  
  @GetMapping("/_deploy")
  public R createDeploy() {
    holidayService.createDeploy();
    return R.success() ;
  }
  
  
  @GetMapping("/start")
  public R startProcess(String userId, String processDefinitionId) {
    Map variables = new HashMap<>() ;
    variables.put("assignee", userId) ;
    holidayService.startProcessInstanceAssignVariables(processDefinitionId, variables) ;
    return R.success() ;
  }
  
  
  @GetMapping("/tasks")
  public R myTasks(String userId) {
    List list = holidayService.queryTasks(userId) ;
    // 注意这里需要我们自己组装下数据，不然会报错。
    List> result = list.stream().map(task -> {
      Map res = new HashMap() ;
      res.put("id", task.getId()) ;
      res.put("assignee", task.getAssignee()) ;
      res.put("createTime", task.getCreateTime()) ;
      res.put("bussinessKey", task.getBusinessKey()) ;
      res.put("category", task.getCategory()) ;
      res.put("dueDate", task.getDueDate()) ; // 到期日期
      res.put("desc", task.getDescription()) ;
      res.put("name", task.getName()) ;
      res.put("owner", task.getOwner()) ;
      res.put("instanceId", task.getProcessInstanceId()) ;
      res.put("variables", task.getProcessVariables()) ;
      return res ;
    }).collect(Collectors.toList()) ;
    return R.success(result) ;
  }
  
  
  @GetMapping("/apply")
  public R fillApply(@RequestParam Map variables) {
    String instanceId = (String) variables.remove("instanceId") ;
    if (StringUtils.isEmpty(instanceId)) {
      return R.failure("未知任务") ;
    }
    holidayService.executionTask(variables, instanceId);
    return R.success() ; 
  }
  
}