Activiti7工作流入门和基本使用-Activiti入门和流程操作

select distinct RES.* 
from ACT_RU_TASK RES inner join ACT_RE_PROCDEF D on RES.PROC_DEF_ID_ = D.ID_ 
WHERE RES.ASSIGNEE_ = 'zhangsan' and D.KEY_ = 'myEvection' 
order by RES.ID_ asc 
LIMIT 2147483647 OFFSET 0 

6.5 流程任务处理

/*** 完成个人任务*/@Testpublic void completTask() {//1.获取流程引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();//2.获取taskServiceTaskService taskService = processEngine.getTaskService();// 根据流程key 和 任务的负责人 查询任务// 返回一个任务对象Task task = taskService.createTaskQuery().processDefinitionKey("myEvection") //流程Key.taskAssignee("zhangsan") //要查询的负责人.singleResult();// 完成任务,参数：任务idtaskService.complete(task.getId());}

操作数据库表：

6.6 流程定义信息查询

/*** 查询流程定义*/@Testpublic void queryProcessDefinition() {// 获取引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();// repositoryServiceRepositoryService repositoryService = processEngine.getRepositoryService();// 得到ProcessDefinitionQuery 对象ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();// 查询出当前所有的流程定义// 条件：processDefinitionKey =evection// orderByProcessDefinitionVersion 按照版本排序// desc倒叙// list 返回集合List<ProcessDefinition> definitionList = processDefinitionQuery.processDefinitionKey("myEvection").orderByProcessDefinitionVersion().desc().list();// 输出流程定义信息for (ProcessDefinition processDefinition : definitionList) {System.out.println("流程定义 id=" + processDefinition.getId());System.out.println("流程定义 name=" + processDefinition.getName());System.out.println("流程定义 key=" + processDefinition.getKey());System.out.println("流程定义 Version=" + processDefinition.getVersion());System.out.println("流程部署ID =" + processDefinition.getDeploymentId());}}

6.7 流程删除

/*** 流程删除*/@Testpublic void deleteDeployment() {// 流程部署idString deploymentId = "1";ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();// 通过流程引擎获取repositoryServiceRepositoryService repositoryService = processEngine.getRepositoryService();// 删除流程定义，如果该流程定义已有流程实例启动则删除时出错repositoryService.deleteDeployment(deploymentId);// 设置true 级联删除流程定义，即使该流程有流程实例启动也可以删除，设置为false非级别删除方式，如果流 程// repositoryService.deleteDeployment(deploymentId, true);}

6.8 流程资源下载

        <dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.6</version></dependency>

@Testpublic void queryBpmnFile() throws IOException {// 1、得到引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();// 2、获取repositoryServiceRepositoryService repositoryService = processEngine.getRepositoryService();// 3、得到查询器：ProcessDefinitionQuery，设置查询条件,得到想要的流程定义ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionKey("myEvection").singleResult();// 4、通过流程定义信息，得到部署IDString deploymentId = processDefinition.getDeploymentId();// 5、通过repositoryService的方法，实现读取图片信息和bpmn信息// png图片的流InputStream pngInput = repositoryService.getResourceAsStream(deploymentId, processDefinition.getDiagramResourceName());// bpmn文件的流InputStream bpmnInput = repositoryService.getResourceAsStream(deploymentId, processDefinition.getResourceName());// 6、构造OutputStream流File file_png = new File("E:\\activiti\\code\\activiti01\\evectionflow01.png");File file_bpmn = new File("E:\\activiti\\code\\activiti01\\evectionflow01.bpmn");FileOutputStream bpmnOut = new FileOutputStream(file_bpmn);FileOutputStream pngOut = new FileOutputStream(file_png);// 7、输入流，输出流的转换IOUtils.copy(pngInput, pngOut);IOUtils.copy(bpmnInput, bpmnOut);// 8、关闭流pngOut.close();bpmnOut.close();pngInput.close();bpmnInput.close();}

    /*** 查看历史信息*/@Testpublic void findHistoryInfo() {// 获取引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();// 获取HistoryServiceHistoryService historyService = processEngine.getHistoryService();// 获取 actinst表的查询对象HistoricActivityInstanceQuery instanceQuery = historyService.createHistoricActivityInstanceQuery();// 查询 actinst表，条件：根据 InstanceId 查询// instanceQuery.processInstanceId("2501");// 查询 actinst表，条件：根据 DefinitionId 查询instanceQuery.processDefinitionId("myEvection:1:4");// 增加排序操作,orderByHistoricActivityInstanceStartTime 根据开始时间排序 asc 升序instanceQuery.orderByHistoricActivityInstanceStartTime().asc();// 查询所有内容List<HistoricActivityInstance> activityInstanceList = instanceQuery.list();// 输出for (HistoricActivityInstance hi : activityInstanceList) {System.out.println(hi.getActivityId());System.out.println(hi.getActivityName());System.out.println(hi.getProcessDefinitionId());System.out.println(hi.getProcessInstanceId());System.out.println("<==========================>");}}