Java_Activiti5_菜鳥也來學Activiti5工作流_之入門簡單例子（一）

// VacationRequest.java

/**
 * author : 馮孟活 ^_^ 
 * dates : 2015年9月1日 下午10:32:58 
 * class : 演示簡單的公司請假流程
 * 
 *         一個簡單的流程分三個步驟：
 *                 1、發布流程(部署流程定義)
 *                 2、啟動流程實例
 *                 3、完成任務(先查詢任務，后完成任務)
 *                 4、掛起、激活一個流程實例(可選)
 */
public class VacationRequest {
    public static void main(String[] args) {

        /**
         *  第一步：發布流程
         */
        ProcessEngine processEngine = ProcessEngineConfiguration // 通過流程引擎配置類來創建流程引擎
                .createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService(); // 通過流程引擎來得到知識庫服務
        repositoryService.createDeployment().addClasspathResource("VacationRequest.bpmn").deploy(); // 通過只是庫部署流程定義
        System.out.println("流程定義的個數="+repositoryService.createDeploymentQuery().count()); // 查詢所有發布的流程定義的個數
        
        /**
         *  第二步：啟動一個流程實例
         */
        /*定義Map來存放流程變量：流程變量經常會被用到，因為他們賦予來自同一個流程定義的不同流程實例
           的特別含義，簡單來說，流程變量是區分流程實例的關鍵
        */
        Map<String, Object> variables = new HashMap<>(); // 定義一個Map來存放流程變量
        variables.put("employeeName","Kermit");
        variables.put("numberOfDays",new Integer(4));
        variables.put("vacationMotivation","I'm really tired!");
        RuntimeService runtimeService = processEngine.getRuntimeService(); // 獲取運行服務
        runtimeService.startProcessInstanceByKey("vacationRequest",variables); // 通過運行服務來啟動流程實例，並且設置流程變量(通過key 或者 id 部署都可以)
        System.out.println("流程實例的個數="+runtimeService.createProcessInstanceQuery().count()); // 通過運行服務來查詢所有的流程實例的個數
        
        /**
         *  第三部：完成任務
         */
        TaskService taskService = processEngine.getTaskService(); // 通過流程引擎獲取任務服務
        List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("management").list(); // 通過任務服務來查詢任務候選組(這是通過組來分區)
        for (Task task : tasks) { // 遍歷打印任務
            System.err.println("能找到的任務="+task.getName());
        }
        Task task = tasks.get(0); // 獲取第一個任務
        Map<String,Object> taskVariables = new HashMap<>(); // 定義一個Map來存放任務變量
        taskVariables.put("vacationApproved","false");
        taskVariables.put("managerMotivation","We have a tight deadline!");
        taskService.complete(task.getId(),taskVariables); // 根據Id來完成任務
        
        /**
         *  掛起，激活一個流程
         */
        /*
         * 我們可以掛起一個流程定義。當掛起流程定義時， 就不能創建新流程了（會拋出一個異常）。 
         * 可以通過RepositoryService掛起一個流程：
         */
        //repositoryService.suspendProcessDefinitionByKey("vacationRequest"); // 掛起一個流程定義
        //try{
            //runtimeService.startProcessInstanceByKey("vacationRequest"); // 啟動一個流程實例
        //}catch(ActivitiException e){ // 這里會拋出一個Activiti自定義異常
            //e.printStackTrace();
        //}
        
        /*
         * 備注下：
         *         也可以掛起一個流程實例。掛起時，流程不能繼續執行（比如，完成任務會拋出異常），
         * 異步操作（比如定時器）也不會執行。 掛起流程實例可以調用 runtimeService.suspendProcessInstance方法。 
         * 激活流程實例可以調用runtimeService.activateProcessInstanceXXX方法。
         */
    }
}

<!-- activiti.cfg.xml -->

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       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">
 
    <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="databaseSchemaUpdate" value="update"/>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db_activiti?useUnicode=true&amp;characterEncoding=utf-8"/>
        <property name="jdbcDriver" value="com.mysql.jdbc.Driver"/>
        <property name="jdbcUsername" value="root"/>
        <property name="jdbcPassword" value="root"/>
        <property name="jobExecutorActivate" value="true"/>
    </bean>
    
</beans>

<!-- VacationRequest.bpmn -->
<?xml version="1.0" encoding="UTF-8" ?>
<definitions id="definitions"
             targetNamespace="http://activiti.org/bpmn20"
             xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xmlns:activiti="http://activiti.org/bpmn">

  <process id="vacationRequest" name="Vacation request">

    <startEvent id="request" activiti:initiator="employeeName">
      <extensionElements>
        <activiti:formProperty id="numberOfDays" name="Number of days" type="long" value="1" required="true"/>
        <activiti:formProperty id="startDate" name="First day of holiday (dd-MM-yyy)" datePattern="dd-MM-yyyy hh:mm" type="date" required="true" />
        <activiti:formProperty id="vacationMotivation" name="Motivation" type="string" />
      </extensionElements>
    </startEvent>
    <sequenceFlow id="flow1" sourceRef="request" targetRef="handleRequest" />

    <userTask id="handleRequest" name="Handle vacation request" >
      <documentation>
        ${employeeName} would like to take ${numberOfDays} day(s) of vacation (Motivation: ${vacationMotivation}).
      </documentation>
      <extensionElements>
         <activiti:formProperty id="vacationApproved" name="Do you approve this vacation" type="enum" required="true">
          <activiti:value id="true" name="Approve" />
          <activiti:value id="false" name="Reject" />
        </activiti:formProperty>
        <activiti:formProperty id="managerMotivation" name="Motivation" type="string" />
      </extensionElements>
      <potentialOwner>
        <resourceAssignmentExpression>
          <formalExpression>management</formalExpression>
        </resourceAssignmentExpression>
      </potentialOwner>
    </userTask>
    <sequenceFlow id="flow2" sourceRef="handleRequest" targetRef="requestApprovedDecision" />

    <exclusiveGateway id="requestApprovedDecision" name="Request approved?" />
    <sequenceFlow id="flow3" sourceRef="requestApprovedDecision" targetRef="sendApprovalMail">
      <conditionExpression xsi:type="tFormalExpression">${vacationApproved == 'true'}</conditionExpression>
    </sequenceFlow>

    <task id="sendApprovalMail" name="Send confirmation e-mail" />
    <sequenceFlow id="flow4" sourceRef="sendApprovalMail" targetRef="theEnd1" />
    <endEvent id="theEnd1" />

    <sequenceFlow id="flow5" sourceRef="requestApprovedDecision" targetRef="adjustVacationRequestTask">
      <conditionExpression xsi:type="tFormalExpression">${vacationApproved == 'false'}</conditionExpression>
    </sequenceFlow>

    <userTask id="adjustVacationRequestTask" name="Adjust vacation request">
      <documentation>
        Your manager has disapproved your vacation request for ${numberOfDays} days.
        Reason: ${managerMotivation}
      </documentation>
      <extensionElements>
        <activiti:formProperty id="numberOfDays" name="Number of days" value="${numberOfDays}" type="long" required="true"/>
        <activiti:formProperty id="startDate" name="First day of holiday (dd-MM-yyy)" value="${startDate}" datePattern="dd-MM-yyyy hh:mm" type="date" required="true" />
        <activiti:formProperty id="vacationMotivation" name="Motivation" value="${vacationMotivation}" type="string" />
        <activiti:formProperty id="resendRequest" name="Resend vacation request to manager?" type="enum" required="true">
          <activiti:value id="true" name="Yes" />
          <activiti:value id="false" name="No" />
        </activiti:formProperty>
      </extensionElements>
      <humanPerformer>
        <resourceAssignmentExpression>
          <formalExpression>${employeeName}</formalExpression>
        </resourceAssignmentExpression>
      </humanPerformer>
    </userTask>
    <sequenceFlow id="flow6" sourceRef="adjustVacationRequestTask" targetRef="resendRequestDecision" />

    <exclusiveGateway id="resendRequestDecision" name="Resend request?" />
    <sequenceFlow id="flow7" sourceRef="resendRequestDecision" targetRef="handleRequest">
      <conditionExpression xsi:type="tFormalExpression">${resendRequest == 'true'}</conditionExpression>
    </sequenceFlow>

     <sequenceFlow id="flow8" sourceRef="resendRequestDecision" targetRef="theEnd2">
      <conditionExpression xsi:type="tFormalExpression">${resendRequest == 'false'}</conditionExpression>
    </sequenceFlow>
    <endEvent id="theEnd2" />

  </process>

</definitions>