• 创建Activiti项目


     1.创建项目

     2.导入Activiti的jar包

    项目上右击创建lib文件夹

    将jar包复制进lib文件夹

    3.导入数据库连接jar包

    4.使用代码创建Activiti用来存放流程数据的23张表

    package junit;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngineConfiguration;
    import org.junit.Test;
    
    public class TestActiviti {
        /**
         * 使用代码创建工作流需要的23张表
         */
        @Test
        public void createTable(){
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
            //连接数据库配置
            processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");
            processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf8");
            processEngineConfiguration.setJdbcUsername("root");
            processEngineConfiguration.setJdbcPassword("******");
            
            /**
              public static final String DB_SCHEMA_UPDATE_FALSE = "false";//不能自动创建表,需要表存在
              public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";//先删除表再创建表
              public static final String DB_SCHEMA_UPDATE_TRUE = "true";//如果表不存在,自动创建表
              */
            processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
            //工作流的核心对象,ProcessEngine对象
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
            System.out.println("processEngine:"+ processEngine);
        }
    }

     5.优化使用配置文件来创建工作流需要的23张表

    activiti.cfg.xml

    <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: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-2.5.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
    
        <!-- 
        ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
            //连接数据库配置
            processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");
            processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf8");
            processEngineConfiguration.setJdbcUsername("root");
            processEngineConfiguration.setJdbcPassword("******");
            
            /**
              public static final String DB_SCHEMA_UPDATE_FALSE = "false";//不能自动创建表,需要表存在
              public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";//先删除表再创建表
              public static final String DB_SCHEMA_UPDATE_TRUE = "true";//如果表不存在,自动创建表
              */
            processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
         -->
        
        <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?useUnicode=true&amp;characterEncoding=utf8"></property>
            <property name="jdbcUsername" value="root"></property>
            <property name="jdbcPassword" value="******"></property>
            <!-- 没有表创建表 -->
            <property name="databaseSchemaUpdate" value="true"></property>
        </bean>
    
    </beans>

    log4j.properties

    log4j.rootLogger=INFO, CA
    
    # ConsoleAppender
    log4j.appender.CA=org.apache.log4j.ConsoleAppender
    log4j.appender.CA.layout=org.apache.log4j.PatternLayout
    log4j.appender.CA.layout.ConversionPattern= %d{hh:mm:ss,SSS} [%t] %-5p %c %x - %m%n
    TestActiviti.java
    package junit;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngineConfiguration;
    import org.junit.Test;
    
    public class TestActiviti {
        /**
         * 使用代码创建工作流需要的23张表
         */
        @Test
        public void createTable(){
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
            //连接数据库配置
            processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");
            processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf8");
            processEngineConfiguration.setJdbcUsername("root");
            processEngineConfiguration.setJdbcPassword("******");
            
            /**
              public static final String DB_SCHEMA_UPDATE_FALSE = "false";//不能自动创建表,需要表存在
              public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";//先删除表再创建表
              public static final String DB_SCHEMA_UPDATE_TRUE = "true";//如果表不存在,自动创建表
              */
            processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
            //工作流的核心对象,ProcessEngine对象
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
            System.out.println("processEngine:"+ processEngine);
        }
        
        /*
         * 使用配置文件来创建工作流需要的23张表
         */
        @Test
        public void createTable2(){
    //        ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml");
    //        //工作流的核心对象,ProcessEngine对象
    //        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
            
            ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
            System.out.println("processEngine:"+ processEngine);
        }
    }
    
    

     6.创建流程图



     















    <?xml version="1.0" encoding="UTF-8"?>
    <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
      <process id="HelloWorld" name="HelloWorldProcess" isExecutable="true">
        <startEvent id="startevent1" name="Start"></startEvent>
        <endEvent id="endevent1" name="End"></endEvent>
        <userTask id="usertask1" name="提交申请" activiti:assignee="张三"></userTask>
        <userTask id="usertask2" name="审批【部门经理】" activiti:assignee="李四"></userTask>
        <userTask id="usertask3" name="审批【总经理】" activiti:assignee="王五"></userTask>
        <sequenceFlow id="flow2" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
        <sequenceFlow id="flow3" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow>
        <sequenceFlow id="flow4" sourceRef="usertask2" targetRef="usertask3"></sequenceFlow>
        <sequenceFlow id="flow5" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow>
      </process>
      <bpmndi:BPMNDiagram id="BPMNDiagram_HelloWorld">
        <bpmndi:BPMNPlane bpmnElement="HelloWorld" id="BPMNPlane_HelloWorld">
          <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
            <omgdc:Bounds height="35.0" width="41.0" x="20.0" y="240.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
            <omgdc:Bounds height="35.0" width="35.0" x="570.0" y="240.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">
            <omgdc:Bounds height="55.0" width="105.0" x="90.0" y="230.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">
            <omgdc:Bounds height="55.0" width="101.0" x="240.0" y="230.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="usertask3" id="BPMNShape_usertask3">
            <omgdc:Bounds height="55.0" width="111.0" x="400.0" y="230.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
            <omgdi:waypoint x="61.0" y="257.0"></omgdi:waypoint>
            <omgdi:waypoint x="90.0" y="257.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
            <omgdi:waypoint x="195.0" y="257.0"></omgdi:waypoint>
            <omgdi:waypoint x="240.0" y="257.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
            <omgdi:waypoint x="341.0" y="257.0"></omgdi:waypoint>
            <omgdi:waypoint x="400.0" y="257.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
            <omgdi:waypoint x="511.0" y="257.0"></omgdi:waypoint>
            <omgdi:waypoint x="570.0" y="257.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
        </bpmndi:BPMNPlane>
      </bpmndi:BPMNDiagram>
    </definitions>
    
    

     7.部署流程定义

    HelloWorld.java
    package com.mycom.helloWorld;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.junit.Test;
    
    public class HelloWorld {
        
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        /*
         *部署流程定义
         */
        @Test
        public void deploymentProcessDefinition(){
            Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                            .createDeployment()//创建一个部署对象
                            .name("HelloWorld入门")//添加部署名称
                            .addClasspathResource("diagrams/HelloWorld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
                            .addClasspathResource("diagrams/HelloWorld.png")
                            .deploy();//完成部署
            System.out.println(deployment.getId());
            System.out.println(deployment.getName());
            
        }
    }

    8.启动流程实例

    package com.mycom.helloWorld;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.junit.Test;
    
    public class HelloWorld {
        
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        /*
         *部署流程定义
         */
        @Test
        public void deploymentProcessDefinition(){
            Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                            .createDeployment()//创建一个部署对象
                            .name("HelloWorld入门")//添加部署名称
                            .addClasspathResource("diagrams/HelloWorld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
                            .addClasspathResource("diagrams/HelloWorld.png")
                            .deploy();//完成部署
            System.out.println("部署ID:"+deployment.getId());
            System.out.println("部署名称:"+deployment.getName());
            
        }
        
        /*
         * 启动流程实例
         */
        @Test
        public void startProcessInstance(){
            //流程定义的key
            String processDefinitionKey = "HelloWorld";
            ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                            .startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例,key对应HelloWorld.bpmn文件中的ID的属性值,使用key值启动,默认是按照最新版本的流程定义启动
                            
            System.out.println("流程实例ID:"+processInstance.getId());//流程实例ID
            System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId());//流程定义ID
            
        }
    }

    9. 查询当前人的个人任务

    package com.mycom.helloWorld;
    
    import java.util.List;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.activiti.engine.task.Task;
    import org.junit.Test;
    
    public class HelloWorld {
        
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        /*
         *部署流程定义
         */
        @Test
        public void deploymentProcessDefinition(){
            Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                            .createDeployment()//创建一个部署对象
                            .name("HelloWorld入门")//添加部署名称
                            .addClasspathResource("diagrams/HelloWorld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
                            .addClasspathResource("diagrams/HelloWorld.png")
                            .deploy();//完成部署
            System.out.println("部署ID:"+deployment.getId());
            System.out.println("部署名称:"+deployment.getName());
            
        }
        
        /*
         * 启动流程实例
         */
        @Test
        public void startProcessInstance(){
            //流程定义的key
            String processDefinitionKey = "HelloWorld";
            ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                            .startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例,key对应HelloWorld.bpmn文件中的ID的属性值,使用key值启动,默认是按照最新版本的流程定义启动
                            
            System.out.println("流程实例ID:"+processInstance.getId());//流程实例ID
            System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId());//流程定义ID
            
        }
        
        /*
         * 查询当前人的个人任务
         */
        @Test
        public void findMyPersonalTask(){
            String assignee = "张三";
            List<Task> list = processEngine.getTaskService()//与正在执行任务相关的Service
                            .createTaskQuery()//创建任务查询对象
                            .taskAssignee(assignee)//指定个人任务查询,指定办理人
                            .list();
            
            if(list!=null && list.size()>0){
                for(Task task:list){
                    System.out.println("任务ID:"+task.getId());
                    System.out.println("任务名称:"+task.getName());
                    System.out.println("任务创建时间:"+task.getCreateTime());
                    System.out.println("任务办理人:"+task.getAssignee());
                    System.out.println("流程实例ID:"+task.getProcessInstanceId());
                    System.out.println("执行对象ID:"+task.getExecutionId());
                    System.out.println("流程定义ID:"+task.getProcessDefinitionId());
                }
            }
        }
    }

     

    10.完成我的任务

    package com.mycom.helloWorld;
    
    import java.util.List;
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.activiti.engine.task.Task;
    import org.junit.Test;
    
    public class HelloWorld {
        
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        /*
         *部署流程定义
         */
        @Test
        public void deploymentProcessDefinition(){
            Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                            .createDeployment()//创建一个部署对象
                            .name("HelloWorld入门")//添加部署名称
                            .addClasspathResource("diagrams/HelloWorld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
                            .addClasspathResource("diagrams/HelloWorld.png")
                            .deploy();//完成部署
            System.out.println("部署ID:"+deployment.getId());
            System.out.println("部署名称:"+deployment.getName());
            
        }
        
        /*
         * 启动流程实例
         */
        @Test
        public void startProcessInstance(){
            //流程定义的key
            String processDefinitionKey = "HelloWorld";
            ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                            .startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例,key对应HelloWorld.bpmn文件中的ID的属性值,使用key值启动,默认是按照最新版本的流程定义启动
                            
            System.out.println("流程实例ID:"+processInstance.getId());//流程实例ID
            System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId());//流程定义ID
            
        }
        
        /*
         * 查询当前人的个人任务
         */
        @Test
        public void findMyPersonalTask(){
            String assignee = "张三";
            List<Task> list = processEngine.getTaskService()//与正在执行任务相关的Service
                            .createTaskQuery()//创建任务查询对象
                            .taskAssignee(assignee)//指定个人任务查询,指定办理人
                            .list();
            
            if(list!=null && list.size()>0){
                for(Task task:list){
                    System.out.println("任务ID:"+task.getId());
                    System.out.println("任务名称:"+task.getName());
                    System.out.println("任务创建时间:"+task.getCreateTime());
                    System.out.println("任务办理人:"+task.getAssignee());
                    System.out.println("流程实例ID:"+task.getProcessInstanceId());
                    System.out.println("执行对象ID:"+task.getExecutionId());
                    System.out.println("流程定义ID:"+task.getProcessDefinitionId());
                }
            }
        }
        
        /*
         * 完成我的任务
         */
        @Test
        public void completeMyPersonalTask(){
            //任务Id
            String taskId = "104";
            processEngine.getTaskService()//与正在执行任务相关的Service
                            .complete(taskId);
            System.out.println("完成任务:任务Id:"+taskId);
            
        }
        
        
        
    }
  • 相关阅读:
    TensorFlow 用神经网络解决非线性问题
    找第一个只出现一次的字符
    scanf("%[^ ]",str)
    求第n个质数
    得到任意数字的各个数位
    Tensorflow 对上一节神经网络模型的优化
    Tensorflow 安装 和 初识
    算法竞赛入门 (一)语言篇 数组和字符串 2
    char* a = "abc" 和 char a[] = "abc" 之间的区别
    Python实现英文文章加密传送,收到后进行解密
  • 原文地址:https://www.cnblogs.com/mingforyou/p/5347789.html
走看看 - 开发者的网上家园