雁过留声 发表于 2024-6-27 07:10:57

BPMN开始事件-Activiti7从入门到专家(7)

开始事件类型

bpmn开始事件表示流程的开始,定义流程如何启动,在某种情况下启动,好比吸收事件启动,指定事件启动等,开始事件有5种类型:

[*]空开始事件
[*]定时器开始事件
[*]信号开始事件
[*]消息开始事件
[*]错误开始事件

https://img-blog.csdnimg.cn/img_convert/332020add6c532097cd2a6a950f5ae71.png
继承关系如上,基本事件属性如下:
https://img-blog.csdnimg.cn/img_convert/4a0a38185ef0e53819df7909a10abb24.png
asynchronous:是否异步(默认否)表示是否能被异步实行。
exclusive: 是否排他(默认是)表示同一个流程实例在同一时候只能由一个人实行该步骤, 跟asynchronous互斥。
initiator:定义一个变量来记录谁发起了该流程实例。
Form Key:与其关联的一个外部表单的名字,如果采用了外部表单的话。

其中 FormProperty继承 BaseElement 有一大坨属性,其里面还有个list,也有一大坨属性,值得关注,动态表单属性
AlfrescoStartEvent 继承了start事件,外部脚本啥的启动
开始事件里面加上各类事件定义,就构成了5种类型。
空开始事件

空圆圈表示,未指定触发类型,可以由api触发,直接调用runtimeService中的startProcessInstanceBy启动各类流程。
定时器开始事件

指定某个时间条件启动流程,条件是由job实行器。
例子如下:
<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
    <startEvent id="_2" name="StartEvent">
      <timerEventDefinition>
      <!--从每分钟的0s开始,每隔5秒开始一次流程(生成一个流程实例)-->
      <timeCycle>0/5 * * * * ?</timeCycle>
      </timerEventDefinition>
    </startEvent>
    <userTask activiti:exclusive="true" id="UserTask" name="UserTask"/>
    <endEvent id="_4" name="EndEvent"/>
    <sequenceFlow id="_5" sourceRef="_2" targetRef="UserTask"/>
    <sequenceFlow id="_6" sourceRef="UserTask" targetRef="_4"/>
    </process> 固然,需要摆设流程,然后job就会启动流程。
留意事项


[*]子流程不能嵌入定时器开始事件
[*]自动触发
[*]如果摆设新版本时,上一个版本定时器作业会被移除
消息开始事件

<message id="msg" name="msgName"></message>
<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
<startEvent id="_2" name="StartEvent">
    <!--开始事件引用消息-->
    <messageEventDefinition messageRef="msg"></messageEventDefinition>
</startEvent>
<userTask activiti:exclusive="true" id="UserTask" name="UserTask"/>
<endEvent id="_4" name="EndEvent"/>
<sequenceFlow id="_5" sourceRef="_2" targetRef="UserTask"/>
<sequenceFlow id="_6" sourceRef="UserTask" targetRef="_4"/>
</process> 代码如下:

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();

Deployment deployment = repositoryService.createDeployment().addClasspathResource("message-start-event.bpmn").deploy();
//通过消息启动流程实例,在一个项目中的消息事件会存储在表act_ru_event_subscr中,
// 并且因为流程实例依靠具体的消息来启动,因此在该项目中的消息需要唯一。例:如果一个流程的消息name定义为"msgName",第一次部署时act_ru_event_subscr
// 表会存储消息与部署的流程定义的关联,之后再部署相同的消息时,不会再增加记录,不会与消息绑定;即只有第一绑定消息的流程定义是有效的。
ProcessInstance processInstance = runtimeService.startProcessInstanceByMessage("msgName");
System.out.println("流程实例ID:" + processInstance.getId());

processEngine.close();
System.exit(0); 信号开始事件

<singalEventDefinition siganlRel='theSignal'>
触发方式有3种:

[*]订阅某个信号的信号开始事件接到抛出的信号,启动流程
[*]通过Api抛出信号,runtimeService 中 以signalEventReceived开头的方法
[*]作为平凡开始事件,启动事件
错误开始事件

可以触发一个事件子流程,且总在别的一个流程非常竣事时触发,闪电符号
一个班级,班长盘点人数,发现人数少了后,马上去报告班主任。


https://img-blog.csdnimg.cn/img_convert/2edc0d8bb0f82fa0176fda0c45a82548.png
<error id="errorId" errorCode="abc"></error>
<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
<startEvent id="_2" name="StartEvent"/>
<serviceTask activiti:exclusive="true" id="CountPeople" name="CountPeople"
               activiti:class="com.xjf.test.delegate.CountPeopleDelegate"/>
<endEvent id="_4" name="EndEvent"/>
<sequenceFlow id="_5" sourceRef="_2" targetRef="CountPeople"/>
<sequenceFlow id="_6" sourceRef="CountPeople" targetRef="_4"/>
<!--triggeredByEvent配置必须为true,默认是false-->
<subProcess activiti:exclusive="true" id="_7" name="SubProcess" triggeredByEvent="true">
    <startEvent id="_8" name="StartEvent">
      <errorEventDefinition errorRef="errorId"></errorEventDefinition>
    </startEvent>
    <serviceTask activiti:exclusive="true" id="Report" name="Report"
               activiti:class="com.xjf.test.delegate.ReportDelegate"/>
    <endEvent id="_10" name="EndEvent"/>
    <sequenceFlow id="_3" sourceRef="_8" targetRef="Report"/>
    <sequenceFlow id="_11" sourceRef="Report" targetRef="_10"/>
</subProcess>
</process>
servicetask 两个委托类

public class CountPeopleDelegate implements JavaDelegate {
    @Override
    public void execute(DelegateExecution delegateExecution) {
      System.out.println("清点人数,要抛出错误");

      //抛出错误,子流程的错误开始事件会捕获
      throw new BpmnError("abc");
    }
}

public class ReportDelegate implements JavaDelegate {
    @Override
    public void execute(DelegateExecution delegateExecution) {
      System.out.println("少人了,准备上报");
    }
} 启动流程测试
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();

Deployment deployment = repositoryService.createDeployment().addClasspathResource("error-start-event.bpmn").deploy();
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();

//流程实例启动后,会自动执行:主流程抛出错误,子流程捕获到错误然后一直执行完
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
System.out.println("流程实例id:" + processInstance.getId());

processEngine.close();
System.exit(0);
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: BPMN开始事件-Activiti7从入门到专家(7)