activity(工作流）初步学习记录

@Test
    public  void test() {
        //1.创建Activity配置对象的实例
        ProcessEngineConfiguration configuration  = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
        //2.设置数据库连接信息
        //设置数据库地址
        configuration.setJdbcUrl("jdbc:mysql://localhost:3306/activity?createDatabaseIfNotExist=true");
        //数据库驱动
        configuration.setJdbcDriver("com.mysql.jdbc.Driver");
        //用户名
        configuration.setJdbcUsername("root");
        //密码
        configuration.setJdbcPassword("");
        //设置数据建表策略
        /**
         *DB_SCHEMA_UPDATE_TRUE 如果不存在表就创建表，存在表就使用
         */
        configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
        //3.使用配置对象创建流程引擎实例（检查数据库等连接环境）
        ProcessEngine processEngine = configuration.buildProcessEngine();
        System.out.println(processEngine);
    }

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:jee="http://www.springframework.org/schema/jee" xmlns:aop="http://www.springframework.org/schema/aop"
  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
       http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd
       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.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/activity2"></property>
        <property name="jdbcUsername" value="root"></property>
        <property name="jdbcPassword" value=""></property>
        <!--建表策略-->
        <property name="databaseSchemaUpdate" value="true"></property>
    </bean>
  
</beans>

/**
     * 使用配置文件
     */
    @Test
    public void test2() throws Exception{
        ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
        System.out.println(processEngine);
    }

//调用引擎,初始化
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    /**
     * 部署流程定义
     */
    @Test
    public void deployment() {
        Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的Service
                .createDeployment()//创建一个部署对象
                .name("helloword")//添加部署的名称
                .addClasspathResource("diagrams/helloword.bpmn")//从classpath下加载资源，一次一个
                .addClasspathResource("diagrams/helloword.png")
                .deploy();//完成部署
            System.out.println("部署ID"+deployment.getId());//1
            System.out.println("部署名称"+deployment.getName());
    }
    
    /**
     *启动流程实例
     */
    @Test
    public void startProcessInstance() {
        String processDefinitionKey = "helloword";
        ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                .startProcessInstanceByKey(processDefinitionKey);//根据Key值来查询流程,也可以根据ID
        System.out.println("流程实例ID:"+processInstance.getId());  //2501
                                                                    //对应数据库act_ru_execution
        System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId()); //helloword:1:4
                                                                                //对应数据库act_re_deployment
    }
    
    /**
     * 查询当前个人的任务
     */
    @Test
    public void fingByPerson() {
        String assignee = "张三";
        List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service
                .createTaskQuery()//创建任务查询对象
                .taskAssignee(assignee)//指定个人任务查询，指定代理人
                .list();//以list形式记录对象
        if(list != null && list.size()>0) {
            for(Task task:list) {
                System.out.println("任务ID:"+task.getId());//2501
                System.out.println("任务名称："+task.getName());//提交申请
                System.out.println("任务的创建时间："+task.getCreateTime());//Wed Jun 06 18:12:15 CST 2018
                System.out.println("任务的代理人："+task.getAssignee());//张三
                System.out.println("流程实例ID："+task.getProcessInstanceId());//2501
                System.out.println("执行对象ID："+task.getExecutionId());//2501
                System.out.println("流程定义ID："+task.getProcessDefinitionId());//helloword:1:4
            }
        }
    }
    
    /**
     * 完成个人任务
     */
    @Test
    public void complete() {
        String taskId = "2504";
        processEngine.getTaskService()
            .complete(taskId );
        System.out.println("完成任务ID："+taskId);
    }