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:31:48 +08:00
parent 69ba0e4979
commit 3a4fd12acb
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,7 @@
package com.qiwenshare.file.controller; package com.qiwenshare.file.controller;
import co.elastic.clients.elasticsearch.ElasticsearchClient; import co.elastic.clients.elasticsearch.ElasticsearchClient;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.qiwenshare.file.api.IShareFileService; import com.qiwenshare.file.api.IShareFileService;
import com.qiwenshare.file.component.FileDealComp; import com.qiwenshare.file.component.FileDealComp;
import com.qiwenshare.file.domain.ShareFile; import com.qiwenshare.file.domain.ShareFile;
@ -32,7 +33,7 @@ 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(new QueryWrapper<UserFile>().eq("deleteFlag", 0));
for (int i = 0; i < userfileList.size(); i++) { 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); QiwenFile ufopFile = new QiwenFile(userfileList.get(i).getFilePath(), userfileList.get(i).getFileName(), userfileList.get(i).getIsDir() == 1);
fileDealComp.restoreParentFilePath(ufopFile, userfileList.get(i).getUserId()); fileDealComp.restoreParentFilePath(ufopFile, userfileList.get(i).getUserId());
@ -40,7 +41,7 @@ public class TaskController {
log.info("目录健康检查进度：" + (i + 1) + "/" + userfileList.size()); log.info("目录健康检查进度：" + (i + 1) + "/" + userfileList.size());
} }
} }
userfileList = userFileService.list(); userfileList = userFileService.list(new QueryWrapper<UserFile>().eq("deleteFlag", 0));
for (UserFile userFile : userfileList) { for (UserFile userFile : userfileList) {
fileDealComp.uploadESByUserFileId(userFile.getUserFileId()); fileDealComp.uploadESByUserFileId(userFile.getUserFileId());
} }