一、Flowable 介绍

DeploymentBuilder addInputStream(String resourceName, InputStreaminputStream);

DeploymentBuilder addClasspathResource(String resource);

DeploymentBuilder addString(String resourceName, String text);

DeploymentBuilder addBytes(String resourceName, byte[] bytes);

DeploymentBuilder addZipInputStream(ZipInputStream zipInputStream);

DeploymentBuilder addBpmnModel(String resourceName, BpmnModel bpmnModel);

@Test
public void addInputStreamTest() throws IOException {
	// 定义的文件信息的流读取
	InputStream inputStream = DeploymentBuilderTest.class.getClassLoader()
		.getResource("com/shareniu/shareniu_flowable6/ch2/leave.bpmn")
		.openStream();
	// 流程定义的分类
	String category = "shareniu_addInputStream";
	// 构造DeploymentBuilder对象
	DeploymentBuilder deploymentBuilder = repositoryService
			.createDeployment().category(category)
			.addInputStream(resourceName, inputStream);
	// 部署
	Deployment deploy = deploymentBuilder.deploy();
	System.out.println(deploy);
}

public void addClasspathResource() throws InterruptedException {	
	ProcessEngineConfigurationImpl processEngineConfiguration = Context
			.getProcessEngineConfiguration();
	System.out.println(processEngineConfiguration);
	String resource = "com/shareniu/chapter3/common.bpmn";
	// 流程定义的分类
	String category = "shareniu_addClasspathResource";
	// 构造DeploymentBuilder对象
	Date date = new Date();
	DeploymentBuilder deploymentBuilder = repositoryService
			.createDeployment()
			// .activateProcessDefinitionsOn(date)
			.addClasspathResource(resource).category(category);
	// 部署
	processEngineConfiguration = Context.getProcessEngineConfiguration();
	System.out.println(processEngineConfiguration);
	Deployment deploy = deploymentBuilder.deploy();
	System.out.println(deploy);

}

@Test
public void addString() {
	String resource = "shareniu_addString.bpmn";
	// 读取文件获取文件中定义的xml信息
	String text = readTxtFile("E:/activitilearing/activiti/src/main/java/com/shareniu/chapter3/common.bpmn");
	// 构造DeploymentBuilder对象
	DeploymentBuilder deploymentBuilder = repositoryService
			.createDeployment().addString(resource, text);
	// 部署
	Deployment deploy = deploymentBuilder.deploy();
}

@Test
public void zip() {
	InputStream inputStream = DeploymentBuilderTest.class.getClassLoader()
			.getResourceAsStream("1.zip");
	ZipInputStream zipInputStream = new ZipInputStream(inputStream);
	Deployment deploy = repositoryService.createDeployment()
			.addZipInputStream(zipInputStream).deploy();
	identityService.setAuthenticatedUserId("shareniu");
}

SequenceFlow flow1 = new SequenceFlow();
	flow1.setId("flow1");
	flow1.setName("开始节点->任务节点1");
	flow1.setSourceRef("start1");
	flow1.setTargetRef("userTask1");
	// 任务节点1->任务节点2
	SequenceFlow flow2 = new SequenceFlow();
	flow2.setId("flow2");
	flow2.setName("任务节点1->任务节点2");
	flow2.setSourceRef("userTask1");
	flow2.setTargetRef("userTask2");

	// 任务节点1->任务节点2
	SequenceFlow flow3 = new SequenceFlow();
	flow3.setId("flow3");
	flow3.setName("任务节点2->结束节点");
	flow3.setSourceRef("userTask2");
	flow3.setTargetRef("endEvent");

	String resource = "shareniu_addBpmnModel";
	// 声明BpmnModel对象
	BpmnModel bpmnModel = new BpmnModel();
	// 声明Process对象 一个BpmnModel可以包含多个Process对象
	Process process = new Process();
	process.setId("process1");
	// 开始节点的封装
	StartEvent start = new StartEvent();
	start.setName("开始节点");
	start.setId("start1");
	start.setOutgoingFlows(Arrays.asList(flow1));
	// 任务节点1
	UserTask userTask1 = new UserTask();
	userTask1.setName("任务节点1");
	userTask1.setId("userTask1");
	userTask1.setIncomingFlows(Arrays.asList(flow1));
	userTask1.setOutgoingFlows(Arrays.asList(flow2));
	// 任务节点2
	UserTask userTask2 = new UserTask();
	userTask2.setName("任务节点2");
	userTask2.setId("userTask2");
	userTask2.setIncomingFlows(Arrays.asList(flow2));
	userTask2.setOutgoingFlows(Arrays.asList(flow3));

	// 结束节点
	EndEvent endEvent = new EndEvent();
	endEvent.setName("结束节点");
	endEvent.setId("endEvent");
	endEvent.setIncomingFlows(Arrays.asList(flow3));
	// 将所有的FlowElement添加到process中
	process.addFlowElement(start);
	process.addFlowElement(flow1);
	process.addFlowElement(userTask1);
	process.addFlowElement(flow2);
	process.addFlowElement(userTask2);
	process.addFlowElement(flow3);
	process.addFlowElement(endEvent);
	bpmnModel.addProcess(process);

String processDefinitionId="myProcess:1:9527";//部署的流程ID
runtimeService.startProcessInstanceById(processDefinitionId);//发起流程

Authentication.setAuthenticatedUserId("Foolish");
String processDefinitionId="myProcess:1:9527";
runtimeService.startProcessInstanceById(processDefinitionId);
Authentication.setAuthenticatedUserId(null);

public GritResult instanceList(String userId) {
	ProcessInstanceQuery query = runtimeService.createProcessInstanceQuery();
	if(!StringUtils.isEmpty(userId)){
		query.startedBy(userId);
	}
	List<ProcessInstance> processInstanceList = query.list();
}

public GritResult taskList(String userId, String group) {
    TaskQuery query = taskService.createTaskQuery();
    if(!StringUtils.isEmpty(group)){
        query.taskCandidateGroup("managers");
    }else if(!StringUtils.isEmpty(userId)){
        query.taskCandidateOrAssigned("userId");
    }

    List<Task> tasks = query.orderByTaskCreateTime().desc().list();
}

public GritResult historicTaskList(String userId) {
    HistoricProcessInstanceQuery query = historyService.createHistoricProcessInstanceQuery();
    if(!StringUtils.isEmpty(userId)){
        query.involvedUser(userId);
    }
    query.finished();
    List<HistoricProcessInstance> hpis = query.orderByProcessInstanceEndTime().desc().list();
    List<HistoricProcessInstance_> list = new ArrayList<>();
    for (HistoricProcessInstance hpi : hpis) {
        HistoricProcessInstance_ ft = new HistoricProcessInstance_(hpi);
        System.out.println(ft.toString());
        list.add(ft);
    }
    GritResult gr = new GritResult("success",list.size(),list);
    return gr;
}

/**
 * 批准
 *
 * @param taskId 任务ID
 */
public String apply(String taskId) {
    Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
    if (task == null) {
        throw new RuntimeException("流程不存在");
    }
    //通过审核
    HashMap<String, Object> map = new HashMap<>();
    map.put("outcome", "通过");
    taskService.complete(taskId, map);
    return "processed ok!";
}

/**
 * 拒绝
 */
public String reject(String taskId) {
    HashMap<String, Object> map = new HashMap<>();
    map.put("outcome", "驳回");
    taskService.complete(taskId, map);
    return "reject";
}