JBPM5.4 SSH 完整项目整合

package com.action; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.UnsupportedEncodingException; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.struts2.ServletActionContext; import com.entity.Account; import com.entity.ApproveInfo; import com.entity.Document; import com.entity.WorkFlow; import com.service.ApproveInfoService; import com.service.DocService; import com.service.WorkFlowService; public class DocAction { @Resource(name = "docServiceImpl") private DocService ds; @Resource(name = "workFlowServiceImpl") private WorkFlowService ws; @Resource(name="approveInfoServiceImpl") private ApproveInfoService as; private Integer wfId; private String contentFileName; private File content; private String docTitle; private String docDesc; private Integer docId; //审批信息 private String comment; private Integer prize; // 显示选择公文 public String showAddDoc() { HttpServletRequest request = ServletActionContext.getRequest(); List<WorkFlow> wfs = ws.findAll(); request.setAttribute("wfs", wfs); return "showAddDoc"; } // 显示公文对应的表单 public String showAddDocForm() { HttpServletRequest request = ServletActionContext.getRequest(); WorkFlow workFlow = ws.findById(wfId); request.setAttribute("workFlow", workFlow); return "showAddDocForm"; } //添加公文（填写表单） public String addDoc() { HttpServletRequest request = ServletActionContext.getRequest(); Account account = (Account)request.getSession().getAttribute("account"); Document doc = new Document(); doc.setCreateTime(new Date()); doc.setCreator(account); doc.setDocDesc(docDesc); doc.setDocTitle(docTitle); WorkFlow wf = ws.findById(wfId); doc.setStatus(Document.STATUS_NEW); doc.setFlag(1); doc.setLoadName(contentFileName); doc.setContent(getByteFromFile(content)); Map<String, Object> params = new HashMap<String, Object>(); params.put("emp", account.getUname()); params.put("prize", prize); System.out.println(prize); ds.addDocForProcess(doc, wf, params); return "addDoc"; } //显示我的公文 public String showMyDoc() { HttpServletRequest request = ServletActionContext.getRequest(); //得到登陆用户的对象 Account account = (Account)request.getSession().getAttribute("account"); //根据UID获取集合 Integer uid = account.getUid(); List<Document> docs = ds.findAllByKey("from Document doc where doc.creator.uid=?", new Object[]{uid}); request.setAttribute("docs", docs); return "showMyDoc"; } //下载 public String execute() throws Exception { HttpServletResponse response = ServletActionContext.getResponse(); Document doc = ds.findById(docId); response.reset(); String loadName = doc.getLoadName(); String name = new String(loadName.getBytes("utf-8"),"iso-8859-1"); response.setContentType("application/x-download;charset=utf-8"); response.setHeader("content-Disposition", "attachment;filename="+name); response.getOutputStream().write(doc.getContent()); response.getOutputStream().flush(); response.getOutputStream().close(); return null; } //提交流程 public String appDoc() { HttpServletRequest request = ServletActionContext.getRequest(); Account account = (Account)request.getSession().getAttribute("account"); String uname = account.getUname(); Document doc = ds.findById(docId); ds.applyDoc(uname, doc); return "appDoc"; } //显示待审公文 public String showApproveingDoc() { HttpServletRequest request = ServletActionContext.getRequest(); Account account = (Account)request.getSession().getAttribute("account"); String uname = account.getUname(); List<Document> docs = ds.findApprovingDoc(uname); request.setAttribute("docs",docs); return "showApproveingDoc"; } //显示审批意见 public String showApprove() { HttpServletRequest request = ServletActionContext.getRequest(); request.setAttribute("docId",docId); return "showApprove"; } //提交审批信息 public String approve() { HttpServletRequest request = ServletActionContext.getRequest(); ApproveInfo approveInfo = new ApproveInfo(); approveInfo.setComment(comment); approveInfo.setApproveTime(new Date()); Account account = (Account)request.getSession().getAttribute("account"); String uname = account.getUname(); approveInfo.setApprover(account); Document doc = ds.findById(docId); ds.endDoc(approveInfo, uname, doc); return "approve"; } //显示已审公文的页面 public String showApprovedDoc() { HttpServletRequest request = ServletActionContext.getRequest(); Account account = (Account)request.getSession().getAttribute("account"); Integer uid = account.getUid(); List<ApproveInfo> approves = as.findAllByKey("from ApproveInfo ao where ao.approver.uid=?", new Object[]{uid}); request.setAttribute("approves", approves); return "showApprovedDoc"; } //显示审批历史 public String showApprovedHistory() { HttpServletRequest request = ServletActionContext.getRequest(); //根据docId获取审批历史 List<ApproveInfo> approveHistory = as.findAllByKey("from ApproveInfo ao where ao.document.did=?", new Object[]{docId}); request.setAttribute("approveHistory", approveHistory); return "showApprovedHistory"; } public Integer getWfId() { return wfId; } public void setWfId(Integer wfId) { this.wfId = wfId; } public String getContentFileName() { return contentFileName; } public void setContentFileName(String contentFileName) { this.contentFileName = contentFileName; } public File getContent() { return content; } public void setContent(File content) { this.content = content; } public String getDocTitle() { return docTitle; } public void setDocTitle(String docTitle) { this.docTitle = docTitle; } public String getDocDesc() { return docDesc; } public void setDocDesc(String docDesc) { this.docDesc = docDesc; } public Integer getDocId() { return docId; } public void setDocId(Integer docId) { this.docId = docId; } public String getComment() { return comment; } public void setComment(String comment) { this.comment = comment; } public Integer getPrize() { return prize; } public void setPrize(Integer prize) { this.prize = prize; } // 文件转换为字节数组 private byte[] getByteFromFile(File file) { byte[] be = null; try { if (file == null) { return null; } FileInputStream in = new FileInputStream(file); ByteArrayOutputStream out = new ByteArrayOutputStream(4000); byte[] b = new byte[4000]; int n; while ((n = in.read(b)) != -1) { out.write(b, 0, n); } in.close(); out.close(); be = out.toByteArray(); } catch (Exception e) { e.printStackTrace(); } return be; } }