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

 

log4j.properties

log4j.rootLogger=INFO, CA# ConsoleAppenderlog4j.appender.CA=org.apache.log4j.ConsoleAppenderlog4j.appender.CA.layout=org.apache.log4j.PatternLayoutlog4j.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.创建流程图

 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
     
       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
     
       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);            }            }