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

ES操作失败由报错改为日志打印

Browse Source
This commit is contained in:
马超 2021-06-01 18:59:21 +08:00
parent 49d93543c1
commit 52ea04512d
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -11,6 +11,7 @@ import com.qiwenshare.file.domain.UserFile;
import com.qiwenshare.file.mapper.UserFileMapper; import com.qiwenshare.file.mapper.UserFileMapper;
import com.qiwenshare.file.vo.file.FileListVo; import com.qiwenshare.file.vo.file.FileListVo;
import com.qiwenshare.ufo.util.PathUtil; import com.qiwenshare.ufo.util.PathUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -23,6 +24,7 @@ import java.util.concurrent.Executors;
/** /**
* 文件逻辑处理组件 * 文件逻辑处理组件
*/ */
@Slf4j
@Component @Component
public class FileDealComp { public class FileDealComp {
@Resource @Resource
@ -221,20 +223,27 @@ public class FileDealComp {
public void uploadESByUserFileId(Long userFileId) { public void uploadESByUserFileId(Long userFileId) {
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);
elasticSearchService.save(fileSearch); elasticSearchService.save(fileSearch);
}
} catch (Exception e) {
log.error("ES更新操作失败，请检查配置");
} }
} }
public void deleteESByUserFileId(Long userFileId) { public void deleteESByUserFileId(Long userFileId) {
elasticSearchService.deleteById(userFileId); try {
elasticSearchService.deleteById(userFileId);
} catch (Exception e) {
log.error("ES删除操作失败，请检查配置");
}
} }
} }