ak/file
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(目录健康检查): 目录健康检查批处理

Browse Source
This commit is contained in:
MAC 2022-05-08 10:29:46 +08:00
parent e878179351
commit 69ba0e4979
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/qiwenshare/file/controller/TaskController.java
View File

@ -33,6 +33,14 @@ public class TaskController {
@Scheduled(fixedRate = 1000 * 60 * 60 * 24) @Scheduled(fixedRate = 1000 * 60 * 60 * 24)
public void updateElasticSearch() { public void updateElasticSearch() {
List<UserFile> userfileList = userFileService.list(); List<UserFile> userfileList = userFileService.list();
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());
}
}
userfileList = userFileService.list();
for (UserFile userFile : userfileList) { for (UserFile userFile : userfileList) {
fileDealComp.uploadESByUserFileId(userFile.getUserFileId()); fileDealComp.uploadESByUserFileId(userFile.getUserFileId());
} }