From abf16522a49161292d117527dc5b61be996c4082 Mon Sep 17 00:00:00 2001
From: xiong_cl <140612616@qq.com>
Date: Fri, 12 Apr 2024 15:06:50 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=96=87=E4=BB=B6=E5=AE=A1?=
 =?UTF-8?q?=E6=89=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/ReviewRecordServiceImpl.java | 22 +++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/shandan-system/src/main/java/com/keyware/shandan/bianmu/service/impl/ReviewRecordServiceImpl.java b/shandan-system/src/main/java/com/keyware/shandan/bianmu/service/impl/ReviewRecordServiceImpl.java
index dbfb140..266f552 100644
--- a/shandan-system/src/main/java/com/keyware/shandan/bianmu/service/impl/ReviewRecordServiceImpl.java
+++ b/shandan-system/src/main/java/com/keyware/shandan/bianmu/service/impl/ReviewRecordServiceImpl.java
@@ -165,6 +165,21 @@ public class ReviewRecordServiceImpl extends BaseServiceImpl<ReviewRecordMapper,
         return true;
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean directoryFileReview(String id, ReviewStatus status, String opinion, Boolean sendNotice) {
+        ReviewEntityType type = ReviewEntityType.FILE;
+        DirectoryVo dir = directoryService.getById(id);
+        Assert.notNull(dir, "数据资源审核异常，数据未找到！id=" + id);
+        dir.setReviewStatus(status);
+        directoryService.updateById(dir);
+        //保存审核记录
+        ReviewRecordVo record = saveReviewRecord(id, type, status, opinion);
+        if (sendNotice) {
+            notificationService.sendNotification(newReviewNotify(record, dir.getDirectoryName(), dir.getDirectoryName()));
+        }
+        return true;
+    }
 
     private ReviewRecordVo saveReviewRecord(String entityId, ReviewEntityType entityType, ReviewStatus reviewOperate, String reviewOpinion) {
         ReviewRecordVo record = new ReviewRecordVo(entityId, entityType, reviewOperate, reviewOpinion);
@@ -225,10 +240,13 @@ public class ReviewRecordServiceImpl extends BaseServiceImpl<ReviewRecordMapper,
 
     private List<DirectoryVo> updateDirAndChildrenStatus(DirectoryVo dir, ReviewStatus status) {
         QueryWrapper<DirectoryVo> wrapper = new QueryWrapper<>();
-        wrapper.likeRight("DIRECTORY_PATH", dir.getDirectoryPath() + "/").in("DIRECTORY_TYPE", DirectoryType.DIRECTORY, DirectoryType.LINK_DIR);
+        wrapper.likeRight("DIRECTORY_PATH", dir.getDirectoryPath() + "/").in("DIRECTORY_TYPE", DirectoryType.DIRECTORY, DirectoryType.LINK_DIR,DirectoryType.FILE);
         List<DirectoryVo> list = directoryService.list(wrapper);
         list.add(dir);
-        list.forEach(item -> item.setReviewStatus(status));
+        //提交文件时将文件状态改成PASS
+        list.forEach(item -> {
+            item.setReviewStatus("FILE".equals(item.getDirectoryType().getValue()) && "SUBMITTED".equals(status.getValue()) ? ReviewStatus.valueOf("PASS") : status);
+        });
         directoryService.saveOrUpdateBatch(list);
         return list;
     }