<dependency>
 
    <groupId>org.activiti</groupId>
 
    <artifactId>activiti-spring-boot-starter-basic</artifactId>
 
    <version>6.0.0</version>
 
</dependency>

@Autowired
 
private RuntimeService runtimeService;
 
 
 
@Autowired
 
private TaskService taskService;
 
 
 
@Autowired
 
private IdentityService identityService;
 
 
 
@Autowired
 
private RepositoryService repositoryService;
 
 
 
@Autowired

private ProcessEngine processEngine;
 
 
 
@Autowired

private HistoryService historyService;
 

说明： 
 
1) 在Activiti中最核心的类，其他的类都是由他而来。 
 
2) 产生方式：
 
 
 
在前面看到了两种创建ProcessEngine（流程引擎）的方式，而这里要简化很多，调用ProcessEngines的getDefaultProceeEngine方法时会自动加载classpath下名为activiti.cfg.xml文件。 
 
3) 可以产生RepositoryService
 
 
 
4) 可以产生RuntimeService
 
 
 
5) 可以产生TaskService
 
 
 
各个Service的作用： 
 
RepositoryService 管理流程定义 
 
RuntimeService 执行管理，包括启动、推进、删除流程实例等操作 
 
TaskService 任务管理 
 
HistoryService 历史管理(执行完的数据的管理) 
 
IdentityService 组织机构管理 
 
FormService 一个可选服务，任务表单管理 
 
ManagerService
 
 
 
5.2：RepositoryService 
 
是Activiti的仓库服务类。所谓的仓库指流程定义文档的两个文件：bpmn文件和流程图片。 
 
1) 产生方式
 
 
 
2) 可以产生DeploymentBuilder，用来定义流程部署的相关参数
 
 
 
3) 删除流程定义
 
 
 
5.3：RuntimeService 
 
是activiti的流程执行服务类。可以从这个服务类中获取很多关于流程执行相关的信息。 
 
5.4：TaskService 
 
是activiti的任务服务类。可以从这个类中获取任务的信息。 
 
5.5：HistoryService 
 
是activiti的查询历史信息的类。在一个流程执行完成后，这个对象为我们提供查询历史信息。 
 
5.6：ProcessDefinition 
 
流程定义类。可以从这里获得资源文件等。 
 
5.7：ProcessInstance 
 
代表流程定义的执行实例。如范冰冰请了一天的假，她就必须发出一个流程实例的申请。一个流程实例包括了所有的运行节点。我们可以利用这个对象来了解当前流程实例的进度等信息。流程实例就表示一个流程从开始到结束的最大的流程分支，即一个流程中流程实例只有一个。 
 
5.8：Execution 
 
Activiti用这个对象去描述流程执行的每一个节点。在没有并发的情况下，Execution就是同ProcessInstance。流程按照流程定义的规则执行一次的过程，就可以表示执行对象Execution。 

 
//项目中每创建一个新用户，对应的要创建一个Activiti用户
 
//两者的userId和userName一致
 
User admin=identityService.newUser("1");
 
admin.setLastName("admin");
 
identityService.saveUser(admin);
 
 
 
//项目中每创建一个角色，对应的要创建一个Activiti用户组
 
Group adminGroup=identityService.newGroup("1");
 
adminGroup.setName("admin");
 
identityService.saveGroup(adminGroup);
 
 
 
//用户与用户组关系绑定
 
identityService.createMembership("1","1");

 
//启动流程实例，字符串"vacation"是BPMN模型文件里process元素的id
 
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("vacation");
 
//流程实例启动后，流程会跳转到请假申请节点
 
Task vacationApply = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();
 
//设置请假申请任务的执行人
 
taskService.setAssignee(vacationApply.getId(), req.getUserId().toString());
 
 
 
//设置流程参数：请假天数和表单ID
 
//流程引擎会根据请假天数days>3判断流程走向
 
//formId是用来将流程数据和表单数据关联起来
 
Map<String, Object> args = new HashMap<>();
 
args.put("days", req.getDays());
 
args.put("formId", formId);
 
 
 
//完成请假申请任务
 
taskService.complete(vacationApply.getId(), args);

 
//查出当前登录用户所在的用户组
 
List<Group> groups = identityService.createGroupQuery()
 
        .groupMember(String.valueOf(userId)).list();
 
List<String> groupNames = groups.stream()
 
        .map(group -> group.getName()).collect(Collectors.toList());
 
 
 
//查询用户组的待审批请假流程列表
 
List<Task> tasks = taskService.createTaskQuery()
 
        .processDefinitionKey("vacation")
 
        .taskCandidateGroupIn(groupNames)
 
        .listPage(pageNum - 1, pageSize);
 
 
 
//根据流程实例ID查询请假申请表单数据
 
List<String> processInstanceIds = tasks.stream()
 
        .map(task -> task.getProcessInstanceId())
 
        .collect(Collectors.toList());
 
List<VacationApplyBasicPO> vacationApplyList = 
 
        vacationRepository.getVacationApplyList(processInstanceIds);

//查询当前审批节点
 
Task vacationAudit = taskService.createTaskQuery()
 
        .taskId(req.getTaskId()).singleResult();
 
 
 
if (req.getAuditResult() == 1) {//审批通过
 
    //设置流程参数：审批ID
 
    Map<String, Object> args = new HashMap<>();
 
    args.put("auditId", auditId);
 
 
 
    //设置审批任务的执行人
 
    taskService.claim(vacationAudit.getId(), req.getUserId().toString());
 
    //完成审批任务
 
    taskService.complete(vacationAudit.getId(), args);
 
} else {
 
    //审批不通过，结束流程
 
    runtimeService.deleteProcessInstance(vacationAudit.getProcessInstanceId(), auditId);
 
}

 
//controller层代码
 
@RequestMapping(value = "/image", method = RequestMethod.GET)
 
public void image(HttpServletResponse response,
 
 @RequestParam String processInstanceId) {
 
    try {
 
        InputStream is = vacationService.getDiagram(processInstanceId);
 
        if (is == null)
 
            return;
 
 
 
        response.setContentType("image/png");
 
 
 
        BufferedImage image = ImageIO.read(is);
 
        OutputStream out = response.getOutputStream();
 
        ImageIO.write(image, "png", out);
 
 
 
        is.close();
 
        out.close();
 
    } catch (Exception ex) {
 
        logger.error("查看流程图失败", ex);
 
    }
 
}
 
 
 
//service层代码
 
@Override
 
public InputStream getDiagram(String processInstanceId) {
 
    //获得流程实例
 
    ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
 
            .processInstanceId(processInstanceId).singleResult();
 
    String processDefinitionId = StringUtils.EMPTY;
 
    if (processInstance == null) {
 
        //查询已经结束的流程实例
 
        HistoricProcessInstance processInstanceHistory =
 
                historyService.createHistoricProcessInstanceQuery()
 
                        .processInstanceId(processInstanceId).singleResult();
 
        if (processInstanceHistory == null)
 
            return null;
 
        else
 
            processDefinitionId = processInstanceHistory.getProcessDefinitionId();
 
    } else {
 
        processDefinitionId = processInstance.getProcessDefinitionId();
 
    }
 
 
 
    //使用宋体
 
    String fontName = "宋体";
 
    //获取BPMN模型对象
 
    BpmnModel model = repositoryService.getBpmnModel(processDefinitionId);
 
    //获取流程实例当前的节点，需要高亮显示
 
    List<String> currentActs = Collections.EMPTY_LIST;
 
    if (processInstance != null)
 
        currentActs = runtimeService.getActiveActivityIds(processInstance.getId());
 
 
 
    return processEngine.getProcessEngineConfiguration()
 
            .getProcessDiagramGenerator()
 
            .generateDiagram(model, "png", currentActs, new ArrayList<String>(),
 
                    fontName, fontName, fontName, null, 1.0);
 
}