java 工作流

BPM是jboss旗下遵守LGPL许可的java开源工作流，功能比较完善，从4.0开始引入了pvm的概念，支持jPDL、BPEL等流程定义语言。由于相关资料还比较少，开发自己的一个demo还不是太容易，本文详细讲解如何做一个简单的demo程序。

    我们从http://www.jboss.org/jbossjbpm/jbpm_downloads/下载jBPM，实际使用时发现4.0.CR1和4.1版本各有一些问题，此处把这两个版本都下载下来。开发使用4.1版本，Eclipse插件GPD（图形化设计流程）使用4.0.CR1版本的，tomcat使用6.0.18版本的，jdk要求5.0及以上，Eclipse使用eclipse-jee-galileo-win32版本的。

    下载包里面有自带的一个example，根据jBMP的文档可以部署，但这个example把工作流部分封装为RESTful Web Service，学习起来有一定难度，看了会让人一头雾水，此处就不讲了。以下讲述如何把jBPM嵌入到应用系统中去。

    1、在Eclipse中安装GPD。

    把%jbpm-4.0.CR1_HOME%/gpd下的jbpm-gpd-site.zip安装到Eclipse中，熟悉Eclipse的知道安装方法，在jBPM的文档中也有介绍。

    2、在Eclipse中建立一个动态网站的项目jBPMDemo，复制必要的jar文件到WEB-INF/lib下面。

    把%jbpm-4.1_HOME%/lib下的所有jar文件、%jbpm-4.1_HOME%/jbpm.jar复制过去。

    但juel.jar中javax/el中的类与tomcat中的有冲突，把juel.jar中的javax/el删除。

    3、配置mysql数据库。

    在mysql数据库中建立一个名为jbpmdb的数据库，在里面执行%jbpm-4.1_HOME%/install/src/db/jbpm.mysql.create.sql建立jbpm所需的数据库表。

    另外建立一个表存放业务数据：

create table ask_for_leave ( 
id MEDIUMINT NOT NULL AUTO_INCREMENT primary key, 
apply_user varchar(50), -- 申请人 
apply_time timestamp default now(), -- 申请时间 
begin_leave_time timestamp, -- 假期开始时间 
end_leave_time timestamp, -- 假期结束时间 
leave_reason varchar(500), -- 请假理由 
approve_user varchar(50), -- 审批人 
approve_time timestamp, -- 审批时间 
is_passed smallint, -- 是否同意，1 同意，2 驳回 
approve_remark varchar(500), -- 审批备注，如驳回的原因 
back_time timestamp -- 销假时间 
);

    4、配置JOTM事务支持。

    把carol.properties、jta.jar、commons-logging.jar、carol.jar、connector-1_5.jar、jotm.jar、jotm_jrmp_stubs.jar、jts1_0.jar、mysql-connector-java-3.1.11-bin.jar、objectweb-datasource.jar、xapool.jar放到%tomcat_home%/lib下面。

    把howl.jar、jotm.jar、objectweb-datasource.jar、ow_carol.jar、xapool.jar放到WEB-INF/lib下面。

    在jBPLDemo的context配置数据源，代码如下：

<?xml version='1.0' encoding='utf-8'?> 
<Context displayName="jBPMDemo" 
         docBase="${catalina.base}/webapps/jBPMDemo"  
         path="/jBPMDemo"  
         workDir="work/Catalina/localhost/jBPMDemo" reloadable="true"> 
          
   <Resource name="UserTransaction" 
      auth="Container" 
      type="javax.transaction.UserTransaction" 
      factory="org.objectweb.jotm.UserTransactionFactory" 
      jotm.timeout="180" /> 

   <Resource name="JbpmDS" type="javax.sql.DataSource" 
      factory="org.objectweb.jndi.DataSourceFactory" 
      maxWait="5000" 
      maxActive="300" 
      maxIdle="2" 
      username="root" 
      password="" 
      driverClassName="com.mysql.jdbc.Driver" 
      url="jdbc:mysql://127.0.0.1:3306/jbpmdb" 
   />      
        
</Context>

    在应用的WEB-INF/classes下建立文件jbpm.cfg.xml，内容如下：

<?xml version="1.0" encoding="UTF-8"?> 

<jbpm-configuration> 

  <import resource="jbpm.default.cfg.xml" /> 
  <import resource="jbpm.tx.hibernate.cfg.xml" /> 
  <import resource="jbpm.jpdl.cfg.xml" /> 
  <import resource="jbpm.identity.cfg.xml" /> 
  <import resource="jbpm.businesscalendar.cfg.xml" /> 
  <import resource="jbpm.jobexecutor.cfg.xml" /> 

</jbpm-configuration>

    在应用的WEB-INF/classes下建立文件jbpm.hibernate.cfg.xml，内容如下：

<?xml version="1.0" encoding="utf-8"?> 

<!DOCTYPE hibernate-configuration PUBLIC 
          "-//Hibernate/Hibernate Configuration DTD 3.0//EN" 
          "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> 

<hibernate-configuration> 
<session-factory> 

<property name="hibernate.dialect">org.hibernate.dialect.MySQLInnoDBDialect</property> 
<property name="hibernate.connection.datasource">java:comp/env/JbpmDS</property> 
<property name="hibernate.transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</property> 
<property name="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.JOTMTransactionManagerLookup</property>
<property name="jta.UserTransaction">java:comp/env/UserTransaction</property> 

<mapping resource="jbpm.repository.hbm.xml" /> 
<mapping resource="jbpm.execution.hbm.xml" /> 
<mapping resource="jbpm.history.hbm.xml" /> 
<mapping resource="jbpm.task.hbm.xml" /> 
<mapping resource="jbpm.identity.hbm.xml" /> 

</session-factory> 
</hibernate-configuration>

    5、在Eclipse中GPD定义流程。

    GPD对中文的支持还有问题，要用图形界面与直接编写代码相结合的方式，最后效果如下图：

流程图

    产生的代码askForLeave.jpdl.xml放到应用的WEN-INF/classes/jpdl下面，代码如下：

<?xml version="1.0" encoding="UTF-8"?> 

<process key="askForLeave" name="请假流程" version="1" xmlns="http://jbpm.org/4.0/jpdl"> 
   <swimlane candidate-groups="manager" name="manager"/> 
   <start g="188,10,48,48" name="start1"> 
      <transition g="-30,-10" name="开始" to="填写请假申请"/> 
   </start> 
   <task assignee="#{owner}" g="167,86,92,52" name="填写请假申请"> 
      <transition g="-50,-11" name="提交审批" to="审批"/> 
   </task> 
   <task g="169,159,92,52" name="审批" swimlane="manager"> 
      <transition g="-76,-8" name="判断审批结果" to="exclusive1"/> 
   </task> 
   <task assignee="#{owner}" g="91,298,92,52" name="销假"> 
      <transition g="-50,-11" name="休假结束" to="end1"/> 
   </task> 
   <task assignee="#{owner}" g="252,295,92,52" name="查看原因"> 
      <transition g="-34,-10" name="请假结束" to="end2"/> 
   </task> 
   <end g="116,377,48,48" name="end1"/> 
   <end g="275,372,48,48" name="end2"/> 
   <decision g="190,227,48,48" name="exclusive1"> 
      <transition g="0,-15" name="拒绝" to="查看原因"> 
        <condition expr="#{is_passed==false}"/> 
      </transition> 
      <transition g="-31,-16" name="通过" to="销假"/> 
   </decision> 
</process>

    产生的图片askForLeave.png放到应用的askForLeave文件夹下面。

    6、建立几个java类。

demo.jbpm.DBUtil：

package demo.jbpm; 

import java.sql.Connection; 

import javax.naming.InitialContext; 
import javax.sql.DataSource; 

import javax.transaction.UserTransaction; 

public class DBUtil { 
    private static DataSource ds; 
    /** 
     * 获取数据源 
     * @return 
     * @throws Exception 
     */ 
    public static DataSource getDS() throws Exception { 
        if (ds == null) ds = (DataSource) new InitialContext().lookup("java:comp/env/JbpmDS"); 
        return ds; 
    } 
     
    /** 
     * 获取数据库连接 
     * @return 
     * @throws Exception 
     */ 
    public static Connection getConn() throws Exception { 
        return getDS().getConnection(); 
    } 
     
    /** 
     * 获取事务UserTransaction 
     * @return 
     * @throws Exception 
     */ 
    public static UserTransaction getUserTransaction() throws Exception { 
        UserTransaction ut = (UserTransaction) new InitialContext().lookup("java:comp/env/UserTransaction"); 
        return ut; 
    } 
}

    demo.jbpm.JBPMUtil.java：

package demo.jbpm; 

import org.jbpm.api.Configuration; 
import org.jbpm.api.ExecutionService; 
import org.jbpm.api.IdentityService; 
import org.jbpm.api.ProcessEngine; 
import org.jbpm.api.RepositoryService; 
import org.jbpm.api.TaskService; 

public class JBPMUtil { 
    private static ProcessEngine pe; 
    private static RepositoryService repositoryService; 
    private static ExecutionService executionService; 
    private static IdentityService identityService; 
    private static TaskService taskService; 
     
    public static void deploy(String jdplPath) { 
        String deployId = getRepositoryService().createDeployment().addResourceFromClasspath(jdplPath).deploy(); 
        System.out.println("----------deploy id:" + deployId); 
    } 
     
    public static ProcessEngine getProcessEngine() { 
        if (pe == null) { 
            Configuration config = new Configuration(); 
            pe = config.buildProcessEngine(); 
        } 
        return pe; 
    } 
     
    public static RepositoryService getRepositoryService() { 
        if (repositoryService == null) repositoryService = getProcessEngine().getRepositoryService(); 
        return repositoryService; 
    } 
     
    public static ExecutionService getExecutionService() { 
        if (executionService == null) executionService = getProcessEngine().getExecutionService(); 
        return executionService; 
    } 
     
    public static IdentityService getIdentityService() { 
        if (identityService == null) identityService = getProcessEngine().getIdentityService(); 
        return identityService; 
    } 
     
    public static TaskService getTaskService() { 
        if (taskService == null) taskService = getProcessEngine().getTaskService(); 
        return taskService; 
    } 
}

    demo.jbpm.AskForLeave.java：

package demo.jbpm; 

import java.sql.Connection; 
import java.sql.ResultSet; 
import java.sql.Statement; 
import java.util.ArrayList; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
import java.util.Set; 

import javax.servlet.http.HttpServletRequest; 
import javax.transaction.Status; 
import javax.transaction.UserTransaction; 

import org.jbpm.api.ProcessDefinition; 
import org.jbpm.api.ProcessInstance; 
import org.jbpm.api.model.ActivityCoordinates; 
import org.jbpm.api.task.Task; 

public class AskForLeave { 
    private final static String employeeName = "王三"; 
    private final static String managerName = "李五"; 
     
    public static void deploy() { 
        JBPMUtil.deploy("jpdl/askForLeave.jpdl.xml"); 
        JBPMUtil.getIdentityService().createUser(employeeName, "王", "三"); 
        JBPMUtil.getIdentityService().createUser(managerName, "李", "五"); 
        JBPMUtil.getIdentityService().createGroup("manager"); 
        JBPMUtil.getIdentityService().createMembership(managerName, "manager"); 
    } 
     
    /** 
     * 请假申请 
     * @param request 
     * @throws Exception 
     */ 
    public static void apply(HttpServletRequest request) throws Exception { 
        UserTransaction ut =DBUtil.getUserTransaction(); 
        Connection conn = DBUtil.getConn(); 
        boolean rollback = false; 
        try { 
            ut.begin(); 
            //*********业务部分 
            //请假申请存入数据库 
            Statement stmt = conn.createStatement(); 
            String sql = "insert into ask_for_leave(apply_user," + 
                  "begin_leave_time,end_leave_time,leave_reason) values(" + 
                  "'" + request.getParameter("apply_user") + "'," + 
                  "'" + request.getParameter("begin_leave_time") + "'," + 
                  "'" + request.getParameter("end_leave_time") + "'," + 
                  "'" + request.getParameter("leave_reason") + "')"; 
            System.out.println("insert:" + sql); 
            stmt.executeUpdate(sql, Statement.RETURN_GENERATED_KEYS); 
            ResultSet rs = stmt.getGeneratedKeys(); 
            int id = 0; 
            if (rs.next()) id = rs.getInt(1); 
            System.out.println("--------------id:" + id); 
             
             
            //*********工作流部分 
            //新建工作流实例 
            Map var = new HashMap(); 
            var.put("owner", employeeName); 
            var.put("biz_id", id); 
            ProcessInstance processInstance = JBPMUtil.getExecutionService().startProcessInstanceByKey("askForLeave", var);
             
            //执行动作 
            List<Task> tasks = JBPMUtil.getTaskService().findPersonalTasks(employeeName); 
            for (Task t : tasks) { 
                if (processInstance.getId().equals(JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getId())
                        && t.getActivityName().equals("填写请假申请")) { 
                     
                    JBPMUtil.getTaskService().completeTask(t.getId()); 
                } 
                 
            } 
        } 
        catch (Exception e) { 
            rollback = true; 
            e.printStackTrace(); 
            throw e; 
        } 
        finally { 
            if (ut != null && ut.getStatus() != Status.STATUS_NO_TRANSACTION) { 
                if (rollback) ut.rollback(); 
                else ut.commit(); 
            } 
             
            if (conn != null) conn.close(); 
        } 
    } 
     
    /** 
     * 获取经理的工作列表 
     * @return 
     * @throws Exception 
     */ 
    public static List<Map> getManagerWorkList() throws Exception { 
        List<Map> workList = new ArrayList<Map>(); 
        List<Task> tasks = JBPMUtil.getTaskService().findGroupTasks(managerName); 
        System.out.println("---------task count:" + tasks.size()); 
        for (Task t : tasks) { 
            String processDefinitionId = JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getProcessDefinitionId();
            ProcessDefinition processDefinition = JBPMUtil.getRepositoryService().createProcessDefinitionQuery().processDefinitionId(processDefinitionId).uniqueResult();
            System.out.println("---------pro name:" + JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getProcessDefinitionId());
            System.out.println("---------acct name:" + t.getActivityName()); 
            if ("请假流程".equals(processDefinition.getName()) 
                    && t.getActivityName().equals("审批")) { 
                Map item = new HashMap(); 
                item.put("wfId", JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getId());
                item.put("wfName", "请假流程"); 
                item.put("taskId", t.getId()); 
                item.put("taskName", t.getActivityName()); 
                workList.add(item); 
            } 
        } 
        return workList; 
    } 
     
    /** 
     * 获取位置 
     * @param wfId 
     * @return 
     */ 
    public static List<ActivityCoordinates> getActiveActivityCoordinates(String wfId) { 
        List<ActivityCoordinates> result = new ArrayList<ActivityCoordinates>(); 
        ProcessInstance processInstance = JBPMUtil.getExecutionService().findProcessInstanceById(wfId); 
        String processDefinitionId = processInstance.getProcessDefinitionId(); 
        Set<String> activities = processInstance.findActiveActivityNames(); 
        for (String act : activities) { 
            ActivityCoordinates coor = JBPMUtil.getRepositoryService().getActivityCoordinates(processDefinitionId, act); 
            result.add(coor); 
        } 
         
        return result; 
    } 
     
    /** 
     * 根据请假单id获取请假单信息 
     * @param id 
     * @return 
     * @throws Exception 
     */ 
    public static Map getById(String id) throws Exception { 
        Map form = new HashMap(); 
        Connection conn = DBUtil.getConn(); 
         
        try { 
            Statement stmt = conn.createStatement(); 
            ResultSet rst = stmt.executeQuery("select * from ask_for_leave where id=" + id); 
            if (rst.next()) { 
                form.put("apply_user", rst.getString("apply_user")); 
                form.put("begin_leave_time", rst.getString("begin_leave_time")); 
                form.put("end_leave_time", rst.getString("end_leave_time")); 
                form.put("leave_reason", rst.getString("leave_reason")); 
            } 
            rst.close(); 
            stmt.close(); 
        } 
        catch (Exception e) { 
            e.printStackTrace(); 
            throw e; 
        } 
        finally { 
             
            if (conn != null) conn.close(); 
        } 
         
        return form; 
    } 
     
    /** 
     * 根据工作流id货物请假单id 
     * @param wfId 
     * @return 
     * @throws Exception 
     */ 
    public static String getBizId(String taskId) throws Exception { 
         
        return JBPMUtil.getTaskService().getVariable(taskId, "biz_id").toString(); 
    } 
     
    /** 
     * 审批 
     * @param request 
     * @throws Exception 
     */ 
    public static void approval(HttpServletRequest request) throws Exception { 
        UserTransaction ut = DBUtil.getUserTransaction(); 
        Connection conn = DBUtil.getConn(); 
        boolean rollback = false; 
        try { 
            ut.begin(); 
             
            //*********业务部分 
            //审批信息存入数据库 
            Statement stmt = conn.createStatement(); 
            String sql = "update ask_for_leave set " + 
                  "approve_user='" + managerName + "', " + 
                  "approve_time=now()," + 
                  "is_passed=" + request.getParameter("is_passed") + "," + 
                  "approve_remark='" + request.getParameter("approve_remark") + "' " + 
                  "where id=" + request.getParameter("biz_id"); 
            System.out.println("--------------update:" + sql); 
            stmt.executeUpdate(sql); 
            System.out.println("--------------update complete"); 
             
            //*********工作流部分 
            boolean isPassed = false; 
            if ("1".equals(request.getParameter("is_passed"))) isPassed = true; 
            Map var = new HashMap(); 
            var.put("is_passed", isPassed); 
            JBPMUtil.getTaskService().completeTask(request.getParameter("taskId"), var); 
        } 
        catch (Exception e) { 
            rollback = true; 
            e.printStackTrace(); 
            throw e; 
        } 
        finally { 
            if (ut != null && ut.getStatus() != Status.STATUS_NO_TRANSACTION) { 
                if (rollback) ut.rollback(); 
                else ut.commit(); 
            } 
             
            if (conn != null) conn.close(); 
        } 
    } 
     
    /** 
     * 获取员工的工作列表 
     * @return 
     * @throws Exception 
     */ 
    public static List<Map> getEmployeeWorkList() throws Exception { 
        List<Map> workList = new ArrayList<Map>(); 
        List<Task> tasks = JBPMUtil.getTaskService().findPersonalTasks(employeeName); 
        System.out.println("---------task count:" + tasks.size()); 
        for (Task t : tasks) { 
            String processDefinitionId = JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getProcessDefinitionId();
            ProcessDefinition processDefinition = JBPMUtil.getRepositoryService().createProcessDefinitionQuery().processDefinitionId(processDefinitionId).uniqueResult();
            System.out.println("---------pro name:" + JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getProcessDefinitionId());
            System.out.println("---------acct name:" + t.getActivityName()); 
            if ("请假流程".equals(processDefinition.getName())) { 
                Map item = new HashMap(); 
                item.put("wfId", JBPMUtil.getExecutionService().findExecutionById(t.getExecutionId()).getProcessInstance().getId());
                item.put("wfName", "请假流程"); 
                item.put("taskId", t.getId()); 
                item.put("taskName", t.getActivityName()); 
                item.put("biz_id", JBPMUtil.getTaskService().getVariable(t.getId(), "biz_id")); 
                workList.add(item); 
            } 
        } 
        return workList; 
    } 
     
    /** 
     * 申请人处理审批后的事务 
     * @param request 
     * @throws Exception 
     */ 
    public static void leave(HttpServletRequest request) throws Exception { 
        UserTransaction ut = DBUtil.getUserTransaction(); 
        Connection conn = DBUtil.getConn(); 
        boolean rollback = false; 
        try { 
            ut.begin(); 
            //处理休假情况 
            boolean isPassed = (Boolean) JBPMUtil.getTaskService().getVariable(request.getParameter("taskId"), "is_passed");
            int bizId = (Integer) JBPMUtil.getTaskService().getVariable(request.getParameter("taskId"), "biz_id"); 
            if (isPassed) { 
                Statement stmt = conn.createStatement(); 
                String sql = "update ask_for_leave set " + 
                      "back_time=now() " + 
                      "where id=" + bizId; 
                System.out.println("--------------update:" + sql); 
                stmt.executeUpdate(sql); 
            } 
             
            //*********工作流部分 
            JBPMUtil.getTaskService().completeTask(request.getParameter("taskId")); 
        } 
        catch (Exception e) { 
            rollback = true; 
            e.printStackTrace(); 
            throw e; 
        } 
        finally { 
            if (ut != null && ut.getStatus() != Status.STATUS_NO_TRANSACTION) { 
                if (rollback) ut.rollback(); 
                else ut.commit(); 
            } 
             
            if (conn != null) conn.close(); 
        } 
    } 
}

    7、建立jsp文件。

    askForLeave/deploy.jsp（用于部署jpdl，需要首先运行，只需要运行一次）：

<%@page import="demo.jbpm.AskForLeave"%> 
<% 
AskForLeave.deploy(); 
%>

    askForLeave/apply.jsp（用于启动业务，需要第二个运行）：

<%@ page language="java" contentType="text/html; charset=UTF-8"     pageEncoding="UTF-8"%> 
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<form name="form1" method="POST" action="apply_result.jsp"> 
申请人：<input type="text" name="apply_user" value="suntao"/><br/> 
假期开始时间：<input type="text" name="begin_leave_time" value="2009-08-07 09:00"/>(YYYY-MM-DD HH24:MI)<br/> 
假期结束时间：<input type="text" name="end_leave_time" value="2009-08-07 18:00"/>(YYYY-MM-DD HH24:MI)<br/> 
请假理由：<input type="text" name="leave_reason" value="事假"/><br/> 
<input type="submit" value="提交"/><br/> 
</form> 
</body> 
</html>

    askForLeave/apply_result.jsp（用于响应apply.jsp）：

<%@ page language="java" contentType="text/html; charset=UTF-8" 
    pageEncoding="UTF-8"%> 
<%@page import="demo.jbpm.AskForLeave"%> 
<% 
request.setCharacterEncoding("UTF-8"); 
String result = "成功"; 
try { 
    AskForLeave.apply(request); 
} 
catch(Exception e) { 
    result = "失败"; 
    e.printStackTrace(); 
} 
%> 

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<%=result %> 
</body> 
</html>

    askForLeave/managerWorkList.jsp（用于显示经理的工作列表，需要第三个运行）：

<%@ page language="java" contentType="text/html; charset=UTF-8" 
    pageEncoding="UTF-8"%> 
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<%@page import="demo.jbpm.AskForLeave"%> 
<%@page import="java.util.List"%> 
<%@page import="java.util.Map"%> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<% 
List<Map> workList = AskForLeave.getManagerWorkList(); 
%> 
<table border="1"> 
  <tr> 
    <td>工作名称</td> 
    <td>工作任务</td> 
    <td>处理</td> 
    <td>流程图</td> 
  </tr> 
  <%for(int i=0;i<workList.size();i++){ %> 
  <tr> 
    <td><%=workList.get(i).get("wfName") %></td> 
    <td><%=workList.get(i).get("taskName") %></td> 
    <td><a href="approval.jsp?wfId=<%=workList.get(i).get("wfId")%>&taskId=<%=workList.get(i).get("taskId")%>">处理</a></td> 
    <td><a href="viewWfGraph.jsp?wfId=<%=workList.get(i).get("wfId")%>&wfFileName=askForLeave.png">查看</a></td> 
  </tr> 
  <%} %> 
</table> 
</body> 
</html>

    askForLeave/approval.jsp（用于经理审批）：

<%@<page<language="java"<contentType="text/html;<charset=UTF-8" 
<<<<pageEncoding="UTF-8"%> 
<!DOCTYPE<html<PUBLIC<"-//W3C//DTD<HTML<4.01<Transitional//EN"<"http://www.w3.org/TR/html4/loose.dtd"> 
<%@page<import="demo.jbpm.AskForLeave"%> 
<%@page<import="java.util.Map"%> 
<html> 
<head> 
<meta<http-equiv="Content-Type"<content="text/html;<charset=UTF-8"> 
<title>apply</title> 
<script<language="javascript"> 
function<go(is_passed) 
{ 
<<document.getElementById("is_passed").value<=<is_passed; 
<<document.getElementById("form1").submit(); 
} 
</script> 
</head> 
<body> 
<% 
String<taskId=request.getParameter("taskId"); 
String<id<=<AskForLeave.getBizId(taskId); 
Map<formData<=<AskForLeave.getById(id); 
%> 
<form<id="form1"<name="form1"<method="POST"<action="approval_result.jsp"> 
<input<type="hidden"<name="biz_id"<value="<%=id<%>"/> 
<input<type="hidden"<name="taskId"<value="<%=taskId<%>"/> 
<input<type="hidden"<id="is_passed"<name="is_passed"<value=""/> 
申请人：<%=formData.get("apply_user")<%><br/> 
假期开始时间：<%=formData.get("begin_leave_time")<%><br/> 
假期结束时间：<%=formData.get("end_leave_time")<%><br/> 
请假理由：<%=formData.get("leave_reason")<%><br/> 
审批意见：<input<type="text"<name="approve_remark"<value=""/><br/> 
<input<type="button"<value="同意"<onclick="go(1)"/>  <input<type="button"<value="拒绝"<onclick="go(2)"/><br/> 
</form> 
</body> 
</html>

    askForLeave/approval_result.jsp（用于响应approval.jsp）：

<%@ page language="java" contentType="text/html; charset=UTF-8" 
    pageEncoding="UTF-8"%> 
<%@page import="demo.jbpm.AskForLeave"%> 
<% 
request.setCharacterEncoding("UTF-8"); 
String result = "成功"; 
try { 
    AskForLeave.approval(request); 
} 
catch(Exception e) { 
    result = "失败"; 
    e.printStackTrace(); 
} 
%> 

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<%=result %> 
</body> 
</html>

    askForLeave/employeeWorkList.jsp（用于显示员工工作列表，需要第四个运行）：

<%@ page language="java" contentType="text/html; charset=UTF-8" 
    pageEncoding="UTF-8"%> 
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<%@page import="demo.jbpm.AskForLeave"%> 
<%@page import="java.util.List"%> 
<%@page import="java.util.Map"%> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<% 
List<Map> workList = AskForLeave.getEmployeeWorkList(); 
%> 
<table border="1"> 
  <tr> 
    <td>工作名称</td> 
    <td>业务id</td> 
    <td>处理</td> 
    <td>流程图</td> 
  </tr> 
  <%for(int i=0;i<workList.size();i++){ %> 
  <tr> 
    <% 
    List<Map> actions = (List<Map>) workList.get(i).get("actions");  
    %> 
    <td><%=workList.get(i).get("wfName") %></td> 
    <td><%=workList.get(i).get("biz_id") %></td> 
    <td> 
    <a href="leave_result.jsp?biz_id=<%=workList.get(i).get("biz_id") %>&wfId=<%=workList.get(i).get("wfId") %>&taskId=<%=workList.get(i).get("taskId") %>"><%=workList.get(i).get("taskName") %></a> 
    </td> 
    <td><a href="viewWfGraph.jsp?wfId=<%=workList.get(i).get("wfId")%>&wfFileName=askForLeave.png">查看</a></td> 
  </tr> 
  <%} %> 
</table> 
</body> 
</html>

    askForLeave/leave_result.jsp（用于员工处理后续事务）：

<%@ page language="java" contentType="text/html; charset=UTF-8" 
    pageEncoding="UTF-8"%> 
<%@page import="demo.jbpm.AskForLeave"%> 
<% 
request.setCharacterEncoding("UTF-8"); 
String result = "成功"; 
try { 
    AskForLeave.leave(request); 
} 
catch(Exception e) { 
    result = "失败"; 
    e.printStackTrace(); 
} 
%> 

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
<title>apply</title> 
</head> 
<body> 
<%=result %> 
</body> 
</html>

    8、增加图形显示流程状态。

    此处采用OSWorkflow的做法，把OSWorkflow中的wz_jsgraphics.js放到应用的js目录下。

    建立askForLeave/viewWfGraph.jsp：

<%@ page import="java.util.List" %> 
<%@page import="demo.jbpm.JBPMUtil"%> 
<%@page import="demo.jbpm.AskForLeave"%> 
<%@page import="org.jbpm.api.model.ActivityCoordinates"%> 
<% 
String wfId = request.getParameter("wfId"); 
String wfFileName = request.getParameter("wfFileName"); 
List<ActivityCoordinates> coors = AskForLeave.getActiveActivityCoordinates(wfId); 
%> 

<div id="workflowCanvas" style="position:relative;height:566px;508px;"> 
<img src="<%=wfFileName %>" border=0/> 
</div> 
<script type="text/javascript" src="../js/wz_jsgraphics.js"></script> 

<script type="text/javascript"> 
var jg = new jsGraphics("workflowCanvas"); 
jg.setColor("#ff0000"); 
jg.setStroke(3); 
var xAdjust = 4; 
var yAdjust = 4; 
var widthAdjust = -10; 
var heightAdjust = -10; 
<%for (ActivityCoordinates coor : coors) {%> 
jg.drawRect(parseInt("<%=coor.getX()%>") + xAdjust, parseInt("<%=coor.getY()%>") + yAdjust, parseInt("<%=coor.getWidth()%>") + widthAdjust, parseInt("<%=coor.getHeight()%>") + heightAdjust); 
<%}%> 
jg.paint(); 

</script>

    这样就做完了，运行应用程序，就可以看到效果了。值得一提的是，图形化显示流程状态的效果，如下：

 

流程效果图