From 438edb21c57f03c5867de34e1417a4333d0c03b8 Mon Sep 17 00:00:00 2001
From: Yen <yen1130@qq.com>
Date: Tue, 23 Aug 2022 11:00:53 +0800
Subject: [PATCH] =?UTF-8?q?controller=E5=B1=82=E6=95=B4=E5=90=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../bpm/controller/FlowTaskController.java    | 215 ++++++++++++++++++
 1 file changed, 215 insertions(+)
 create mode 100644 src/main/java/com/qs/serve/modules/bpm/controller/FlowTaskController.java

diff --git a/src/main/java/com/qs/serve/modules/bpm/controller/FlowTaskController.java b/src/main/java/com/qs/serve/modules/bpm/controller/FlowTaskController.java
new file mode 100644
index 0000000..2b50c8b
--- /dev/null
+++ b/src/main/java/com/qs/serve/modules/bpm/controller/FlowTaskController.java
@@ -0,0 +1,215 @@
+package com.qs.serve.modules.bpm.controller;
+
+import com.qs.serve.common.model.dto.R;
+import com.qs.serve.modules.bpm.entity.dto.FlowTaskDto;
+import com.qs.serve.modules.bpm.entity.vo.FlowTaskVo;
+import com.qs.serve.modules.bpm.service.IFlowTaskService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 工作流任务
+ * @author YenHex
+ * @since 2022/8/23
+ */
+@Slf4j
+@AllArgsConstructor
+@RestController
+@RequestMapping("bpm/task")
+public class FlowTaskController {
+
+    private IFlowTaskService flowTaskService;
+
+    /**
+     * 我发起的流程
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @GetMapping(value = "/myProcess")
+    public R myProcess(@RequestParam Integer pageNum,@RequestParam Integer pageSize) {
+        return flowTaskService.myProcess(pageNum, pageSize);
+    }
+
+    /**
+     * 取消申请
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/stopProcess")
+    public R stopProcess(@RequestBody FlowTaskVo flowTaskVo) {
+        return flowTaskService.stopProcess(flowTaskVo);
+    }
+
+    /**
+     * 撤回流程
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/revokeProcess")
+    public R revokeProcess(@RequestBody FlowTaskVo flowTaskVo) {
+        return flowTaskService.revokeProcess(flowTaskVo);
+    }
+
+    /**
+     * 获取待办列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @GetMapping(value = "/todoList")
+    public R todoList(@RequestParam Integer pageNum,@RequestParam Integer pageSize) {
+        return flowTaskService.todoList(pageNum, pageSize);
+    }
+
+    /**
+     * 获取已办任务
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @GetMapping(value = "/finishedList")
+    public R finishedList(@RequestParam Integer pageNum,@RequestParam Integer pageSize) {
+        return flowTaskService.finishedList(pageNum, pageSize);
+    }
+
+    /**
+     * 流程历史流转记录
+     * @param procInsId
+     * @param deployId
+     * @return
+     */
+    @GetMapping(value = "/flowRecord")
+    public R flowRecord(String procInsId, String deployId) {
+        return flowTaskService.flowRecord(procInsId, deployId);
+    }
+
+    /**
+     * 获取流程变量
+     * @param taskId
+     * @return
+     */
+    @GetMapping(value = "/processVariables/{taskId}")
+    public R processVariables( @PathVariable(value = "taskId") String taskId) {
+        return flowTaskService.processVariables(taskId);
+    }
+
+    /**
+     * 审批任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/complete")
+    public R complete(@RequestBody FlowTaskVo flowTaskVo) {
+        return flowTaskService.complete(flowTaskVo);
+    }
+
+    /**
+     * 驳回任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/reject")
+    public R taskReject(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.taskReject(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 退回任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/return")
+    public R taskReturn(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.taskReturn(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 获取所有可回退的节点
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping("/returnList")
+    public R findReturnTaskList(@RequestBody FlowTaskVo flowTaskVo) {
+        return flowTaskService.findReturnTaskList(flowTaskVo);
+    }
+
+    /**
+     * 删除任务
+     * @param flowTaskVo
+     * @return
+     */
+    @DeleteMapping(value = "/delete")
+    public R delete(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.deleteTask(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 认领/签收任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/claim")
+    public R claim(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.claim(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 取消认领/签收任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/unClaim")
+    public R unClaim(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.unClaim(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 委派任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/delegate")
+    public R delegate(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.delegateTask(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 转办任务
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/assign")
+    public R assign(@RequestBody FlowTaskVo flowTaskVo) {
+        flowTaskService.assignTask(flowTaskVo);
+        return R.ok();
+    }
+
+    /**
+     * 获取下一节点
+     * @param flowTaskVo
+     * @return
+     */
+    @PostMapping(value = "/nextFlowNode")
+    public R getNextFlowNode(@RequestBody FlowTaskVo flowTaskVo) {
+        return flowTaskService.getNextFlowNode(flowTaskVo);
+    }
+
+    /**
+     * 获取流程执行过程
+     * @param procInsId 流程实例编号
+     * @param procInsId 任务执行编号
+     */
+    @RequestMapping("/flowViewer")
+    public R getFlowViewer( String procInsId, String executionId) {
+        return flowTaskService.getFlowViewer(procInsId, executionId);
+    }
+
+}