From de8120c73723e35a72a792aa638e95d4d67aa754 Mon Sep 17 00:00:00 2001 From: backdev-1 Date: Wed, 13 May 2026 15:32:55 +0700 Subject: [PATCH] dev add context for notifcations --- .../service/search/GlobalSearchAsyncProcessor.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 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 ea91a81..3b9cfd1 100644 --- a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java +++ b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java @@ -60,10 +60,13 @@ public class GlobalSearchAsyncProcessor { try { for (int i = 0; i < filesToProcess.size(); i++) { String uuid = filesToProcess.get(i); - FileEntity file = fileEntityRepository.findById(uuid) - .orElseThrow(() -> new RuntimeException("File not found: " + uuid)); + log.info("UUID: " + uuid); + FileEntity file = fileEntityRepository.findById(uuid).orElse(null); - tariffInfoService.writeOffTokens(userId, TariffConstants.TOKEN_VALUE_FOR_SEARCH, OperationType.GLOBAL_SEARCH); + if (file == null) continue; + + tariffInfoService.writeOffTokens(userId, TariffConstants.TOKEN_VALUE_FOR_SEARCH, + OperationType.GLOBAL_SEARCH); GlobalSearchResult result = processFile(file, taskId, userId); globalSearchResultRepository.save(result);