Activiti工作流学习笔记

工作流的基本操作

• 创建数据库表

• 部署流程定义

• 流程定义查询

• 流程定义删除

• 流程资源文件的查询

  package com.hyq;

  import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngineConfiguration; import org.activiti.engine.ProcessEngines; import org.activiti.engine.RepositoryService; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.repository.ProcessDefinitionQuery; import org.junit.Test;

  import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.util.List; import java.util.zip.ZipInputStream;

  /**

  • Created byq on 2017/7/1. */ public class Main {

    /获取流程引擎/ private ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); /*

    • 创建数据库表 */ @Test public void createDb(){ String source = "activiti.cfg.xml"; ProcessEngineConfiguration configuration = ProcessEngineConfiguration. createProcessEngineConfigurationFromResource(source); ProcessEngine processEngine = configuration.buildProcessEngine(); System.out.print(processEngine); }

    /**

    • 部署流程定义-方式一 */ @Test public void deployProcess(){ System.out.print(processEngine); RepositoryService repositoryService = processEngine.getRepositoryService(); String bpmn = "/diagram/purchasingflow01.bpmn"; String png = "/diagram/purchasingflow01.png";

      InputStream bpmn_inputStream = this.getClass().getResourceAsStream(bpmn); InputStream png_inputStream = this.getClass().getResourceAsStream(png);

      Deployment deployment = repositoryService.createDeployment() .addInputStream(bpmn, bpmn_inputStream) .addInputStream(png, png_inputStream) .name("我的流程部署") .deploy();

      String id = deployment.getId(); String name = deployment.getName(); System.out.print("部署id:"+id); System.out.print("部署name:"+name); }

    /**

    • 通过zip压缩包的方式部署 */ @Test public void deployByZip(){ RepositoryService repositoryService = processEngine.getRepositoryService(); InputStream inputStream = this.getClass().getResourceAsStream("/diagram/diagram.zip"); ZipInputStream zipInputStream = new ZipInputStream(inputStream); Deployment deploy = repositoryService.createDeployment() .addZipInputStream(zipInputStream).deploy(); System.out.print(deploy.getId()); }

    /**

    • 流程定义的查询 */ @Test public void queryProcessDefinetion(){ RepositoryService repositoryService = processEngine.getRepositoryService(); ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery(); //设置查询条件：流程定义的id组成：流程定义key+版本号+流水号 // processDefinitionQuery.processDefinitionId("purchasingflow:2:104"); processDefinitionQuery.processDefinitionKey("purchasingflow"); List<ProcessDefinition> processDefinitions = processDefinitionQuery.list(); for(ProcessDefinition pd : processDefinitions){ System.out.println("============================================"); System.out.println("流程定义id:"+pd.getId()); System.out.println("流程部署id:"+pd.getDeploymentId()); System.out.println("流程定义的key:"+pd.getKey()); System.out.println("资源名:"+pd.getDiagramResourceName()); System.out.println("流程定义名称："+pd.getName()); System.out.println("流程定义的版本:"+pd.getVersion()); } }

    @Test /**

    • 流程文件的删除 */ public void deleteProcess(){ RepositoryService repositoryService = processEngine.getRepositoryService(); String processDefinitionId = "purchasingflow:2:104"; ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefinitionId).singleResult(); repositoryService.deleteDeployment(processDefinition.getDeploymentId()); // repositoryService.deleteDeployment(processDefinition.getDeploymentId(),true); }

    @Test /**

    • 流程资源文件的查询 */ public void queryFlowResource() throws Exception { String depolymentId = "1"; RepositoryService repositoryService = processEngine.getRepositoryService(); ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(depolymentId).singleResult(); String resourceName_bpmn =processDefinition.getResourceName(); String resourceName_png =processDefinition.getDiagramResourceName(); InputStream diagramStream = repositoryService.getResourceAsStream(depolymentId,resourceName_bpmn); InputStream resourcStream = repositoryService.getResourceAsStream(depolymentId,resourceName_png);

      byte[] buf = new byte[1024]; int line = -1; File file_bpmn = new File("d:"+resourceName_bpmn); File file_png = new File("d:"+resourceName_png); FileOutputStream fileOutputStream_bpmn = new FileOutputStream(file_bpmn); FileOutputStream fileOutputStream_png = new FileOutputStream(file_png);

  // while((line=resourcStream.read(buf))>0){

  // fileOutputStream_bpmn.write(buf,0,line); // } while((line=diagramStream.read(buf,0,1024))!=-1){ fileOutputStream_png.write(buf,0,line); } fileOutputStream_png.flush(); diagramStream.close(); fileOutputStream_png.close(); } }

本文分享 CSDN - 独行侠梦。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。