flowable 学习（三） 并行网关

时间  2019-11-10
标签 flowable 学习 并行 网关 繁體版
原文   原文链接

一 部署设计器java

代码：https://gitee.com/weim/flowable_demomysql

1. 将flowable-idm.war, flowable-modeler.war放到tomcat的webapps目录下，而后启动tomcatgit

2. 在浏览器中访问http://localhost:8080/flowable-modeler，用户名/密码：admin/test 登录，设计流程后，保存并导出文件。web

二 代码sql

1 建立流程引擎，而且部署一个流程定义浏览器

ProcessEngine processEngine = null;

Map<String, String> userMap = new HashMap<>();


@Before
public void Before() {
	userMap.put("11", "周六");
	userMap.put("22", "周六大佬");
	userMap.put("33", "管周六大佬");
	userMap.put("44", "周天大佬");
	userMap.put("55", "管周天大佬");
	userMap.put("66", "大佬");

	ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
			.setJdbcUrl("jdbc:mysql://localhost:3306/flowable?useSSL=true&serverTimezone=UTC&nullCatalogMeansCurrent=true")
			.setJdbcUsername("xxxx")
			.setJdbcPassword("xxxx")
			.setJdbcDriver("com.mysql.cj.jdbc.Driver")
			.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);

	processEngine = cfg.buildProcessEngine();
}


@Test
public void Test01(){
	// 获取Flowable服务
	RepositoryService repositoryService = processEngine.getRepositoryService();

	// 部署流程定义
	Deployment deployment = repositoryService.createDeployment().addClasspathResource("bing_xing_wang_guan.bpmn20.xml").deploy();

	//查找部署流程定义
	ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
	System.out.println(processDefinition.getName() + "  " + processDefinition.getDeploymentId() + "   " + processDefinition.getId());
}

2 一个完整的流程tomcat

@Test
public void test02() {
	String processDefinitionId = "bing_xing_wang_guan_key:1:4";

	RuntimeService runtimeService = processEngine.getRuntimeService();
	TaskService taskService = processEngine.getTaskService();

	Map<String, Object> variables = new HashMap<>();
	variables.put("user", "11");

	//启动流程
	ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);
	System.out.println("processInstanceId = " + processInstance.getProcessInstanceId());

	//查询周六下的任务
	List<Task> tasks = taskService.createTaskQuery().taskAssignee("11").list();
	queryTask();

	//第一个并行网关
	variables = new HashMap<>();
	variables.put("oneManager", "22");
	variables.put("twoManager", "44");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("22").list();
	variables.put("oneNextManager", "33");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("44").list();
	variables.put("twoNextManager", "55");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周天大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("33").list();
	variables.put("nextManager", "66");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----管周六大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("55").list();
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----管周天大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("66").list();
	taskService.complete(tasks.get(0).getId());
	System.out.println("-----大佬 结束了任务-----");

	queryTask();
}

private void queryTask() {
	TaskService taskService = processEngine.getTaskService();

	System.out.println("---------------------------");
	List<Task> tasks = taskService.createTaskQuery().taskAssignee("11").list();
	System.out.println("周六有" + tasks.size() + " 个任务：");

	tasks = taskService.createTaskQuery().taskAssignee("22").list();
	System.out.println("周六大佬有" + tasks.size() + " 个任务：");

	tasks = taskService.createTaskQuery().taskAssignee("33").list();
	System.out.println("管周六大佬有" + tasks.size() + " 个任务：");

	tasks = taskService.createTaskQuery().taskAssignee("44").list();
	System.out.println("周天大佬有" + tasks.size() + " 个任务：");

	tasks = taskService.createTaskQuery().taskAssignee("55").list();
	System.out.println("管周天大佬有" + tasks.size() + " 个任务：");

	tasks = taskService.createTaskQuery().taskAssignee("66").list();
	System.out.println("大佬有" + tasks.size() + " 个任务：");
	System.out.println("---------------------------");
}

完整流程的执行结果：app

processInstanceId = 12501
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有1 个任务：
管周六大佬有0 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有1 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周天大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有1 个任务：
周天大佬有0 个任务：
管周天大佬有1 个任务：
大佬有0 个任务：
---------------------------
-----管周六大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有1 个任务：
大佬有0 个任务：
---------------------------
-----管周天大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有1 个任务：
---------------------------
-----大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------

3 驳回状况一： 同级别第一个或者第二个管理者驳回webapp

   驳回状况二： 同级别第一个管理者结束了任务，同级别第二个管理者驳回ui

   驳回状况三：管理者上级驳回

这里主要问题在于如何寻找上一个节点的activityId，采用了一种迂回的方式，保存到了变量里。

 3.1 驳回状况一

@Test
public void test03() {
	String processDefinitionId = "bing_xing_wang_guan_key:1:4";

	RuntimeService runtimeService = processEngine.getRuntimeService();
	TaskService taskService = processEngine.getTaskService();

	Map<String, Object> variables = new HashMap<>();
	variables.put("user", "11");
	variables.put("11", null);

	//启动流程
	ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);
	System.out.println("processInstanceId = " + processInstance.getProcessInstanceId());

	//查询managers下的任务
	List<Task> tasks = taskService.createTaskQuery().taskAssignee("11").list();
	String lastActivityId = tasks.get(0).getTaskDefinitionKey();

	queryTask();

	//第一个并行网关
	variables = new HashMap<>();
	variables.put("22", lastActivityId);
	variables.put("44", lastActivityId);
	variables.put("oneManager", "22");
	variables.put("twoManager", "44");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六 结束了任务-----");

	queryTask();

	System.out.println("-----周天大佬 回退了任务-----");
	List<Execution> executionList = runtimeService.createExecutionQuery().parentId(processInstance.getProcessInstanceId()).list();
	List<String> currentExecutionIds = executionList.stream().map(item -> item.getId()).collect(Collectors.toList());

	tasks = taskService.createTaskQuery().taskAssignee("44").list();
	String targetActivityId = taskService.getVariable(tasks.get(0).getId(), "44").toString();

	runtimeService.createChangeActivityStateBuilder()
			.moveExecutionsToSingleActivityId(currentExecutionIds, targetActivityId)
			.changeState();
	queryTask();
}

驳回状况一执行结果：

processInstanceId = 15001
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有1 个任务：
管周六大佬有0 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周天大佬 回退了任务-----
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------

 3.2 驳回状况二

@Test
public void test04() {
	String processDefinitionId = "bing_xing_wang_guan_key:1:4";

	RuntimeService runtimeService = processEngine.getRuntimeService();
	TaskService taskService = processEngine.getTaskService();

	Map<String, Object> variables = new HashMap<>();
	variables.put("user", "11");
	variables.put("11", null);

	//启动流程
	ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);
	System.out.println("processInstanceId = " + processInstance.getProcessInstanceId());

	String processInstanceId = processInstance.getProcessInstanceId();

	//查询managers下的任务
	List<Task> tasks = taskService.createTaskQuery().taskAssignee("11").list();
	String lastActivityId = tasks.get(0).getTaskDefinitionKey();

	queryTask();

	//第一个并行网关
	variables = new HashMap<>();
	variables.put("22", lastActivityId);
	variables.put("44", lastActivityId);
	variables.put("oneManager", "22");
	variables.put("twoManager", "44");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("22").list();
	lastActivityId = tasks.get(0).getTaskDefinitionKey();
	variables.put("33", lastActivityId);
	variables.put("oneNextManager", "33");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六大佬 结束了任务-----");

	queryTask();

	System.out.println("-----周天大佬 回退了任务-----");
	List<Execution> executionList = runtimeService.createExecutionQuery().parentId(processInstanceId).list();
	List<String> currentExecutionIds = executionList.stream().map(item -> item.getId()).collect(Collectors.toList());

	tasks = taskService.createTaskQuery().taskAssignee("44").list();
	String targetActivityId = taskService.getVariable(tasks.get(0).getId(), "44").toString();

	runtimeService.createChangeActivityStateBuilder()
			.processInstanceId(processInstanceId)
			.moveExecutionsToSingleActivityId(currentExecutionIds, targetActivityId)
			.changeState();
	queryTask();
}

驳回状况二执行结果：

processInstanceId = 20001
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有1 个任务：
管周六大佬有0 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有1 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周天大佬 回退了任务-----
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------

 3.3 驳回状况三

@Test
public void test06() {
	String processDefinitionId = "bing_xing_wang_guan_key:1:4";

	RuntimeService runtimeService = processEngine.getRuntimeService();
	TaskService taskService = processEngine.getTaskService();

	Map<String, Object> variables = new HashMap<>();
	variables.put("user", "11");
	variables.put("11", null);

	//启动流程
	ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);
	System.out.println("processInstanceId = " + processInstance.getProcessInstanceId());

	String processInstanceId = processInstance.getProcessInstanceId();

	//查询managers下的任务
	List<Task> tasks = taskService.createTaskQuery().taskAssignee("11").list();
	String lastActivityId = tasks.get(0).getTaskDefinitionKey();

	queryTask();

	//第一个并行网关
	variables = new HashMap<>();
	variables.put("22", lastActivityId);
	variables.put("44", lastActivityId);
	variables.put("oneManager", "22");
	variables.put("twoManager", "44");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("22").list();
	lastActivityId = tasks.get(0).getTaskDefinitionKey();
	variables.put("33", lastActivityId);
	variables.put("oneNextManager", "33");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周六大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("33").list();
	lastActivityId = tasks.get(0).getTaskDefinitionKey();
	variables.put("nextManager", "66");
	variables.put("66", lastActivityId);
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----管周六大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("44").list();
	lastActivityId = tasks.get(0).getTaskDefinitionKey();
	variables.put("55", lastActivityId);
	variables.put("twoNextManager", "55");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----周天大佬 结束了任务-----");

	queryTask();

	tasks = taskService.createTaskQuery().taskAssignee("55").list();
	lastActivityId = tasks.get(0).getTaskDefinitionKey();
	Object variable = taskService.getVariable(tasks.get(0).getId(), "66");
	if(variable != null) {
		lastActivityId = String.valueOf(variable) + "&&" + lastActivityId;
	}
	variables.put("66", lastActivityId);
	variables.put("nextManager", "66");
	taskService.complete(tasks.get(0).getId(), variables);
	System.out.println("-----管周天大佬 结束了任务-----");

	queryTask();

	System.out.println("-----大佬 回退了任务-----");
	List<Execution> executionList = runtimeService.createExecutionQuery().parentId(processInstanceId).list();
	String currentActivityId02 = executionList.get(0).getActivityId();

	tasks = taskService.createTaskQuery().taskAssignee("66").list();
	String currentActivityId = runtimeService.getActiveActivityIds(tasks.get(0).getExecutionId()).get(0);
	String variable02 = taskService.getVariable(tasks.get(0).getId(), "66").toString();
	List<String> targetActivityIds = Arrays.asList(variable02.split("&&"));
	runtimeService.createChangeActivityStateBuilder()
			.processInstanceId(processInstanceId)
			.moveSingleActivityIdToActivityIds(currentActivityId, targetActivityIds)
			.changeState();

	queryTask();
}

驳回状况三执行结果：

processInstanceId = 25001
---------------------------
周六有1 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有1 个任务：
管周六大佬有0 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周六大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有1 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----管周六大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有1 个任务：
管周天大佬有0 个任务：
大佬有0 个任务：
---------------------------
-----周天大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有1 个任务：
大佬有0 个任务：
---------------------------
-----管周天大佬 结束了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有0 个任务：
周天大佬有0 个任务：
管周天大佬有0 个任务：
大佬有1 个任务：
---------------------------
-----大佬 回退了任务-----
---------------------------
周六有0 个任务：
周六大佬有0 个任务：
管周六大佬有1 个任务：
周天大佬有0 个任务：
管周天大佬有1 个任务：
大佬有0 个任务：
---------------------------
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程