activiti自定义流程之整合（七）：完成我的申请任务

时间：2023-03-08 23:01:19
activiti自定义流程之整合（七）：完成我的申请任务

在上一篇的获得我的申请中，可以看到js代码中还包含了预览和完成任务的代码，既然上一篇已经罗列了相关代码，这里也就不重复。

那么需要补充的是，在上边的完成任务的js代码中，我们还调用了getTaskForm请求，目的是从后台获取提交任务时的其他数据，例如指定下一个处理人等，当然了，根据不同的业务逻辑可能有所变化。

那么这个请求对应的后台代码如下，如果弄明白了整个数据库的设计，那么对于这些代码就很容易明白。

  1. @RequestMapping(value = "/getTaskForm.do", method = RequestMethod.POST, produces = "application/json;charset=utf-8")
  2. @ResponseBody
  3. public Object getTaskForm(@RequestBody String taskFormKey) {
  4. Map<String, String> map = new HashMap<String, String>();
  5. //System.out.println(taskFormKey);
  6. taskFormKey = taskFormKey.replace("=", "");
  7. String form = myFormService.findFormByFormName(taskFormKey);
  8. // (String)formService.getRenderedTaskForm(taskFormKey);
  9. map.put("form", form);
  10. return map;
  11. }

这里边的findFormByFormName方法在前边的章节中讲过，就是很简单的根据一个字段查询整条记录的操作。

那么这里补充的说明完了，下一步就是提交申请，把任务交到下一个人的手上，也就是上边的js中的complete.do请求，这个请求的后台代码如下：

  1. /**
  2. * @throwsXMLStreamException
  3. *             完成个人任务
  4. *
  5. * @author：tuzongxun
  6. * @Title: completeTask
  7. * @param@return
  8. * @return Object
  9. * @date Mar 17, 20164:55:31 PM
  10. * @throws
  11. */
  12. @RequestMapping(value = "/completeTask.do", method = RequestMethod.POST, produces = "application/json;charset=utf-8")
  13. @ResponseBody
  14. public Object completeTask(HttpServletRequest req)
  15. throws XMLStreamException {
  16. Map<String, String[]> formMap = req.getParameterMap();
  17. String taskId = (String) formMap.get("taskId")[0];
  18. boolean isLogin = this.isLogin(req);
  19. if (isLogin) {
  20. if (taskId != null) {
  21. // 根据taskName和流程节点中的名字判断当前节点之后是否还有任务
  22. Task task = taskService.createTaskQuery().taskId(taskId)
  23. .singleResult();
  24. String taskName = task.getName();
  25. Iterator<FlowElement> flows = this.findFlow(task
  26. .getProcessDefinitionId());
  27. String row0 = null;
  28. Map<String, Object> formProperties = new HashMap<String, Object>();
  29. while (flows.hasNext()) {
  30. FlowElement flowElement = flows.next();
  31. // 找到当前节点，查询出下下一个节点是否是结束节点，如果不是则需要设置下一个任务人，否则直接保存相关流程变量结束
  32. // 同时要查处当前任务的行数用来设置流程变量名称
  33. if (taskName.equals(flowElement.getName())) {
  34. // 设置行号
  35. row0 = flowElement.getXmlRowNumber() + "";
  36. FlowElement flowElement3 = flows.next();
  37. System.out.println("SequenceFlow".equals(flowElement3
  38. .getClass().getSimpleName()));
  39. if ("SequenceFlow".equals(flowElement3.getClass()
  40. .getSimpleName())) {
  41. SequenceFlow seq = (SequenceFlow) flowElement3;
  42. System.out.println(seq.getConditionExpression()
  43. + "," + seq.getName());
  44. }
  45. FlowElement flowElement2 = flows.next();
  46. // 当前任务不是最后一个任务,流程没有结束,需要设置下一个处理人
  47. if (flowElement2 != null
  48. && !("EndEvent".equals(flowElement2.getClass()
  49. .getSimpleName()) && !("SequenceFlow"
  50. .equals(flowElement2.getClass()
  51. .getSimpleName())))) {
  52. UserTask userTask = (UserTask) flowElement2;
  53. // 获取userTask中的
  54. String assignee = userTask.getAssignee();
  55. int index1 = assignee.indexOf("{");
  56. int index2 = assignee.indexOf("}");
  57. String person1 = (String) formMap.get("data_1")[0];
  58. formProperties.put(
  59. assignee.substring(index1 + 1, index2),
  60. person1);
  61. }
  62. break;
  63. }
  64. }
  65. // 从request中读取参数然后转换0
  66. Set<Entry<String, String[]>> entrySet = formMap.entrySet();
  67. for (Entry<String, String[]> entry : entrySet) {
  68. String key = entry.getKey() + row0;
  69. String value = entry.getValue()[0];
  70. if (!key.equals("taskId")) {
  71. formProperties.put(key, value);
  72. }
  73. }
  74. taskService.complete(taskId, formProperties);
  75. ;
  76. }
  77. }
  78. return null;
  79. }

因为这一个完成任务的方法和之后处理别人提交给自己的任务方法共用了，因此我便同时列出查询别人提交给我的任务的后台代码，如下：

  1. /**
  2. * @throwsXMLStreamException
  3. *             查询别人提交给我的任务
  4. *
  5. * @author：tuzongxun
  6. * @Title: findTask
  7. * @param@return
  8. * @return Object
  9. * @date Mar 17, 20162:44:11 PM
  10. * @throws
  11. */
  12. @RequestMapping(value = "/findTask.do", method = RequestMethod.POST, produces = "application/json;charset=utf-8")
  13. @ResponseBody
  14. public Object findTask(HttpServletRequest req) throws XMLStreamException{
  15. Map<String, Object> map = new HashMap<String, Object>();
  16. boolean isLogin = this.isLogin(req);
  17. if (isLogin) {
  18. List<TaskModel> taskList = new ArrayList<TaskModel>();
  19. HttpSession session = req.getSession();
  20. String assginee = (String) session.getAttribute("userName");
  21. List<Task> taskList1 = taskService.createTaskQuery()
  22. .taskAssignee(assginee).list();
  23. if (taskList1 != null && taskList1.size() > 0) {
  24. for (Task task : taskList1) {
  25. TaskModel taskModel = new TaskModel();
  26. // 获取部署名
  27. String processdefintionId = task.getProcessDefinitionId();
  28. ProcessDefinition processDefinition = repositoryService
  29. .createProcessDefinitionQuery()
  30. .processDefinitionId(processdefintionId)
  31. .singleResult();
  32. // 根据taskname和节点判断是否是第一个
  33. String taskName = task.getName();
  34. Iterator<FlowElement> iterator = this
  35. .findFlow(processdefintionId);
  36. String row0 = null;
  37. String eleName0 = null;
  38. String rowStart = null;
  39. // 保存上上一个节点的信息
  40. FlowElement flowElement00 = null;
  41. findFole: while (iterator.hasNext()) {
  42. FlowElement flowElement0 = iterator.next();
  43. // 注意usertask下一个节点是连线而不是task
  44. FlowElement flowElement = null;
  45. String eleName = null;
  46. // 得到流程启动节点的行号
  47. if (flowElement0.getClass().getSimpleName()
  48. .equals("StartEvent")) {
  49. rowStart = flowElement0.getXmlRowNumber() + "";
  50. // 如果当前不是连线，则下一个是
  51. } else if (flowElement0 != null
  52. && !(flowElement0.getClass().getSimpleName()
  53. .equals("SequenceFlow"))
  54. && iterator.hasNext()) {
  55. do {
  56. iterator.next();
  57. if (iterator.hasNext()) {
  58. flowElement = iterator.next();
  59. eleName = flowElement.getName();
  60. // 下下一个节点
  61. if (taskName.equals(eleName)) {
  62. row0 = flowElement0.getXmlRowNumber()
  63. + "";
  64. eleName0 = flowElement0.getClass()
  65. .getSimpleName();
  66. flowElement00 = flowElement0;
  67. break findFole;
  68. } else {
  69. flowElement0 = flowElement;
  70. }
  71. }
  72. } while (true);
  73. }
  74. }
  75. // 此处需要修改,怎么判断是别人提交给我的？如果当前节点名是申请，那么当上一个节点类名是StartEvent时，证明是自己的申请
  76. if (eleName0 != null && !("StartEvent".equals(eleName0))) {
  77. // 先查询出上一个任务（已完成）,根据流程实例id
  78. List<HistoricTaskInstance> hisTaskList = historyService
  79. .createHistoricTaskInstanceQuery()
  80. .processDefinitionId(processdefintionId)
  81. .finished()
  82. .orderByHistoricTaskInstanceEndTime().desc()
  83. .list();
  84. String formName = null;
  85. if (hisTaskList != null && hisTaskList.size() > 0) {
  86. HistoricTaskInstance historicTaskInstance = hisTaskList
  87. .get(0);
  88. formName = historicTaskInstance.getFormKey();
  89. String form = this.getTaskForm1(formName);
  90. taskModel.setLastForm(form);
  91. }
  92. // 当是别人提交过来的任务时，form就应该是任务相关的form，task里边保存的有formName
  93. taskModel.setAssignee(task.getAssignee());
  94. taskModel.setCreateTime(task.getCreateTime());
  95. taskModel.setId(task.getId());
  96. taskModel.setName(task.getName());
  97. taskModel.setProcessInstanceId(task
  98. .getProcessInstanceId());
  99. taskModel
  100. .setProcessDefId(task.getProcessDefinitionId());
  101. taskModel.setFormKey(task.getFormKey());
  102. String deploymentId = processDefinition
  103. .getDeploymentId();
  104. Deployment deployment = repositoryService
  105. .createDeploymentQuery()
  106. .deploymentId(deploymentId).singleResult();
  107. String deploymentName = deployment.getName();
  108. taskModel.setDeploymentName(deploymentName);
  109. List<HistoricVariableInstance> variables = historyService
  110. .createHistoricVariableInstanceQuery()
  111. .processInstanceId(task.getProcessInstanceId())
  112. .list();
  113. // 获取上一个节点填写的数据
  114. Map<String, String> formData = new HashMap<String,String>();
  115. Map<String, String> formData1 = new HashMap<String,String>();
  116. for (HistoricVariableInstance variableInstance : variables) {
  117. System.out.println(variableInstance);
  118. String varName = variableInstance.getVariableName();
  119. System.out.println(varName);
  120. System.out.println(variableInstance.getValue());
  121. if (varName.contains(row0)) {
  122. formData.put(varName,
  123. (String) variableInstance.getValue());
  124. }
  125. if (varName.contains(rowStart)) {
  126. formData1.put(varName,
  127. (String) variableInstance.getValue());
  128. }
  129. }
  130. // 获取流程启动时填写的数据，即申请数据
  131. // 获取流程启动的表单form
  132. String firstForm = this.getStartForm1(deploymentId);
  133. // 这里的代码提取出去成为getStartFormAndData
  134. StringBuffer firstFormAndData = setFormAndData(
  135. rowStart, formData1, firstForm);
  136. taskModel.setFirstFormAndData(firstFormAndData
  137. .toString());
  138. taskModel.setFormData(formData);
  139. taskList.add(taskModel);
  140. }
  141. }
  142. }
  143. map.put("isLogin", "yes");
  144. map.put("userName",
  145. (String) req.getSession().getAttribute("userName"));
  146. map.put("result", "success");
  147. map.put("data", taskList);
  148. } else {
  149. map.put("isLogin", "no");
  150. }
  151. return map;
  152. }

我觉得这里边最重要的便是如何判断究竟是别人提交给我的，还是我自己申请的任务，而这里边如果用流程节点flowElevent来判断的话，会出现一些问题，因为我操作的过程中发现，当一个任务后便的连线不唯一时，各个节点的顺序也是不固定的，endEvent并不一定就在最后边，因此还需要从其他的地方进行判断。

如果有需要了解的朋友，可以把之前的那个我的申请列表的代码和这个一起拿到eclipse中对比一下，然后大概就能了解个七七八八了。

那么对于我的任务，也就是别人提交给我的任务列表，其相关的前端代码，与我的申请的前端代码非常类似，我也就不列出了。

还有之后的历史任务等等，也都可以结合之前的内容，只要了解了流程节点的结构，以及各个表的关联关系，那么简单实现自定义应该就不是太难。难得就是真正的要逻辑非常缜密，然后更加智能。

相关文章