基于JBPM的请假系统

package com.tplink.action; import java.io.IOException; import java.io.InputStream; import java.io.PrintWriter; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.servlet.ServletOutputStream; import org.apache.struts2.ServletActionContext; import org.apache.struts2.interceptor.SessionAware; import com.opensymphony.xwork2.ActionSupport; import com.opensymphony.xwork2.ModelDriven; import com.tplink.po.MemberInfo; import com.tplink.po.PageInfo; import com.tplink.service.util.IJbpmService; import com.tplink.service.util.IMemberService; public class LoginAction extends ActionSupport implements ModelDriven<PageInfo>, SessionAware { /** * */ private static final long serialVersionUID = -5997178895900095361L; private PageInfo pageInfo = new PageInfo(); private Map<String, Object> session; private IMemberService memberService; private IJbpmService jbpmService; private String id; public String checkLogin() throws Exception { List<MemberInfo> list = memberService.checkMemberLogin(pageInfo.getMemberName(), pageInfo.getPassword()); if(list.size() > 0){ MemberInfo memberInfo = list.get(0); session.put("name", memberInfo.getMemberName()); session.put("role", memberInfo.getRole()); return SUCCESS; }else{ return ERROR; } } public String init() throws Exception { pageInfo.setProcessDefinitions(jbpmService.getProcessDefinitions()); pageInfo.setProcessInstances(jbpmService.getProcessInstances()); pageInfo.setHistoryProcessInstances(jbpmService.getHistoryProcessInstances()); pageInfo.setTasks(jbpmService.getTasks(session.get("name").toString())); return SUCCESS; } public String start()throws Exception{ // 启动流程时，需要对流程中的参数赋值 Map<String,Object> map = new HashMap<String,Object>(); map.put("person", session.get("name").toString()); // 从pageInfo中取得界面上传过来的流程id jbpmService.start(pageInfo.getId(), map); return SUCCESS; } public String view() throws Exception { // 通过流程实例的id找到现在流程进展的地方的坐标 pageInfo.setActivityCoordinates(jbpmService.findActivityCoordinates(pageInfo.getId())); return "view"; } /** * 获取流程图片 * @return * @throws Exception */ public String pic()throws Exception{ InputStream inputStream = jbpmService.findPicInputStream(pageInfo.getId()); PrintWriter pw = null; if(inputStream == null){ try{ pw = ServletActionContext.getResponse().getWriter(); pw.write("error"); }catch (IOException e) { e.printStackTrace(); } finally { pw.close(); } }else{ byte[] b = new byte[1024]; int len = -1; ServletOutputStream sos = null; try { sos = ServletActionContext.getResponse().getOutputStream(); while ((len = inputStream.read(b, 0, 1024)) != -1) { sos.write(b, 0, len); } } catch (IOException e) { e.printStackTrace(); } finally { if (sos != null) { try { sos.close(); } catch (IOException e) { e.printStackTrace(); } } } } return SUCCESS; } public String request()throws Exception{ return "request"; } /** * 用户填写请假单，并提交 * @return * @throws Exception */ public String submit()throws Exception{ Map<String,Object> map = new HashMap<String,Object>(); String taskId = pageInfo.getLeave().getTaskId(); map.put("taskId", pageInfo.getLeave().getTaskId()); map.put("person", pageInfo.getLeave().getPerson()); map.put("day", pageInfo.getLeave().getDay()); map.put("reason", pageInfo.getLeave().getReason()); jbpmService.complateByUser(taskId, map); return SUCCESS; } /** * 转移到经理审批页面 * @return * @throws Exception */ public String manager() throws Exception { // 获取前面用户填写申请单的参数 pageInfo.setMap(jbpmService.manager(pageInfo.getId())); return "manager"; } /** * 经理审批后，需要记录经理审批结果和审批备注 * @return * @throws Exception */ public String submitManager() throws Exception { jbpmService.complateByManager(pageInfo.getId(), pageInfo.getManagerResult(), pageInfo.getManagerComment()); return SUCCESS; } /** * 转移到老板审批页面 * @return * @throws Exception */ public String boss()throws Exception{ // 获取本次流程的参数 pageInfo.setMap(jbpmService.boss(pageInfo.getId())); return "boss"; } /** * 老板审批后，流程结束 * @return * @throws Exception */ public String submitBoss()throws Exception{ jbpmService.complateByBoss(pageInfo.getId(), pageInfo.getBossComment()); return SUCCESS; } public PageInfo getModel() { return pageInfo; } public void setSession(Map<String, Object> session) { this.session = session; } public IMemberService getMemberService() { return memberService; } public void setMemberService(IMemberService memberService) { this.memberService = memberService; } public IJbpmService getJbpmService() { return jbpmService; } public void setJbpmService(IJbpmService jbpmService) { this.jbpmService = jbpmService; } public String deploy(){ jbpmService.deployProcess(); return SUCCESS; } public String undeploy(){ jbpmService.undeploy(pageInfo.getId()); return SUCCESS; } }