【工作流】jbpm（三）——开发流程

系统管理员 2022-06-13 22:10 624阅读 0赞

# 一、前言 #

在上一篇博客中，小编向大家介绍了jbpm的环境搭建以及一些服务，的确这些服务我们确实经常使用。所以在这篇博客小编就正式带大家走进jbpm，通过一个实战Demo来领略一下。

# 二、开发步骤 #

*  业务分析，画流程图
 *  开发人员，根据活动图建立jpdl流程定义
 *  开发人员，编写代码
 *  用户，发起流程实例
 *  用户，审批流程

# 三、开发Demo #

## 3.1 流程定义文件和配置文件 ##

![这里写图片描述][SouthEast]

在src目录下面建立Jbpm，new –> JBPM4 Process Definition，建立如下的流程图：

![这里写图片描述][SouthEast 1]

<?xml version="1.0" encoding="UTF-8"?>
    
    <process name="qingjia" key="test" xmlns="http://jbpm.org/4.4/jpdl">
       <start name="start1" g="263,53,48,48">
          <transition name="to 申请请假" to="申请请假" g="-46,-20"/>
       </start>
       <end name="end1" g="272,351,48,48"/>
       <task assignee="张三" name="申请请假" g="205,143,92,52">
          <transition name="to 部门经理审批" to="部门经理审批" g="-46,-20"/>
       </task>
       <task assignee="李四" name="部门经理审批" g="333,251,92,52">
          <transition name="to 总经理审批" to="总经理审批" g="-45,-20"/>
       </task>
       <task assignee="王五" name="总经理审批" g="491,308,92,52">
          <transition name="to end1" to="end1" g="-45,-20"/>
       </task>
    </process>

jbpm.cfg.xml：

<?xml version="1.0" encoding="UTF-8"?>
    
    <jbpm-configuration>
    
      <import resource="jbpm.default.cfg.xml" />
      <import resource="jbpm.businesscalendar.cfg.xml" />
      <import resource="jbpm.tx.hibernate.cfg.xml" />
      <import resource="jbpm.jpdl.cfg.xml" />
      <import resource="jbpm.bpmn.cfg.xml" />
      <import resource="jbpm.identity.cfg.xml" />
    
      
      
      
    
    </jbpm-configuration>

jbpm.hibernate.cfg.xml：

<?xml version="1.0" encoding="utf-8"?>
    
    <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
    
    <hibernate-configuration>
    <session-factory>
        <property name="hibernate.connection.driver_class">
            com.mysql.jdbc.Driver
        </property>
        <property name="hibernate.connection.url">
            jdbc:mysql://localhost:3306/jbpmnew
        </property>
        <property name="connectio.useUnicode">true</property>
        <property name="connection.characterEncoding">utf-8</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">123456</property>
        <property name="hibernate.dialect">
            org.hibernate.dialect.MySQLDialect
        </property>
        <property name="hibernate.show_sql">true</property>
        <property name="hibernate.hbm2ddl.auto">update</property>
    
         <mapping resource="jbpm.repository.hbm.xml" />
         <mapping resource="jbpm.execution.hbm.xml" />
         <mapping resource="jbpm.history.hbm.xml" />
         <mapping resource="jbpm.task.hbm.xml" />
         <mapping resource="jbpm.identity.hbm.xml" />
    
      </session-factory>
    </hibernate-configuration>

logging.properties：

handlers= java.util.logging.ConsoleHandler
    redirect.commons.logging = enabled
    
    java.util.logging.ConsoleHandler.level = FINEST
    java.util.logging.ConsoleHandler.formatter = org.jbpm.internal.log.LogFormatter
    
    org.jbpm.level=FINE
    # org.jbpm.pvm.internal.tx.level=FINE
    # org.jbpm.pvm.internal.wire.level=FINE
    # org.jbpm.pvm.internal.util.level=FINE
    
    org.hibernate.level=INFO
    org.hibernate.cfg.SettingsFactory.level=SEVERE
    org.hibernate.cfg.HbmBinder.level=SEVERE
    org.hibernate.SQL.level=FINEST
    org.hibernate.type.level=FINEST
    # org.hibernate.tool.hbm2ddl.SchemaExport.level=FINEST
    # org.hibernate.transaction.level=FINEST

建立服务类JbpmService：专门提供服务。

package com.dmsd.jbpm;
    
    import org.jbpm.api.Configuration;
    import org.jbpm.api.ExecutionService;
    import org.jbpm.api.HistoryService;
    import org.jbpm.api.IdentityService;
    import org.jbpm.api.ManagementService;
    import org.jbpm.api.ProcessEngine;
    import org.jbpm.api.RepositoryService;
    import org.jbpm.api.TaskService;
    
    public class JbpmService { 
        protected RepositoryService repositoryService; // 部署流程服务
    
        protected ExecutionService executionService; //流程执行服务
    
        protected TaskService taskService; //任务服务
    
        protected HistoryService historyService; //历史服务
    
        protected ManagementService managementService; //流程管理服务
    
        protected IdentityService identityService; //身份认证
    
    
        protected void setup() {
            ProcessEngine processEngine = Configuration.getProcessEngine();
            this.repositoryService=processEngine.getRepositoryService();
            this.executionService = processEngine.getExecutionService();
            this.taskService =processEngine.getTaskService();
            this.historyService=processEngine.getHistoryService();
            this.managementService =processEngine.getManagementService();
            this.identityService =processEngine.getIdentityService();
        }
    }

## 3.2 部署 ##

/** * 部署 */
        @Override
        @Test
        public void deploy() {
            //获取服务
            super.setup();
            //根据文件路径进行部署
            repositoryService.createDeployment().addResourceFromClasspath("qingjia.jpdl.xml").deploy();
        }

## 3.3 创建流程实例 ##

/** * 创建流程实例 */
        @Override
        @Test
        public void createInstance() {
            //获取服务
            super.setup();
            Map<String, Object> testMap = new HashMap<String, Object>();
            testMap.put("userId", "001");
            testMap.put("userName", "tom");
            //创建流程实例
            ProcessInstance processInstance =executionService.startProcessInstanceByKey("test",testMap );
            System.out.println("流程实例ID============"+processInstance.getId() );
    
        }

## 3.4 查看所在节点 ##

根据流程实例ID,获取流程实例（唯一值），再得到活动节点名称（当前节点）。

/** * 查询流程当前所在节点 */
        @Override
        public void getCurrectActivity() {
            //获取服务
            super.setup();
            String activityName = executionService.createProcessInstanceQuery().processInstanceId("test.10001").uniqueResult().findActiveActivityNames().toString();
            System.out.println("当前任务所在节点===" + activityName);
    
        }

## 3.5 获取任务 ##

/** * 获取任务 */
        @Override
        public void getTask() {
            //获取服务
            super.setup();
            List<Task> tasks = taskService.findPersonalTasks("张三");
            Task task = tasks.get(0);
            System.out.println("任务数量============="+tasks.size());
            System.out.println("任务名称==============="+ task.getActivityName());
            System.out.println("任务人员==============="+task.getAssignee()+"任务id=========="+task.getId());
        }

## 3.6 完成任务 ##

/** * 完成任务 */
        @Override
        public void completeTask() {
            //获取服务
            super.setup();
            //根据任务id完成任务
            taskService.completeTask("10004");
        }

# 四、小结 #

通过对jbpm的学习，熟悉了整个的流程，发现其中的API真是不少，所以以后还是要多多的练习的， 套路很固定，就看自己如何发挥了。

下一篇博客将向大家一一解释jbpm中的各个节点。

[SouthEast]: /images/20220614/28a82efa46ce4eff99bf8c2d6ad9fc30.png
[SouthEast 1]: /images/20220614/1ba999eec74544bbb61b07cd96ac4e24.png