From ec57af8afe57f8c5d46b58d76e2e9d053943c20b Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期二, 26 八月 2025 16:19:50 +0800
Subject: [PATCH] yys  修改协同审批编辑接口

---
 src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java |   57 ++++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 42 insertions(+), 15 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 2de1c71..e866bbf 100644
--- a/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java
+++ b/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java
@@ -14,11 +14,15 @@
 import com.ruoyi.approve.utils.DailyRedisCounter;
 import com.ruoyi.approve.vo.ApproveGetAndUpdateVo;
 import com.ruoyi.approve.vo.ApproveProcessVO;
+import com.ruoyi.common.enums.FileNameType;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.other.service.impl.TempFileServiceImpl;
 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 com.ruoyi.sales.mapper.CommonFileMapper;
+import com.ruoyi.sales.pojo.CommonFile;
 import lombok.AllArgsConstructor;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +32,7 @@
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
+import java.io.IOException;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
@@ -52,9 +57,11 @@
     private final IApproveNodeService approveNodeService;
     private final SysUserMapper sysUserMapper;
     private final ApproveProcessMapper approveProcessMapper;
+    private final TempFileServiceImpl tempFileService;
+    private final CommonFileMapper commonFileMapper;
 
     @Override
-    public void addApprove(ApproveProcessVO approveProcessVO) throws ParseException {
+    public void addApprove(ApproveProcessVO approveProcessVO) throws  Exception {
         SysUser sysUser = sysUserMapper.selectUserById(approveProcessVO.getApproveUser());
         SysDept sysDept = sysDeptMapper.selectDeptById(approveProcessVO.getApproveDeptId());
         String[] split = approveProcessVO.getApproveUserIds().split(",");
@@ -103,6 +110,8 @@
         save(approveProcess);
         //鍒濆鍖栧鎵硅妭鐐�
         approveNodeService.initApproveNodes(approveProcessVO.getApproveUserIds(),approveID,approveProcessVO.getApproveDeptId());
+        // 闄勪欢缁戝畾
+        tempFileService.migrateTempFilesToFormal(approveProcess.getId(), approveProcessVO.getTempFileIds(), FileNameType.ApproveProcess.getValue());
     }
 
     @Override
@@ -118,6 +127,13 @@
     @Override
     public IPage<ApproveProcess> listAll(Page page,ApproveProcess approveProcess) {
         IPage<ApproveProcess> approveProcessIPage = approveProcessMapper.listPage(page,approveProcess);
+        List<ApproveProcess> records = approveProcessIPage.getRecords();
+        for (ApproveProcess record : records) {
+            List<CommonFile> commonFiles = commonFileMapper.selectList(new LambdaQueryWrapper<CommonFile>()
+                    .eq(CommonFile::getCommonId, record.getId())
+                    .eq(CommonFile::getType, FileNameType.ApproveProcess.getValue()));
+            record.setCommonFileList(commonFiles);
+        }
         return approveProcessIPage;
     }
 
@@ -143,6 +159,9 @@
         queryWrapper.eq(ApproveProcess::getTenantId, SecurityUtils.getLoginUser().getTenantId());
         queryWrapper.last("limit 1");
         ApproveProcess one = getOne(queryWrapper);
+        one.setCommonFileList(commonFileMapper.selectList(new LambdaQueryWrapper<CommonFile>()
+                .eq(CommonFile::getCommonId, one.getId())
+                .eq(CommonFile::getType, FileNameType.ApproveProcess.getValue())));
         return one;
     }
 
@@ -150,7 +169,7 @@
 
 
     @Override
-    public void updateByApproveId(ApproveGetAndUpdateVo approveGetAndUpdateVo) {
+    public void updateByApproveId(ApproveGetAndUpdateVo approveGetAndUpdateVo) throws IOException {
         ApproveProcess approve = approveProcessMapper.selectById(approveGetAndUpdateVo.getId());
         approve.setApproveUserIds(approveGetAndUpdateVo.getApproveUserIds());
         approve.setApproveReason(approveGetAndUpdateVo.getApproveReason());
@@ -171,24 +190,32 @@
         }
         updateById(approve);
         //淇敼瀹℃壒浜�
+        // 鍏堝垹闄� 鍚庢柊澧�
         LambdaQueryWrapper<ApproveNode> approveNodeLambdaQueryWrapper = new LambdaQueryWrapper<>();
         approveNodeLambdaQueryWrapper.eq(ApproveNode::getApproveProcessId, approve.getApproveId())
                 .eq(ApproveNode::getDeleteFlag, 0)
                 .eq(ApproveNode::getTenantId, SecurityUtils.getLoginUser().getTenantId())
                 .orderByAsc(ApproveNode::getApproveNodeOrder);
-        List<ApproveNode> list = approveNodeMapper.selectList(approveNodeLambdaQueryWrapper);
-        int i = 0;
-        for (ApproveNode approveNode : list) {
-            int finalI = i;
-            List<SysUser> collect = sysUsers.stream().filter(user -> user.getUserId().equals(Long.parseLong(split[finalI]))).collect(Collectors.toList());
-            if(CollectionUtils.isEmpty(collect)){
-                throw new RuntimeException("璇烽�夋嫨姝g‘鐨勫鎵逛汉");
-            }
-            approveNode.setApproveNodeUserId(collect.get(0).getUserId());
-            approveNode.setApproveNodeUser(collect.get(0).getNickName());
-            approveNodeMapper.updateById(approveNode);
-            i++;
-        }
+        approveNodeMapper.delete(approveNodeLambdaQueryWrapper);
+        approveNodeService.initApproveNodes(approveGetAndUpdateVo.getApproveUserIds(),approve.getApproveId(),approve.getTenantId());
+
+//        int i = 0;
+//        for (ApproveNode approveNode : list) {
+//            int finalI = i;
+//            if(i >= split.length){
+//                approveNode.setDeleteFlag(1);
+//            }else{
+//                List<SysUser> collect = sysUsers.stream().filter(user -> user.getUserId().equals(Long.parseLong(split[finalI]))).collect(Collectors.toList());
+//                if(CollectionUtils.isEmpty(collect)){
+//                    throw new RuntimeException("璇烽�夋嫨姝g‘鐨勫鎵逛汉");
+//                }
+//                approveNode.setApproveNodeUserId(collect.get(0).getUserId());
+//                approveNode.setApproveNodeUser(collect.get(0).getNickName());
+//            }
+//            approveNodeMapper.updateById(approveNode);
+//            i++;
+//        }
+        tempFileService.migrateTempFilesToFormal(approve.getId(), approveGetAndUpdateVo.getTempFileIds(), FileNameType.ApproveProcess.getValue());
     }
 
 

--
Gitblit v1.9.3