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); + } + +}