approveaction.java

workflow 工作流系统的初步学习 自己下载JBPM的包 系统是可以跑的

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package com.fj.struts.action;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.jbpm.JbpmContext;
import org.jbpm.db.GraphSession;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;

import cn.com.dreamtech.ehrd.etraining.domain.ApplyItem;
import cn.com.dreamtech.ehrd.etraining.domain.ApproveItem;

import com.dao.BaseDao;
import com.firstflow.FlowProcessUtil;
import com.fj.struts.form.ApproveForm;

import framework.exception.BaseException;

/** 
 * MyEclipse Struts
 * Creation date: 06-11-2008
 * 
 * XDoclet definition:
 * @struts.action path="/approve" name="approveForm" scope="request" validate="true"
 * @struts.action-forward name="success" path="/error.jsp"
 */
public class ApproveAction extends BaseAction {
	/*
	 * Generated Methods
	 */
	BaseDao baseDao=(BaseDao)this.getInstince("baseDao");

	/** 
	 * Method execute
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 * @throws BaseException 
	 */
	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws BaseException {
		ApproveForm approveForm = (ApproveForm) form;// TODO Auto-generated method stub
		String action=request.getParameter("action");
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
		FlowProcessUtil fputil=new FlowProcessUtil();
		if(action!=null&&action.equals("init")){
			return mapping.findForward("initApprove");
		}else if(action!=null&&action.equals("add")){//发起一起申请
			ApplyItem item=new ApplyItem();
			this.beanCopy(item, approveForm);
			if(approveForm.getMoney()!=null&&approveForm.getMoney().length()>0){
				item.setApplyMoney(Integer.parseInt(approveForm.getMoney()));
			}
			if(approveForm.getApplyTimeS()!=null&&approveForm.getApplyTimeS().length()>0){
				try {
					item.setApplyTime(sdf.parse(approveForm.getApplyTimeS()));
				} catch (ParseException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				}
			
			baseDao.insertOrUpdate(item);
			
			fputil.createProcessInstanceDB(request.getSession().getAttribute("userId").toString(),item.getId());
			fputil.checkTasks(item.getId());
			fputil.submitApplicationDB(request.getSession().getAttribute("userId").toString(),Integer.parseInt(approveForm.getMoney()),item.getId());
			fputil.checkTasks(item.getId());
			return mapping.findForward("success");
		}else if(action!=null&&action.equals("initTaskList")){
			List ls=fputil.getTasksByRole(request.getSession().getAttribute("userType").toString());
			System.out.println("ls............"+ls.size());
			approveForm.setLsTask(ls);
			return mapping.findForward("initTaskList");
		}else if(action!=null&&action.equals("initExamne")){
			String taskId=request.getParameter("taskId");
			String applyId=fputil.getApplyIdByTaskId(taskId);
			ApplyItem item=(ApplyItem)baseDao.getObjectById(ApplyItem.class, applyId);
			request.setAttribute("item", item);
			request.setAttribute("taskId", taskId);
			return mapping.findForward("initExamne");
		}else if(action!=null&&action.equals("examineAdd")){
			ApproveItem item=new ApproveItem();
			item.setApplyId(approveForm.getApplyId());
			item.setApproveDate(new Date());
			item.setApproveResult(approveForm.getApproveResult());
			item.setApproveMemo(approveForm.getApproveMemo());
			item.setApproveUserId(request.getSession().getAttribute("userId").toString());//审核者
			baseDao.insertOrUpdate(item);
			if(approveForm.getApproveResult().equals("0")){//不同意
				fputil.approveByManagerDB(false, request.getParameter("taskId"));
			}else{//同意
				fputil.approveByManagerDB(true, request.getParameter("taskId"));
			}
			
			List ls=fputil.getTasksByRole(request.getSession().getAttribute("userType").toString());
			System.out.println("ls............"+ls.size());
			approveForm.setLsTask(ls);
			return mapping.findForward("initTaskList");
		}
		
		return mapping.getInputForward();
	}
}