jBPM4.1 workflow sample

package com.neusoft.workflow.leave.view; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.zip.ZipInputStream; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.ServletFileUpload; import org.jbpm.api.ExecutionService; import org.jbpm.api.ProcessDefinition; import org.jbpm.api.ProcessDefinitionQuery; import org.jbpm.api.ProcessInstance; import org.jbpm.api.RepositoryService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.ModelAttribute; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.servlet.ModelAndView; @Controller public class DeployProcessController { @Autowired private RepositoryService repositoryService; @Autowired private ExecutionService executionService; @RequestMapping("/deploy.do") public ModelAndView deploy(HttpServletRequest request, HttpServletResponse response) throws Exception { this.loadProcessDefFile(request, response); List list = this.getLatestProcessDefinition(); //String number = ServletRequestUtils.getStringParameter(request, "number"); ModelAndView mav = new ModelAndView("/deployProcess"); mav.addObject("processList", list); return mav; } protected void loadProcessDefFile(HttpServletRequest request, HttpServletResponse response) throws Exception { DiskFileItemFactory factory = new DiskFileItemFactory(); ServletFileUpload upload = new ServletFileUpload(factory); List fileItems = upload.parseRequest(request);// 上传文件解析 Iterator iter = fileItems.iterator();// 枚举方法 if (iter.hasNext()) { FileItem item = (FileItem) iter.next(); if (!item.isFormField()) { String name = item.getName(); long size = item.getSize(); System.out.println("name: " + name + " & size:" + size); if (name != null && !name.equals("") && size > 0) { // Deploying a process部署流程 repositoryService.createDeployment() .addResourcesFromZipInputStream( new ZipInputStream(item.getInputStream())) .deploy(); } } } } @RequestMapping("/processDefView.do") public ModelMap processDefView(){ List<ProcessDefinition> list = this.getLatestProcessDefinition(); return new ModelMap().addAttribute("processList",list); } /** * 获取最新版本的流程定义 */ protected List<ProcessDefinition> getLatestProcessDefinition(){ List<ProcessDefinition> processDefinitions = repositoryService .createProcessDefinitionQuery().orderAsc( ProcessDefinitionQuery.PROPERTY_NAME).list(); Map<String, ProcessDefinition> map = new LinkedHashMap<String, ProcessDefinition>(); for (ProcessDefinition pd : processDefinitions) { String key = pd.getKey(); ProcessDefinition definition = map.get(key); if ((definition == null) || (definition.getVersion() < pd.getVersion())) { map.put(key, pd); } } return new ArrayList(map.values()); } @RequestMapping("/processInstanceView.do") protected ModelMap processInstanceView(@RequestParam("id")String pdId) { List<ProcessInstance> list = getProcessInstanceById(pdId.trim()==""?null:pdId); return new ModelMap().addAttribute("pi", list); } /** * 根据流程定义ID获取流程实例 */ protected List<ProcessInstance> getProcessInstanceById(String pdId) { System.out.println("getProcessInstanceById - pdId=" + pdId); return executionService.createProcessInstanceQuery() .processDefinitionId(pdId).list(); } @RequestMapping("/processDiagramView.do") public void processDiagramView(HttpServletRequest request, HttpServletResponse response) throws Exception { String managemark = request.getParameter("managemark"); if (managemark.equals("view")) { String id = request.getParameter("id");// 流程定义ID ProcessDefinition processDefinition = repositoryService .createProcessDefinitionQuery().processDefinitionId(id) .uniqueResult(); // 获取流程图 InputStream io = repositoryService.getResourceAsStream( processDefinition.getDeploymentId(), processDefinition .getImageResourceName()); if (io != null) { byte[] bytes = new byte[1024 * 4]; int size = 0; // 输出流程图 while ((size = io.read(bytes, 0, 1024 * 4)) != -1) { response.getOutputStream().write(bytes, 0, size); } } } } }