From 98a414f7f8b18171ea397febc1ec311da1891589 Mon Sep 17 00:00:00 2001
From: MAC <1162714483@qq.com>
Date: Sun, 21 Nov 2021 16:15:40 +0800
Subject: [PATCH] =?UTF-8?q?fix(=E6=90=9C=E7=B4=A2):=20=E5=88=A0=E9=99=A4ES?=
 =?UTF-8?q?=E6=90=9C=E7=B4=A2=E5=B9=B6=E5=8F=91=E5=AD=98=E5=82=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../file/component/FileDealComp.java          | 26 +++++++++----------
 1 file changed, 12 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/qiwenshare/file/component/FileDealComp.java b/src/main/java/com/qiwenshare/file/component/FileDealComp.java
index e97d929..720a75a 100644
--- a/src/main/java/com/qiwenshare/file/component/FileDealComp.java
+++ b/src/main/java/com/qiwenshare/file/component/FileDealComp.java
@@ -253,14 +253,14 @@ public class FileDealComp {
 
 
     public void uploadESByUserFileId(Long userFileId) {
-        exec.execute(()->{
-            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);
+
+        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);
 //                if (fileSearch.getIsDir() == 0) {
 //
 //                    Reader reader = ufopFactory.getReader(fileSearch.getStorageType());
@@ -271,13 +271,11 @@ public class FileDealComp {
 //    //                fileSearch.setContent(content);
 //
 //                }
-                    elasticSearchService.save(fileSearch);
-                }
-            } catch (Exception e) {
-                log.debug("ES更新操作失败，请检查配置");
+                elasticSearchService.save(fileSearch);
             }
-        });
-
+        } catch (Exception e) {
+            log.debug("ES更新操作失败，请检查配置");
+        }
 
     }