activiti 流程定义部署及查询

发表于:2018-4-12 16:58  作者:chen_lay   来源:51Testing软件测试网采编

字体: | 上一篇 | 下一篇 |我要投稿 | 推荐标签: 流程 业务知识

  package com.mycom.processDefinition;
  import java.io.InputStream;
  import java.util.List;
  import java.util.zip.ZipInputStream;
  import org.activiti.engine.ProcessEngine;
  import org.activiti.engine.ProcessEngines;
  import org.activiti.engine.repository.Deployment;
  import org.activiti.engine.repository.ProcessDefinition;
  import org.junit.Test;
  public class ProcessDefinitionTest {
      ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  
      @Autowired
      private RepositoryService repositoryService;

  /**
       * 根据modelId部署模型
       * @param modelId
       * @param response
       * @param request
       * @return
       */
      @RequestMapping("/deploy")
      @ResponseBody
      public Map deploy(final String modelId, HttpServletResponse response,final HttpServletRequest request) {
          OperateTemplete templete = new HttpTemplete(request) {
              protected void doSomething() throws BizException {
                  JSONObject result = new JSONObject();
                  try {
                      Model modelData = repositoryService.getModel(modelId);
                      ObjectNode modelNode = (ObjectNode) new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
                      byte[] bpmnBytes = null;
                      BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);
                      bpmnBytes = new BpmnXMLConverter().convertToXML(model);
                      String processName = modelData.getName() + ".bpmn20.xml";
                      DeploymentBuilder db = repositoryService.createDeployment().name(modelData.getName());
                      Deployment deployment = db.addString(processName, new String(bpmnBytes,"utf-8")).deploy();
                  } catch (Exception e) {
                      e.printStackTrace();
                      throw new BizException("部署失败");
                  }
              }
          };
          return templete.operate();
      }
      
      /*
       *部署流程定义 (从classpath)
       */
      @Test
      public void deploymentProcessDefinition_classpath(){
          Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                          .createDeployment()//创建一个部署对象
                          .name("流程定义")//添加部署名称
                          .addClasspathResource("diagrams/HelloWorld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
                          .addClasspathResource("diagrams/HelloWorld.png")
                          .deploy();//完成部署
          System.out.println("部署ID:"+deployment.getId());
          System.out.println("部署名称:"+deployment.getName());
          
      }
      
      /*
       *部署流程定义 (从zip)
       */
      @Test
      public void deploymentProcessDefinition_zip(){
          InputStream in = this.getClass().getClassLoader().getResourceAsStream("diagrams/HelloWorld.zip");
          ZipInputStream zipInputStream = new ZipInputStream(in);
          Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                          .createDeployment()//创建一个部署对象
                          .name("流程定义")//添加部署名称
                          .addZipInputStream(zipInputStream)//完成zip文件的部署
                          .deploy();//完成部署
          System.out.println("部署ID:"+deployment.getId());
          System.out.println("部署名称:"+deployment.getName());
          
      }
      
      /*
       * 查询流程定义
       */
      @Test
      public void findProcessDefinition(){
          List<ProcessDefinition> list = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                          .createProcessDefinitionQuery()//创建一个流程定义查询
                          /*指定查询条件,where条件*/
                          //.deploymentId(deploymentId)//使用部署对象ID查询
                          //.processDefinitionId(processDefinitionId)//使用流程定义ID查询
                          //.processDefinitionKey(processDefinitionKey)//使用流程定义的KEY查询
                          //.processDefinitionNameLike(processDefinitionNameLike)//使用流程定义的名称模糊查询
                          
                          /*排序*/
                          .orderByProcessDefinitionVersion().asc()//按照版本的升序排列
                          //.orderByProcessDefinitionName().desc()//按照流程定义的名称降序排列
                          
                          .list();//返回一个集合列表,封装流程定义
                          //.singleResult();//返回唯一结果集
                          //.count();//返回结果集数量
                          //.listPage(firstResult, maxResults)//分页查询
          
          if(list != null && list.size()>0){
              for(ProcessDefinition processDefinition:list){
                  System.out.println("流程定义ID:"+processDefinition.getId());//流程定义的key+版本+随机生成数
                  System.out.println("流程定义名称:"+processDefinition.getName());//对应HelloWorld.bpmn文件中的name属性值
                  System.out.println("流程定义的key:"+processDefinition.getKey());//对应HelloWorld.bpmn文件中的id属性值
                  System.out.println("流程定义的版本:"+processDefinition.getVersion());//当流程定义的key值相同的情况下,版本升级,默认从1开始
                  System.out.println("资源名称bpmn文件:"+processDefinition.getResourceName());
                  System.out.println("资源名称png文件:"+processDefinition.getDiagramResourceName());
                  System.out.println("部署对象ID:"+processDefinition.getDeploymentId());
                  System.out.println("################################");
              }
          }
          
      }
      
  }
  相关的表:
  select * from act_re_model;#模型表
  SELECT * FROM activiti.act_re_deployment a; #部署对象表
   SELECT * FROM activiti.act_re_procdef a; #流程定义表
   SELECT * FROM activiti.act_ge_bytearray a;# 资源文件表
   
  SELECT * FROM activiti.act_ge_property a; #主键生成策略表



上文内容不用于商业目的,如涉及知识产权问题,请权利人联系博为峰小编(021-64471599-8017),我们将立即处理。

【直播预售】接口测试行业大佬带你从青铜上王者>>立即查看

评 论

论坛新帖

顶部 底部


建议使用IE 6.0以上浏览器,800×600以上分辨率,法律顾问:上海瀛东律师事务所 张楠律师
版权所有 上海博为峰软件技术股份有限公司 Copyright©51testing.com 2003-2018, 沪ICP备05003035号
投诉及意见反馈:webmaster@51testing.com; 业务联系:service@51testing.com 021-64471599-8017

沪公网安备 31010102002173号

51Testing官方微信

51Testing官方微博

扫一扫 测试知识全知道