/**
|
* 版权所有，侵权必究！
|
*/
|
|
package com.zt.modules.workflow.controller;
|
|
import com.zt.common.servlet.Result;
|
import com.zt.modules.workflow.model.WfRunInstance;
|
import com.zt.modules.workflow.model.WfRunTask;
|
import com.zt.modules.workflow.service.WfRunInstanceService;
|
import com.zt.modules.workflow.service.WorkflowService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 工作流controller
|
*
|
* @author 朱曙光
|
* @since 1.0.0
|
*/
|
@RestController
|
@RequestMapping("wf")
|
@Api(value = "工作流", tags = "工作流")
|
public class WorkflowController {
|
@Autowired
|
private WorkflowService workflowService;
|
@Autowired
|
private WfRunInstanceService wfRunInstanceService;
|
|
// @PostMapping("queryAllSteps")
|
// @ApiOperation("查询steps")
|
// public Result queryAllSteps(@RequestBody WorkflowDto workflowDto) {
|
// List<WfDefStep> list = null;
|
// try {
|
// list = workflowService.queryAllSteps(workflowDto.getWfCode());
|
// } catch (RuntimeException e) {
|
// return Result.error(e.getLocalizedMessage());
|
// }
|
// return Result.ok(list);
|
// }
|
//
|
// @PostMapping("queryAllSteps2")
|
// @ApiOperation("查询steps")
|
// public Result queryAllSteps2(@RequestBody WorkflowDto workflowDto) {
|
// List<WfDefStep> list = null;
|
// try {
|
// list = workflowService.queryAllSteps2(workflowDto.getWfCode(), new Long(workflowDto.getWfRunLog().getBizId()));
|
// } catch (RuntimeException e) {
|
// return Result.error(e.getLocalizedMessage());
|
// }
|
// return Result.ok(list);
|
// }
|
//
|
// @PostMapping("queryWfCurrentInfo")
|
// @ApiOperation("查询流程当前信息")
|
// public Result queryWfCurrentInfo(@RequestBody WorkflowDto workflowDto) {
|
// QueryWfInfoDto dto = null;
|
// try {
|
// dto = workflowService.queryWfCurrentInfo(workflowDto.getWfCode(), new Long(workflowDto.getWfRunLog().getBizId()));
|
// } catch (RuntimeException e) {
|
// return Result.error(e.getLocalizedMessage());
|
// }
|
// return Result.ok(dto);
|
// }
|
//
|
// @PostMapping("approve")
|
// @ApiOperation("提交同意")
|
// public Result approve(@RequestBody WorkflowDto workflowDto) {
|
// try {
|
// workflowService.startProcess(workflowDto.getWfCode(), new Long(workflowDto.getWfRunLog().getBizId()));
|
// if ("no".equalsIgnoreCase(workflowDto.getWfRunLog().getApproveAction())) {
|
// workflowService.refuse(workflowDto.getWfCode(), workflowDto.getWfRunLog());
|
// } else {
|
// workflowService.approve(workflowDto.getWfCode(), workflowDto.getWfRunLog());
|
// }
|
// } catch (RuntimeException e) {
|
// return Result.error(e.getLocalizedMessage());
|
// }
|
// return Result.ok();
|
// }
|
//
|
//
|
//
|
// @PostMapping("refuse")
|
// @ApiOperation("回退")
|
// @LogOperation("回退")
|
// public Result refuse(@RequestBody WorkflowDto workflowDto, HttpServletResponse response) throws Exception {
|
// workflowService.refuse(workflowDto.getWfCode(), workflowDto.getWfRunLog());
|
// return Result.ok();
|
// }
|
//
|
// @PostMapping("queryFirstStep")
|
// @ApiOperation("查询第一步")
|
// @LogOperation("查询第一步")
|
// public Result<WfDefStep> queryFirstStep(@RequestBody WorkflowDto workflowDto, HttpServletResponse response) throws Exception {
|
// WfDefStep step = workflowService.queryFirstStep(workflowDto.getWfCode());
|
// return Result.ok(step);
|
// }
|
//
|
// @PostMapping("queryCurrentStep")
|
// @ApiOperation("查询当前步")
|
// @LogOperation("查询当前步")
|
// public Result<WfDefStep> queryCurrentStep(@RequestBody WorkflowDto workflowDto, HttpServletResponse response) throws Exception {
|
// WfDefStep step = workflowService.queryCurrentStep(workflowDto.getWfCode(), new Long(workflowDto.getWfRunLog().getBizId()));
|
// return Result.ok(step);
|
// }
|
|
// @PostMapping("saveDraft")
|
// @ApiOperation("保存审批草稿数据")
|
// @LogOperation("保存审批草稿数据")
|
// public Result<WfDefStep> saveDraft(@RequestBody WorkflowDto workflowDto, HttpServletResponse response) throws Exception {
|
// if (workflowDto.getWfRunLog().getApproverIds() == null || StringUtils.isEmpty(workflowDto.getWfRunLog().getApproverIds())) {
|
// workflowDto.getWfRunLog().setApproverIds(UserContext.getUserId().toString());
|
// }
|
// workflowService.saveDraft(workflowDto);
|
// return Result.ok(null);
|
// }
|
|
// @PostMapping("queryDraft")
|
// @ApiOperation("查询审批草稿数据")
|
// @LogOperation("查询审批草稿数据")
|
// public Result<WfRunLogDraft> queryDraft(@RequestBody WorkflowDto workflowDto, HttpServletResponse response) throws Exception {
|
// if (workflowDto.getWfRunLog().getApproverIds() == null || StringUtils.isEmpty(workflowDto.getWfRunLog().getApproverIds())) {
|
// workflowDto.getWfRunLog().setApproverIds(UserContext.getUserId().toString());
|
// }
|
// WfRunLogDraft draft = workflowService.queryDraft(workflowDto);
|
// return Result.ok(draft);
|
// }
|
|
|
@GetMapping("/approvePass")
|
@ApiOperation("审批通过")
|
public Result<String> approvePass(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId, @RequestParam("stepIdMark") String stepIdMark) {
|
workflowService.approvePass(wfIdCode, bizId, stepIdMark);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/approvePass2")
|
@ApiOperation("审批通过")
|
public Result<String> approvePass2(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId, @RequestParam("stepIdMark") String stepIdMark,@RequestParam("nextStepIdMark") String nextStepIdMark) {
|
workflowService.approvePass2(wfIdCode, bizId, stepIdMark,nextStepIdMark);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/approveRefuse")
|
@ApiOperation("审批驳回")
|
public Result<String> approveRefuse(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId, @RequestParam("stepIdMark") String stepIdMark) {
|
workflowService.approveRefuse(wfIdCode, bizId, stepIdMark);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/approveRefuse2")
|
@ApiOperation("审批驳回")
|
public Result<String> approveRefuse2(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId, @RequestParam("stepIdMark") String stepIdMark,@RequestParam("prevStepIdMark") String prevStepIdMark) {
|
workflowService.approveRefuse2(wfIdCode, bizId, stepIdMark,prevStepIdMark);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/reStartFlow")
|
@ApiOperation("重新启动流程")
|
public Result<String> reStartFlow(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId, @RequestParam("stepIdMark") String stepIdMark,@RequestParam("prevStepIdMark") String prevStepIdMark) {
|
workflowService.reStartFlow(wfIdCode, bizId, stepIdMark,prevStepIdMark);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/startFlow")
|
@ApiOperation("启动流程")
|
public Result<Boolean> startFlow(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId) {
|
Boolean result = workflowService.startFlow(wfIdCode, bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/deleteFlowTask")
|
@ApiOperation("删除流程")
|
public Result<String> deleteFlowTask(@RequestParam("wfIdCode") String wfIdCode, @RequestParam("bizId") Long bizId) {
|
workflowService.deleteFlowTask(wfIdCode, bizId);
|
return Result.ok("删除完成");
|
}
|
|
@GetMapping("/getFlowStatus")
|
@ApiOperation("类型1流程状态")
|
public Result<Map<String, WfRunTask>> getFlowStatus(String wfIdCodes, Long bizId) {
|
Map<String, WfRunTask> result = workflowService.getFlowStatus(wfIdCodes, bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getAllSteps")
|
@ApiOperation("类型1流程状态")
|
public Result<Map<String, Map<String, String>>> getAllSteps() {
|
Map<String, Map<String, String>> result = workflowService.getAllSteps();
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getSingleFlowStatus")
|
@ApiOperation("单个类型流程状态")
|
public Result<Map<String, WfRunTask>> getSingleFlowStatus(String wfIdCodes, Long bizId) {
|
Map<String, WfRunTask> result = workflowService.getSingleFlowStatus(wfIdCodes, bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getFlowStatus2")
|
@ApiOperation("类型2流程状态")
|
public Result<Map<String, WfRunTask>> getFlowStatus2(String wfIdCodes, Long bizId) {
|
Map<String, WfRunTask> result = workflowService.getFlowStatus2(wfIdCodes, bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getPlanFlowStatus")
|
@ApiOperation("计划修理总体流程状态")
|
public Result<Map<String, Integer>> getPlanFlowStatus(Long bizId) {
|
Map<String, Integer> result = workflowService.getPlanFlowStatus(bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getFlowStepStatus")
|
@ApiOperation("流程步骤状态")
|
public Result<WfRunTask> getFlowStepStatus(String wfIdCodes, Long bizId, String stepIdMark) {
|
WfRunTask result = workflowService.getFlowStepStatus(wfIdCodes, bizId, stepIdMark);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getStepCount")
|
@ApiOperation("流程步骤")
|
public Result<List<Map<String, Object>>> getStepCount(String wfIdCodes,Long bizId) {
|
return Result.ok(workflowService.getStepCount(wfIdCodes,bizId));
|
}
|
|
@GetMapping("/hasExistFlow")
|
@ApiOperation("流程步骤")
|
public Boolean hasExistFlow(String wfIdCode,Long bizId) {
|
return workflowService.hasExistFlow(wfIdCode,bizId);
|
}
|
|
@GetMapping("/reCallFlow")
|
@ApiOperation("撤回流程")
|
public Result<String> recallFlow(String flowCode, Long bizId, String stepMarker, Long id, Long prevId) {
|
String result = workflowService.recallFlow(flowCode, bizId, stepMarker, id, prevId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/getFlowInstance")
|
@ApiOperation("获取流程步骤")
|
public Result<WfRunInstance> getFlowInstance(String flowCode, Long bizId) {
|
WfRunInstance flowInstance = wfRunInstanceService.getFlowInstance(flowCode, bizId);
|
return Result.ok(flowInstance);
|
}
|
|
@GetMapping("/getFlowTrack")
|
@ApiOperation("获取流程步骤")
|
public Result<List<WfRunTask>> getFlowTrack(String flowCode, Long bizId) {
|
List<WfRunTask> flowTrack = workflowService.getFlowTrack(flowCode, bizId);
|
return Result.ok(flowTrack);
|
}
|
|
@GetMapping("/getFlowStepName")
|
@ApiOperation("获取当前流程步骤名称")
|
public Result<String> getFlowStepName(String wfIdCodes, Long bizId) {
|
String result = workflowService.getFlowStepName(wfIdCodes, bizId);
|
return Result.ok(result);
|
}
|
|
@GetMapping("/setTaskPartFinish2")
|
@ApiOperation("审批通过")
|
public Result<String> setTaskPartFinish2(@RequestParam("bizId") Long bizId, @RequestParam("receiveId") Long receiveId, @RequestParam("status") Integer status) {
|
workflowService.setTaskPartFinish2(bizId, receiveId, status);
|
return Result.ok("审批完成");
|
}
|
|
@GetMapping("/setTaskPartFinish3")
|
@ApiOperation("审批通过")
|
public Result<String> setTaskPartFinish3(@RequestParam("bizId") Long bizId, @RequestParam("receiveDeptId") Long receiveDeptId, @RequestParam("status") Integer status) {
|
workflowService.setTaskPartFinish3(bizId, receiveDeptId, status);
|
return Result.ok("审批完成");
|
}
|
|
}
|
