jBPM一(概念及管理控制流程)

相关概念:

privateProcessEngineprocessEngine=Configuration.getProcessEngine();

//部署（添加）

//jbpm4_deployment,jbpm4_deployprop,jbpm4_lob

@Test

publicvoiddeploy(){

StringdeploymentId=processEngine.getRepositoryService()//

.createDeployment()//

.addResourceFromClasspath("aa/aa.jpdl.xml")//必须要有一个.jpdl.xml文件

.addResourceFromClasspath("aa/aa.png")//

.deploy();

System.out.println("部署成功，deploymentId="+deploymentId);

}

/**

*创建一个流程定义

*/

@Test

publicvoidcreateProcessDefinition(){

//获取当前类路径下的文件

ZipInputStreamin=newZipInputStream(CRD.class.getClassLoader()

.getResourceAsStream("JBPM.zip"));

processEngine.getRepositoryService()//

.createDeployment()//

.addResourcesFromZipInputStream(in)//

.deploy();

}

//Deployment：一次部署的信息（包含多个文件）。

//ProcessDefinition（流程定义）：是指解析xx.jpdl.xml后得到的流程信息。

@Test

publicvoidfindAll(){

//查询

Listlist=processEngine.getRepositoryService()//

.createProcessDefinitionQuery()//

.list();

//显示

for(ProcessDefinitionpd:list){

System.out.println("id="+pd.getId()//格式为：{key}-{version}

+",name="+pd.getName()//.jpdl.xml中根元素的name属性的值

+",key="+pd.getKey()//.jpdl.xml中根元素的key属性的值，如果没有指定，默认为name属性的值。

+",version="+pd.getVersion()//版本，默认是1，或自动累加。

+",deploymentId="+pd.getDeploymentId());//所属的Deployment记录的id

}

}

//OrderBy的属性名在ProcessDefinitionQuery中有常量的定义。

@Test

publicvoidfindAllLatestVersions(){

//1，查询所有的流程定义

//按version排序，以便让所有最大的版本都排在最后面

ListallList=processEngine.getRepositoryService()//

.createProcessDefinitionQuery()//

.orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION)//

.list();

//2，过滤出所需的最新版本流程定义的集合

Mapmap=newHashMap();

for(ProcessDefinitionpd:allList){

//ProcessDefinitionpdInMap=map.get(pd.getKey());

//if(pdInMap==null||pdInMap.getVersion()<pd.getVersion()){

//map.put(pd.getKey(),pd);

//}

map.put(pd.getKey(),pd);

}

//显示

for(ProcessDefinitionpd:map.values()){

System.out.println("id="+pd.getId()//格式为：{key}-{version}

+",name="+pd.getName()//.jpdl.xml中根元素的name属性的值

+",key="+pd.getKey()//.jpdl.xml中根元素的key属性的值，如果没有指定，默认为name属性的值。

+",version="+pd.getVersion()//版本，默认是1，或自动累加。

+",deploymentId="+pd.getDeploymentId());//所属的Deployment记录的id

}

}

@Test

publicvoiddeleteById(){

StringdeploymentId="40001";

////删除一次部署的信息（删除相关的文件），如果有相关的运行信息，则报错

//processEngine.getRepositoryService().deleteDeployment(deploymentId);

//删除一次部署的信息（删除相关的文件），会级联删除所有相关的运行信息

processEngine.getRepositoryService().deleteDeploymentCascade(deploymentId);

}

@Test

publicvoiddeleteByKey(){

//1，查询出指定key的所有版本的流程定义

Stringkey="test";

Listlist=processEngine.getRepositoryService()//

.createProcessDefinitionQuery()//

.processDefinitionKey(key)//

.list();

//2，循环删除

for(ProcessDefinitionpd:list){

processEngine.getRepositoryService().deleteDeploymentCascade(pd.getDeploymentId());

}

}

@Test

publicvoidgetProcessImage()throwsException{

StringdeploymentId="60001";

StringresourceName="a/helloworld.png";

//获取某Deployment中所有的文件资源的名称

Setset=processEngine.getRepositoryService().getResourceNames(deploymentId);

for(Strings:set){

System.out.println(s);

}

//获取某Deployment中某资源的InputStream（内容）

InputStreamin=processEngine.getRepositoryService().getResourceAsStream(deploymentId,resourceName);

//保存到c盘

FileOutputStreamout=newFileOutputStream("c:/processImage.png");

for(intb=-1;(b=in.read())!=-1;){

out.write(b);

}

in.close();

out.close();

}