activiti工作流笔记

2022-10-05 19:55:05

什么是activiti？

Activiti是一个身经百战的业务流程管理引擎，并且还是一个流程平台

为什么要用工作流引擎？

简单来说，就是为了统一管理流程业务。
想想看，如果要设计一个流程的程序，通常需要在数据库中存各种状态值，比如一个订单程序，要标记订单是未付款、已付款、已出库等等状态，而这些各种各样的状态参杂在程序中，逻辑自然就变得复杂了。
而将这些状态对应到流程里的一个个步骤，交由流程引擎去管理，这样不仅简化了业务逻辑代码，

而且，还有很强的扩展性。

eg：我可以修改我的流程，我可以添加一些步骤而不用改我的数据库表结构，不用改我的业务逻辑。

状态机---->工作流。

API介绍

（一）

额外再加一个： DynamicBpmnService:提供动态获取，以及动态修改流程定义的方法。

Activiti的后台是有数据库的支持，所有的表都以ACT_开头。第二部分是表示表的用途的两个字母标识。用途也和服务的API对应。
1) ACT_RE_*: ‘RE’表示repository。这个前缀的表包含了流程定义和流程静态资源（图片，规则，等等）。
2) ACT_RU_*: ‘RU’表示runtime。这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据，在流程结束时就会删除这些记录。这样运行时表可以一直很小速度很快。
3) ACT_ID_*: ‘ID’表示identity。这些表包含身份信息，比如用户，组等等。
4) ACT_HI_*: ‘HI’表示history。这些表包含历史数据，比如历史流程实例，变量，任务等等。
5) ACT_GE_*: 通用数据，用于不同场景下。
资源库流程规则表
　　1) act_re_deployment 部署信息表
　　2) act_re_model 流程设计模型部署表
　　3) act_re_procdef 流程定义数据表
运行时数据库表
　　1) act_ru_execution 运行时流程执行实例表
　　2) act_ru_identitylink 运行时流程人员表，主要存储任务节点与参与者的相关信息
　　3) act_ru_task 运行时任务节点表
　　4) act_ru_variable 运行时流程变量数据表
　　5) act_ru_timer_job （5.22不存在）
　　6) act_ru_suspended_job （5.22不存在）
　　7) act_ru_event_subscr
　　8) act_ru_deadletter_job （5.22不存在）
　　9) act_ru_job

历史数据库表
　　1) act_hi_actinst 历史节点表
　　2) act_hi_attachment 历史附件表
　　3) act_hi_comment 历史意见表
　　4) act_hi_identitylink 历史流程人员表
　　5) act_hi_detail 历史详情表，提供历史变量的查询
　　6) act_hi_procinst 历史流程实例表
　　7) act_hi_taskinst 历史任务实例表
　　8) act_hi_varinst 历史变量表
组织机构表
　　1) act_id_group 用户组信息表
　　2) act_id_info 用户扩展信息表
　　3) act_id_membership 用户与用户组对应信息表
　　4) act_id_user 用户信息表
　　这四张表很常见，基本的组织机构管理，关于用户认证方面建议还是自己开发一套，组件自带的功能太简单，使用中有很多需求难以满足
通用数据表
　　1) act_ge_bytearray 二进制数据表
　　2) act_ge_property 属性数据表存储整个流程引擎级别的数据,初始化表结构时，会默认插入三条记录

（二） ACT_RE_MODEL

1 查询model 是否存在

List<Model> modelList = repositoryService.createModelQuery().modelName("Demo model").list();

2 有三个外键，对应ACT_GE_BYTEARRAY的有两个。

EDITOR_SOURCE_VALUE_ID_对应ACT_GE_BYTEARRAY的ID_，表示该模型对应的模型文件（json格式数据）。

repositoryService.addModelEditorSource方法实现。

EDITOR_SOURCE_EXTRA_VALUE_ID_对应ACT_GE_BYTEARRAY的ID_，表示该模型生成的图片文件。

repositoryService.addModelEditorSourceExtra方法实现。

3 保存model

Model modelData = repositoryService.newModel()；

repositoryService.saveModel(modelData);

执行对应的SaveModelCmd。会插入或更新ACT_RE_MODEL的数据。

SaveModelCmd对应的execute方法：

public Void execute(CommandContext commandContext) {

        if (this.model == null) {

            throw new ActivitiIllegalArgumentException("model is null");

        } else {

            if (this.model.getId() == null) {

                commandContext.getModelEntityManager().insertModel(this.model);

            } else {

                commandContext.getModelEntityManager().updateModel(this.model);

            }

            return null;

        }

    }

// insert方法分发ENTITY_CREATED和ENTITY_INITIALIZED事件：

public void insertModel(Model model) {

        ((ModelEntity)model).setCreateTime(Context.getProcessEngineConfiguration().getClock().getCurrentTime());

        ((ModelEntity)model).setLastUpdateTime(Context.getProcessEngineConfiguration().getClock().getCurrentTime());

        this.getDbSqlSession().insert((PersistentObject)model);

        if (Context.getProcessEngineConfiguration().getEventDispatcher().isEnabled()) {

            Context.getProcessEngineConfiguration().getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createEntityEvent(ActivitiEventType.ENTITY_CREATED, model));

            Context.getProcessEngineConfiguration().getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createEntityEvent(ActivitiEventType.ENTITY_INITIALIZED, model));

        }

    }

 // update方法分发ENTITY_UPDATED方法：

    public void updateModel(ModelEntity updatedModel) {

        CommandContext commandContext = Context.getCommandContext();

        updatedModel.setLastUpdateTime(Context.getProcessEngineConfiguration().getClock().getCurrentTime());

        DbSqlSession dbSqlSession = commandContext.getDbSqlSession();

        dbSqlSession.update(updatedModel);

        if (Context.getProcessEngineConfiguration().getEventDispatcher().isEnabled()) {

            Context.getProcessEngineConfiguration().getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createEntityEvent(ActivitiEventType.ENTITY_UPDATED, updatedModel));

        }

    }

（三）流程发起人

identityService.setAuthenticatedUserId(user.getId());

参考:https://www.cnblogs.com/skilltalent-huan/articles/5091592.html

workFlow学习总结---------------------常用的工作流引擎

https://blog.csdn.net/liuwenbiao1203/article/details/53158254

Activiti 5.16 用户手册

http://www.mossle.com/docs/activiti/index.html#bpmnConstructs

三分钟明白 Activity工作流 -- java运用

https://blog.csdn.net/jiangyu1013/article/details/73250902

官网Quick Start Guide

https://www.activiti.org/quick-start

BPMN 2.0规范详解

https://blog.csdn.net/a123demi/article/details/50674124

码农公寓