diff --git a/src/main/java/com/qiwenshare/file/controller/TaskController.java b/src/main/java/com/qiwenshare/file/controller/TaskController.java index 8dad675..ada7a75 100644 --- a/src/main/java/com/qiwenshare/file/controller/TaskController.java +++ b/src/main/java/com/qiwenshare/file/controller/TaskController.java @@ -35,10 +35,16 @@ public class TaskController { public void updateElasticSearch() { 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()); - if (i % 1000 == 0 || i == userfileList.size() - 1) { - log.info("目录健康检查进度:" + (i + 1) + "/" + userfileList.size()); + try { + + QiwenFile ufopFile = new QiwenFile(userfileList.get(i).getFilePath(), userfileList.get(i).getFileName(), userfileList.get(i).getIsDir() == 1); + fileDealComp.restoreParentFilePath(ufopFile, userfileList.get(i).getUserId()); + if (i % 1000 == 0 || i == userfileList.size() - 1) { + log.info("目录健康检查进度:" + (i + 1) + "/" + userfileList.size()); + } + + } catch (Exception e) { + log.error(e.getMessage()); } } userfileList = userFileService.list(new QueryWrapper().eq("deleteFlag", 0));