Jbpm整合Spring3+Struts2

一. 编写Reimbursement.jpdl.xml，以及整合Jbpm与Spring3，Struts2。

Reimbursement.jpdl.xml

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

<process name="Reimbursement" xmlns="http://jbpm.org/4.3/jpdl">
    <start g="371,21,48,48" name="start1">
        <transition g="11,-8" name="to SubmitAnApplication" to="SubmitAnApplication" />
    </start>
    <task assignee="User" form="User.jsp" g="333,109,123,52" name="SubmitAnApplication">
        <transition g="14,-9" name="to Manager" to="Manager" />
    </task>
    <task assignee="Manager" form="Manager.jsp" g="333,215,123,52"
        name="Manager">
        <transition g="586,242;585,134:6,-8" name="to Refuse"
            to="SubmitAnApplication" />
        <transition name="to exclusive1" to="exclusive1" g="8,-7" />
    </task>
    <decision expr="#{money > 2000 ? 'to Deputy': 'to end1'}" g="371,309,48,48"
        name="exclusive1">
        <transition name="to Deputy" to="Deputy" g="-14,-20" />
        <transition name="to end1" to="end1" g="23,-9" />
    </decision>
    <task assignee="Deputy" form="Manager.jsp" g="180,309,123,52"
        name="Deputy">
        <transition g="-58,-13" name="to Refuse" to="SubmitAnApplication" />
        <transition g="11,-3" name="to GeneralManager" to="GeneralManager" />
    </task>
    <task assignee="GeneralManager" form="Manager.jsp" g="180,422,123,52"
        name="GeneralManager">
        <transition g="-16,-19" name="to end1" to="end1" />
        <transition g="119,449;116,320;114,191;113,136:10,-1" name="to Refuse"
            to="SubmitAnApplication" />
    </task>
    <end g="371,426,48,48" name="end1" />

</process>

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">

    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/applicationContext.xml</param-value>
    </context-param>
    
    <filter>
        <filter-name>struts2</filter-name>
        <filter-class>org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>struts2</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>

    <welcome-file-list>
        <welcome-file>index.jsp</welcome-file>
    </welcome-file-list>
</web-app>

jbpm.cfg.xml

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

<jbpm-configuration>

    <import resource="jbpm.default.cfg.xml" />
    <import resource="jbpm.tx.spring.cfg.xml" />
    <import resource="jbpm.jpdl.cfg.xml" />
    <import resource="jbpm.bpmn.cfg.xml" />
    <import resource="jbpm.identity.cfg.xml" />
    <import resource="jbpm.businesscalendar.cfg.xml" />
    <import resource="jbpm.console.cfg.xml" />

    <!--   这一句会会导致启动服务器后定时发出查询JBPM4_JOB的sql语句 -->
    <!--<import resource="jbpm.jobexecutor.cfg.xml" /> -->
 
    <process-engine-context>
        <string name="spring.cfg" value="/WEB-INF/applicationContext.xml" />
    </process-engine-context>

</jbpm-configuration>

applicationContext.xml

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

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx" 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-3.0.xsd
          http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-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">

    <!--定义DataSource-->
    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
        <property name="url" value="jdbc:oracle:thin:@localhost:1521:ARIMADIS" />
        <property name="username" value="scott" />
        <property name="password" value="tiger" />
    </bean>

    <!--定义SessionFactory-->
    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="hibernateProperties">
            <props>
                <prop key="javax.persistence.validation.mode">none</prop>
                <prop key="hibernate.dialect">org.hibernate.dialect.Oracle10gDialect</prop>
                <prop key="hibernate.show_sql">true</prop>
                <prop key="hibernate.format_sql">true</prop>
                <prop key="hibernate.hbm2ddl.auto">none</prop>
            </props>
        </property>

        <property name="mappingResources">
            <list>
                <value>jbpm.repository.hbm.xml</value>
                <value>jbpm.execution.hbm.xml</value>
                <value>jbpm.history.hbm.xml</value>
                <value>jbpm.task.hbm.xml</value>
                <value>jbpm.identity.hbm.xml</value>
            </list>
        </property>
    </bean>

    <!--定义TransactionManager-->
    <bean id="transactionManager"
        class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactory" />
        <property name="dataSource" ref="dataSource" />
    </bean>

    <!--定义SpringHelper该类可以产生ProcessEngine-->
    <bean id="springHelper" class="org.jbpm.pvm.internal.processengine.SpringHelper" />

    <!--产生ProcessEngine-->
    <bean id="processEngine" factory-bean="springHelper"
        factory-method="createProcessEngine" />

    <!--产生 *UserLoginAction-->
    <bean id="UserLogin" class="com.demo.reimbursement.UserLoginAction"
        scope="prototype"></bean>

    <bean id="ListProcess" class="com.demo.reimbursement.ListProcessAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="DeployProcess" class="com.demo.reimbursement.DeployProcessAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="StartProcessDefinition" class="com.demo.reimbursement.StartProcessDefinitionAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="DeleteProcessDefinitionCascade"
        class="com.demo.reimbursement.DeleteProcessDefinitionCascadeAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="ViewCurrentTask" class="com.demo.reimbursement.ViewCurrentTaskAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="SubmitApplication" class="com.demo.reimbursement.SubmitApplicationAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="AssessmentApplication" class="com.demo.reimbursement.AssessmentApplicationAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="GetProcessImage" class="com.demo.reimbursement.GetProcessImageAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

    <bean id="ViewDirectionOfCurrentProcessInstance"
        class="com.demo.reimbursement.ViewDirectionOfCurrentProcessInstanceAction"
        scope="prototype">
        <property name="processEngine" ref="processEngine"></property>
    </bean>

</beans>

二. 编写前台页面

Login.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib prefix="s" uri="/struts-tags"%>
<%
    String path = request.getContextPath();
    String basePath = request.getScheme() + "://"
            + request.getServerName() + ":" + request.getServerPort()
            + path + "/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
    <head>
        <base href="<%=basePath%>">

        <title>用户登录</title>

        <meta http-equiv="pragma" content="no-cache">
        <meta http-equiv="cache-control" content="no-cache">
        <meta http-equiv="expires" content="0">
        <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
        <meta http-equiv="description" content="This is my page">
        <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

    </head>

    <body>
        <form action="Reimbursement/UserLoginAction.action" method="POST">
            用户名:
            <input type="text" name="userName" />
            <br />
            密码:
            <input type="password" name="password" />
            <br />
            <input type="submit" value="登录" />
        </form>
    </body>
</html>

Manager.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@taglib prefix="s" uri="/struts-tags"%>
<%
    String path = request.getContextPath();
    String basePath = request.getScheme() + "://"
            + request.getServerName() + ":" + request.getServerPort()
            + path + "/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
    <head>
        <base href="<%=basePath%>">

        <title>申请审批</title>

        <meta http-equiv="pragma" content="no-cache">
        <meta http-equiv="cache-control" content="no-cache">
        <meta http-equiv="expires" content="0">
        <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
        <meta http-equiv="description" content="This is my page">
        <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

    </head>

    <body>
        <center>
            <h2>
                审核：
            </h2>
        </center>

        <form action="Reimbursement/AssessmentApplicationAction.action"
            method="post">

            <input type="hidden" name="taskId"
                value="<s:property value='taskId'/>">

            报销数额：
            <s:property value="money" />
            <br>

            批准：
            <input type="radio" name="result" value="1">
            &nbsp;&nbsp;拒绝
            <input type="radio" name="result" value="2">
            <br>

            <input type="submit" value="提交">

        </form>

    </body>
</html>

Success.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib prefix="s" uri="/struts-tags"%>
<%
    String path = request.getContextPath();
    String basePath = request.getScheme() + "://"
            + request.getServerName() + ":" + request.getServerPort()
            + path + "/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
    <head>
        <base href="<%=basePath%>">

        <title>流程相关内容列表</title>

        <meta http-equiv="pragma" content="no-cache">
        <meta http-equiv="cache-control" content="no-cache">
        <meta http-equiv="expires" content="0">
        <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
        <meta http-equiv="description" content="This is my page">
        <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

    </head>

    <body>
        <center>
            <h2>
                流程相关内容列表
            </h2>
        </center>
        <table width="80%" align="center">
            <tr>
                <td width="100%">
                    <b><font color="red">待处理任务列表</font> </b>
                </td>
            </tr>
        </table>
        <table cellpadding="3" cellspacing="1" border="0" align="center"
            class="table" width="80%">
            <tr class="tr">
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    序号
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    名称
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    状态
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    任务详情
                </td>
            </tr>
            <s:iterator value="tasks">
                <tr class="tr">
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="id" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="name" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="state" />
                    </td> 
                    <td align="center" bgcolor="#E6ECF9">
                        <a href="Reimbursement/ViewCurrentTaskAction.action?taskId=<s:property value='id' />&formResourceName=/<s:property value='formResourceName'/>" />查看</a>
                    </td>
                </tr>
            </s:iterator>
        </table>

        <table width="80%" align="center">
            <tr>
                <td width="100%">
                    <b><font color="red">流程实例列表</font> </b>
                </td>
            </tr>
        </table>
        <table cellpadding="3" cellspacing="1" border="0" align="center"
            class="table" width="80%">
            <tr class="tr">
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    序号
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    状态
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    实例详情
                </td>
            </tr>
            <s:iterator value="processInstances">
                <tr class="tr">
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="id" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="state" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <a href="Reimbursement/ViewDirectionOfCurrentProcessInstanceAction.action?processInstanceId=<s:property value='id' />" />查看</a>
                    </td>
                </tr>
            </s:iterator>
        </table>

        <table width="80%" align="center">
            <tr>
                <td width="100%">
                    <b><font color="red">流程定义列表</font> </b>
                </td>
            </tr>
        </table>
        <table cellpadding="3" cellspacing="1" border="0" align="center"
            class="table" width="80%">
            <tr class="tr">
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    序号
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    名称
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    版本号
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    开启流程
                </td>
                <td align="center" bgcolor="#78A1E6" nowrap="nowrap">
                    删除
                </td>
            </tr>
            <s:iterator value="processDefinitions">
                <tr class="tr">
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="id" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="name" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <s:property value="version" />
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <a
                            href="Reimbursement/StartProcessDefinitionAction.action?processDefinitionId=<s:property value='id' />" />开启</a>
                    </td>
                    <td align="center" bgcolor="#E6ECF9">
                        <a
                            href="Reimbursement/DeleteProcessDefinitionCascadeAction.action?deploymentId=<s:property value='deploymentId' />" />删除</a>
                    </td>
                </tr>
            </s:iterator>
        </table>




        <center>
            用户:
            <font color="red"><s:property value="userName" /> </font>
            &nbsp;&nbsp;&nbsp;
            <a href="Reimbursement/DeployProcessAction.action">部署流程</a>
            &nbsp;&nbsp;&nbsp;
            <a href="/jbpm/Login.jsp">重新登录</a>
        </center>
    </body>
</html>

User.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@taglib prefix="s" uri="/struts-tags" %>
<%
    String path = request.getContextPath();
    String basePath = request.getScheme() + "://"
            + request.getServerName() + ":" + request.getServerPort()
            + path + "/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
    <head>
        <base href="<%=basePath%>">

        <title>提交报销申请</title>

        <meta http-equiv="pragma" content="no-cache">
        <meta http-equiv="cache-control" content="no-cache">
        <meta http-equiv="expires" content="0">
        <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
        <meta http-equiv="description" content="This is my page">
        <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

    </head>

    <body>
        <center>
            <h2>
                报销申请：
            </h2>
        </center>

        <form action="Reimbursement/SubmitApplicationAction.action" method="post">

            <input type="hidden" name="taskId" value="<s:property value='taskId'/>">

            报销金额：
            <input type="text" name="money">
            <br>
            <input type="submit" value="提交">

        </form>
        
    </body>
</html>

ViewProcess.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@taglib prefix="s" uri="/struts-tags"%>
<%
    String path = request.getContextPath();
    String basePath = request.getScheme() + "://"
            + request.getServerName() + ":" + request.getServerPort()
            + path + "/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
    <head>
        <base href="<%=basePath%>">

        <title>查看流程图</title>

        <meta http-equiv="pragma" content="no-cache">
        <meta http-equiv="cache-control" content="no-cache">
        <meta http-equiv="expires" content="0">
        <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
        <meta http-equiv="description" content="This is my page">
        <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

    </head>

    <body>
        <img
            src="Reimbursement/GetProcessImageAction.action?processInstanceId=<s:property value='processInstanceId'/>"
            style="position: absolute; left: 0; top: 0">
        <div
            style="position: absolute; border: 2px dashed blue; left:<s:property value='x'/>; top:<s:property value='y'/>; 
                <s:property value='width'/>; height:<s:property value='height'/>"></div>
    </body>
</html>

三. 编写Action

AssessmentApplicationAction.java

package com.demo.reimbursement;

import org.jbpm.api.ProcessEngine;
import org.jbpm.api.TaskService;

import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;

public class AssessmentApplicationAction extends ActionSupport
{
    private String taskId;
    private ProcessEngine processEngine;
    private Integer result;

    public String getTaskId()
    {
        return taskId;
    }

    public void setTaskId(String taskId)
    {
        this.taskId = taskId;
    }

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public Integer getResult()
    {
        return result;
    }

    public void setResult(Integer result)
    {
        this.result = result;
    }

    public String execute() throws Exception
    {
        TaskService taskService = this.processEngine.getTaskService();
        String loginUserName = (String) ActionContext.getContext().getSession()
                .get("userName");
        if ("Manager".equals(loginUserName))
        {
            if (1 == this.result)
            {
                taskService.completeTask(this.taskId, "to exclusive1");
            }
            else
            {
                taskService.completeTask(this.taskId, "to Refuse");
            }
        }
        else if ("Deputy".equals(loginUserName))
        {
            if (1 == this.result)
            {
                taskService.completeTask(this.taskId, "to GeneralManager");
            }
            else
            {
                taskService.completeTask(this.taskId, "to Refuse");
            }
        }
        else
        {
            if (1 == this.result)
            {
                taskService.completeTask(this.taskId, "to end1");
            }
            else
            {
                taskService.completeTask(this.taskId, "to Refuse");
            }
        }

        return SUCCESS;
    }
}

DeleteProcessDefinitionCascadeAction.java

package com.demo.reimbursement;

import org.jbpm.api.ProcessEngine;
import org.jbpm.api.RepositoryService;

import com.opensymphony.xwork2.ActionSupport;

public class DeleteProcessDefinitionCascadeAction extends ActionSupport
{
    private ProcessEngine processEngine;
    private String deploymentId;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String getDeploymentId()
    {
        return deploymentId;
    }

    public void setDeploymentId(String deploymentId)
    {
        this.deploymentId = deploymentId;
    }

    public String execute() throws Exception
    {
        RepositoryService repositoryService = this.processEngine
                .getRepositoryService();
        repositoryService.deleteDeploymentCascade(this.deploymentId);
        return SUCCESS;
    }
}

DeployProcessAction.java

package com.demo.reimbursement;

import java.io.IOException;
import java.util.zip.ZipInputStream;

import org.jbpm.api.ProcessEngine;

import com.opensymphony.xwork2.ActionSupport;

public class DeployProcessAction extends ActionSupport
{
    private ProcessEngine processEngine;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String execute()
    {
        ZipInputStream zipInputStream = null;

        zipInputStream = new ZipInputStream(this.getClass()
                .getResourceAsStream("/Reimbursement.zip"));
        this.processEngine.getRepositoryService().createDeployment()
                .addResourcesFromZipInputStream(zipInputStream).deploy();
        try
        {
            zipInputStream.close();
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }

        return SUCCESS;
    }
}

GetProcessImageAction.java

package com.demo.reimbursement;

import java.io.InputStream;
import java.io.OutputStream;

import org.apache.struts2.ServletActionContext;
import org.jbpm.api.ExecutionService;
import org.jbpm.api.ProcessDefinition;
import org.jbpm.api.ProcessEngine;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.RepositoryService;

import com.opensymphony.xwork2.ActionSupport;

public class GetProcessImageAction extends ActionSupport
{
    private ProcessEngine processEngine;
    private String processInstanceId;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String getProcessInstanceId()
    {
        return processInstanceId;
    }

    public void setProcessInstanceId(String processInstanceId)
    {
        this.processInstanceId = processInstanceId;
    }

    public String execute() throws Exception
    {
        RepositoryService repositoryService = this.processEngine
                .getRepositoryService();

        ExecutionService executionService = this.processEngine
                .getExecutionService();
        ProcessInstance processInstance = executionService
                .findProcessInstanceById(this.processInstanceId);

        String processDefinitionId = processInstance.getProcessDefinitionId();
        ProcessDefinition processDefinition = repositoryService
                .createProcessDefinitionQuery().processDefinitionId(
                        processDefinitionId).uniqueResult();

        InputStream imageInputStream = repositoryService.getResourceAsStream(
                processDefinition.getDeploymentId(), "Reimbursement.png");
        OutputStream out = ServletActionContext.getResponse().getOutputStream();

        byte buffer[] = new byte[1024];
        int length = 0;
        while ((length = imageInputStream.read(buffer)) != -1)
        {
            out.write(buffer, 0, length);
        }
        imageInputStream.close();
        out.close();
        return null;

    }
}

ListProcessAction.java

package com.demo.reimbursement;

import java.util.List;

import org.jbpm.api.ExecutionService;
import org.jbpm.api.ProcessDefinition;
import org.jbpm.api.ProcessEngine;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.RepositoryService;
import org.jbpm.api.TaskService;
import org.jbpm.api.task.Task;

import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;

public class ListProcessAction extends ActionSupport
{
    private ProcessEngine processEngine;
    private List<Task> tasks;
    private List<ProcessDefinition> processDefinitions;
    private List<ProcessInstance> processInstances;
    private String userName;

    public List<Task> getTasks()
    {
        return tasks;
    }

    public void setTasks(List<Task> tasks)
    {
        this.tasks = tasks;
    }

    public List<ProcessDefinition> getProcessDefinitions()
    {
        return processDefinitions;
    }

    public void setProcessDefinitions(List<ProcessDefinition> processDefinitions)
    {
        this.processDefinitions = processDefinitions;
    }

    public List<ProcessInstance> getProcessInstances()
    {
        return processInstances;
    }

    public void setProcessInstances(List<ProcessInstance> processInstances)
    {
        this.processInstances = processInstances;
    }

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String getUserName()
    {
        return userName;
    }

    public void setUserName(String userName)
    {
        this.userName = userName;
    }

    public String execute() throws Exception
    {
        this.userName = (String) ActionContext.getContext().getSession().get(
                "userName");

        RepositoryService repositoryService = this.processEngine
                .getRepositoryService();
        this.processDefinitions = repositoryService
                .createProcessDefinitionQuery().list();

        ExecutionService executionService = this.processEngine
                .getExecutionService();
        this.processInstances = executionService.createProcessInstanceQuery()
                .list();

        TaskService taskService = this.processEngine.getTaskService();
        this.tasks = taskService.findPersonalTasks(this.userName);

        return SUCCESS;
    }
}

StartProcessDefinitionAction.java

package com.demo.reimbursement;

import org.jbpm.api.ExecutionService;
import org.jbpm.api.ProcessEngine;

import com.opensymphony.xwork2.ActionSupport;

public class StartProcessDefinitionAction extends ActionSupport
{
    private ProcessEngine processEngine;
    private String processDefinitionId;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String getProcessDefinitionId()
    {
        return processDefinitionId;
    }

    public void setProcessDefinitionId(String processDefinitionId)
    {
        this.processDefinitionId = processDefinitionId;
    }

    public String execute() throws Exception
    {
        ExecutionService executionService = this.processEngine
                .getExecutionService();
        executionService.startProcessInstanceById(this.processDefinitionId);
        return SUCCESS;
    }
}

SubmitApplicationAction.java

package com.demo.reimbursement;

import java.util.HashMap;
import java.util.Map;

import org.jbpm.api.ProcessEngine;
import org.jbpm.api.TaskService;

import com.opensymphony.xwork2.ActionSupport;

public class SubmitApplicationAction extends ActionSupport
{
    private String taskId;
    private String money;
    private ProcessEngine processEngine;

    public String getTaskId()
    {
        return taskId;
    }

    public void setTaskId(String taskId)
    {
        this.taskId = taskId;
    }

    public String getMoney()
    {
        return money;
    }

    public void setMoney(String money)
    {
        this.money = money;
    }

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String execute() throws Exception
    {
        TaskService taskService = this.processEngine.getTaskService();
        Map<String, Object> mp = new HashMap<String, Object>();
        mp.put("money", this.money);
        taskService.completeTask(this.taskId, "to Manager", mp);

        return SUCCESS;
    }
}

UserLoginAction.java

package com.demo.reimbursement;


import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;

public class UserLoginAction extends ActionSupport
{
    private String userName;
    private String password;

    public String getUserName()
    {
        return userName;
    }

    public void setUserName(String userName)
    {
        this.userName = userName;
    }

    public String getPassword()
    {
        return password;
    }

    public void setPassword(String password)
    {
        this.password = password;
    }

    public String execute() throws Exception
    {
        ActionContext.getContext().getSession().put("userName", this.userName);

        return SUCCESS;
    }
}

ViewCurrentTaskAction.java

package com.demo.reimbursement;

import org.jbpm.api.ProcessEngine;
import org.jbpm.api.TaskService;

import com.opensymphony.xwork2.ActionSupport;

public class ViewCurrentTaskAction extends ActionSupport
{
    private String taskId;
    private String formResourceName;
    private ProcessEngine processEngine;
    private Integer money;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public Integer getMoney()
    {
        return money;
    }

    public void setMoney(Integer money)
    {
        this.money = money;
    }

    public String getTaskId()
    {
        return taskId;
    }

    public void setTaskId(String taskId)
    {
        this.taskId = taskId;
    }

    public String getFormResourceName()
    {
        return formResourceName;
    }

    public void setFormResourceName(String formResourceName)
    {
        this.formResourceName = formResourceName;
    }

    public String execute() throws Exception
    {
        TaskService taskService = this.processEngine.getTaskService();
        if (null != taskService.getVariable(this.taskId, "money"))
        {
            this.money = Integer.parseInt((String) taskService.getVariable(
                    taskId, "money"));
        }
        return SUCCESS;
    }
}

ViewDirectionOfCurrentProcessInstanceAction.java

package com.demo.reimbursement;

import java.util.Set;

import org.jbpm.api.ExecutionService;
import org.jbpm.api.ProcessEngine;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.RepositoryService;
import org.jbpm.api.model.ActivityCoordinates;

import com.opensymphony.xwork2.ActionSupport;

public class ViewDirectionOfCurrentProcessInstanceAction extends ActionSupport
{
    private ProcessEngine processEngine;
    private String processInstanceId;
    private int x;
    private int y;
    private int width;
    private int height;

    public ProcessEngine getProcessEngine()
    {
        return processEngine;
    }

    public void setProcessEngine(ProcessEngine processEngine)
    {
        this.processEngine = processEngine;
    }

    public String getProcessInstanceId()
    {
        return processInstanceId;
    }

    public void setProcessInstanceId(String processInstanceId)
    {
        this.processInstanceId = processInstanceId;
    }

    public int getX()
    {
        return x;
    }

    public void setX(int x)
    {
        this.x = x;
    }

    public int getY()
    {
        return y;
    }

    public void setY(int y)
    {
        this.y = y;
    }

    public int getWidth()
    {
        return width;
    }

    public void setWidth(int width)
    {
        this.width = width;
    }

    public int getHeight()
    {
        return height;
    }

    public void setHeight(int height)
    {
        this.height = height;
    }

    public String execute() throws Exception
    {
        RepositoryService repositoryService = this.processEngine
                .getRepositoryService();
        ExecutionService executionService = this.processEngine
                .getExecutionService();
        ProcessInstance processInstance = executionService
                .findProcessInstanceById(this.processInstanceId);

        Set<String> activeActivityNames = processInstance
                .findActiveActivityNames();
        ActivityCoordinates activityCoordinates = repositoryService
                .getActivityCoordinates(processInstance
                        .getProcessDefinitionId(), activeActivityNames
                        .iterator().next());
        this.x = activityCoordinates.getX();
        this.y = activityCoordinates.getY();
        this.width = activityCoordinates.getWidth();
        this.height = activityCoordinates.getHeight();
        return SUCCESS;
    }
}

四. 编写struts.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 2.1//EN" "http://struts.apache.org/dtds/struts-2.1.dtd">
<struts>

    <!-- <constant name="struts.i18n.encoding" value="GBK"></constant> -->

    <package name="Reimbursement" extends="struts-default"
        namespace="/Reimbursement">
        <action name="UserLoginAction" class="UserLogin">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="ListProcessAction" class="ListProcess">
            <result name="success">/Success.jsp</result>
        </action>

        <action name="DeployProcessAction" class="DeployProcess">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="StartProcessDefinitionAction" class="StartProcessDefinition">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="DeleteProcessDefinitionCascadeAction" class="DeleteProcessDefinitionCascade">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="ViewCurrentTaskAction" class="ViewCurrentTask">
            <result name="success">/${formResourceName}</result>
        </action>

        <action name="SubmitApplicationAction" class="SubmitApplication">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="AssessmentApplicationAction" class="AssessmentApplication">
            <result name="success" type="redirectAction">
                <param name="actionName">ListProcessAction</param>
            </result>
        </action>

        <action name="GetProcessImageAction" class="GetProcessImage">
        </action>

        <action name="ViewDirectionOfCurrentProcessInstanceAction"
            class="ViewDirectionOfCurrentProcessInstance">
            <result name="success">/ViewProcess.jsp</result>
        </action>



    </package>
</struts>    

五. 打包Reimbursement.jpdl.xml，Reimbursement.png，测试