From 0594e539cbe8ac734377f148a87eb7812255ddc0 Mon Sep 17 00:00:00 2001
From: liyong <18434998025@163.com>
Date: 星期二, 26 五月 2026 17:56:58 +0800
Subject: [PATCH] 审批代码迁移,   销售台账审批添加

---
 src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java |   51 +++++++++++++++++++++++++++++++--------------------
 1 files changed, 31 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 f6af037..bd23fdf 100644
--- a/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java
+++ b/src/main/java/com/ruoyi/approve/service/impl/ApproveProcessServiceImpl.java
@@ -71,13 +71,13 @@
     public void addApprove(ApproveProcessVO approveProcessVO) throws Exception {
         SysUser sysUser = SecurityUtils.getLoginUser().getUser();
         SysDept sysDept = sysDeptMapper.selectDeptById(SecurityUtils.getLoginUser().getCurrentDeptId());
-        List<ApproveProcessConfigNodeVo> list = approveProcessConfigNodeService.listNode(approveProcessVO.getApproveType());
+        List<ApproveProcessConfigNodeVo> list = approveProcessConfigNodeService.listNode( approveProcessVO.getApproveType());
+        if(list.isEmpty()) {
+            throw new RuntimeException("娴佺▼涓嶅瓨鍦�");
+        }
         List<Long> nodeIds = list.stream()
                 .map(ApproveProcessConfigNodeVo::getApproverId)
                 .collect(Collectors.toList());
-        if (list.isEmpty()) {
-            throw new RuntimeException("娴佺▼涓嶅瓨鍦�");
-        }
         List<SysUser> sysUsers = sysUserMapper.selectUserByIds(nodeIds);
         if (CollectionUtils.isEmpty(sysUsers)) throw new RuntimeException("瀹℃牳鐢ㄦ埛涓嶅瓨鍦�");
         if (sysDept == null) throw new RuntimeException("閮ㄩ棬涓嶅瓨鍦�");
@@ -89,18 +89,18 @@
 //        String approveID = today + formattedCount;
         SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
         ApproveProcess approveProcess = new ApproveProcess();
-        String no = OrderUtils.countTodayByCreateTime(approveProcessMapper, "", "approve_id");
+        String no = OrderUtils.countTodayByCreateTime(approveProcessMapper, "SP","approve_id");
         approveProcess.setApproveId(no);
         approveProcess.setApproveUser(sysUser.getUserId());
         approveProcess.setApproveUserName(sysUser.getNickName());
         approveProcess.setApproveDeptId(sysDept.getDeptId());
+        approveProcess.setRecordId(approveProcessVO.getRecordId());
         approveProcess.setApproveUserIds(nodeIds.stream().map(String::valueOf).collect(Collectors.joining(",")));
         approveProcess.setApproveDeptName(sysDept.getDeptName());
         approveProcess.setApproveUserNames(sysUsers.stream().map(SysUser::getNickName).collect(Collectors.joining(",")));
-        approveProcess.setApproveTime(StringUtils.isEmpty(approveProcessVO.getApproveTime()) ? new Date() : dateFormat.parse(approveProcessVO.getApproveTime()));
+        approveProcess.setApproveTime(StringUtils.isEmpty(approveProcessVO.getApproveTime()) ? new Date(): dateFormat.parse(approveProcessVO.getApproveTime()));
         approveProcess.setApproveReason(approveProcessVO.getApproveReason());
         approveProcess.setDeviceRepairId(approveProcessVO.getDeviceRepairId());
-        approveProcess.setRecordId(approveProcessVO.getRecordId());
         approveProcess.setMaintenancePrice(approveProcessVO.getMaintenancePrice());
         approveProcess.setPrice(approveProcessVO.getPrice());
         approveProcess.setStartDate(approveProcessVO.getStartDate());
@@ -133,12 +133,12 @@
         tempFileService.migrateTempFilesToFormal(approveProcess.getId(), approveProcessVO.getTempFileIds(), FileNameType.ApproveProcess.getValue());
         /*娑堟伅閫氱煡*/
         Long id = nodeIds.get(0);
-        if (approveProcess.getApproveType() == 8) {
+        if (approveProcess.getApproveType()==8){
             sysNoticeService.simpleNoticeByUser(approveProcessType(approveProcess.getApproveType()),
                     approveProcess.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Collections.singletonList(id),
                     "/safeProduction/safeWorkApproval?approveType=" + approveProcess.getApproveType() + "&approveId=" + approveProcess.getApproveId());
-        } else {
+        }else {
             sysNoticeService.simpleNoticeByUser(approveProcessType(approveProcess.getApproveType()),
                     approveProcess.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Collections.singletonList(id),
@@ -155,6 +155,7 @@
         }
         return sysDeptList;
     }
+
 
     @Override
     public IPage<ApproveProcess> listAll(Page page, ApproveProcess approveProcess) {
@@ -275,9 +276,9 @@
 
             //  鍒犻櫎瀵瑰簲鐨勬秷鎭�氱煡
             sysNoticeService.remove(new LambdaQueryWrapper<SysNotice>()
-                    .eq(SysNotice::getNoticeTitle, approveProcessType(latestProcess.getApproveType()))
-                    .eq(SysNotice::getSenderId, latestProcess.getApproveUser())
-                    .apply("CAST(notice_content AS CHAR) LIKE CONCAT('%', {0}, '%')", latestProcess.getApproveId()));
+                            .eq(SysNotice::getNoticeTitle, approveProcessType(latestProcess.getApproveType()))
+                            .eq(SysNotice::getSenderId, latestProcess.getApproveUser())
+                            .apply("CAST(notice_content AS CHAR) LIKE CONCAT('%', {0}, '%')", latestProcess.getApproveId()));
         }
 
     }
@@ -285,12 +286,23 @@
     @Override
     public ApproveProcess getApproveById(String id) {
         ApproveProcess one = approveProcessMapper.selectList(Wrappers.<ApproveProcess>lambdaQuery()
-                .eq(ApproveProcess::getApproveId, id)
-                .eq(ApproveProcess::getApproveDelete, 0)).get(0);
+                .eq(ApproveProcess::getApproveId,id)
+                .eq(ApproveProcess::getApproveDelete,0)).get(0);
         one.setCommonFileList(commonFileMapper.selectList(new LambdaQueryWrapper<CommonFile>()
                 .eq(CommonFile::getCommonId, one.getId())
                 .eq(CommonFile::getType, FileNameType.ApproveProcess.getValue())));
         return one;
+    }
+
+    @Override
+    public void deleteByRecordId(Long recordId) {
+        LambdaQueryWrapper<ApproveProcess> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ApproveProcess::getRecordId, recordId)
+                .eq(ApproveProcess::getApproveType, 6);
+        List<ApproveProcess> approveProcess = list(wrapper);
+        if (approveProcess != null) {
+            approveProcess.forEach(p -> this.removeById(p.getId()));
+        }
     }
 
 
@@ -301,7 +313,6 @@
                 .eq(ApproveProcess::getApproveReason, approveGetAndUpdateVo.getApproveReason())
                 .last("limit 1");
         ApproveProcess approveProcess = approveProcessMapper.selectOne(approveProcessLambdaQueryWrapper);
-
         if (approveProcess == null) throw new RuntimeException("璇烽�夋嫨瀹℃壒浜�");
         //鏌ヨ瀹℃壒閰嶇疆
         List<ApproveProcessConfigNode> approveProcessConfig = approveProcessConfigNodeMapper.selectList(new LambdaQueryWrapper<ApproveProcessConfigNode>().eq(ApproveProcessConfigNode::getApproveType, approveGetAndUpdateVo.getApproveType()));
@@ -335,12 +346,12 @@
         approveNodeService.initApproveNodes(approveGetAndUpdateVo.getApproveUserIds(), approveProcess.getApproveId(), approveProcess.getTenantId());
         /*娑堟伅閫氱煡*/
         Long id = configNodeIds.get(0);
-        if (approveProcess.getApproveType() == 8) {
+        if (approveProcess.getApproveType()==8){
             sysNoticeService.simpleNoticeByUser(approveProcessType(approveProcess.getApproveType()),
                     approveProcess.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Collections.singletonList(id),
                     "/safeProduction/safeWorkApproval?approveType=" + approveProcess.getApproveType() + "&approveId=" + approveProcess.getApproveId());
-        } else {
+        }else {
             sysNoticeService.simpleNoticeByUser(approveProcessType(approveProcess.getApproveType()),
                     approveProcess.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Collections.singletonList(id),
@@ -400,12 +411,12 @@
         tempFileService.migrateTempFilesToFormal(approve.getId(), approveGetAndUpdateVo.getTempFileIds(), FileNameType.ApproveProcess.getValue());
         /*娑堟伅閫氱煡*/
         String id = approve.getApproveUserIds().split(",")[0];
-        if (approve.getApproveType() == 8) {
+        if (approve.getApproveType()==8){
             sysNoticeService.simpleNoticeByUser(approveProcessType(approve.getApproveType()),
                     approve.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Arrays.asList(Long.valueOf(id)),
                     "/safeProduction/safeWorkApproval?approveType=" + approve.getApproveType() + "&approveId=" + approve.getApproveId());
-        } else {
+        }else {
             sysNoticeService.simpleNoticeByUser(approveProcessType(approve.getApproveType()),
                     approve.getApproveId() + "娴佺▼缂栧彿鐨勫鎵归渶瑕佹偍瀹℃牳!!!!!",
                     Arrays.asList(Long.valueOf(id)),
@@ -434,7 +445,7 @@
                 return "鍙戣揣瀹℃壒";
             case 8:
                 return "鍗遍櫓浣滀笟瀹℃壒";
-            case 9:
+            case 10:
                 return "閿�鍞鎵�";
         }
         return null;

--
Gitblit v1.9.3