From 17850710b51fdf807223e40fc89c110fad5ea27b Mon Sep 17 00:00:00 2001 From: backdev-1 Date: Wed, 13 May 2026 15:43:43 +0700 Subject: [PATCH] dev add context for notifcations --- .../nocopy/service/search/GlobalSearchAsyncProcessor.java | 8 ++------ .../soune/nocopy/service/search/GlobalSearchService.java | 2 +- 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java index 3b9cfd1..0382188 100644 --- a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java +++ b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java @@ -54,9 +54,7 @@ public class GlobalSearchAsyncProcessor { private final FileEntityRepository fileEntityRepository; @Async - public void processFilesAsync(String taskId, List filesToProcess, Long userId) { - GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow(); - + public void processFilesAsync(GlobalSearchTask task, List filesToProcess, Long userId) { try { for (int i = 0; i < filesToProcess.size(); i++) { String uuid = filesToProcess.get(i); @@ -67,7 +65,7 @@ public class GlobalSearchAsyncProcessor { tariffInfoService.writeOffTokens(userId, TariffConstants.TOKEN_VALUE_FOR_SEARCH, OperationType.GLOBAL_SEARCH); - GlobalSearchResult result = processFile(file, taskId, userId); + GlobalSearchResult result = processFile(file, task.getTaskId(), userId); globalSearchResultRepository.save(result); task.setProcessedFiles(i + 1); @@ -81,8 +79,6 @@ public class GlobalSearchAsyncProcessor { addSearchResultNotification(save, filesToProcess, userId); } catch (Exception e) { - log.error("Global search failed for task: {}", taskId, e); - task.setStatus(SearchStatus.FAILED.name()); task.setUpdatedAt(LocalDateTime.now()); globalSearchTaskRepository.save(task); diff --git a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchService.java b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchService.java index 1d7095f..37d2528 100644 --- a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchService.java +++ b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchService.java @@ -48,7 +48,7 @@ public class GlobalSearchService { List fileIds = filesToProcess.stream().map(FileEntity::getId).toList(); - asyncProcessor.processFilesAsync(save.getTaskId(), fileIds, userId); + asyncProcessor.processFilesAsync(save, fileIds, userId); return save.getTaskId(); }