增加serviceTask处理类

src/main/java/com/bbd/bpm/controller/taskOperate/TaskOperateController.java

@@ -16,8 +16,11 @@ import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.activiti.bpmn.model.BpmnModel;
 import org.activiti.engine.*;
 import org.activiti.engine.history.HistoricProcessInstance;
+import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
+import org.activiti.engine.impl.util.ProcessDefinitionUtil;
 import org.activiti.engine.runtime.ProcessInstance;
 import org.activiti.engine.task.Task;
 import org.apache.commons.lang3.StringUtils;
@@ -57,13 +60,16 @@ public class TaskOperateController {
     @Autowired
     private ActivitiService activitiService;
 
+    @Autowired
+    private RepositoryService repositoryService;
+
     /**
      * taskStatus 1 已完成  2 未完成  3 全部
      */
     @ApiOperation(value = "查询我发起的流程")
     @PostMapping("/queryStartedPiByUserId")
     @ResponseBody
-    public BpmResponse queryStartedPiByUserId(QueryStartedPiByUserIdRequest req, PageUtil pageUtil) {
+    public BpmResponse queryStartedPiByUserId(@RequestBody  QueryStartedPiByUserIdRequest req) {
         BpmResponse resp = new BpmResponse();
         try {
             //数据校验
@@ -75,6 +81,7 @@ public class TaskOperateController {
                 resp.setSuccess(false);
                 return resp;
             }
+            PageUtil pageUtil = req.getPage();
             // QueryPiByUserIdBean
             //任务办理人
             PageHelper.startPage(pageUtil.getPageNumber(), pageUtil.getPageSize());
@@ -149,7 +156,7 @@ public class TaskOperateController {
     @ApiOperation(value = "查询待处理任务")
     @PostMapping("/pendingTaskList")
     @ResponseBody
-    public BpmResponse pendingTaskList(PendingTaskListRequest req, PageUtil pageUtil) {
+    public BpmResponse pendingTaskList(@RequestBody PendingTaskListRequest req) {
         BpmResponse resp = new BpmResponse();
         try {
             //数据校验
@@ -161,6 +168,7 @@ public class TaskOperateController {
                 resp.setSuccess(false);
                 return resp;
             }
+            PageUtil pageUtil  = req.getPage();
             //任务办理人
             PageHelper.startPage(pageUtil.getPageNumber(), pageUtil.getPageSize());
             List<Task> taskList = taskService.createTaskQuery().taskAssignee(req.getAssignee()).listPage(pageUtil.getPageNumber(), pageUtil.getPageSize());
@@ -349,4 +357,27 @@ public class TaskOperateController {
         return null;
     }
 
+    @ApiOperation(value = "根据任务id获取本节点的所有出路")
+    @GetMapping("/outGoing")
+    @ResponseBody
+    public BpmResponse outGoing(String taskId,String processInstanceId) {
+        BpmResponse resp = new BpmResponse();
+        try {
+            ProcessInstance pi =runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
+
+            System.out.println(pi.getProcessDefinitionId());
+
+            BpmnModel bpmnModel = ProcessDefinitionUtil.getBpmnModel(pi.getProcessDefinitionId());
+            //获取前一个活动节点的实现类对象
+            bpmnModel.getFlowLocationMap();
+
+            resp.setSuccess(true);
+            resp.setMessage("根据任务id获取本节点的所有出路成功");
+        } catch (Exception e) {
+            Log.error("根据任务id获取本节点的所有出路失败", e);
+            resp.setSuccess(false);
+        }
+        return resp;
+    }
+
 }