Activiti7 常用 Api

public ProcessDefinition selectProcessDefinitionByKey(String definitionKey) {
    List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery()
        .processDefinitionKey(definitionKey)
        .orderByProcessDefinitionVersion()
        .desc()
        .list();

    ProcessDefinition processDefinition = null;
    if (processDefinitions.size() > 0) {
        processDefinition = processDefinitions.get(0);
    }
    return processDefinition;
}

public ProcessDefinition selectProcessDefinitionByDeploymentId(String deploymentId) {
    return repositoryService.createProcessDefinitionQuery()
        .deploymentId(deploymentId)
        .singleResult();
}

public InputStream getResourceAsStream(String deploymentId, String resourceName) {
    return repositoryService.getResourceAsStream(deploymentId, resourceName);
}

public InputStream getProcessImage(String processDefinitionId,
                                   List<String> highLightedActivities,
                                   List<String> highLightedFlows) {
    BpmnModel model = repositoryService.getBpmnModel(processDefinitionId);
    ProcessDiagramGenerator generator = new DefaultProcessDiagramGenerator();
    //generateDiagram(流程模型,需要高亮的节点,需要高亮的线条,后面三个参数都表示是字体)
    InputStream inputStream = generator.generateDiagram(model, highLightedActivities, highLightedFlows, "宋体", "宋体", "宋体");
    return inputStream;
}

public void findUserTaskNode() {
    // 获取流程信息，获取方法查看上面👆提得到的 Api
    ProcessDefinition processDefinition = selectProcessDefinitionByKey("XXXKey");
    BpmnModel model = repositoryService.getBpmnModel(processDefinition.getId());
    if (model != null) {
        // 获取所有节点信息
        Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
		// 查找指定 UserTask 类型的节点
        for (FlowElement e : flowElements) {
            // 判断节点类型
            if (e instanceof UserTask) {
                // 审批人
                String sp1 = ((UserTask) e).getAssignee();
                // 候选人
                List<String> sp2 = ((UserTask) e).getCandidateUsers();
            }
        }
    }
}

public ProcessInstance getProcessInstanceById(String processInstanceId) {
    return runtimeService.createProcessInstanceQuery()
        .processInstanceId(processInstanceId)
        .singleResult();
}

/**
  * 删除部署的流程实例
  *
  * @param instanceId 流程实例ID
  * @param deleteReason 删除原因，可为空
  */
 public void deleteProcIns(String instanceId, String deleteReason) {
   runtimeService.deleteProcessInstance(instanceId, deleteReason);
 }

public List<String> getActiveActivityIds(String processInstanceId) {
    return runtimeService.getActiveActivityIds(processInstanceId);
}

public HistoricProcessInstance getHistoricProcessInstanceById(String processInstanceId) {
    return historyService
        .createHistoricProcessInstanceQuery()
        .processInstanceId(processInstanceId)
        .singleResult();
}

public String getTaskComments(String taskId) {
    List<Comment> taskComments = taskService.getTaskComments(taskId);
    if (taskComments == null) {
        return "暂无批注";
    }

    return taskComments.stream()
        .map(Comment::getFullMessage)
        .collect(Collectors.joining(";"));
}

public List<HistoricActivityInstance> selectHistoryTaskList(String instanceId) {
    return historyService.createHistoricActivityInstanceQuery()
        .processInstanceId(instanceId)
        .activityType("userTask")
        .finished()
        .orderByHistoricActivityInstanceStartTime()
        .desc()
        .list();
}

public List<Task> getTaskByInstanceId(String instanceId) {
    return taskService.createTaskQuery().processInstanceId(instanceId).List();
}

public void addCandidateUser(String taskId, String candidateUser) {
    taskService.addCandidateUser(taskId, candidateUser);
}

public List<Task> selectTodoTaskList(String definitionKey, String candidateUser) {
    return taskService.createTaskQuery()
        .processDefinitionKey(definitionKey)
        .taskCandidateUser(candidateUser)
        .orderByTaskCreateTime()
        .desc()
        .listPage();
}

public Task getTaskByTaskId(String taskId) {
    return taskService.createTaskQuery().taskId(taskId).singleResult();
}

public void claimAndComplateTask(Task task, String userId, boolean auditStatusBoolean, String commentStr) {
    String taskId = task.getId();
    // 如果候选任务没有进行领取就直接完成的话，那么在历史记录中就不会记录是哪个用户执行了这个任务.
    taskService.claim(taskId, userId);
    // 添加批注
    taskService.addComment(taskId, task.getProcessInstanceId(), commentStr);
    // 添加流程变量
    taskService.setVariable(taskId, task.getTaskDefinitionKey(), auditStatusBoolean);
    // 完成任务
    taskService.complete(taskId);
}

public void setVariable(String taskId, String variableName, Object variableValue) {
    taskService.setVariable(taskId, variableName, variableValue);
}

public List<HistoricTaskInstance> selectDoneTaskList(String definitionKey, String userId) {
    return historyService
        .createHistoricTaskInstanceQuery()
        .processDefinitionKey(definitionKey)
        .taskAssignee(userId)
        .finished()
        .orderByHistoricTaskInstanceEndTime()
        .desc()
        .list();
}