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

fix(搜索): 删除ES搜索并发存储

Browse Source
This commit is contained in:
MAC 2021-11-21 16:15:40 +08:00
parent 20f2d3cbf2
commit 98a414f7f8
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/com/qiwenshare/file/component/FileDealComp.java
View File

@ -253,14 +253,14 @@ public class FileDealComp {
public void uploadESByUserFileId(Long userFileId) { public void uploadESByUserFileId(Long userFileId) {
exec.execute(()->{
try { try {
UserFile userFile = new UserFile(); UserFile userFile = new UserFile();
userFile.setUserFileId(userFileId); userFile.setUserFileId(userFileId);
List<FileListVo> userfileResult = userFileMapper.userFileList(userFile, null, null); List<FileListVo> userfileResult = userFileMapper.userFileList(userFile, null, null);
if (userfileResult != null && userfileResult.size() > 0) { if (userfileResult != null && userfileResult.size() > 0) {
FileSearch fileSearch = new FileSearch(); FileSearch fileSearch = new FileSearch();
BeanUtil.copyProperties(userfileResult.get(0), fileSearch); BeanUtil.copyProperties(userfileResult.get(0), fileSearch);
// if (fileSearch.getIsDir() == 0) { // if (fileSearch.getIsDir() == 0) {
// //
// Reader reader = ufopFactory.getReader(fileSearch.getStorageType()); // Reader reader = ufopFactory.getReader(fileSearch.getStorageType());
@ -271,13 +271,11 @@ public class FileDealComp {
// // fileSearch.setContent(content); // // fileSearch.setContent(content);
// //
// } // }
elasticSearchService.save(fileSearch); elasticSearchService.save(fileSearch);
}
} catch (Exception e) {
log.debug("ES更新操作失败，请检查配置");
} }
}); } catch (Exception e) {
log.debug("ES更新操作失败，请检查配置");
}
} }