Activiti工作流学习笔记入门（三）——流程定义的部署、查询、删除、不能修改

╰+攻爆jí腚メ 2022-04-15 23:57 308阅读 0赞

[更详细的介绍：http://blog.java1234.com/blog/articles/84.html   ][http_blog.java1234.com_blog_articles_84.html_]

**1.流程定义的部署（两种方式）**

package com.java1234.activiti.procdef;
    
    import java.io.InputStream;
    import java.util.zip.ZipInputStream;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.junit.Test;
    
    public class DepolyProcdef {
    	private ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    	/**
    	 * 直接添加资源文件方式
    	 */
    	@Test
    	public void deploy() {
    		Deployment deployment = processEngine.getRepositoryService()//获取相关Service
    				.createDeployment()//创建部署
    				.addClasspathResource("diagrams/HelloWorld.bpmn")//添加资源文件
    				.addClasspathResource("diagrams/HelloWorld.png")//添加资源文件
    				.name("HelloWorld流程")//流程名称
    				.deploy();//部署
    		System.out.println("流程部署ID："+deployment.getId());
    		System.out.println("流程部署名称："+deployment.getName());
    	}
    	
    	/**
    	 * 部署流程定义  使用ZIP方式
    	 */
    	@Test
    	public void deployWithZip() {
    		InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("diagrams/HelloWorld.zip");
    		ZipInputStream zipInputStream = new ZipInputStream(inputStream);
    		Deployment deployment = processEngine.getRepositoryService()
    				.createDeployment()
    				.addZipInputStream(zipInputStream)
    				.name("HelloWorld流程")
    				.deploy();
    		System.out.println("流程部署ID："+deployment.getId());
    		System.out.println("流程部署名称："+deployment.getName());
    	}
    }

**2.流程定义的查询、流程图片的查询和最高版本流程查询**

导出图片需要添加工具包,如下：

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

/**
    	 * 查询流程定义返回流程定义集合
    	 */
            @Test
    	public void list() {
    		String processDefinitionKey = "myProcess";
    		List<ProcessDefinition> list = processEngine.getRepositoryService()
    				.createProcessDefinitionQuery()
    				.processDefinitionKey(processDefinitionKey)//通过Key查询
    				.list();
    		for (ProcessDefinition processDefinition : list) {
    			System.out.println(processDefinition.getId());
    			System.out.println(processDefinition.getKey());
    			System.out.println(processDefinition.getName());
    			System.out.println(processDefinition.getResourceName());
    			System.out.println(processDefinition.getDiagramResourceName());
    			System.out.println("====================================================");
    		}
    	}
    	/**
    	 * 根据流程部署ID和资源文件名称来查询流程图片
    	 */
    	@Test
    	public void getImageById() throws Exception{
    		InputStream inputStream = processEngine.getRepositoryService()
    				.getResourceAsStream("10001", "HelloWorld.png");
    		FileUtils.copyInputStreamToFile(inputStream, new File("D:/HelloWorld.png"));
    		System.out.println("图片写出完成");
    				
    	}
    	
    	/**
    	 * 查询流程定义最高版本的数据
    	 */
    	@Test
    	public void listLastVersion() {
    		List<ProcessDefinition> listAll = processEngine.getRepositoryService()
    				.createProcessDefinitionQuery()
    				.orderByProcessDefinitionVersion().asc()
    				.list();
    		Map<String,ProcessDefinition> map = new LinkedHashMap<String,ProcessDefinition>();
    		for (ProcessDefinition pd : listAll) {
    			map.put(pd.getKey(), pd);
    		}
    		List<ProcessDefinition> pdList = new LinkedList<ProcessDefinition>(map.values());
    		for (ProcessDefinition pd : pdList) {
    			System.out.println("ID_"+pd.getId());
    			System.out.println("NAME_"+pd.getName());
    			System.out.println("KEY_"+pd.getKey());
    			System.out.println("VERSION_"+pd.getVersion());
    			System.out.println("========================");
    		}
    	}

**3.流程定义的删除**

processEngine.getRepositoryService()  
                    .deleteDeployment(deploymentId, cascade);

cascade不写默认为false,cascade为true则级联删除

/**
    	 * 删除所有key相同的流程定义
    	 */
    	@Test
    	public void delete() {
    		String processDefinitionKey = "myProcess";
    		List<ProcessDefinition> list = processEngine.getRepositoryService()
    				.createProcessDefinitionQuery()
    				.processDefinitionKey(processDefinitionKey)
    				.list();
    		for(ProcessDefinition pd:list) {
    			processEngine.getRepositoryService()
    					.deleteDeployment(pd.getDeploymentId(), true);
    		}
    	}

[http_blog.java1234.com_blog_articles_84.html_]: http://blog.java1234.com/blog/articles/84.html