package com.dl.web.controller.workflow;
|
|
import cn.dev33.satoken.annotation.SaCheckPermission;
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.dl.common.annotation.Log;
|
import com.dl.common.core.controller.BaseController;
|
import com.dl.common.core.domain.PageQuery;
|
import com.dl.common.core.domain.R;
|
import com.dl.common.core.page.TableDataInfo;
|
import com.dl.common.enums.BusinessType;
|
import com.dl.common.utils.poi.ExcelUtil;
|
import com.dl.flowable.core.domain.ProcessQuery;
|
import com.dl.workflow.domain.bo.WfCopyBo;
|
import com.dl.workflow.domain.vo.*;
|
import com.dl.workflow.service.IWfCopyService;
|
import com.dl.workflow.service.IWfProcessService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 工作流流程管理
|
*
|
* @author KonBAI
|
* @createTime 2022/3/24 18:54
|
*/
|
@Slf4j
|
@RequiredArgsConstructor
|
@RestController
|
@RequestMapping("/workflow/process")
|
public class WfProcessController extends BaseController {
|
|
private final IWfProcessService processService;
|
private final IWfCopyService copyService;
|
|
/**
|
* 查询可发起流程列表
|
*
|
* @param pageQuery 分页参数
|
*/
|
@GetMapping(value = "/list")
|
@SaCheckPermission("workflow:process:startList")
|
public TableDataInfo<WfDefinitionVo> startProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
|
return processService.selectPageStartProcessList(processQuery, pageQuery);
|
}
|
|
/**
|
* 我拥有的流程
|
*/
|
@SaCheckPermission("workflow:process:ownList")
|
@GetMapping(value = "/ownList")
|
public TableDataInfo<WfTaskVo> ownProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
|
return processService.selectPageOwnProcessList(processQuery, pageQuery);
|
}
|
|
/**
|
* 获取待办列表
|
*/
|
@SaCheckPermission("workflow:process:todoList")
|
@GetMapping(value = "/todoList")
|
public TableDataInfo<WfTaskVo> todoProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
|
return processService.selectPageTodoProcessList(processQuery, pageQuery);
|
}
|
|
/**
|
* 获取待签列表
|
*
|
* @param processQuery 流程业务对象
|
* @param pageQuery 分页参数
|
*/
|
@SaCheckPermission("workflow:process:claimList")
|
@GetMapping(value = "/claimList")
|
public TableDataInfo<WfTaskVo> claimProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
|
return processService.selectPageClaimProcessList(processQuery, pageQuery);
|
}
|
|
/**
|
* 获取已办列表
|
*
|
* @param pageQuery 分页参数
|
*/
|
@SaCheckPermission("workflow:process:finishedList")
|
@GetMapping(value = "/finishedList")
|
public TableDataInfo<WfTaskVo> finishedProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
|
return processService.selectPageFinishedProcessList(processQuery, pageQuery);
|
}
|
|
/**
|
* 获取抄送列表
|
*
|
* @param copyBo 流程抄送对象
|
* @param pageQuery 分页参数
|
*/
|
@SaCheckPermission("workflow:process:copyList")
|
@GetMapping(value = "/copyList")
|
public TableDataInfo<WfCopyVo> copyProcessList(WfCopyBo copyBo, PageQuery pageQuery) {
|
copyBo.setUserId(getUserId());
|
return copyService.selectPageList(copyBo, pageQuery);
|
}
|
|
/**
|
* 导出可发起流程列表
|
*/
|
@SaCheckPermission("workflow:process:startExport")
|
@Log(title = "可发起流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/startExport")
|
public void startExport(@Validated ProcessQuery processQuery, HttpServletResponse response) {
|
List<WfDefinitionVo> list = processService.selectStartProcessList(processQuery);
|
ExcelUtil.exportExcel(list, "可发起流程", WfDefinitionVo.class, response);
|
}
|
|
/**
|
* 导出我拥有流程列表
|
*/
|
@SaCheckPermission("workflow:process:ownExport")
|
@Log(title = "我拥有流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/ownExport")
|
public void ownExport(@Validated ProcessQuery processQuery, HttpServletResponse response) {
|
List<WfTaskVo> list = processService.selectOwnProcessList(processQuery);
|
List<WfOwnTaskExportVo> listVo = BeanUtil.copyToList(list, WfOwnTaskExportVo.class);
|
for (WfOwnTaskExportVo exportVo : listVo) {
|
exportVo.setStatus(ObjectUtil.isNull(exportVo.getFinishTime()) ? "进行中" : "已完成");
|
}
|
ExcelUtil.exportExcel(listVo, "我拥有流程", WfOwnTaskExportVo.class, response);
|
}
|
|
/**
|
* 导出待办流程列表
|
*/
|
@SaCheckPermission("workflow:process:todoExport")
|
@Log(title = "待办流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/todoExport")
|
public void todoExport(@Validated ProcessQuery processQuery, HttpServletResponse response) {
|
List<WfTaskVo> list = processService.selectTodoProcessList(processQuery);
|
List<WfTodoTaskExportVo> listVo = BeanUtil.copyToList(list, WfTodoTaskExportVo.class);
|
ExcelUtil.exportExcel(listVo, "待办流程", WfTodoTaskExportVo.class, response);
|
}
|
|
/**
|
* 导出待签流程列表
|
*/
|
@SaCheckPermission("workflow:process:claimExport")
|
@Log(title = "待签流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/claimExport")
|
public void claimExport(@Validated ProcessQuery processQuery, HttpServletResponse response) {
|
List<WfTaskVo> list = processService.selectClaimProcessList(processQuery);
|
List<WfClaimTaskExportVo> listVo = BeanUtil.copyToList(list, WfClaimTaskExportVo.class);
|
ExcelUtil.exportExcel(listVo, "待签流程", WfClaimTaskExportVo.class, response);
|
}
|
|
/**
|
* 导出已办流程列表
|
*/
|
@SaCheckPermission("workflow:process:finishedExport")
|
@Log(title = "已办流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/finishedExport")
|
public void finishedExport(@Validated ProcessQuery processQuery, HttpServletResponse response) {
|
List<WfTaskVo> list = processService.selectFinishedProcessList(processQuery);
|
List<WfFinishedTaskExportVo> listVo = BeanUtil.copyToList(list, WfFinishedTaskExportVo.class);
|
ExcelUtil.exportExcel(listVo, "已办流程", WfFinishedTaskExportVo.class, response);
|
}
|
|
/**
|
* 导出抄送流程列表
|
*/
|
@SaCheckPermission("workflow:process:copyExport")
|
@Log(title = "抄送流程", businessType = BusinessType.EXPORT)
|
@PostMapping("/copyExport")
|
public void copyExport(WfCopyBo copyBo, HttpServletResponse response) {
|
copyBo.setUserId(getUserId());
|
List<WfCopyVo> list = copyService.selectList(copyBo);
|
ExcelUtil.exportExcel(list, "抄送流程", WfCopyVo.class, response);
|
}
|
|
/**
|
* 查询流程部署关联表单信息
|
*
|
* @param definitionId 流程定义id
|
* @param deployId 流程部署id
|
*/
|
@GetMapping("/getProcessForm")
|
@SaCheckPermission("workflow:process:start")
|
public R<?> getForm(@RequestParam(value = "definitionId") String definitionId,
|
@RequestParam(value = "deployId") String deployId,
|
@RequestParam(value = "procInsId", required = false) String procInsId) {
|
return R.ok(processService.selectFormContent(definitionId, deployId, procInsId));
|
}
|
|
/**
|
* 根据流程定义id启动流程实例
|
*
|
* @param processDefId 流程定义id
|
* @param variables 变量集合,json对象
|
*/
|
@SaCheckPermission("workflow:process:start")
|
@PostMapping("/start/{processDefId}")
|
public R<Void> start(@PathVariable(value = "processDefId") String processDefId, @RequestBody Map<String, Object> variables) {
|
processService.startProcessByDefId(processDefId, variables);
|
return R.ok("流程启动成功");
|
|
}
|
|
/**
|
* 删除流程实例
|
*
|
* @param instanceIds 流程实例ID串
|
*/
|
@DeleteMapping("/instance/{instanceIds}")
|
public R<Void> delete(@PathVariable String[] instanceIds) {
|
processService.deleteProcessByIds(instanceIds);
|
return R.ok();
|
}
|
|
/**
|
* 读取xml文件
|
* @param processDefId 流程定义ID
|
*/
|
@GetMapping("/bpmnXml/{processDefId}")
|
public R<String> getBpmnXml(@PathVariable(value = "processDefId") String processDefId) {
|
return R.ok(null, processService.queryBpmnXmlById(processDefId));
|
}
|
|
/**
|
* 查询流程详情信息
|
*
|
* @param procInsId 流程实例ID
|
* @param taskId 任务ID
|
*/
|
@GetMapping("/detail")
|
public R detail(String procInsId, String taskId) {
|
return R.ok(processService.queryProcessDetail(procInsId, taskId));
|
}
|
|
|
/**
|
* 根据业务主键id查询流程信息
|
* @param businessKey
|
* @return
|
*/
|
@GetMapping("/detail/{businessKey}")
|
public R detail(@PathVariable String businessKey) {
|
return R.ok(processService.queryProcessDetail(businessKey));
|
}
|
}
|
