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

!82 代码合并

Browse Source 
Merge pull request !82 from 小鲤鱼听听/develop
This commit is contained in:
小鲤鱼听听 2021-11-21 08:16:12 +00:00 committed by Gitee
commit 6764efbc26
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更新操作失败，请检查配置");
}
} }