From 91c0906bda26d3718b2fa450eed27419388b24a5 Mon Sep 17 00:00:00 2001 From: maven <2163098428@qq.com> Date: 星期五, 11 七月 2025 14:49:44 +0800 Subject: [PATCH] yys 修改协同审批bug --- src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java | 74 +++++++++++++++++++++++++++---------- 1 files changed, 54 insertions(+), 20 deletions(-) diff --git a/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java b/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java index 322a498..426a8d8 100644 --- a/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java +++ b/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java @@ -1,6 +1,9 @@ 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.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.approve.mapper.ApproveProcessMapper; import com.ruoyi.approve.pojo.ApproveNode; @@ -12,19 +15,28 @@ import com.ruoyi.approve.vo.ApproveProcessVO; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.project.system.domain.SysDept; +import com.ruoyi.project.system.domain.SysUser; import com.ruoyi.project.system.mapper.SysDeptMapper; +import com.ruoyi.project.system.mapper.SysUserMapper; import lombok.AllArgsConstructor; import lombok.RequiredArgsConstructor; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; +import org.springframework.util.StringUtils; +import java.text.ParseException; +import java.text.SimpleDateFormat; import java.time.LocalDate; +import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; +import java.util.Arrays; import java.util.Date; import java.util.List; +import java.util.stream.Collectors; @Service @RequiredArgsConstructor @@ -37,34 +49,52 @@ private final SysDeptMapper sysDeptMapper; private final IApproveNodeService approveNodeService; + private final SysUserMapper sysUserMapper; + private final ApproveProcessMapper approveProcessMapper; @Override - public void addApprove(ApproveProcessVO approveProcessVO) { - Long userId = SecurityUtils.getUserId(); - //绉熸埛id - Long tenantId = SecurityUtils.getLoginUser().getTenantId(); - + public void addApprove(ApproveProcessVO approveProcessVO) throws ParseException { + SysUser sysUser = sysUserMapper.selectUserById(approveProcessVO.getApproveUser()); + SysDept sysDept = sysDeptMapper.selectDeptById(approveProcessVO.getApproveDeptId()); + String[] split = approveProcessVO.getApproveUserIds().split(","); + List<Long> longList = Arrays.stream(split) + .map(Long::valueOf) // 灏嗘瘡涓� String 杞崲涓� Long + .collect(Collectors.toList()); + List<SysUser> sysUsers = sysUserMapper.selectUserByIds(longList); + if(CollectionUtils.isEmpty(sysUsers)) throw new RuntimeException("瀹℃牳鐢ㄦ埛涓嶅瓨鍦�"); + if(sysDept == null) throw new RuntimeException("閮ㄩ棬涓嶅瓨鍦�"); + if(sysUser == null) throw new RuntimeException("鐢宠浜轰笉瀛樺湪"); String today = LocalDate.now().format(DATE_FORMAT); - Long approveId = dailyRedisCounter.incrementAndGet("approveId"); + Long approveId = dailyRedisCounter.incrementAndGetByDb(); String formattedCount = String.format("%03d", approveId); //娴佺▼ ID String approveID = today + formattedCount; - + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); ApproveProcess approveProcess = new ApproveProcess(); approveProcess.setApproveId(approveID); - approveProcess.setApproveUser(userId); - approveProcess.setApproveDeptName(approveProcessVO.getDeptName()); - approveProcess.setApproveUserNames(approveProcessVO.getApproverNames()); - approveProcess.setApproveTime(new Date()); + approveProcess.setApproveUser(approveProcessVO.getApproveUser()); + approveProcess.setApproveUserName(sysUser.getNickName()); + approveProcess.setApproveDeptId(approveProcessVO.getApproveDeptId()); + approveProcess.setApproveDeptName(sysDept.getDeptName()); + approveProcess.setApproveUserNames(sysUsers.stream().map(SysUser::getNickName).collect(Collectors.joining(","))); + approveProcess.setApproveTime(StringUtils.isEmpty(approveProcessVO.getApproveTime()) ? null : dateFormat.parse(approveProcessVO.getApproveTime())); approveProcess.setApproveReason(approveProcessVO.getApproveReason()); approveProcess.setApproveOverTime(null); approveProcess.setApproveStatus(0); approveProcess.setApproveDelete(0); - approveProcess.setTenantId(tenantId); - + approveProcess.setCreateTime(LocalDateTime.now()); + approveProcess.setTenantId(approveProcessVO.getApproveDeptId()); + approveProcess.setApproveUserIds(approveProcessVO.getApproveUserIds()); + approveProcess.setApproveUserCurrentId(longList.get(0)); + approveProcess.setApproveUserCurrentName(sysUsers + .stream() + .filter(SysUser -> SysUser.getUserId().equals(longList.get(0))) + .collect(Collectors.toList()) + .get(0) + .getNickName()); save(approveProcess); //鍒濆鍖栧鎵硅妭鐐� - approveNodeService.initApproveNodes(approveID); + approveNodeService.initApproveNodes(approveProcessVO.getApproveUserIds(),approveID,approveProcessVO.getApproveDeptId()); } @Override @@ -78,19 +108,23 @@ } @Override - public List<ApproveProcess> listAll() { - LambdaQueryWrapper<ApproveProcess> queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(ApproveProcess::getApproveDelete, 0); - return list(queryWrapper); + public IPage<ApproveProcess> listAll(Page page,ApproveProcess approveProcess) { + IPage<ApproveProcess> approveProcessIPage = approveProcessMapper.listPage(page,approveProcess); + return approveProcessIPage; } @Override public void delApprove(Long[] ids) { for (Long id : ids) { - LambdaQueryWrapper<ApproveProcess> queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(ApproveProcess::getApproveId, id); + UpdateWrapper<ApproveProcess> queryWrapper = new UpdateWrapper<>(); + queryWrapper.lambda().set(ApproveProcess::getApproveDelete, 1) + .eq(ApproveProcess::getApproveId, id); update(queryWrapper); + // 鍒犻櫎鍏宠仈鐨勫鎵硅妭鐐� + approveNodeService.delApproveNodeByApproveId(id); } + + } @Override -- Gitblit v1.9.3