当前位置: 首页>编程语言>正文

工作流设计思想 java 工作流java demo

一、idea安装BPM插件

二、配置pom.xml

三、开发

1、创建数据库

2、初始化表

(1)方式一:创建类去初始化表

(2)方式二:通过配置文件

(3)方式三:默认读取配置文件

3、核心API

(1)ProcessEngine

(2)RepositoryService

(3)RuntimeService

(4)TaskService

(5)HistoryService

(6)ProcessDefinition  表:act_re_procdef

(7)ProcessInstance   表:act_ru_excution

(8)Execution   表:act_ru_excution

(9)TaskInstance

4、HelloWorld程序

(1)画流程图

(2)、部署定义

(3)、启动流程

(4)、查询任务

(5)、办理任务


一、idea安装BPM插件

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_activiti,第1张

二、配置pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zctiviti</groupId>
    <artifactId>test_activiti</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- 配置版本 -->
    <properties>
        <spring.version>4.3.17.RELEASE</spring.version>
        <mysql.version>5.1.39</mysql.version>
        <!-- 注意只能使用2.0以下的版本 -->
        <activiti.version>5.22.0</activiti.version>
        <mybatis.version>3.4.6</mybatis.version>
        <!-- 注意只能使用2.0以下的版本 -->
        <log4j.version>1.2.17</log4j.version>
    </properties>

    <dependencies>
        <!-- activiti的依赖 -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-engine</artifactId>
            <version>${activiti.version}</version>
        </dependency>
        <!-- ssm集成的时候使用 -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring</artifactId>
            <version>${activiti.version}</version>
        </dependency>
        <!-- mysql驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-expression</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <!-- mybatis -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>${mybatis.version}</version>
        </dependency>
        <!-- log4j -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>${log4j.version}</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.25</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.7.25</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <!-- 配置编译的jdk版本 -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.7.0</version>
                <configuration>
                    <!-- 指定source和target的版本 -->
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

三、开发

1、创建数据库

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_bc_02,第2张

2、初始化表

(1)方式一:创建类去初始化表

@Test
private ProcessEngine initTables() {
        ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
                .setJdbcUrl("jdbc:mysql://localhost:3306/activiti?characterEncoding=UTF-8")
                .setJdbcUsername("root")
                .setJdbcPassword("123456")
                .setJdbcDriver("com.mysql.jdbc.Driver")
                .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
        return cfg.buildProcessEngine();
}
/** 
* ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE  如果数据库里面没有activit的表,也不会创建
* ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP 创建表,使用完之后删除
* ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE  如果数据库里面没有表,就创建
* dorp-create 代表如果数据库里面有表,那么先删除再创建
*/

(2)方式二:通过配置文件

activiti.cfg.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans.xsd
	http://www.springframework.org/schema/context
	http://www.springframework.org/schema/context/spring-context.xsd
	http://www.springframework.org/schema/tx
	http://www.springframework.org/schema/tx/spring-tx.xsd
	http://www.springframework.org/schema/aop
	http://www.springframework.org/schema/aop/spring-aop.xsd">
	
	
   <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
   		<property name="jdbcDriver" value="com.mysql.jdbc.Driver"></property>
   		<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activiti?characterEncoding=UTF-8"></property>
   		<property name="jdbcUsername" value="root"></property>
   		<property name="jdbcPassword" value="123456"></property>
		<!--    		
		flase: 默认值。activiti在启动时,会对比数据库表中保存的版本,如果没有表或者版本不匹配,将抛出异常。
		true: activiti会对数据库中所有表进行更新操作。如果表不存在,则自动创建。
		create_drop: 在activiti启动时创建表,在关闭时删除表(必须手动关闭引擎,才能删除表)。
		drop-create: 在activiti启动时删除原来的旧表,然后在创建新表(不需要手动关闭引擎)。 -->
   		<property name="databaseSchemaUpdate" value="drop-create"></property>
   </bean>
</beans>

读取配置文件,初始化表

@Test
public void intiTables2() {
	ProcessEngineConfiguration configuration = ProcessEngineConfiguration
				.createProcessEngineConfigurationFromResource("/activiti.cfg.xmls");
	// 得到流程引擎
	ProcessEngine processEngine = configuration.buildProcessEngine();
	System.out.println(processEngine);

}

(3)方式三:默认读取配置文件

@Test
public void intiTables3() {
	//必须创建activiti.cfg.xml  并配置好数据库的信息放在resources目录下
	ProcessEngine processEngine=ProcessEngines.getDefaultProcessEngine();
	System.out.println(processEngine);
}

3、核心API

(1)ProcessEngine

1、说明

在Activiti中最核心的类,其他的类都是由他而来。

2、获取方式

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_工作流设计思想 java_03,第3张

(2)RepositoryService

1、说明

是Activiti的仓库服务类。所谓的仓库指流程定义文档的两个文件,bpmn文件和流程图片。

2、产生方式

RepositoryService repositoryService = processEngine.getRepositoryService();

3、部署流程并定义流程部署的相关参数

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_spring_04,第4张

4、删除流程定义

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_工作流设计思想 java_05,第5张

(3)RuntimeService

activiti的流程执行服务类。可以从这个服务类中获取很多关于流程执行相关的信息。

(4)TaskService

是activiti的任务服务类。可以从这个类中获取任务的信息。

(5)HistoryService

是activiti的查询历史信息的类。在一个流程执行完成后,这个对象为我们提供查询历史信息。

(6)ProcessDefinition  表:act_re_procdef

流程定义类。可以从这里获得资源文件等。当流程图被部署之后,查询出来的数据就是流程定义的数据

(7)ProcessInstance   表:act_ru_excution

代表流程定义的执行实例

(8)Execution   表:act_ru_excution

Activiti用这个对象去描述流程执行的每一个节点。在没有并发的情况下,Execution就是同ProcessInstance。流程按照流程定义的规则执行一次的过程,就可以表示执行对象Execution。

(9)TaskInstance

任务实例

ProcessInstance、Excution图解:没有分支或没有汇合两个就是同样的东西

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_工作流设计思想 java_06,第6张

4、HelloWorld程序

(1)画流程图

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_activiti_07,第7张

工作流设计思想 java 工作流java demo,工作流设计思想 java 工作流java demo_spring_08,第8张

(2)、部署定义

@Test
public void deployProcess() {
    ProcessEngine processEngine = initTables();
    //得到流程部署的service
    RepositoryService repositoryService = processEngine.getRepositoryService();
    Deployment deploy = repositoryService.createDeployment().name("请假流程001")
            .addClasspathResource("HelloWorld.bpmn")
            .deploy();
    String deploymentId = "1";
    // 根据流程部署id删除删除流程定义 如果当前id的流程正在执行,
    // deploymentId会把正在执行的流程数据删除 act_ru_*和act_hi_*表里面的数据
    repositoryService.deleteDeployment(deploymentId, true);
    System.out.println("部署成功:流程部署ID:"+deploy.getId());
}

(3)、启动流程

@Test
public void startProcess() {
    // 启动流程
    ProcessEngine processEngine = initTables();
    RuntimeService runtimeService = processEngine.getRuntimeService();
    String processDefinitionKey="HelloWorld";
    runtimeService.startProcessInstanceByKey(processDefinitionKey);
    System.out.println("流程启动成功");
}

(4)、查询任务

@Test
public void findTask() {
    ProcessEngine processEngine = initTables();
    TaskService taskService = processEngine.getTaskService();
    String assignee="王五";
    List<Task> list = taskService.createTaskQuery().taskAssignee(assignee).list();
    if(null!=list&&list.size()>0) {
        for (Task task : list) {
            System.out.println("任务ID:"+task.getId());
            System.out.println("流程实例ID:"+task.getProcessInstanceId());
            System.out.println("执行实例ID:"+task.getExecutionId());
            System.out.println("流程定义ID:"+task.getProcessDefinitionId());
            System.out.println("任务名称:"+task.getName());
            System.out.println("任务办理人:"+task.getAssignee());
            System.out.println("################################");
        }
    }
}

(5)、办理任务

@Test
public void completeTask() {
    ProcessEngine processEngine = initTables();
    TaskService taskService = processEngine.getTaskService();
    String taskId="10002";
    taskService.complete(taskId);
    System.out.println("任务完成");
}

 


https://www.xamrdz.com/lan/5kn1941982.html

相关文章: