package com.ruoyi.approve.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.approve.mapper.ApproveNodeMapper;
|
import com.ruoyi.approve.mapper.ApproveProcessMapper;
|
import com.ruoyi.approve.pojo.ApproveNode;
|
import com.ruoyi.approve.pojo.ApproveProcess;
|
import com.ruoyi.approve.service.IApproveNodeService;
|
import com.ruoyi.approve.vo.ApproveProcessVO;
|
import com.ruoyi.common.enums.FileNameType;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.device.mapper.DeviceRepairMapper;
|
import com.ruoyi.device.pojo.DeviceRepair;
|
import com.ruoyi.other.service.impl.TempFileServiceImpl;
|
import com.ruoyi.project.system.domain.SysUser;
|
import com.ruoyi.project.system.mapper.SysUserMapper;
|
import com.ruoyi.project.system.service.ISysNoticeService;
|
import com.ruoyi.sales.mapper.CommonFileMapper;
|
import com.ruoyi.sales.pojo.CommonFile;
|
import com.ruoyi.sales.service.impl.CommonFileServiceImpl;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.io.IOException;
|
import java.time.LocalDateTime;
|
import java.util.Arrays;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@RequiredArgsConstructor
|
public class ApproveNodeServiceImpl extends ServiceImpl<ApproveNodeMapper, ApproveNode> implements IApproveNodeService {
|
|
@Autowired
|
private ApproveNodeMapper approveNodeMapper;
|
@Autowired
|
private ApproveProcessMapper approveProcessMapper;
|
@Autowired
|
private SysUserMapper sysUserMapper;
|
|
@Autowired
|
private TempFileServiceImpl tempFileService;
|
@Autowired
|
private ISysNoticeService sysNoticeService;
|
|
@Autowired
|
private CommonFileMapper fileMapper;
|
@Autowired
|
private DeviceRepairMapper deviceRepairMapper;
|
|
|
|
public ApproveProcess getApproveById(String id) {
|
LambdaQueryWrapper<ApproveProcess> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(ApproveProcess::getApproveId, id);
|
queryWrapper.eq(ApproveProcess::getApproveDelete, 0);
|
queryWrapper.eq(ApproveProcess::getTenantId, SecurityUtils.getLoginUser().getTenantId());
|
queryWrapper.last("limit 1");
|
ApproveProcess one = approveProcessMapper.selectOne(queryWrapper);
|
return one;
|
}
|
|
@Override
|
public void initApproveNodes(String approveUserIds,String approveID,Long tenantId) {
|
Long userId = SecurityUtils.getLoginUser().getUser().getUserId();
|
ApproveProcess approve = getApproveById(approveID);
|
String[] names = approveUserIds.split(",");
|
String approveId = approve.getApproveId();
|
for (int i = 0; i < names.length; i++) {
|
SysUser sysUser = sysUserMapper.selectUserById(Long.parseLong(names[i]));
|
if (sysUser == null) continue;
|
ApproveNode approveNode = new ApproveNode();
|
approveNode.setApproveProcessId(approveId);
|
approveNode.setApproveNodeOrder(i +1);
|
approveNode.setApproveNodeUser(sysUser.getNickName());
|
approveNode.setApproveNodeUserId(sysUser.getUserId());
|
approveNode.setApproveNodeTime(new Date());
|
approveNode.setApproveNodeStatus(0);
|
approveNode.setTenantId(tenantId);
|
approveNode.setDeleteFlag(0);
|
approveNode.setCreateUser(userId);
|
approveNode.setUpdateUser(userId);
|
approveNode.setCreateTime(LocalDateTime.now());
|
approveNode.setUpdateTime(LocalDateTime.now());
|
approveNodeMapper.insert(approveNode);
|
}
|
}
|
|
@Override
|
public List<ApproveNode> details(String id) {
|
LambdaQueryWrapper<ApproveNode> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(ApproveNode::getApproveProcessId, id);
|
queryWrapper.eq(ApproveNode::getDeleteFlag, 0);
|
queryWrapper.eq(ApproveNode::getTenantId, SecurityUtils.getLoginUser().getTenantId());
|
List<ApproveNode> list = list(queryWrapper);
|
// 按照 approveNodeOrder 字段升序排序
|
list.sort(Comparator.comparingInt(ApproveNode::getApproveNodeOrder));
|
LambdaQueryWrapper<ApproveProcess> approveProcessLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
approveProcessLambdaQueryWrapper.eq(ApproveProcess::getApproveId, id)
|
.eq(ApproveProcess::getApproveDelete, 0)
|
.eq(ApproveProcess::getTenantId, SecurityUtils.getLoginUser().getTenantId())
|
.last("limit 1");
|
ApproveProcess approveProcess = approveProcessMapper.selectOne(approveProcessLambdaQueryWrapper);
|
if(approveProcess != null && approveProcess.getApproveStatus() == 3){
|
return list;
|
}
|
for (ApproveNode approveNode : list) {
|
List<CommonFile> commonFiles = fileMapper.selectList(new LambdaQueryWrapper<CommonFile>()
|
.eq(CommonFile::getCommonId, approveNode.getId())
|
.eq(CommonFile::getType, FileNameType.ApproveNode.getValue()));
|
if(!CollectionUtils.isEmpty(commonFiles)){
|
approveNode.setUrl(commonFiles.get(0).getUrl());
|
}
|
if(approveNode.getApproveNodeStatus() == 1){
|
continue;
|
}
|
approveNode.setIsShen(true);
|
break;
|
}
|
return list;
|
}
|
|
public void updateApproveProcessStatus(ApproveNode approveNode,Integer status) throws IOException {
|
LambdaQueryWrapper<ApproveProcess> approveProcessLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
approveProcessLambdaQueryWrapper.eq(ApproveProcess::getApproveId, approveNode.getApproveProcessId())
|
.eq(ApproveProcess::getApproveDelete, 0)
|
.eq(ApproveProcess::getTenantId, SecurityUtils.getLoginUser().getTenantId())
|
.last("limit 1");
|
ApproveProcess approveProcess = approveProcessMapper.selectOne(approveProcessLambdaQueryWrapper);
|
if(approveProcess == null) throw new RuntimeException("审批不存在");
|
LambdaQueryWrapper<ApproveNode> approveNodeLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
approveNodeLambdaQueryWrapper.eq(ApproveNode::getApproveProcessId, approveNode.getApproveProcessId())
|
.eq(ApproveNode::getApproveNodeOrder, approveNode.getApproveNodeOrder() + 1)
|
.eq(ApproveNode::getDeleteFlag, 0)
|
.eq(ApproveNode::getTenantId, SecurityUtils.getLoginUser().getTenantId())
|
.last("limit 1");
|
ApproveNode approveNode1 = approveNodeMapper.selectOne(approveNodeLambdaQueryWrapper);
|
approveProcess.setApproveStatus(status);
|
if(approveNode1 != null){
|
approveProcess.setApproveUserCurrentId(approveNode1.getApproveNodeUserId());
|
approveProcess.setApproveUserCurrentName(approveNode1.getApproveNodeUser());
|
}
|
if(approveProcess.getApproveStatus().equals(2) || approveProcess.getApproveStatus().equals(3) || approveProcess.getApproveStatus().equals(4)){
|
approveProcess.setApproveOverTime(new Date());
|
}
|
approveProcessMapper.updateById(approveProcess);
|
|
DeviceRepair deviceRepair = deviceRepairMapper.selectById(approveProcess.getDeviceRepairId());
|
if(ObjectUtils.isNotNull(deviceRepair)) {
|
if(approveProcess.getApproveStatus().equals(2)){
|
// 同意
|
deviceRepair.setStatus(1);
|
}else if(approveProcess.getApproveStatus().equals(3)){
|
// 拒绝
|
deviceRepair.setStatus(2);
|
}
|
deviceRepairMapper.updateById(deviceRepair);
|
}
|
// 绑定附件
|
if(!CollectionUtils.isEmpty(approveNode.getTempFileIds()) && approveNode.getApproveNodeStatus() == 1){
|
tempFileService.migrateTempFilesToFormal(approveNode.getId(), approveNode.getTempFileIds(), FileNameType.ApproveNode.getValue());
|
}
|
}
|
|
@Override
|
public void updateApproveNode(ApproveNode approveNode) throws IOException {
|
// 审批节点状态:1同意，2拒绝，0尚未审核
|
switch (approveNode.getApproveNodeStatus()){
|
case 1:
|
updateApproveProcessStatus(approveNode, Boolean.TRUE.equals(approveNode.getIsLast()) ? 2 : 1);
|
/*消息通知*/
|
Integer nodeOrder = approveNode.getApproveNodeOrder();
|
ApproveProcess approveProcess = approveProcessMapper.selectList(Wrappers.<ApproveProcess>lambdaQuery()
|
.eq(ApproveProcess::getApproveId, approveNode.getApproveProcessId())).get(0);
|
if (approveProcess.getApproveUserIds().split(",").length > nodeOrder){
|
String id = approveProcess.getApproveUserIds().split(",")[nodeOrder];
|
sysNoticeService.simpleNoticeByUser(approveProcessType(approveProcess.getApproveType()),
|
approveNode.getApproveProcessId()+"流程编号的审批需要您审核!!!!!",
|
Arrays.asList(Long.valueOf(id)),
|
approveNode.getTenantId(),
|
"/collaborativeApproval/approvalProcess?approveType="+approveProcess.getApproveType()+"&approveId="+approveNode.getApproveProcessId());
|
}
|
break;
|
case 2:
|
updateApproveProcessStatus(approveNode, 3);
|
break;
|
default:
|
break;
|
}
|
approveNode.setApproveNodeTime(new Date());
|
approveNodeMapper.updateById(approveNode);
|
}
|
|
@Override
|
public void delApproveNodeByApproveId(Long id) {
|
UpdateWrapper<ApproveNode> queryWrapper = new UpdateWrapper<>();
|
queryWrapper.lambda().set(ApproveNode::getDeleteFlag, 1)
|
.eq(ApproveNode::getApproveProcessId, id);
|
update(queryWrapper);
|
}
|
|
//审批类型获取(与前端页面对应)
|
private String approveProcessType(Integer approveType){
|
switch (approveType){
|
case 1:
|
return "公出管理";
|
case 2:
|
return "请假管理";
|
case 3:
|
return "出差管理";
|
case 4:
|
return "报销管理";
|
case 5:
|
return "采购审批";
|
case 6:
|
return "报价审批";
|
case 7:
|
return "出库审批";
|
}
|
return null;
|
}
|
|
}
|
