Package com.founder.fix.fixflow.core.impl.bpmn.behavior

Examples of com.founder.fix.fixflow.core.impl.bpmn.behavior.ProcessDefinitionBehavior


    assertNotNull(deploymentIdTemp);
    //定义一个流程定义查询
    ProcessDefinitionQuery processDefinitionQuery=modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否得到流程定义
    assertNotNull(processDefinitionBehavior);
   
    //定义部署资源的字节流
    ResourceEntity resourceEntity = modelService.getResourceAsStream(processDefinitionBehavior.getResourceId());
    //验证是否得到定义部署资源的字节流
    assertNotNull(resourceEntity);
  }
View Full Code Here


    assertNotNull(deploymentIdTemp);
    //定义一个流程定义查询
    ProcessDefinitionQuery processDefinitionQuery=modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否得到流程定义
    assertNotNull(processDefinitionBehavior);
   
    //根据流程定义号获得流程定义
    ProcessDefinitionBehavior processDefinitionBehavior2 = modelService.getProcessDefinition(processDefinitionBehavior.getProcessDefinitionId());
    //验证获得的流程定义正确
    assertEquals(processDefinitionBehavior, processDefinitionBehavior2);
  }
View Full Code Here

    assertNotNull(deploymentIdTemp);
    //定义一个流程定义查询
    ProcessDefinitionQuery processDefinitionQuery=modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否得到流程定义
    assertNotNull(processDefinitionBehavior);
    //获得流程图节点的位置信息
    Map<String,Map<String,Object>> map = modelService.GetFlowGraphicsElementPosition(processDefinitionBehavior.getProcessDefinitionId());
    //验证是否含有UserTask_1,UserTask_4,EndEvent_1等节点
    assertTrue(map.containsKey("UserTask_1"));
    assertTrue(map.containsKey("UserTask_4"));
    assertTrue(map.containsKey("EndEvent_1"));
  }
View Full Code Here

    assertNotNull(deploymentId);
    //创建流程定义查询
    ProcessDefinitionQuery processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
  }
View Full Code Here

    assertNotNull(deploymentId);
    //创建流程定义查询
    ProcessDefinitionQuery processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
   
    //获取流程定义编号
    String processDefinitionId = processDefinitionBehavior.getProcessDefinitionId();
    //获取流程定义key
    String processDefinitionKey = processDefinitionBehavior.getProcessDefinitionKey();
    //通过流程定义编号获取流程图的文件流
    InputStream streamById = modelService.GetFlowGraphicsImgStreamByDefId(processDefinitionId);
    //验证是否成功获取
    assertNotNull(streamById);
    //通过流程定义key获取流程图的文件流
View Full Code Here

    assertNotNull(deploymentId);
    //创建流程定义查询
    ProcessDefinitionQuery processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
   
    String deployId = processDefinitionBehavior.getDeploymentId();
    deploymentBuilder = processEngine.getModelService().createDeployment().name("测试名称");
    //获取zip文件的inputStream流
    inputStream = ReflectUtil.getResourceAsStream("com/founder/fix/fixflow/test/engine/api/model/Process_TaskServiceTest_new.zip");
    //发布流程定义
    deploymentBuilder.addZipInputStream(new ZipInputStream(inputStream));
    //设置需要更新的发布号
    deploymentBuilder.updateDeploymentId(deployId);
    //更新流程定义
    deploymentId = deploymentBuilder.deploy().getId();
    //重置流程定义查询
    processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    //获取查询到的流程定义
    processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
   
    //查询新的流程定义中有没有ScriptTask_1
    FlowElement flowElement = processDefinitionBehavior.getFlowElement("ScriptTask_1");
    //验证是否查询到此节点
    assertNotNull(flowElement);
   
  }
View Full Code Here

    //创建流程定义查询
    ProcessDefinitionQuery processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    ProcessDefinitionBehavior processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
   
    String deployId = processDefinitionBehavior.getDeploymentId();
   
    //更新流程定义
    deploymentId = modelService.updateDeploymentByZip("com/founder/fix/fixflow/test/engine/api/model/Process_TaskServiceTest_new.zip", deployId);
    //重置流程定义查询
    processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //查询刚发布的流程定义
    processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest");
    //获取查询到的流程定义
    processDefinitionBehavior=processDefinitionQuery.singleResult();
    //验证是否查询到
    assertNotNull(processDefinitionBehavior);
   
    //查询新的流程定义中有没有ScriptTask_1
    FlowElement flowElement = processDefinitionBehavior.getFlowElement("ScriptTask_1");
    //验证是否查询到此节点
    assertNotNull(flowElement);
   
  }
View Full Code Here

  @Deployment(resources = { "com/founder/fix/fixflow/test/engine/api/task/TaskServiceTest.bpmn"})
  public void testUserTaskToolBar(){
    //获取流程定义查询
    ProcessDefinitionQuery processDefinitionQuery = modelService.createProcessDefinitionQuery();
    //获得发布的流程定义
    ProcessDefinitionBehavior processDefinitionBehavior  = processDefinitionQuery.processDefinitionKey("Process_TaskServiceTest").singleResult();
    //获取此流程的开始节点可显示的命令
    List<TaskCommandInst> commands = taskService.getTaskCommandById(processDefinitionBehavior.getProcessDefinitionId(), "UserTask_3");
    //验证是否为7个命令,详见流程定义
    assertEquals(7, commands.size());
  }
View Full Code Here

      String processInstanceId = taskInstance.getProcessInstanceId();

      ProcessDefinitionManager processDefinitionManager = Context.getCommandContext().getProcessDefinitionManager();

      ProcessDefinitionBehavior processDefinition = processDefinitionManager.findLatestProcessDefinitionById(processDefinitionId);

      ProcessInstanceEntity processInstanceImpl = processInstanceManager.findProcessInstanceById(processInstanceId, processDefinition);
      if(processInstanceImpl.hasEnded()){
        return false;
      }
View Full Code Here

      if (StringUtil.isNotEmpty(this.nodeId)) {
        ProcessInstanceEntity processInstanceEntity = getProcessInstance();
        if (processInstanceEntity == null) {
          return null;
        }
        ProcessDefinitionBehavior processDefinitionBehavior = getProcessInstance().getProcessDefinition();
        if (processDefinitionBehavior == null) {
          return null;
        }
        this.flowNode = (FlowNode) processDefinitionBehavior.getDefinitions().getElement(this.nodeId);
        return this.flowNode;
      }

      return null;
View Full Code Here

TOP

Related Classes of com.founder.fix.fixflow.core.impl.bpmn.behavior.ProcessDefinitionBehavior

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.