package jnpf.flowable.controller;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.google.common.collect.ImmutableList;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jnpf.base.ActionResult;
|
import jnpf.base.Pagination;
|
import jnpf.base.controller.SuperController;
|
import jnpf.base.vo.ListVO;
|
import jnpf.base.vo.PaginationVO;
|
import jnpf.constant.MsgCode;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.flowable.entity.CirculateEntity;
|
import jnpf.flowable.entity.OperatorEntity;
|
import jnpf.flowable.entity.RecordEntity;
|
import jnpf.flowable.entity.TaskEntity;
|
import jnpf.flowable.enums.*;
|
import jnpf.flowable.model.candidates.CandidateCheckFo;
|
import jnpf.flowable.model.candidates.CandidateCheckVo;
|
import jnpf.flowable.model.candidates.CandidateUserVo;
|
import jnpf.flowable.model.operator.FlowBatchModel;
|
import jnpf.flowable.model.operator.OperatorVo;
|
import jnpf.flowable.model.task.AuditModel;
|
import jnpf.flowable.model.task.FlowModel;
|
import jnpf.flowable.model.task.TaskPagination;
|
import jnpf.flowable.model.templatenode.BackNodeModel;
|
import jnpf.flowable.model.util.FlowNature;
|
import jnpf.flowable.service.CirculateService;
|
import jnpf.flowable.service.OperatorService;
|
import jnpf.flowable.service.RecordService;
|
import jnpf.flowable.service.TaskService;
|
import jnpf.flowable.util.FlowUtil;
|
import jnpf.flowable.util.OperatorUtil;
|
import jnpf.flowable.util.RedisLock;
|
import jnpf.flowable.util.ServiceUtil;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.UserProvider;
|
import jnpf.util.context.RequestContext;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* 类的描述
|
*
|
* @author JNPF@YinMai Info. Co., Ltd
|
* @version 5.0.x
|
* @since 2024/4/25 14:48
|
*/
|
@Tag(name = "经办", description = "OperatorController")
|
@RestController
|
@RequestMapping("/operator")
|
@RequiredArgsConstructor
|
public class OperatorController extends SuperController<OperatorService, OperatorEntity> {
|
private final OperatorService operatorService;
|
private final TaskService taskService;
|
@Autowired
|
private ServiceUtil serviceUtil;
|
@Autowired
|
private RecordService recordService;
|
@Autowired
|
private CirculateService circulateService;
|
@Autowired
|
private FlowUtil flowUtil;
|
@Autowired
|
private OperatorUtil operatorUtil;
|
@Autowired
|
private RedisLock redisLock;
|
|
/**
|
* 判断候选人
|
*
|
* @param id 经办主键
|
* @param fo 参数类
|
*/
|
@Operation(summary = "判断候选人")
|
@PostMapping("/CandidateNode/{id}")
|
public ActionResult candidates(@PathVariable("id") String id, @RequestBody CandidateCheckFo fo) throws WorkFlowException {
|
OperatorEntity info = !ObjectUtil.equals(id, "0") ? operatorService.getInfo(id) : null;
|
if (info != null) {
|
operatorUtil.checkOperatorPermission(id);
|
}
|
return ActionResult.success(taskService.checkCandidates(id, fo));
|
}
|
|
/**
|
* 获取候选人
|
*
|
* @param fo 参数类
|
*/
|
@Operation(summary = "获取候选人")
|
@PostMapping("/CandidateUser/{id}")
|
public ActionResult candidateUser(@PathVariable("id") String id, @RequestBody CandidateCheckFo fo) throws WorkFlowException {
|
OperatorEntity info = !ObjectUtil.equals(id, "0") ? operatorService.getInfo(id) : null;
|
if (info != null) {
|
operatorUtil.checkOperatorPermission(id);
|
}
|
List<CandidateUserVo> candidates = taskService.getCandidateUser(id, fo);
|
PaginationVO paginationVO = JsonUtil.getJsonToBean(fo, PaginationVO.class);
|
return ActionResult.page(candidates, paginationVO);
|
}
|
|
/**
|
* 列表
|
*
|
* @param category 列表标识
|
* @param pagination 参数
|
*/
|
@Operation(summary = "列表")
|
@GetMapping("/List/{category}")
|
public ActionResult list(@PathVariable("category") String category, TaskPagination pagination) {
|
List<OperatorVo> list = new ArrayList<>();
|
CategoryEnum categoryEnum = CategoryEnum.getType(category);
|
pagination.setCategory(categoryEnum.getType());
|
pagination.setDelegateType(true);
|
pagination.setSystemId(serviceUtil.getSystemCodeById(RequestContext.getAppCode()));
|
switch (categoryEnum) {
|
case Sign: // 待签
|
case Todo: // 待办
|
case Doing: // 在办
|
case BatchDoing: // 批量在办
|
list = operatorService.getList(pagination);
|
break;
|
case Done: // 已办
|
list = recordService.getList(pagination);
|
break;
|
case Circulate: // 抄送
|
list = circulateService.getList(pagination);
|
}
|
List<OperatorVo> vos = new ArrayList<>();
|
List<UserEntity> userList = serviceUtil.getUserName(list.stream().map(OperatorVo::getCreatorUserId).collect(Collectors.toList()));
|
for (OperatorVo operatorVo : list) {
|
OperatorVo vo = JsonUtil.getJsonToBean(operatorVo, OperatorVo.class);
|
UserEntity userEntity = userList.stream().filter(t -> t.getId().equals(vo.getCreatorUserId())).findFirst().orElse(null);
|
vo.setCreatorUser(userEntity != null ? userEntity.getRealName() + "/" + userEntity.getAccount() : "");
|
if (ObjectUtil.equals(operatorVo.getIsProcessing(), 1) && ObjectUtil.equals(operatorVo.getStatus(), OperatorStateEnum.Transfer.getCode())) {
|
vo.setStatus(OperatorStateEnum.TransferProcessing.getCode());
|
}
|
vos.add(vo);
|
}
|
PaginationVO paginationVO = JsonUtil.getJsonToBean(pagination, PaginationVO.class);
|
return ActionResult.page(vos, paginationVO);
|
}
|
|
/**
|
* 签收或退签
|
*
|
* @param flowModel 参数类，ids 主键集合、type 0 签收 1 退签
|
*/
|
@Operation(summary = "签收或退签")
|
@PostMapping("/Sign")
|
public ActionResult<String> sign(@RequestBody FlowModel flowModel) throws WorkFlowException {
|
operatorService.sign(flowModel);
|
return ActionResult.success(MsgCode.SU005.get());
|
}
|
|
/**
|
* 开始办理
|
*
|
* @param flowModel 参数类，ids 主键集合
|
*/
|
@Operation(summary = "开始办理")
|
@PostMapping("/Transact")
|
public ActionResult<String> startHandle(@RequestBody FlowModel flowModel) throws WorkFlowException {
|
operatorService.startHandle(flowModel);
|
return ActionResult.success(MsgCode.SU005.get());
|
}
|
|
/**
|
* 保存草稿
|
*
|
* @param id 经办主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "保存草稿")
|
@PostMapping("/SaveAudit/{id}")
|
public ActionResult<String> saveAudit(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws WorkFlowException {
|
operatorUtil.checkOperatorPermission(id);
|
operatorService.saveAudit(id, flowModel);
|
return ActionResult.success(MsgCode.SU002.get());
|
}
|
|
/**
|
* 同意拒绝
|
*
|
* @param id 经办主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "同意拒绝")
|
@PostMapping("/Audit/{id}")
|
public ActionResult audit(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws Exception {
|
OperatorEntity operator = operatorUtil.checkOperator(id);
|
TaskEntity taskEntity = taskService.getInfo(operator.getTaskId());
|
if (null == taskEntity) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
operatorUtil.checkOperatorPermission(id);
|
boolean lock = redisLock.lock(taskEntity.getId() + operator.getNodeId(), operator.getId(), 5, TimeUnit.SECONDS);
|
if (!lock) {
|
throw new WorkFlowException("当前节点正在审批中，请稍后再试");
|
}
|
Integer handleStatus = flowModel.getHandleStatus();
|
try {
|
operatorService.auditWithCheck(id, flowModel);
|
} catch (Exception e) {
|
operatorUtil.compensate(taskEntity);
|
throw e;
|
} finally {
|
redisLock.unlock(taskEntity.getId() + operator.getNodeId(), operator.getId());
|
}
|
operatorUtil.handleOperator();
|
operatorUtil.handleEvent();
|
taskEntity = flowModel.getTaskEntity();
|
if (taskEntity.getRejectDataId() == null) {
|
operatorUtil.autoAudit(flowModel);
|
operatorUtil.handleOperator();
|
operatorUtil.handleEvent();
|
}
|
operatorUtil.handleTaskStatus();
|
TaskEntity task = taskService.getById(taskEntity.getId());
|
taskEntity = task == null ? taskEntity : task;
|
AuditModel model = operatorUtil.getAuditModel(taskEntity.getId(), flowModel, operator);
|
String msg = Objects.equals(handleStatus, FlowNature.RejectCompletion) ? MsgCode.WF065.get() : MsgCode.WF066.get();
|
if (ObjectUtil.equals(operator.getIsProcessing(), FlowNature.Processing)) {
|
msg = MsgCode.WF148.get();
|
}
|
return ActionResult.success(msg, model);
|
}
|
|
/**
|
* 加签
|
*
|
* @param id 经办主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "加签")
|
@PostMapping("/AddSign/{id}")
|
public ActionResult<String> freeApprover(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws Exception {
|
operatorUtil.checkOperatorPermission(id);
|
operatorService.addSign(id, flowModel);
|
operatorUtil.autoAudit(flowModel);
|
operatorUtil.handleOperator();
|
operatorUtil.handleEvent();
|
return ActionResult.success(MsgCode.WF004.get());
|
}
|
|
|
/**
|
* 获取加签的人
|
*
|
* @param id 经办主键
|
* @param pagination 参数
|
*/
|
@Operation(summary = "获取加签的人")
|
@PostMapping("/AddSignUserIdList/{id}")
|
public ActionResult getAddSignUserIdList(@PathVariable("id") String id, @RequestBody Pagination pagination) throws WorkFlowException {
|
List<CandidateUserVo> reduceList = operatorService.getReduceList(id, pagination);
|
PaginationVO paginationVO = JsonUtil.getJsonToBean(pagination, PaginationVO.class);
|
return ActionResult.page(reduceList, paginationVO);
|
}
|
|
/**
|
* 减签
|
*
|
* @param flowModel 参数
|
* @param id 记录主键
|
*/
|
@Operation(summary = "减签")
|
@PostMapping("/ReduceApprover/{id}")
|
public ActionResult<String> reduceApprover(@RequestBody FlowModel flowModel, @PathVariable("id") String id) throws WorkFlowException {
|
RecordEntity record = recordService.getInfo(id);
|
if (null == record) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
if (!Objects.equals(record.getHandleId(), UserProvider.getLoginUserId())) {
|
throw new WorkFlowException(MsgCode.AD104.get());
|
}
|
operatorService.reduce(id, flowModel);
|
return ActionResult.success(MsgCode.WF069.get());
|
}
|
|
/**
|
* 获取退回的节点
|
*
|
* @param id 经办主键
|
*/
|
@Operation(summary = "获取退回的节点")
|
@GetMapping("/SendBackNodeList/{id}")
|
public ActionResult getFallbacks(@PathVariable("id") String id) throws WorkFlowException {
|
ListVO<BackNodeModel> vo = new ListVO<>();
|
vo.setList(operatorService.getFallbacks(id));
|
return ActionResult.success(vo);
|
}
|
|
/**
|
* 退回
|
*
|
* @param id 经办主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "退回")
|
@PostMapping("/SendBack/{id}")
|
public ActionResult<String> reject(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws Exception {
|
OperatorEntity operator = operatorUtil.checkOperator(id);
|
TaskEntity taskEntity = taskService.getInfo(operator.getTaskId());
|
if (null == taskEntity) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
operatorUtil.checkOperatorPermission(id);
|
try {
|
operatorService.back(id, flowModel);
|
} catch (Exception e) {
|
operatorUtil.compensate(taskEntity);
|
throw e;
|
}
|
operatorUtil.handleOperator();
|
operatorUtil.handleTaskStatus();
|
operatorUtil.handleEvent();
|
return ActionResult.success(MsgCode.WF002.get());
|
}
|
|
/**
|
* 撤回
|
*
|
* @param id 记录主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "撤回")
|
@PostMapping("/Recall/{taskRecordId}")
|
public ActionResult<String> recall(@PathVariable("taskRecordId") String id, @RequestBody FlowModel flowModel) throws Exception {
|
RecordEntity record = recordService.getInfo(id);
|
if (null == record) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
if (record.getStatus().equals(FlowNature.Invalid)) {
|
throw new WorkFlowException(MsgCode.WF005.get());
|
}
|
OperatorEntity operator = operatorService.getInfo(record.getOperatorId());
|
if (null == operator) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
TaskEntity taskEntity = taskService.getInfo(operator.getTaskId());
|
if (null == taskEntity) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
if (!Objects.equals(record.getHandleId(), UserProvider.getLoginUserId())) {
|
return ActionResult.fail(MsgCode.AD104.get());
|
}
|
flowModel.setRecordEntity(record);
|
flowModel.setOperatorEntity(operator);
|
try {
|
operatorService.recall(id, flowModel);
|
} catch (Exception e) {
|
operatorUtil.compensate(taskEntity);
|
throw e;
|
}
|
operatorUtil.handleOperator();
|
operatorUtil.handleTaskStatus();
|
flowUtil.event(flowModel, EventEnum.Recall.getStatus());
|
return ActionResult.success(MsgCode.WF008.get());
|
}
|
|
/**
|
* 转审
|
*
|
* @param id 经办主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "转审")
|
@PostMapping("/Transfer/{id}")
|
public ActionResult<String> transfer(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws Exception {
|
operatorUtil.checkOperatorPermission(id);
|
operatorService.transfer(id, flowModel);
|
operatorUtil.autoAudit(flowModel);
|
operatorUtil.handleOperator();
|
operatorUtil.handleEvent();
|
OperatorEntity operator = operatorService.getById(id);
|
return ActionResult.success(ObjectUtil.equals(operator.getIsProcessing(), FlowNature.Processing) ? MsgCode.WF003.get() : MsgCode.WF152.get());
|
}
|
|
/**
|
* 协办
|
*
|
* @param id 主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "协办")
|
@PostMapping("/Assist/{id}")
|
public ActionResult<String> assist(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws WorkFlowException {
|
operatorUtil.checkOperatorPermission(id);
|
operatorService.assist(id, flowModel);
|
return ActionResult.success(MsgCode.WF067.get());
|
}
|
|
/**
|
* 协办保存
|
*
|
* @param id 主键
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "协办保存")
|
@PostMapping("/AssistSave/{id}")
|
public ActionResult<String> assistSave(@PathVariable("id") String id, @RequestBody FlowModel flowModel) throws WorkFlowException {
|
operatorUtil.checkOperatorPermission(id);
|
operatorService.assistSave(id, flowModel);
|
return ActionResult.success(MsgCode.WF068.get());
|
}
|
|
/**
|
* 批量审批流程分类列表
|
*/
|
@Operation(summary = "批量审批流程分类列表")
|
@GetMapping("/BatchFlowSelector")
|
public ActionResult<List<FlowBatchModel>> batchFlowSelector() {
|
List<FlowBatchModel> list = operatorService.batchFlowSelector();
|
return ActionResult.success(list);
|
}
|
|
/**
|
* 批量审批流程版本列表
|
*
|
* @param templateId 流程定义主键
|
*/
|
@Operation(summary = "批量审批流程版本列表")
|
@GetMapping("/BatchVersionSelector/{templateId}")
|
public ActionResult<List<FlowBatchModel>> batchVersionSelector(@PathVariable("templateId") String templateId) {
|
List<FlowBatchModel> list = operatorService.batchVersionSelector(templateId);
|
return ActionResult.success(list);
|
}
|
|
/**
|
* 批量审批节点列表
|
*
|
* @param flowId 定义版本主键
|
*/
|
@Operation(summary = "批量审批节点列表")
|
@GetMapping("/BatchNodeSelector/{flowId}")
|
public ActionResult<List<FlowBatchModel>> batchNodeSelector(@PathVariable("flowId") String flowId) {
|
List<FlowBatchModel> list = operatorService.batchNodeSelector(flowId);
|
return ActionResult.success(list);
|
}
|
|
/**
|
* 批量审批节点属性
|
*
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "批量审批节点属性")
|
@GetMapping("/BatchNode")
|
public ActionResult batchNode(FlowModel flowModel) throws WorkFlowException {
|
Map<String, Object> nodeMap = operatorService.batchNode(flowModel);
|
return ActionResult.success(nodeMap);
|
}
|
|
/**
|
* 批量获取候选人
|
*
|
* @param flowId 版本主键
|
* @param operatorId 经办主键
|
* @param batchType 类型，0.同意 1.拒绝
|
*/
|
@Operation(summary = "批量获取候选人")
|
@GetMapping("/BatchCandidate")
|
public ActionResult batchCandidate(String flowId, String operatorId, Integer batchType) throws WorkFlowException {
|
CandidateCheckVo vo = operatorService.batchCandidates(flowId, operatorId, batchType);
|
return ActionResult.success(vo);
|
}
|
|
/**
|
* 批量审批
|
*
|
* @param flowModel 参数
|
*/
|
@Operation(summary = "批量审批")
|
@PostMapping("/BatchOperation")
|
public ActionResult batchOperation(@RequestBody FlowModel flowModel) throws Exception {
|
try {
|
operatorService.batch(flowModel);
|
} catch (Exception e) {
|
List<TaskEntity> taskList = flowModel.getTaskList();
|
if (CollectionUtil.isNotEmpty(taskList)) {
|
for (TaskEntity taskEntity : taskList) {
|
operatorUtil.compensate(taskEntity);
|
}
|
}
|
throw e;
|
}
|
operatorUtil.handleOperator();
|
operatorUtil.handleTaskStatus();
|
operatorUtil.handleEvent();
|
return ActionResult.success(MsgCode.WF011.get());
|
}
|
|
/**
|
* 消息跳转工作流
|
*
|
* @param id 经办或抄送主键
|
*/
|
@Operation(summary = "消息跳转工作流")
|
@GetMapping("/{id}/Info")
|
public ActionResult checkInfo(@PathVariable("id") String id, @RequestParam(value = "opType", required = false) String opType) throws WorkFlowException {
|
Map<String, String> map = new HashMap<>();
|
List<String> list = ImmutableList.of(OpTypeEnum.LaunchDetail.getType(), OpTypeEnum.LaunchCreate.getType());
|
if (list.contains(opType)) {
|
String type = OpTypeEnum.LaunchDetail.getType();
|
TaskEntity task = taskService.getById(id);
|
if (null != task) {
|
operatorUtil.checkTemplateHide(task.getTemplateId());
|
if (ObjectUtil.equals(task.getStatus(), TaskStatusEnum.TO_BE_SUBMIT.getCode())) {
|
type = OpTypeEnum.LaunchCreate.getType();
|
}
|
}
|
map.put("opType", type);
|
return ActionResult.success(map);
|
}
|
String type = taskService.checkInfo(id);
|
map.put("opType", type);
|
return ActionResult.success(map);
|
}
|
|
/**
|
* 进度节点记录列表
|
*
|
* @param taskId 任务主键
|
* @param nodeId 节点id
|
*/
|
@Operation(summary = "进度节点记录列表")
|
@GetMapping("/RecordList")
|
public ActionResult getRecordList(@RequestParam("taskId") String taskId, @RequestParam("nodeId") String nodeId) {
|
return ActionResult.success(recordService.getList(taskId, nodeId));
|
}
|
|
/**
|
* 节点抄送列表
|
*
|
* @param taskId 任务主键
|
* @param nodeId 节点id
|
*/
|
@Operation(summary = "节点抄送列表")
|
@GetMapping("/CirculateList")
|
public ActionResult getCirculateList(@RequestParam("taskId") String taskId, @RequestParam("nodeId") String nodeId) {
|
List<CirculateEntity> list = circulateService.getNodeList(taskId, nodeId);
|
return ActionResult.success(operatorUtil.getCirculateList(list));
|
}
|
}
|
