From 52ea04512dfeb9c719b8080b64a22c486ac7ac2f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=A9=AC=E8=B6=85?= <1162714483@qq.com>
Date: Tue, 1 Jun 2021 18:59:21 +0800
Subject: [PATCH] =?UTF-8?q?ES=E6=93=8D=E4=BD=9C=E5=A4=B1=E8=B4=A5=E7=94=B1?=
 =?UTF-8?q?=E6=8A=A5=E9=94=99=E6=94=B9=E4=B8=BA=E6=97=A5=E5=BF=97=E6=89=93?=
 =?UTF-8?q?=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../file/component/FileDealComp.java          | 27 ++++++++++++-------
 1 file changed, 18 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/qiwenshare/file/component/FileDealComp.java b/src/main/java/com/qiwenshare/file/component/FileDealComp.java
index 433a25d..28723eb 100644
--- a/src/main/java/com/qiwenshare/file/component/FileDealComp.java
+++ b/src/main/java/com/qiwenshare/file/component/FileDealComp.java
@@ -11,6 +11,7 @@ import com.qiwenshare.file.domain.UserFile;
 import com.qiwenshare.file.mapper.UserFileMapper;
 import com.qiwenshare.file.vo.file.FileListVo;
 import com.qiwenshare.ufo.util.PathUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -23,6 +24,7 @@ import java.util.concurrent.Executors;
 /**
  * 文件逻辑处理组件
  */
+@Slf4j
 @Component
 public class FileDealComp {
     @Resource
@@ -221,20 +223,27 @@ public class FileDealComp {
 
 
     public void uploadESByUserFileId(Long userFileId) {
-
-        UserFile userFile = new UserFile();
-        userFile.setUserFileId(userFileId);
-        List<FileListVo> userfileResult = userFileMapper.userFileList(userFile, null, null);
-        if (userfileResult != null && userfileResult.size() > 0) {
-            FileSearch fileSearch = new FileSearch();
-            BeanUtil.copyProperties(userfileResult.get(0), fileSearch);
-            elasticSearchService.save(fileSearch);
+        try {
+            UserFile userFile = new UserFile();
+            userFile.setUserFileId(userFileId);
+            List<FileListVo> userfileResult = userFileMapper.userFileList(userFile, null, null);
+            if (userfileResult != null && userfileResult.size() > 0) {
+                FileSearch fileSearch = new FileSearch();
+                BeanUtil.copyProperties(userfileResult.get(0), fileSearch);
+                elasticSearchService.save(fileSearch);
+            }
+        } catch (Exception e) {
+            log.error("ES更新操作失败，请检查配置");
         }
 
     }
 
     public void deleteESByUserFileId(Long userFileId) {
-        elasticSearchService.deleteById(userFileId);
+        try {
+            elasticSearchService.deleteById(userFileId);
+        } catch (Exception e) {
+            log.error("ES删除操作失败，请检查配置");
+        }
 
     }
 }