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 jakarta.validation.Valid;
|
import jnpf.base.ActionResult;
|
import jnpf.base.UserInfo;
|
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.DelegateEntity;
|
import jnpf.flowable.entity.DelegateInfoEntity;
|
import jnpf.flowable.model.candidates.CandidateUserVo;
|
import jnpf.flowable.model.delegate.*;
|
import jnpf.flowable.service.DelegateInfoService;
|
import jnpf.flowable.service.DelegateService;
|
import jnpf.flowable.util.ServiceUtil;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.JsonUtilEx;
|
import jnpf.util.StringUtil;
|
import jnpf.util.UserProvider;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 类的描述
|
*
|
* @author JNPF@YinMai Info. Co., Ltd
|
* @version 5.0.x
|
* @since 2024/5/13 17:27
|
*/
|
@Tag(name = "流程委托", description = "DelegateController")
|
@RestController
|
@RequestMapping("/delegate")
|
public class DelegateController extends SuperController<DelegateService, DelegateEntity> {
|
@Autowired
|
private DelegateService delegateService;
|
@Autowired
|
private ServiceUtil serviceUtil;
|
@Autowired
|
private DelegateInfoService delegateInfoService;
|
|
/**
|
* 获取流程委托列表
|
*
|
* @param pagination 分页参数
|
*/
|
@Operation(summary = "获取流程委托列表")
|
@GetMapping
|
public ActionResult list(DelegatePagination pagination) {
|
List<DelegateListVO> voList;
|
if (ObjectUtil.equals(pagination.getType(), 2) || ObjectUtil.equals(pagination.getType(), 4)) {
|
voList = delegateInfoService.getList(pagination);
|
} else {
|
voList = delegateService.getList(pagination);
|
}
|
PaginationVO paginationVO = JsonUtil.getJsonToBean(pagination, PaginationVO.class);
|
return ActionResult.page(voList, paginationVO);
|
}
|
|
/**
|
* 委托信息列表
|
*
|
* @param delegateId 委托主键
|
*/
|
@Operation(summary = "委托信息列表")
|
@GetMapping("/Info/{delegateId}")
|
public ActionResult getDelegateInfo(@PathVariable("delegateId") String delegateId) {
|
List<DelegateInfoEntity> list = delegateInfoService.getList(delegateId);
|
return ActionResult.success(JsonUtil.getJsonToList(list, DelegateListVO.class));
|
}
|
|
/**
|
* 获取流程委托信息
|
*
|
* @param id 主键
|
*/
|
@Operation(summary = "获取流程委托信息")
|
@GetMapping("/{id}")
|
public ActionResult info(@PathVariable("id") String id) throws WorkFlowException {
|
DelegateEntity entity = delegateService.getInfo(id);
|
if (null == entity) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
DelegateInfoVO vo = JsonUtilEx.getJsonToBeanEx(entity, DelegateInfoVO.class);
|
List<DelegateInfoEntity> infoList = delegateInfoService.getList(entity.getId());
|
if (CollectionUtil.isNotEmpty(infoList)) {
|
List<String> toUserNameList = infoList.stream().map(DelegateInfoEntity::getToUserName).collect(Collectors.toList());
|
vo.setToUserName(String.join(",", toUserNameList));
|
List<String> toUserIdList = infoList.stream().map(DelegateInfoEntity::getToUserId).collect(Collectors.toList());
|
vo.setToUserId(toUserIdList);
|
}
|
return ActionResult.success(vo);
|
}
|
|
/**
|
* 新建流程委托
|
*
|
* @param fo 参数
|
*/
|
@Operation(summary = "新建流程委托")
|
@PostMapping
|
public ActionResult create(@RequestBody @Valid DelegateCrForm fo) {
|
// 超管和管理员不能新增委托/代理（即：只有普通用户身份才能新建委托/代理，提示：“管理员不能新建委托/代理”）
|
if (!serviceUtil.isCommonUser(UserProvider.getLoginUserId())) {
|
return ActionResult.fail(MsgCode.WF130.get());
|
}
|
if (StringUtil.isBlank(fo.getUserId())) {
|
UserInfo userInfo = UserProvider.getUser();
|
fo.setUserId(userInfo.getUserId());
|
fo.setUserName(userInfo.getUserName() + "/" + userInfo.getUserAccount());
|
}
|
boolean isDelegate = ObjectUtil.equals(fo.getType(), "0");
|
if (fo.getToUserId().contains(fo.getUserId())) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF017.get() : MsgCode.WF137.get());
|
}
|
// 受托人/代理人不能选择admin和本人
|
List<String> toUserList = fo.getToUserId();
|
String admin = serviceUtil.getAdmin();
|
for (String toUser : toUserList) {
|
if (ObjectUtil.equals(toUser, admin)) {
|
return ActionResult.fail(MsgCode.WF131.get());
|
}
|
}
|
if (this.alreadyDelegate(fo, null)) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF018.get() : MsgCode.WF144.get());
|
}
|
DelegateCrForm reverse = new DelegateCrForm();
|
BeanUtils.copyProperties(fo, reverse);
|
reverse.setUserIdList(fo.getToUserId());
|
reverse.setToUserId(ImmutableList.of(fo.getUserId()));
|
if (this.alreadyDelegate(reverse, null)) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF019.get() : MsgCode.WF145.get());
|
}
|
delegateService.create(fo);
|
return ActionResult.success(MsgCode.SU001.get());
|
}
|
|
/**
|
* 更新流程委托
|
*
|
* @param id 主键
|
* @param fo 参数
|
*/
|
@Operation(summary = "更新流程委托")
|
@PutMapping("/{id}")
|
public ActionResult update(@PathVariable("id") String id, @RequestBody @Valid DelegateUpForm fo) throws WorkFlowException {
|
DelegateEntity entity = delegateService.getInfo(id);
|
if (null == entity) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
fo.setUserId(entity.getUserId());
|
boolean isDelegate = ObjectUtil.equals(fo.getType(), "0");
|
if (fo.getToUserId().contains(fo.getUserId())) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF017.get() : MsgCode.WF137.get());
|
}
|
if (this.alreadyDelegate(fo, id)) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF018.get() : MsgCode.WF144.get());
|
}
|
// 判断是否有人接受
|
List<DelegateInfoEntity> infoList = delegateInfoService.getList(id);
|
if (CollectionUtil.isNotEmpty(infoList)) {
|
DelegateInfoEntity delegateInfoEntity = infoList.stream().filter(e -> ObjectUtil.equals(e.getStatus(), 1)).findFirst().orElse(null);
|
if (null != delegateInfoEntity) {
|
return ActionResult.fail(MsgCode.WF132.get());
|
}
|
}
|
DelegateCrForm reverse = new DelegateCrForm();
|
BeanUtils.copyProperties(fo, reverse);
|
reverse.setUserIdList(fo.getToUserId());
|
reverse.setToUserId(ImmutableList.of(fo.getUserId()));
|
if (this.alreadyDelegate(reverse, id)) {
|
return ActionResult.fail(isDelegate ? MsgCode.WF019.get() : MsgCode.WF145.get());
|
}
|
if (delegateService.update(entity, fo)) {
|
return ActionResult.success(MsgCode.SU004.get());
|
}
|
return ActionResult.success(MsgCode.FA002.get());
|
}
|
|
// 判断是否已有委托
|
private boolean alreadyDelegate(DelegateCrForm form, String id) {
|
List<DelegateEntity> delegateEntities = new ArrayList<>();
|
if (CollectionUtil.isNotEmpty(form.getUserIdList())) {
|
for (String userId : form.getUserIdList()) {
|
form.setUserId(userId);
|
List<DelegateEntity> list = delegateService.selectSameParamAboutDelaget(form);
|
delegateEntities.addAll(list);
|
}
|
} else {
|
delegateEntities = delegateService.selectSameParamAboutDelaget(form);
|
}
|
for (DelegateEntity delegate : delegateEntities) {
|
if (delegate.getId().equals(id)) {
|
continue;
|
}
|
//时间交叉
|
if ((form.getStartTime() <= delegate.getStartTime().getTime() && form.getEndTime() >= delegate.getStartTime().getTime()) ||
|
(form.getStartTime() >= delegate.getStartTime().getTime() && form.getStartTime() <= delegate.getEndTime().getTime())) {
|
if (StringUtil.isEmpty(form.getFlowId())) {
|
return true;
|
} else {
|
if (StringUtil.isEmpty(delegate.getFlowId())) {
|
return true;
|
} else {
|
List<String> split = Arrays.asList(delegate.getFlowId().split(","));
|
List<String> split1 = Arrays.asList(form.getFlowId().split(","));
|
for (String srt : split) {
|
if (split1.contains(srt)) {
|
return true;
|
}
|
}
|
}
|
}
|
}
|
}
|
return false;
|
}
|
|
/**
|
* 结束委托
|
*
|
* @param id 主键
|
*/
|
@Operation(summary = "结束委托")
|
@PutMapping("/Stop/{id}")
|
public ActionResult stop(@PathVariable("id") String id) {
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.add(Calendar.SECOND, -1);
|
Date date = calendar.getTime();
|
DelegateEntity entity = delegateService.getInfo(id);
|
if (null != entity) {
|
entity.setStartTime(date);
|
entity.setEndTime(date);
|
delegateService.updateStop(id, entity);
|
return ActionResult.success(MsgCode.SU008.get());
|
}
|
return ActionResult.fail(MsgCode.FA002.get());
|
}
|
|
/**
|
* 删除流程委托
|
*
|
* @param id 主键
|
*/
|
@Operation(summary = "删除流程委托")
|
@DeleteMapping("/{id}")
|
public ActionResult delete(@PathVariable("id") String id) {
|
DelegateEntity entity = delegateService.getInfo(id);
|
if (null != entity) {
|
delegateService.delete(entity);
|
delegateInfoService.delete(entity.getId());
|
return ActionResult.success(MsgCode.SU003.get());
|
}
|
return ActionResult.fail(MsgCode.FA003.get());
|
}
|
|
|
/**
|
* 获取委托人
|
* 根据被委托人查询可发起的流程列表
|
*/
|
@Operation(summary = "获取委托人")
|
@GetMapping("/UserList")
|
public ActionResult getUserListByFlowId(@RequestParam("templateId") String templateId) throws WorkFlowException {
|
ListVO<CandidateUserVo> userList = delegateService.getUserList(templateId);
|
return ActionResult.success(userList);
|
}
|
|
/**
|
* 确认
|
*
|
* @param id 委托信息主键
|
* @param type 类型，1.接受 2.拒绝
|
*/
|
@Operation(summary = "确认")
|
@PostMapping("/Notarize/{id}")
|
public ActionResult accept(@PathVariable("id") String id, @RequestParam("type") Integer type) throws WorkFlowException {
|
DelegateInfoEntity delegateInfo = delegateInfoService.getById(id == null ? "" : id);
|
if (null == delegateInfo) {
|
throw new WorkFlowException(MsgCode.FA001.get());
|
}
|
delegateInfo.setStatus(type);
|
delegateService.notarize(delegateInfo);
|
return ActionResult.success(MsgCode.SU004.get());
|
}
|
|
}
|
