dev add notification entity

src/main/java/ru/soune/nocopy/scheduler/MonitoringScheduler.java

@@ -7,11 +7,16 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import ru.soune.nocopy.entity.monitoring.FileMonitoringEntity;
+import ru.soune.nocopy.entity.notification.NotificationType;
 import ru.soune.nocopy.repository.FileMonitoringRepository;
 import ru.soune.nocopy.service.monitoring.MonitoringSearchService;
+import ru.soune.nocopy.service.notification.NotificationService;
 
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Component
@@ -22,6 +27,8 @@ public class MonitoringScheduler {
 
     private final MonitoringSearchService monitoringSearchService;
 
+    private final NotificationService notificationService;
+
     @Scheduled(cron = "0 1 2 * * *", zone = "Europe/Moscow")
     @Transactional
     public void processScheduledMonitoring() {
@@ -29,6 +36,8 @@ public class MonitoringScheduler {
 
         LocalDateTime now = LocalDateTime.now();
         List<FileMonitoringEntity> readyForRun = monitoringRepository.findReadyForRun(now);
+        Map<Long, List<FileMonitoringEntity>> groupingFilesMonitoring = readyForRun.stream()
+                .collect(Collectors.groupingBy(FileMonitoringEntity::getUserId));
 
         log.info("Found {} files ready for monitoring", readyForRun.size());
 
@@ -43,5 +52,10 @@ public class MonitoringScheduler {
                 monitoringRepository.save(monitoring);
             }
         }
+
+        Set<Long> usersForNotifications = groupingFilesMonitoring.keySet();
+        for (Long userId : usersForNotifications) {
+            notificationService.addNotification(NotificationType.MONITORING_RESULT, userId);
+        }
     }
 }