2023年8月1日发(作者：)
Activiti基础教程--10开始活动节点，接收活动，⽤户任务（个⼈任务，组任务）⼀、开始活动节点public class StartTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("开始活动")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例+判断流程是否结束+查询历史*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "start"; ProcessInstance pi = timeService()//与正在执⾏的流程实例和执⾏对象相关的Service n("流程实例ID:"+());//流程实例ID 101 n("流程定义ID:"+cessDefinitionId());//流程定义ID helloworld:1:4
/**判断流程是否结束，查询正在执⾏的执⾏对象表*/ ProcessInstance rpi = timeService()// .createProcessInstanceQuery()//创建流程实例查询对象 .processInstanceId(()) .singleResult(); //说明流程实例结束了 if(rpi==null){ /**查询历史，获取流程的相关信息*/ HistoricProcessInstance hpi = toryService()// .createHistoricProcessInstanceQuery()// .processInstanceId(())//使⽤流程实例ID查询 .singleResult(); n(()+" "+rtTime()+" "+Time()+" "+ationInMillis()); } }
} .startProcessInstanceByKey(processDefinitionKey);//使⽤流程定义的key启动流程实例，key对应⽂件中id的属性值，使⽤key值启动，默认是按照 1).结束节点没有出⼝
2).其他节点有⼀个或多个出⼝。
如果有⼀个出⼝，则代表是⼀个单线流程；
如果有多个出⼝，则代表是开启并发流程。 ⼆、接收活动 接收任务（receiveTask，即等待活动）是⼀个简单任务，它会等待对应消息的到达。 当前，官⽅只实现了这个任务的java语义。 当流程达到接收任务，流程状态会保存到数据库中。 在任务创建后，意味着流程会进⼊等待状态， 直到引擎接收了⼀个特定的消息， 这会触发流程穿过接收任务继续执⾏public class ReceiveTaskTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("接收活动任务")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例+设置流程变量+获取流程变量+向后执⾏⼀步*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "receiveTask"; ProcessInstance pi = timeService()//与正在执⾏的流程实例和执⾏对象相关的Service n("流程实例ID:"+());//流程实例ID 101 n("流程定义ID:"+cessDefinitionId());//流程定义ID helloworld:1:4
/**查询执⾏对象ID*/ Execution execution1 = timeService()// .createExecutionQuery()//创建执⾏对象查询 .processInstanceId(())//使⽤流程实例ID查询 .activityId("receivetask1")//当前活动的id，对应⽂件中的活动节点id的属性值 .singleResult();
/**使⽤流程变量设置当⽇销售额，⽤来传递业务参数*/ timeService()// .setVariable((), "汇总当⽇销售额", 21000);
/**向后执⾏⼀步，如果流程处于等待状态，使得流程继续执⾏*/ timeService() .signal(());
/**查询执⾏对象ID*/ Execution execution2 = timeService()// .createExecutionQuery()//创建执⾏对象查询 .processInstanceId(())//使⽤流程实例ID查询 .activityId("receivetask2")//当前活动的id，对应⽂件中的活动节点id的属性值 .singleResult();
/**从流程变量中获取汇总当⽇销售额的值*/ Integer value = (Integer)timeService()// .getVariable((), "汇总当⽇销售额"); n("给⽼板发送短信：⾦额是："+value); /**向后执⾏⼀步，如果流程处于等待状态，使得流程继续执⾏*/ timeService() .signal(());
}
} .startProcessInstanceByKey(processDefinitionKey);//使⽤流程定义的key启动流程实例，key对应⽂件中id的属性值，使⽤key值启动，默认是按照说明： 1).当前任务（⼀般指机器⾃动完成，但需要耗费⼀定时间的⼯作）完成后，向后推移流程，可以调⽤(executionId)，传递接收执⾏对象的id。
三、⽤户任务(userTask，即⽤户操作的任务)3-1.个⼈任务--分配个⼈任务⽅式⼀（直接指定办理⼈）1：流程图中任务节点的配置public class TaskTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("任务")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "task"; /**启动流程实例的同时，设置流程变量，使⽤流程变量⽤来指定任务的办理⼈，对应⽂件中#{userID}*/ Map
/**查询当前⼈的个⼈任务*/ @Test public void findMyPersonalTask(){ String assignee = "周芷若"; List
/**完成我的任务*/ @Test public void completeMyPersonalTask(){ //任务ID String taskId = "5505"; kService()//与正在执⾏的任务管理相关的Service .complete(taskId); n("完成任务：任务ID："+taskId); }}说明：
1）张三丰是个⼈任务的办理⼈
2）但是这样分配任务的办理⼈不够灵活，因为项⽬开发中任务的办理⼈不要放置XML⽂件中。
3-2.分配个⼈任务⽅式⼆（使⽤流程变量）测试代码如上。3-3.分配个⼈任务⽅式三（使⽤类）此时流程图的XML⽂件，如图：TaskListenerImpl类，⽤来设置任务的办理⼈@SuppressWarnings("serial")public class TaskListenerImpl implements TaskListener { /**⽤来指定任务的办理⼈*/ @Override public void notify(DelegateTask delegateTask) { //指定个⼈任务的办理⼈，也可以指定组任务的办理⼈ //个⼈任务：通过类去查询数据库，将下⼀个任务的办理⼈查询获取，然后通过setAssignee()的⽅法指定任务的办理⼈ ignee("灭绝师太"); }}public class TaskTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("任务")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "task"; ProcessInstance pi = timeService()//与正在执⾏的流程实例和执⾏对象相关的Service n("流程实例ID:"+());//流程实例ID 101 n("流程定义ID:"+cessDefinitionId());//流程定义ID helloworld:1:4 }
/**查询当前⼈的个⼈任务*/ .startProcessInstanceByKey(processDefinitionKey);//使⽤流程定义的key启动流程实例，key对应⽂件中id的属性值，使⽤key值启动，默认是按照 @Test public void findMyPersonalTask(){ String assignee = "张翠⼭"; List
/**完成我的任务*/ @Test public void completeMyPersonalTask(){ //任务ID String taskId = "5804"; kService()//与正在执⾏的任务管理相关的Service .complete(taskId); n("完成任务：任务ID："+taskId); }
//可以分配个⼈任务从⼀个⼈到另⼀个⼈（认领任务） @Test public void setAssigneeTask(){ //任务ID String taskId = "5804"; //指定的办理⼈ String userId = "张翠⼭"; kService()// .setAssignee(taskId, userId); }}说明：
1).在类中使⽤ignee(assignee);的⽅式分配个⼈任务的办理⼈，此时张⽆忌是下⼀个任务的办理⼈
2).通过kService().setAssignee(taskId, userId);将个⼈任务从⼀个⼈分配给另⼀个⼈，此时张⽆忌不再是下⼀个任务的办理⼈，⽽换成了周芷若
3).在开发中，可以将每⼀个任务的办理⼈规定好，例如张三的领导是李四，李四的领导是王五，这样张三提交任务，就可以查询出张三的领导是李四，通过类的⽅式设置下⼀个任务的办理⼈ 总结个⼈任务及三种分配⽅式： 1：在中直接写 assignee=“张三丰" 2：在中写 assignee=“#{userID}”，变量的值要是String的。 使⽤流程变量指定办理⼈ 3，使⽤TaskListener接⼝，要使类实现该接⼝，在类中定义： ignee(assignee);// 指定个⼈任务的办理⼈
使⽤任务ID和办理⼈重新指定办理⼈： kService().setAssignee(taskId, userId3-4、分配组任务⽅式⼀（直接指定办理⼈）public class TaskTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("任务")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "task"; /**启动流程实例的同时，设置流程变量，使⽤流程变量⽤来指定任务的办理⼈，对应⽂件中#{userIDs}*/ Map
n("流程定义ID:"+cessDefinitionId());//流程定义ID
}
/**查询当前⼈的个⼈任务*/ @Test public void findMyPersonalTask(){ String assignee = "⼩A"; List
/**查询当前⼈的组任务*/ @Test public void findMyGroupTask(){ String candidateUser = "⼤⼤"; List
/**完成我的任务*/ @Test public void completeMyPersonalTask(){ //任务ID String taskId = "6905"; kService()//与正在执⾏的任务管理相关的Service .complete(taskId); n("完成任务：任务ID："+taskId); }
/**查询正在执⾏的任务办理⼈表*/ @Test public void findRunPersonTask(){ //任务ID String taskId = "6204"; List
/**拾取任务，将组任务分给个⼈任务，指定任务的办理⼈字段*/ @Test public void claim(){ //将组任务分配给个⼈任务 //任务ID String taskId = "6905"; //分配的个⼈任务（可以是组任务中的成员，也可以是⾮组任务的成员） String userId = "⼤⼤"; kService()// .claim(taskId, userId); }
/**将个⼈任务回退到组任务，前提，之前⼀定是个组任务*/ @Test public void setAssigee(){ //任务ID String taskId = "6204"; kService()// .setAssignee(taskId, null); }
/**向组任务中添加成员*/ @Test public void addGroupUser(){ //任务ID String taskId = "6204"; //成员办理⼈ String userId = "⼤H"; kService()// .addCandidateUser(taskId, userId); }
/**从组任务中删除成员*/ @Test public void deleteGroupUser(){ //任务ID String taskId = "6204"; //成员办理⼈ String userId = "⼩B"; kService()// .deleteCandidateUser(taskId, userId); }
}说明：
1).⼩A，⼩B，⼩C，⼩D是组任务的办理⼈
2).但是这样分配组任务的办理⼈不够灵活，因为项⽬开发中任务的办理⼈不要放置XML⽂件中。
3).act_ru_identitylink表存放任务的办理⼈，包括个⼈任务和组任务，表⽰正在执⾏的任务
4).act_hi_identitylink表存放任务的办理⼈，包括个⼈任务和组任务，表⽰历史任务
区别在于：如果是个⼈任务TYPE的类型表⽰participant（参与者）
如果是组任务TYPE的类型表⽰candidate（候选者）和participant（参与者）
3-5、分配个⼈任务⽅式⼆（使⽤流程变量）流程图中任务节点的配置测试代码如上，加上流程变量就⾏3-6.分配个⼈任务⽅式三（使⽤类）此时流程图的XML⽂件，如图：
TaskListenerImpl类，⽤来设置任务的办理⼈@SuppressWarnings("serial")public class TaskListenerImpl implements TaskListener { /**⽤来指定任务的办理⼈*/ @Override public void notify(DelegateTask delegateTask) { //指定个⼈任务的办理⼈，也可以指定组任务的办理⼈ //个⼈任务：通过类去查询数据库，将下⼀个任务的办理⼈查询获取，然后通过setAssignee()的⽅法指定任务的办理⼈ //ignee("灭绝师太"); //组任务： didateUser("郭靖"); didateUser("黄蓉"); }}public class TaskTest { ProcessEngine processEngine = aultProcessEngine();
/**部署流程定义（从inputStream）*/ @Test public void deploymentProcessDefinition_inputStream(){ InputStream inputStreamBpmn = ss().getResourceAsStream(""); InputStream inputStreamPng = ss().getResourceAsStream(""); Deployment deployment = ositoryService()//与流程定义和部署对象相关的Service .createDeployment()//创建⼀个部署对象 .name("任务")//添加部署的名称 .addInputStream("", inputStreamBpmn)// .addInputStream("", inputStreamPng)// .deploy();//完成部署 n("部署ID："+());// n("部署名称："+e());// }
/**启动流程实例*/ @Test public void startProcessInstance(){ //流程定义的key String processDefinitionKey = "task"; ProcessInstance pi = timeService()//与正在执⾏的流程实例和执⾏对象相关的Service n("流程实例ID:"+());//流程实例ID
n("流程定义ID:"+cessDefinitionId());//流程定义ID
}
/**查询当前⼈的个⼈任务*/ @Test public void findMyPersonalTask(){ String assignee = "郭靖"; List
/**查询当前⼈的组任务*/ @Test public void findMyGroupTask(){ String candidateUser = "郭靖"; List
/**完成我的任务*/ @Test public void completeMyPersonalTask(){ //任务ID String taskId = "7204"; kService()//与正在执⾏的任务管理相关的Service .complete(taskId); n("完成任务：任务ID："+taskId); }
/**查询正在执⾏的任务办理⼈表*/ @Test public void findRunPersonTask(){ //任务ID String taskId = "6204"; List
/**拾取任务，将组任务分给个⼈任务，指定任务的办理⼈字段*/ @Test public void claim(){ //将组任务分配给个⼈任务 //任务ID String taskId = "7204"; //分配的个⼈任务（可以是组任务中的成员，也可以是⾮组任务的成员） String userId = "郭靖"; kService()// .claim(taskId, userId); }
/**将个⼈任务回退到组任务，前提，之前⼀定是个组任务*/ @Test public void setAssigee(){ //任务ID String taskId = "6204"; kService()// .setAssignee(taskId, null); }
/**向组任务中添加成员*/ @Test public void addGroupUser(){ //任务ID String taskId = "6204"; //成员办理⼈ String userId = "⼤H"; kService()// .addCandidateUser(taskId, userId); }
/**从组任务中删除成员*/ @Test public void deleteGroupUser(){ //任务ID String taskId = "6204"; //成员办理⼈ String userId = "⼩B"; kService()// .deleteCandidateUser(taskId, userId); }
}说明：
1).在类中使⽤didateUser (userId);的⽅式分配组任务的办理⼈，此时孙悟空和猪⼋戒是下⼀个任务的办理⼈。
2).通过kService().claim (taskId, userId);将组任务分配给个⼈任务，也叫认领任务，即指定某个⼈去办理这个任务，此时由如来去办理任务。
注意：认领任务的时候，可以是组任务成员中的⼈，也可以不是组任务成员的⼈，此时通过Type的类型为participant来指定任务的办理⼈
3).addCandidateUser()即向组任务添加成员，deleteCandidateUser()即删除组任务的成员。 4).在开发中，可以将每⼀个任务的办理⼈规定好，例如张三的领导是李四和王五，这样张三提交任务，由李四或者王五去查询组任务，可以看到对应张三的申请，李四或王五再通过认领任务（claim）的⽅式，由某个⼈去完成这个任务
总结
组任务及三种分配⽅式：
1：在中直接写 candidate-users=“⼩A,⼩B,⼩C,⼩D"
2：在中写 candidate-users =“#{userIDs}”，变量的值要是String的。
使⽤流程变量指定办理⼈
Map
("userIDs", "⼤⼤,⼩⼩,中中");
3，使⽤TaskListener接⼝，使⽤类实现该接⼝，在类中定义：
//添加组任务的⽤户
didateUser(userId1);
didateUser(userId2);
组任务分配给个⼈任务（认领任务）：
kService().claim(taskId, userId);
个⼈任务分配给组任务：
kService(). setAssignee(taskId, null);
向组任务添加⼈员：
kService().addCandidateUser(taskId, userId);
向组任务删除⼈员：
kService().deleteCandidateUser(taskId, userId);
个⼈任务和组任务存放办理⼈对应的表：
act_ru_identitylink表存放任务的办理⼈，包括个⼈任务和组任务，表⽰正在执⾏的任务
act_hi_identitylink表存放任务的办理⼈，包括个⼈任务和组任务，表⽰历史任务
区别在于：如果是个⼈任务TYPE的类型表⽰participant（参与者）
如果是组任务TYPE的类型表⽰candidate（候选者）和participant（参与者）
发布者：admin，转转请注明出处：http://www.yc00.com/xiaochengxu/1690872949a451958.html
评论列表（0条）