From 3a4fd12acb8ba0b545c8ed8a4563603b677c12b9 Mon Sep 17 00:00:00 2001 From: MAC <1162714483@qq.com> Date: Sun, 8 May 2022 10:31:48 +0800 Subject: [PATCH] =?UTF-8?q?fix(=E7=9B=AE=E5=BD=95=E5=81=A5=E5=BA=B7?= =?UTF-8?q?=E6=A3=80=E6=9F=A5):=20=E7=9B=AE=E5=BD=95=E5=81=A5=E5=BA=B7?= =?UTF-8?q?=E6=A3=80=E6=9F=A5=E6=89=B9=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/qiwenshare/file/controller/TaskController.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/qiwenshare/file/controller/TaskController.java b/src/main/java/com/qiwenshare/file/controller/TaskController.java index e5a829c..8dad675 100644 --- a/src/main/java/com/qiwenshare/file/controller/TaskController.java +++ b/src/main/java/com/qiwenshare/file/controller/TaskController.java @@ -1,6 +1,7 @@ package com.qiwenshare.file.controller; import co.elastic.clients.elasticsearch.ElasticsearchClient; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.qiwenshare.file.api.IShareFileService; import com.qiwenshare.file.component.FileDealComp; import com.qiwenshare.file.domain.ShareFile; @@ -32,7 +33,7 @@ public class TaskController { @Scheduled(fixedRate = 1000 * 60 * 60 * 24) public void updateElasticSearch() { - List userfileList = userFileService.list(); + List userfileList = userFileService.list(new QueryWrapper().eq("deleteFlag", 0)); for (int i = 0; i < userfileList.size(); i++) { QiwenFile ufopFile = new QiwenFile(userfileList.get(i).getFilePath(), userfileList.get(i).getFileName(), userfileList.get(i).getIsDir() == 1); fileDealComp.restoreParentFilePath(ufopFile, userfileList.get(i).getUserId()); @@ -40,7 +41,7 @@ public class TaskController { log.info("目录健康检查进度：" + (i + 1) + "/" + userfileList.size()); } } - userfileList = userFileService.list(); + userfileList = userFileService.list(new QueryWrapper().eq("deleteFlag", 0)); for (UserFile userFile : userfileList) { fileDealComp.uploadESByUserFileId(userFile.getUserFileId()); }