backdev/no-copy
1
0
Fork 0
Code Issues Pull Requests 5 Actions Packages Projects Releases Wiki Activity

dev add notification entity
Test Workflow / test (push) Successful in 3s
Details

Browse Source
This commit is contained in:
vladp
2026-04-02 12:18:47 +07:00
parent 0f2908b037
commit 9d33c7532a
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java
+2 -3
View File
@@ -48,6 +48,8 @@ public class GlobalSearchAsyncProcessor {
@Async @Async
@Transactional @Transactional
public void processFilesAsync(String taskId, List<FileEntity> filesToProcess, Long userId) { public void processFilesAsync(String taskId, List<FileEntity> filesToProcess, Long userId) {
GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
try { try {
for (int i = 0; i < filesToProcess.size(); i++) { for (int i = 0; i < filesToProcess.size(); i++) {
FileEntity file = filesToProcess.get(i); FileEntity file = filesToProcess.get(i);
@@ -55,13 +57,11 @@ public class GlobalSearchAsyncProcessor {
GlobalSearchResult result = processFile(file, taskId, userId); GlobalSearchResult result = processFile(file, taskId, userId);
globalSearchResultRepository.save(result); globalSearchResultRepository.save(result);
GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
task.setProcessedFiles(i + 1); task.setProcessedFiles(i + 1);
task.setUpdatedAt(LocalDateTime.now()); task.setUpdatedAt(LocalDateTime.now());
globalSearchTaskRepository.save(task); globalSearchTaskRepository.save(task);
} }
GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
task.setStatus(SearchStatus.COMPLETED.name()); task.setStatus(SearchStatus.COMPLETED.name());
task.setUpdatedAt(LocalDateTime.now()); task.setUpdatedAt(LocalDateTime.now());
globalSearchTaskRepository.save(task); globalSearchTaskRepository.save(task);
@@ -70,7 +70,6 @@ public class GlobalSearchAsyncProcessor {
} catch (Exception e) { } catch (Exception e) {
log.error("Global search failed for task: {}", taskId, e); log.error("Global search failed for task: {}", taskId, e);
GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
task.setStatus(SearchStatus.FAILED.name()); task.setStatus(SearchStatus.FAILED.name());
task.setUpdatedAt(LocalDateTime.now()); task.setUpdatedAt(LocalDateTime.now());
globalSearchTaskRepository.save(task); globalSearchTaskRepository.save(task);