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