testbusinessaction.java

公司自己开发的工作流引擎

package cn.com.iaspec.workflow.client.web.action.test;

import java.util.*;
import javax.servlet.http.*;
import org.apache.struts.action.*;
import cn.com.iaspec.workflow.client.*;
import cn.com.iaspec.workflow.client.web.action.base.*;
import cn.com.iaspec.workflow.engine.dao.*;
import cn.com.iaspec.workflow.vo.db.*;
import cn.com.iaspec.workflow.vo.workflow.WorkflowProcessInfo;
import cn.com.iaspec.workflow.helper.CaseWorkflowHelper;
import cn.com.iaspec.workflow.vo.workflow.UserInfo;
import cn.com.iaspec.workflow.util.FlowWebKeys;
import cn.com.iaspec.workflow.vo.workflow.ActivityVariable;

public class TestBusinessAction
    extends BaseAction{
  public TestBusinessAction(){
  }

  public ActionForward query(ActionMapping mapping,ActionForm form,
      HttpServletRequest request,HttpServletResponse response)
      throws Exception{
    String projectId=request.getParameter("wf_project_id")==null?"0":
        request.getParameter("wf_project_id");
    //取得公共项目信息
    WfPublicProjectInfo info=new WfPublicProjectInfo();
    info.setProjectId(Long.parseLong(projectId));
    //为了测试方便，这里直接调用dao
    WfPublicProjectInfoDAO dao=new WfPublicProjectInfoDAO();
    List list=dao.query(info);
    if(list!=null&&list.size()>0){
      request.setAttribute("projectInfo",(WfPublicProjectInfo)list.get(0));
    }
    return mapping.findForward("business");
  }

  public ActionForward submit(ActionMapping mapping,ActionForm form,
      HttpServletRequest request,HttpServletResponse response)
      throws Exception{
    System.out.println("begin submit...");
    String businessTitle=request.getParameter("business_title");
    String wfBusinessId=request.getParameter("wf_business_id")==null?"":
        request.getParameter("wf_business_id");
    WorkflowEngineClient client=new WorkflowEngineClient();
    WorkflowJSPClient jspClient=new WorkflowJSPClient();
    WorkflowProcessInfo wfProInfo=jspClient.getWorkflowProcessInfo(request);
    //更新标题
    client.updateProcessTitle(wfProInfo,businessTitle);
    //修改变量
    wfProInfo.modifyWorkitemVarData(request.getParameter("flow_var_name")==null?
        "":request.getParameter("flow_var_name"),
        request.getParameter("flow_var_value")==null?"":
        request.getParameter("flow_var_value"));
    //暂存工作流
    if(wfBusinessId.equals("")){
      wfBusinessId=Double.toString(Math.random());
    }
    //client.newAndSaveWorkflow(wfProInfo,wfBusinessId);
    //提交工作流
    client.processWorkflow(wfProInfo,wfBusinessId);
    return mapping.findForward("result");
  }

  public ActionForward getAllProcesses(ActionMapping mapping,ActionForm form,
      HttpServletRequest request,HttpServletResponse response)
      throws Exception{

    HttpSession session=request.getSession(false);
    UserInfo userInfo=(UserInfo)session.getAttribute(FlowWebKeys.USER_SESSION);
    CaseWorkflowHelper helper=new CaseWorkflowHelper(userInfo);

    List processList=helper.getAllProcess();
    request.setAttribute("processList",processList);

    return mapping.findForward("show_process_list");
  }

}