Commit 47b93f87 by yanlj@bbdtek.com

获取当前任务节点的所有分支节点

parent a69f6166
package com.bbd.bpm.controller.taskOperate; package com.bbd.bpm.controller.taskOperate;
import com.alibaba.fastjson.JSON;
import com.bbd.bpm.dto.PageUtil; import com.bbd.bpm.dto.PageUtil;
import com.bbd.bpm.dto.SysCode; import com.bbd.bpm.dto.SysCode;
import com.bbd.bpm.dto.request.CompleteTaskRequest; import com.bbd.bpm.dto.request.CompleteTaskRequest;
...@@ -17,8 +16,17 @@ import com.github.pagehelper.PageInfo; ...@@ -17,8 +16,17 @@ import com.github.pagehelper.PageInfo;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.activiti.bpmn.model.BpmnModel; import org.activiti.bpmn.model.BpmnModel;
import org.activiti.engine.*; import org.activiti.bpmn.model.FlowElement;
import org.activiti.bpmn.model.SequenceFlow;
import org.activiti.bpmn.model.UserTask;
import org.activiti.engine.HistoryService;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.impl.ProcessInstanceQueryImpl;
import org.activiti.engine.impl.RepositoryServiceImpl;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity; import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.util.ProcessDefinitionUtil; import org.activiti.engine.impl.util.ProcessDefinitionUtil;
import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.runtime.ProcessInstance;
...@@ -30,14 +38,10 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -30,14 +38,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.io.*; import java.io.IOException;
import java.util.*; import java.util.*;
import static com.sun.mail.util.ASCIIUtility.getBytes;
/** /**
* Created by houkang on 2019/2/27. * Created by houkang on 2019/2/27.
*/ */
...@@ -69,7 +73,7 @@ public class TaskOperateController { ...@@ -69,7 +73,7 @@ public class TaskOperateController {
@ApiOperation(value = "查询我发起的流程") @ApiOperation(value = "查询我发起的流程")
@PostMapping("/queryStartedPiByUserId") @PostMapping("/queryStartedPiByUserId")
@ResponseBody @ResponseBody
public BpmResponse queryStartedPiByUserId(@RequestBody QueryStartedPiByUserIdRequest req) { public BpmResponse queryStartedPiByUserId(@RequestBody QueryStartedPiByUserIdRequest req) {
BpmResponse resp = new BpmResponse(); BpmResponse resp = new BpmResponse();
try { try {
//数据校验 //数据校验
...@@ -168,7 +172,7 @@ public class TaskOperateController { ...@@ -168,7 +172,7 @@ public class TaskOperateController {
resp.setSuccess(false); resp.setSuccess(false);
return resp; return resp;
} }
PageUtil pageUtil = req.getPage(); PageUtil pageUtil = req.getPage();
//任务办理人 //任务办理人
PageHelper.startPage(pageUtil.getPageNumber(), pageUtil.getPageSize()); PageHelper.startPage(pageUtil.getPageNumber(), pageUtil.getPageSize());
List<Task> taskList = taskService.createTaskQuery().taskAssignee(req.getAssignee()).listPage(pageUtil.getPageNumber(), pageUtil.getPageSize()); List<Task> taskList = taskService.createTaskQuery().taskAssignee(req.getAssignee()).listPage(pageUtil.getPageNumber(), pageUtil.getPageSize());
...@@ -341,7 +345,7 @@ public class TaskOperateController { ...@@ -341,7 +345,7 @@ public class TaskOperateController {
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
return null; return null;
} }
...@@ -350,7 +354,7 @@ public class TaskOperateController { ...@@ -350,7 +354,7 @@ public class TaskOperateController {
public byte[] getdeployMent(SpecialRequest request, HttpServletResponse response) { public byte[] getdeployMent(SpecialRequest request, HttpServletResponse response) {
try { try {
byte[] bytes = activitiService.getdeployMent(request); byte[] bytes = activitiService.getdeployMent(request);
return bytes; return bytes;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
...@@ -360,17 +364,15 @@ public class TaskOperateController { ...@@ -360,17 +364,15 @@ public class TaskOperateController {
@ApiOperation(value = "根据任务id获取本节点的所有出路") @ApiOperation(value = "根据任务id获取本节点的所有出路")
@GetMapping("/outGoing") @GetMapping("/outGoing")
@ResponseBody @ResponseBody
public BpmResponse outGoing(String taskId,String processInstanceId) { public BpmResponse outGoing(String taskId) {
BpmResponse resp = new BpmResponse(); BpmResponse resp = new BpmResponse();
try { try {
ProcessInstance pi =runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
System.out.println(pi.getProcessDefinitionId());
BpmnModel bpmnModel = ProcessDefinitionUtil.getBpmnModel(pi.getProcessDefinitionId());
//获取前一个活动节点的实现类对象
bpmnModel.getFlowLocationMap();
Task myTask = taskService.createTaskQuery().taskId(taskId).singleResult();
BpmnModel bpmnModel = repositoryService.getBpmnModel(myTask.getProcessDefinitionId());
UserTask userTask = (UserTask)bpmnModel.getFlowElement(myTask.getTaskDefinitionKey());
List<SequenceFlow> outgoingFlows = userTask.getOutgoingFlows();
resp.setData(outgoingFlows);
resp.setSuccess(true); resp.setSuccess(true);
resp.setMessage("根据任务id获取本节点的所有出路成功"); resp.setMessage("根据任务id获取本节点的所有出路成功");
} catch (Exception e) { } catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment