自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

探索BPMN—工作流技術(shù)的理論與實踐

作者：冬冬
開發(fā) 項目管理
異常處理的支持度不夠友好（SmartEngine是異常丟棄），如果在某一個節(jié)點上執(zhí)行失?。ㄒ话闱闆r是業(yè)務(wù)接口執(zhí)行失敗導(dǎo)致），默認(rèn)當(dāng)前流程進度是卡在該節(jié)點的，需要設(shè)計張異常表，把當(dāng)前流程實例，節(jié)點實例以及變量都保存下載，通過job重新拉起重試去驅(qū)動流程繼續(xù)執(zhí)行，并需要做好告警監(jiān)控，以及任務(wù)實例和流程實例的核對。

一、前言

  • 19世紀(jì)70年代，流程管理思想萌芽階段。怎樣提高工作效率？泰勒：標(biāo)準(zhǔn)化個人操作流程亨利·福特：規(guī)定標(biāo)準(zhǔn)時間定額標(biāo)準(zhǔn)化、精簡化、通用化、專業(yè)化。
  • 20世紀(jì)70年代，工作流技術(shù)起源于辦公自動化領(lǐng)域的研究。由于當(dāng)時計算機尚未普及，網(wǎng)絡(luò)技術(shù)水平還很低以及理論基礎(chǔ)匱乏，這項新技術(shù)并未取得成功，許多公司采用紙張表單，手工傳遞的方式，一級一級審批簽字，工作效率非常低下。
  • 20世紀(jì)90年代，信息技術(shù)驅(qū)動流程自動化階段。信息技術(shù)開始引入管理領(lǐng)域，對傳統(tǒng)的業(yè)務(wù)進行自動化改造。產(chǎn)品：Sabre訂票系統(tǒng)，MRP（物料需求計劃），MIS（管理信息系統(tǒng)），CIMS（計算機集成制造系統(tǒng)）。
  • 21世紀(jì)初，BPM管理與治理結(jié)合。BPR/BPI：以信息技術(shù)為核心重新設(shè)計業(yè)務(wù)流程，失敗率高達(dá)50%-70%；BPM：以業(yè)務(wù)流程為主導(dǎo)的管理思想；BPM治理思想：對BPM實施的成功率以及ROI的高要求，強調(diào)BPM與企業(yè)戰(zhàn)略相結(jié)合。

二、BPMN介紹

BPMN（Business Process Modeling Notation，業(yè)務(wù)流程建模符號）是一種用于描述業(yè)務(wù)流程的標(biāo)準(zhǔn)化建模語言。它通過圖形符號及規(guī)則，幫助企業(yè)建模、分析和優(yōu)化各種業(yè)務(wù)流程。BPMN有兩個主要版本：BPMN 1.0和BPMN 2.0。BPMN 1.0規(guī)范由標(biāo)準(zhǔn)組織BPMI（后并入到OMG）于2004年5月發(fā)布；BPMN 2.0標(biāo)準(zhǔn)由OMG于2011年推出。

2.0相對于1.0規(guī)范了流程引擎的語義和格式，利用標(biāo)準(zhǔn)的圖元描述真實的業(yè)務(wù)發(fā)生過程，保證相同的流程在不同的流程引擎中得到一致的執(zhí)行結(jié)果。

BPMN的理論基礎(chǔ)

  • 流程建模：BPMN使用不同的圖形符號來表示業(yè)務(wù)流程中的各項活動、任務(wù)、決策和事件等。這些符號包括任務(wù)、網(wǎng)關(guān)、事件等，每個符號都有特定的含義和用法。
  • 流程分析：通過BPMN模型，企業(yè)可以分析業(yè)務(wù)流程的效率、資源利用率和風(fēng)險等，以便進行優(yōu)化和改進。
  • 流程執(zhí)行：BPMN不僅是一種建模語言，還可以將建模的業(yè)務(wù)流程實際執(zhí)行起來，并進行監(jiān)控和控制。

BPMN的優(yōu)勢

圖片圖片

傳統(tǒng)使用場景

  • 采購流程：通過BPMN建模，企業(yè)可以規(guī)范采購流程，包括需求確認(rèn)、供應(yīng)商選擇、合同簽訂、物品收貨等環(huán)節(jié)，提高采購效率。
  • 請假審批流程：BPMN模型可以幫助企業(yè)規(guī)范請假審批流程，包括員工請假申請、直屬主管審批、人力資源部門審批等環(huán)節(jié)，減少誤差和糾紛。
  • 客戶投訴處理流程：利用BPMN，企業(yè)可以清晰地展示客戶投訴處理流程，包括客戶投訴登記、處理人員分配、處理過程跟蹤、客戶反饋等環(huán)節(jié)，提高客戶滿意度。

三、實踐舉例：XX平臺XXX商家合規(guī)治理任務(wù)優(yōu)化項目（非真實場景）

背景目標(biāo)

  • 商家合規(guī)治理手段的單一性和對線下人工的過度依賴方面需要優(yōu)化，通過整合商家合規(guī)治理策略，并實現(xiàn)這些策略的可在線化配置。這一舉措將打破傳統(tǒng)的手工操作模式，允許業(yè)務(wù)方直接在系統(tǒng)中配置和更新治理策略，減少人工干預(yù)，提高治理效率。同時，在線化配置也便于策略的快速部署和靈活調(diào)整，以應(yīng)對不同業(yè)務(wù)場景下的合規(guī)要求。
  • 各商家的合規(guī)治理進度和狀態(tài)的透明度方面需要優(yōu)化，為改變這一現(xiàn)狀，我們需要搭建一套高效的工作流引擎。該引擎將支持商家合規(guī)治理流程的編排和自動化流轉(zhuǎn)，從任務(wù)觸發(fā)到完成審核、記錄反饋等各個環(huán)節(jié)都將實現(xiàn)自動化處理。同時，內(nèi)置的進度跟蹤機制將確保業(yè)務(wù)團隊能夠?qū)崟r查看各商家的治理進度，及時發(fā)現(xiàn)問題并采取相應(yīng)措施。這將大大提高治理的透明度和可控性。
  • 評估治理成果和手段的有效性分析方面需要優(yōu)化，將合規(guī)治理成果的數(shù)據(jù)可視化，通過強大的數(shù)據(jù)分析與可視化系統(tǒng)，我們將關(guān)鍵指標(biāo)（如治理效率、違規(guī)率、改進情況等）以圖表、報告等形式直觀展現(xiàn)。同時，通過持續(xù)的數(shù)據(jù)分析與改進循環(huán)，我們將逐步優(yōu)化治理策略和方式，最終形成商家合規(guī)治理的閉環(huán)機制。

方案

業(yè)務(wù)流程

治理流程1治理流程1

治理流程2治理流程2

系統(tǒng)架構(gòu)圖

流程編排流程編排

工作流技術(shù)選型工作流技術(shù)選型

圖片圖片

SmartEngine詳細(xì)介紹

  E-R圖

圖片圖片

CREATE TABLE `se_deployment_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_definition_id` varchar(255) NOT NULL  COMMENT 'process definition id'  ,
  `process_definition_version` varchar(255) DEFAULT NULL  COMMENT 'process definition version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL  COMMENT 'process definition type'  ,
  `process_definition_code` varchar(255) DEFAULT NULL  COMMENT 'process definition code'  ,
  `process_definition_name` varchar(255) DEFAULT NULL  COMMENT 'process definition name'  ,
  `process_definition_desc` varchar(255) DEFAULT NULL  COMMENT 'process definition desc'  ,
  `process_definition_content` mediumtext NOT NULL  COMMENT 'process definition content'  ,
  `deployment_user_id` varchar(128) NOT NULL  COMMENT 'deployment user id' ,
  `deployment_status` varchar(64) NOT NULL   COMMENT 'deployment status' ,
  `logic_status` varchar(64) NOT NULL  COMMENT 'logic status' ,


  PRIMARY KEY (`id`)
) COMMENT='流程定義表' ;


CREATE TABLE `se_process_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time' ,
  `process_definition_id_and_version` varchar(128) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL COMMENT 'process definition type'  ,
  `status` varchar(64) NOT NULL COMMENT ' 1.running 2.completed 3.aborted',
  `parent_process_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'parent process instance id' ,
  `parent_execution_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'parent execution instance id' ,
  `start_user_id` varchar(128) DEFAULT NULL  COMMENT 'start user id' ,
  `biz_unique_id` varchar(255) DEFAULT NULL  COMMENT 'biz unique id' ,
  `reason` varchar(255) DEFAULT NULL   COMMENT 'reason' ,
  `comment` varchar(255) DEFAULT NULL   COMMENT 'comment' ,
  `title` varchar(255) DEFAULT NULL  COMMENT 'title' ,
  `tag` varchar(255) DEFAULT NULL  COMMENT 'tag' ,


  PRIMARY KEY (`id`)
) COMMENT='流程實例表' ;


CREATE TABLE `se_activity_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned DEFAULT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(255) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_activity_id` varchar(64) NOT NULL COMMENT 'process definition activity id'   ,
  PRIMARY KEY (`id`)
) COMMENT='活動節(jié)點實例表' ;


CREATE TABLE `se_task_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(128) DEFAULT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL  COMMENT 'process definition type'  ,
  `activity_instance_id` bigint(20) unsigned NOT NULL   COMMENT 'activity instance id' ,
  `process_definition_activity_id` varchar(255) NOT NULL  COMMENT 'process definition activity id' ,
  `execution_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'execution instance id'  ,
  `claim_user_id` varchar(255) DEFAULT NULL   COMMENT 'claim user id' ,
  `title` varchar(255) DEFAULT NULL COMMENT 'title'   ,
  `priority` int(11) DEFAULT 500 COMMENT 'priority' ,
  `tag` varchar(255) DEFAULT NULL  COMMENT 'tag'  ,
  `claim_time` datetime(6) DEFAULT NULL COMMENT 'claim time'   ,
  `complete_time` datetime(6) DEFAULT NULL COMMENT 'complete time'   ,
  `status` varchar(255) NOT NULL COMMENT 'status'     ,
  `comment` varchar(255) DEFAULT NULL  COMMENT 'comment'  ,
  `extension` varchar(255) DEFAULT NULL COMMENT 'extension'  ,


  PRIMARY KEY (`id`)
) COMMENT='人工任務(wù)節(jié)點實例表'  ;


CREATE TABLE `se_task_assignee_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time'  ,
  `gmt_modified` datetime(6) NOT NULL   COMMENT 'modification time' ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `task_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'task instance id'  ,
  `assignee_id` varchar(255) NOT NULL  COMMENT 'assignee id'  ,
  `assignee_type` varchar(128) NOT NULL  COMMENT 'assignee type'  ,
  PRIMARY KEY (`id`)
) COMMENT='人工任務(wù)節(jié)點代理人實例表'  ;


CREATE TABLE `se_execution_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'PK'   ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(255) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_activity_id` varchar(255) NOT NULL COMMENT 'process definition activity id'   ,
  `activity_instance_id` bigint(20) unsigned NOT NULL COMMENT 'activity instance id'   ,
  `active` tinyint(4) NOT NULL COMMENT '1:active 0:inactive',
  PRIMARY KEY (`id`)
) COMMENT='執(zhí)行節(jié)點實例表-最細(xì)粒度的實例'   ;




CREATE TABLE `se_variable_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time'  ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL   COMMENT 'process instance id' ,
  `execution_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'execution instance id' ,
  `field_key` varchar(128) NOT NULL   COMMENT 'field key' ,
  `field_type` varchar(128) NOT NULL   COMMENT 'field type' ,
  `field_double_value` decimal(65,30) DEFAULT NULL   COMMENT 'field double value' ,
  `field_long_value` bigint(20) DEFAULT NULL  COMMENT 'field long value'  ,
  `field_string_value` varchar(4000) DEFAULT NULL  COMMENT 'field string value' ,


  PRIMARY KEY (`id`)
) COMMENT='執(zhí)行節(jié)點變量量表' ;

代碼實操

第一步，要選擇正確的SmartEngine版本，將其添加到pom依賴中。

<dependency>

  <groupld>com.alibaba.smart.framework</groupld>

  <artifactld>smart-engine-extension-storage-custom</artifactld>

  <version>3.0.0</version>

</dependency>

第二步，完成SmartEngine初始化。在初始化時，一般要加載流程定義到應(yīng)用中。集群情況下，要注意流程定義的一致性（如果純靜態(tài)記載則無此類問題）。在初始化時，可以根據(jù)需要定義Bean的加載優(yōu)先級。

import com.alibaba.smart.framework.engine.SmartEngine;
import com.alibaba.smart.framework.engine.configuration.InstanceAccessor;
import com.alibaba.smart.framework.engine.configuration.ProcessEngineConfiguration;
import com.alibaba.smart.framework.engine.configuration.impl.DefaultProcessEngineConfiguration;
import com.alibaba.smart.framework.engine.configuration.impl.DefaultSmartEngine;
import com.alibaba.smart.framework.engine.exception.EngineException;
import com.alibaba.smart.framework.engine.service.command.RepositoryCommandService;
import com.alibaba.smart.framework.engine.util.IOUtil;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;


import java.io.InputStream;


import static org.springframework.core.Ordered.LOWEST_PRECEDENCE;




@Order(LOWEST_PRECEDENCE)
@Configuration
@ConditionalOnClass(SmartEngine.class)
public class SmartEngineAutoConfiguration implements ApplicationContextAware {


    private ApplicationContext applicationContext;


    @Bean
    @ConditionalOnMissingBean
    public SmartEngine constructSmartEngine() {
        ProcessEngineConfiguration processEngineConfiguration = new DefaultProcessEngineConfiguration();
        // 實現(xiàn)InstanceAccessor接口
        processEngineConfiguration.setInstanceAccessor(new CustomInstanceAccessService());


        SmartEngine smartEngine = new DefaultSmartEngine();
        smartEngine.init(processEngineConfiguration);


        // 加載流程定義
        deployProcessDefinition(smartEngine);


        return smartEngine;
    }


    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }


    private class CustomInstanceAccessService implements InstanceAccessor {
        @Override
        public Object access(String name) {
            return applicationContext.getBean(name);
        }
    }


    private void deployProcessDefinition(SmartEngine smartEngine) {
        RepositoryCommandService repositoryCommandService = smartEngine
                .getRepositoryCommandService();


        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            Resource[] resources = resolver.getResources("classpath*:/smart-engine/*.xml");
            for (Resource resource : resources) {
                InputStream inputStream = resource.getInputStream();
                repositoryCommandService.deploy(inputStream);
                IOUtil.closeQuietly(inputStream);
            }
        } catch (Exception e) {
            throw new EngineException(e);
        }


    }
}

BMPN2.0 xml舉例

附言：排他網(wǎng)關(guān)的條件表達(dá)式是跟著線條綁定的，要自己確保條件的是和否加在一起的總概率是100%，如果不是100%，小概率執(zhí)行節(jié)點會卡在排他網(wǎng)關(guān)走不下去。例如：線條“否”的條件表達(dá)式為：條件1為假且條件2為假，線條“是”的條件表達(dá)式為條件1為真且條件2為真，則其他條件會卡死在排他網(wǎng)關(guān)流程走不下去。

test1.bpmn

<?xml versinotallow="1.0" encoding="UTF-8"?>
<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Web Modeler" exporterVersion="b1a091a" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.5.0" camunda:diagramRelationId="2a2c997b-ff2f-49b0-9ba8-3c4860d223e7">
  <bpmn:process id="Process_1qijgvk" name="test1" isExecutable="true">
    <bpmn:startEvent id="StartEvent_1">
      <bpmn:outgoing>Flow_0soou9n</bpmn:outgoing>
    </bpmn:startEvent>
    <bpmn:sequenceFlow id="Flow_0soou9n" sourceRef="StartEvent_1" targetRef="Activity_02gdgyk" />
    <bpmn:endEvent id="Event_1i2y4ym">
      <bpmn:incoming>Flow_07mf0sc</bpmn:incoming>
      <bpmn:incoming>Flow_1nd3369</bpmn:incoming>
      <bpmn:incoming>Flow_160ji3a</bpmn:incoming>
    </bpmn:endEvent>
    <bpmn:exclusiveGateway id="Gateway_1kykneu" name="檢查是否5天內(nèi)完成治理">
      <bpmn:extensionElements />
      <bpmn:incoming>Flow_0exjsc9</bpmn:incoming>
      <bpmn:outgoing>Flow_0hj860q</bpmn:outgoing>
      <bpmn:outgoing>Flow_1oqjt08</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_0hj860q" name="否" sourceRef="Gateway_1kykneu" targetRef="Activity_1ms8vu6" />
    <bpmn:serviceTask id="Activity_02gdgyk" name="站內(nèi)通知商戶去治理">
      <bpmn:extensionElements />
      <bpmn:incoming>Flow_0soou9n</bpmn:incoming>
      <bpmn:outgoing>Flow_0exjsc9</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0exjsc9" sourceRef="Activity_02gdgyk" targetRef="Gateway_1kykneu" />
    <bpmn:serviceTask id="Activity_1ms8vu6" name="發(fā)送sms通知商戶">
      <bpmn:incoming>Flow_0hj860q</bpmn:incoming>
      <bpmn:outgoing>Flow_0bemgki</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0bemgki" sourceRef="Activity_1ms8vu6" targetRef="Gateway_1dyp6hh" />
    <bpmn:sequenceFlow id="Flow_1oqjt08" name="是" sourceRef="Gateway_1kykneu" targetRef="Activity_1c9i1el" />
    <bpmn:exclusiveGateway id="Gateway_1dyp6hh" name="是否10天內(nèi)完成治理">
      <bpmn:incoming>Flow_0bemgki</bpmn:incoming>
      <bpmn:outgoing>Flow_07xq405</bpmn:outgoing>
      <bpmn:outgoing>Flow_1w4qeti</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_07xq405" name="是" sourceRef="Gateway_1dyp6hh" targetRef="Activity_0m5dsna" />
    <bpmn:serviceTask id="Activity_1c9i1el" name="發(fā)放獎勵給到商戶">
      <bpmn:incoming>Flow_1oqjt08</bpmn:incoming>
      <bpmn:outgoing>Flow_1t7ectj</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_1t7ectj" sourceRef="Activity_1c9i1el" targetRef="Activity_1p6mkdy" />
    <bpmn:task id="Activity_0m5dsna" name="任務(wù)完成">
      <bpmn:incoming>Flow_07xq405</bpmn:incoming>
      <bpmn:outgoing>Flow_07mf0sc</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_07mf0sc" sourceRef="Activity_0m5dsna" targetRef="Event_1i2y4ym" />
    <bpmn:sequenceFlow id="Flow_1w4qeti" name="否" sourceRef="Gateway_1dyp6hh" targetRef="Activity_1gud1rw" />
    <bpmn:task id="Activity_1p6mkdy" name="任務(wù)完成">
      <bpmn:incoming>Flow_1t7ectj</bpmn:incoming>
      <bpmn:outgoing>Flow_1nd3369</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_1nd3369" sourceRef="Activity_1p6mkdy" targetRef="Event_1i2y4ym" />
    <bpmn:serviceTask id="Activity_1gud1rw" name="通知運營下線商戶店鋪">
      <bpmn:incoming>Flow_1w4qeti</bpmn:incoming>
      <bpmn:outgoing>Flow_0vr5zs3</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0vr5zs3" sourceRef="Activity_1gud1rw" targetRef="Activity_1pfbnmo" />
    <bpmn:task id="Activity_1pfbnmo" name="任務(wù)結(jié)束">
      <bpmn:incoming>Flow_0vr5zs3</bpmn:incoming>
      <bpmn:outgoing>Flow_160ji3a</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_160ji3a" sourceRef="Activity_1pfbnmo" targetRef="Event_1i2y4ym" />
  </bpmn:process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_1">
    <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Process_1qijgvk">
      <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1">
        <dc:Bounds x="152" y="232" width="36" height="36" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Gateway_1kykneu_di" bpmnElement="Gateway_1kykneu" isMarkerVisible="true">
        <dc:Bounds x="465" y="225" width="50" height="50" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="448" y="188" width="84" height="27" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_02gdgyk_di" bpmnElement="Activity_02gdgyk">
        <dc:Bounds x="270" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1ms8vu6_di" bpmnElement="Activity_1ms8vu6">
        <dc:Bounds x="630" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Event_1i2y4ym_di" bpmnElement="Event_1i2y4ym">
        <dc:Bounds x="1182" y="232" width="36" height="36" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Gateway_1dyp6hh_di" bpmnElement="Gateway_1dyp6hh" isMarkerVisible="true">
        <dc:Bounds x="825" y="225" width="50" height="50" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="810" y="285" width="79" height="27" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1c9i1el_di" bpmnElement="Activity_1c9i1el">
        <dc:Bounds x="630" y="320" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_0m5dsna_di" bpmnElement="Activity_0m5dsna">
        <dc:Bounds x="950" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="BPMNShape_0ab1d2g" bpmnElement="Activity_1p6mkdy">
        <dc:Bounds x="840" y="320" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1gud1rw_di" bpmnElement="Activity_1gud1rw">
        <dc:Bounds x="800" y="80" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="BPMNShape_02s3tua" bpmnElement="Activity_1pfbnmo">
        <dc:Bounds x="950" y="80" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge id="Flow_0soou9n_di" bpmnElement="Flow_0soou9n">
        <di:waypoint x="188" y="250" />
        <di:waypoint x="270" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0exjsc9_di" bpmnElement="Flow_0exjsc9">
        <di:waypoint x="370" y="250" />
        <di:waypoint x="465" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0hj860q_di" bpmnElement="Flow_0hj860q">
        <di:waypoint x="515" y="250" />
        <di:waypoint x="630" y="250" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="567" y="232" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1oqjt08_di" bpmnElement="Flow_1oqjt08">
        <di:waypoint x="490" y="275" />
        <di:waypoint x="490" y="360" />
        <di:waypoint x="630" y="360" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="544" y="373" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0bemgki_di" bpmnElement="Flow_0bemgki">
        <di:waypoint x="730" y="250" />
        <di:waypoint x="825" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1t7ectj_di" bpmnElement="Flow_1t7ectj">
        <di:waypoint x="730" y="360" />
        <di:waypoint x="840" y="360" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_07mf0sc_di" bpmnElement="Flow_07mf0sc">
        <di:waypoint x="1050" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_07xq405_di" bpmnElement="Flow_07xq405">
        <di:waypoint x="875" y="250" />
        <di:waypoint x="950" y="250" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="899" y="232" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1w4qeti_di" bpmnElement="Flow_1w4qeti">
        <di:waypoint x="850" y="225" />
        <di:waypoint x="850" y="160" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="853" y="186" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1nd3369_di" bpmnElement="Flow_1nd3369">
        <di:waypoint x="940" y="360" />
        <di:waypoint x="1120" y="360" />
        <di:waypoint x="1120" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0vr5zs3_di" bpmnElement="Flow_0vr5zs3">
        <di:waypoint x="900" y="120" />
        <di:waypoint x="950" y="120" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_160ji3a_di" bpmnElement="Flow_160ji3a">
        <di:waypoint x="1050" y="120" />
        <di:waypoint x="1120" y="120" />
        <di:waypoint x="1120" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</bpmn:definitions>
  • process，表示一個流程。
  • id="exclusiveTest" versinotallow="1.0.0"，分別表示流程定義的id和版本。這兩個字段唯一區(qū)分一個流程定義。
  • startEvent，表示流程開始節(jié)點。只允許有一個開始節(jié)點。
  • endEvent，表示流程結(jié)束節(jié)點?？梢杂卸鄠€結(jié)束節(jié)點。
  • sequenceFlow，表示環(huán)節(jié)流轉(zhuǎn)關(guān)系。sourceRef="theStart" targetRef="submitTask" 分別表示起始節(jié)點和目標(biāo)節(jié)點。該節(jié)點有個子節(jié)點， approve == 'agree'，這個片段很重要，用來描述流程流轉(zhuǎn)的條件。approve == 'upgrade'使用的是MVEL表達(dá)式語法。另外，還值得注意的是，在驅(qū)動流程運轉(zhuǎn)時，需要傳入正確的參數(shù)。比如說，在后面介紹的api中，通常會需要在Map中傳遞業(yè)務(wù)請求參數(shù)。那么需要將Map中的key和Mvel的運算因子關(guān)聯(lián)起來。以這個例子來說，request.put("approve", "agree")；里面的approve和approve == 'agree'命名要一致。
  • exclusiveGateway，表示互斥網(wǎng)關(guān)。該節(jié)點非常重要。用來區(qū)分流程節(jié)點的不同轉(zhuǎn)向?；コ饩W(wǎng)關(guān)在引擎執(zhí)行conditionExpression后，有且只能選擇一條匹配的sequenceFlow繼續(xù)執(zhí)行。
  • serviceTask，服務(wù)任務(wù)，用來表示執(zhí)行一個服務(wù)，所以他會有引擎默認(rèn)的擴展:smart:class="com.alibaba.smart.framework.example.AuditProcessServiceTaskDelegation". Client Developer使用時，需要自定義對應(yīng)的業(yè)務(wù)實現(xiàn)類。在該節(jié)點執(zhí)行時，它會自動執(zhí)行服務(wù)調(diào)用，執(zhí)行smart:class 這個 delegation。該節(jié)點不暫停，會自動往下一個流轉(zhuǎn)。
  • receiveTask，接收任務(wù)。在引擎遇到此類型的節(jié)點時，引擎執(zhí)行會自動暫停，等待外部調(diào)用signal方法。當(dāng)調(diào)用signal方法時，會驅(qū)動流程當(dāng)前節(jié)點離開。在離開該節(jié)點時，引擎會自動執(zhí)行smart:class 這個delegation。在一般業(yè)務(wù)場景中，我們通常使用receiveTask來表示等需要等待外部回調(diào)的節(jié)點。
  • userTask，表示用戶任務(wù)節(jié)點，僅用于DataBase模式。該節(jié)點需要人工參與處理，并且通常需要在待辦列表中展示。在Custom模式下，建議使用receiveTask來代替。
  • parallelGateway，這個節(jié)點并未在上述流程定義中體現(xiàn)，這里詳細(xì)說一下。parallelGateway 首先必須成對出現(xiàn)，分別承擔(dān)fork和join職責(zé)。其次，在join時需要實現(xiàn)分布式鎖接口：LockStrategy。第三，fork默認(rèn)是順序遍歷多個sequeceFlow，但是你如果需要使用并發(fā)fork功能的話，則需要實現(xiàn)該接口：ExecutorService。

重要領(lǐng)域?qū)ο?/h4>
  • 部署實例: DeploymentInstance，描述這個流程定義是誰發(fā)布的，當(dāng)前處于什么狀態(tài)。
  • 流程定義: ProcessDefinition，描述一個流程有幾個環(huán)節(jié)，之間的流轉(zhuǎn)關(guān)系是什么樣子的。
  • 流程實例: ProcessInstance，可以簡單理解為我們常見的一個工單。
  • 活動實例: ActivityInstance，主要是描述流程實例（工單）的流轉(zhuǎn)軌跡。
  • 執(zhí)行實例: ExecutionInstance，主要根據(jù)該實例的狀態(tài)，來判斷當(dāng)前流程處在哪個節(jié)點上。
  • 任務(wù)實例: TaskInstance，用來表示人工任務(wù)處理的，可以理解為一個需要人工參與處理的環(huán)節(jié)。
  • 任務(wù)處理：TaskAssigneeInstance，用來表示當(dāng)前任務(wù)共有幾個處理者。通常在代辦列表中用到此實體。
  • 變量實例：VariableInstance，用來存儲流程實例上下文。

SmartEngine引擎源碼地址：https://github.com/alibaba/SmartEngine/tree/master

SmartEngine UserGuide:  https://github.com/alibaba/SmartEngine/wiki/SmartEngine-UserGuide--Chinese-Version-%28%E4%B8%AD%E6%96%87%E7%89%88%29

Camunda開源流程設(shè)計器（支持在線和本地node.js部署兩種方式）：https://camunda.com/download/modeler/

Camunda設(shè)計器學(xué)習(xí)文檔：https://docs.camunda.io/docs/components/modeler/bpmn/bpmn-primer/

四、總結(jié)與建議

優(yōu)點

  • 業(yè)務(wù)流程可視化與實際系統(tǒng)流程可視化高度一致，所見即所得。
  • 調(diào)整效率高（業(yè)務(wù)平均每個月會升級一次治理流程），如果業(yè)務(wù)流程1.0要升級到1.1，只需要重新復(fù)制一份bpmn.xml流程模板重新編排為1.1，并下發(fā)流程實例即可，不影響原有的流程模板和流程實例執(zhí)行（調(diào)整效率由原來的一周縮短到1小時）。
  • 流程實例和流程節(jié)點實例可視，方便監(jiān)控各個節(jié)點的執(zhí)行和數(shù)據(jù)報表的產(chǎn)出。

缺點

  • 異常處理的支持度不夠友好（SmartEngine是異常丟棄），如果在某一個節(jié)點上執(zhí)行失?。ㄒ话闱闆r是業(yè)務(wù)接口執(zhí)行失敗導(dǎo)致），默認(rèn)當(dāng)前流程進度是卡在該節(jié)點的，需要設(shè)計張異常表，把當(dāng)前流程實例，節(jié)點實例以及變量都保存下載，通過job重新拉起重試去驅(qū)動流程繼續(xù)執(zhí)行，并需要做好告警監(jiān)控，以及任務(wù)實例和流程實例的核對。
  • 高并發(fā)場景的支持度并不是太友好，要通過異步消息的方式來控制創(chuàng)建流程實例的速度，目前得到的創(chuàng)建流程實例的TPS是100/s單臺，只是相對于activiti來說并發(fā)支持度要高，超過這個上限的場景建議謹(jǐn)慎使用。
  • 可擴展性不足，例如：ProcessQueryService只支持findById，findList，count；ExecutionQueryService只支持findActiveExecutionList，findAll這些基本查詢 ，復(fù)雜查詢需要新寫SmartEngine核心包，升級jar包版本后才可使用。
  • 無歷史記錄表，每隔一段時間要清理表中流程實例已經(jīng)完結(jié)的相關(guān)數(shù)據(jù)，否則歷史數(shù)據(jù)堆積影響查詢效率。

建議

如果業(yè)務(wù)流程的復(fù)雜度一般，且經(jīng)常會調(diào)整，并發(fā)量并不高的情況下，建議使用；如果業(yè)務(wù)復(fù)雜度過高，或并發(fā)量TPS超過單臺100/s，不建議使用。

責(zé)任編輯：武曉燕 來源： 得物技術(shù)
BPMN技術(shù)流程
相關(guān)推薦

2021-07-26 18:38:48

Bpmn流程

2023-08-02 18:48:23

Flowable工作流引擎

2022-02-21 10:50:28

SvnGitHub分支

2009-03-03 09:13:36

工作流BPM業(yè)務(wù)流程

2024-04-07 00:06:00

Rust編程技巧

2022-10-26 08:00:43

Activiti工作流BPM

2009-07-31 17:34:40

ASP.NET工作流

2021-10-14 11:34:05

技術(shù)工作流引擎

2017-04-05 10:06:59

工作流界面抽象組件

2024-04-25 08:00:00

DevOps架構(gòu)軟件開發(fā)

2013-04-23 10:28:08

IBeamMDAAWF

2015-03-13 15:58:11

Adobe

2020-08-06 08:26:22

Kubernetes架構(gòu)開發(fā)

2015-07-14 09:26:28

微型工作流引擎設(shè)計

2020-08-06 08:16:26

Kubernetes架構(gòu)開源

2022-06-30 09:30:36

FlinkSQL流批一體京東

2022-07-14 10:06:20

工作流引擎營銷自動化vivo

2024-12-05 12:01:09

2010-01-04 17:42:50

SilverLight

2012-07-23 10:36:46

工作流
點贊
收藏

51CTO技術(shù)棧公眾號