Spring 3.1.x + Hibernate 4.2.x+JBPM 5.2 + Ecache例子源码

package com.gds.web; import static org.springframework.web.bind.annotation.RequestMethod.GET; import static org.springframework.web.bind.annotation.RequestMethod.POST; import static org.springframework.web.bind.annotation.RequestMethod.PUT; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.ObjectOutputStream; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.log4j.Logger; import org.drools.runtime.StatefulKnowledgeSession; import org.drools.runtime.process.WorkflowProcessInstance; import org.jbpm.task.AccessType; import org.jbpm.task.Task; import org.jbpm.task.TaskData; import org.jbpm.task.TaskService; import org.jbpm.task.query.TaskSummary; import org.jbpm.task.service.ContentData; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.ModelAttribute; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import com.gds.jbpm.JbpmSupport; import com.gds.jbpm.Order; @Controller public class OrderController { private Logger log = Logger.getLogger(this.getClass()); @Resource @Qualifier("jbpmSupport") private JbpmSupport jbpmSupport; @RequestMapping("/") public String test() { log.info("this is the index"); return "index"; } @RequestMapping(value = "{user}/create", method = GET) public String create(@PathVariable("user") String user) { //log.info(user + " prepare to create"); System.out.println("用户["+user+"]进入创建界面，准备创建流程。"); return "create"; } @RequestMapping(value = "{user}/create", method = { POST, PUT }) public String doCreate(@PathVariable("user") String user, Model model) { //log.info(user + " create an order"); System.out.println("用户["+user+"]提交了流程单据"); StatefulKnowledgeSession ksession = jbpmSupport.getKsession(); Map<String, Object> params = new HashMap<String, Object>(); params.put("priority", "High"); params.put("modelNumber", "179"); params.put("quantity", "100"); System.out.println("用户["+user+"]赋初始值，并准备启动流程......."); ksession.startProcess("com.gds.jbpm.sample", params); ksession.fireAllRules(); System.out.println("用户["+user+"]创建流程,等待处理......"); model.addAttribute("message", "process created!"); System.out.println("---------------------------------------------------单据提交完成:"+user); return "create"; } @RequestMapping("{user}/list") public String list(@PathVariable("user") String user, Model model) { //log.info(user + " list his tasks"); System.out.println("用户["+user+"]读取任务列表."); TaskService taskService = jbpmSupport.getTaskService(); List<TaskSummary> tasks = taskService.getTasksAssignedAsPotentialOwner(user, "en-UK"); log.info("\n***Task size::" + tasks.size() + "***\n"); for (TaskSummary taskSummary : tasks) { log.info(taskSummary.getId() + " :: " + taskSummary.getActualOwner()); } model.addAttribute("tasks", tasks); model.addAttribute("tasksCount", tasks.size()); model.addAttribute("user", user); System.out.println("---------------------------------------------------列表读取完成:"+user); return "list"; } @RequestMapping(value = "{user}/work/{task}", method = GET) public String work(@PathVariable("user") String user, @PathVariable("task") long taskId, Model model) { //log.info(user + " prepare to work on task " + taskId); System.out.println("用户["+user+"]读取任务以便处理，任务ID="+taskId); StatefulKnowledgeSession ksession = jbpmSupport.getKsession(); TaskService taskService = jbpmSupport.getTaskService(); Task task = taskService.getTask(taskId); TaskData taskData = task.getTaskData(); WorkflowProcessInstance process = (WorkflowProcessInstance) ksession.getProcessInstance(taskData .getProcessInstanceId()); model.addAttribute("taskData", taskData); model.addAttribute("order", new Order(user, taskId, process)); System.out.println("---------------------------------------------------任务读取完成:"+user); return "work"; } @RequestMapping(value = "{user}/work/{task}", method = { POST, PUT }) public String doWork(@ModelAttribute Order order) { System.out.println("处理任务信息:"+order.toString()); String user = order.getUser(); long taskId = order.getTaskId(); log.info(user + " complete work on task " + taskId); TaskService taskService = jbpmSupport.getTaskService(); System.out.println("用户["+user+"]启动人工任务， taskId="+taskId); taskService.start(taskId, user); Map<String, Object> data = new HashMap<String, Object>(); data.put("priority", order.getPriority()); data.put("modelNumber", order.getModelNumber()); data.put("quantity", order.getQuantity()); ContentData contentData = null; if (data != null) { ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream outs; try { outs = new ObjectOutputStream(bos); outs.writeObject(data); outs.close(); contentData = new ContentData(); contentData.setContent(bos.toByteArray()); contentData.setAccessType(AccessType.Inline); } catch (IOException e) { e.printStackTrace(); } } taskService.complete(taskId, user, contentData); System.out.println("用户["+user+"]完成人工任务"); System.out.println("---------------------------------------------------处理任务完成:"+user); return "redirect:/" + user + "/list"; } }