From 78d7929342fbd979b4e378f3a9e76bb6e73711c8 Mon Sep 17 00:00:00 2001
From: Mikhail Trofimov <mtrofimov@mfd.ru>
Date: Fri, 27 Jun 2025 14:31:48 +0300
Subject: [PATCH] Added logs for MonitoringService

---
 .../credit_tracker/service/MonitoringService.java   | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java
index 4d7b7d9..384ca0f 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java
@@ -56,11 +56,14 @@ public class MonitoringService {
     }
 
     private void monitor() {
+        log.info("Start monitoring");
         List<PackageData> packages = signalService.findPackagesOnMonitoring();
         for (PackageData packageData : packages) {
+            log.info("Processing package {}", packageData.getPackageName());
             SgnlOnlineReport onlineReports = signalRestService.getReports(packageData.getUserId().substring(0, 6) + "_" + packageData.getPackageName());
 
             if (onlineReports == null) {
+                log.info("No reports found for package {}", packageData.getPackageName());
                 continue;
             }
 
@@ -73,6 +76,12 @@ public class MonitoringService {
 
             LocalDateTime lastDownloadedReportDate = CTUtil.parseDateFromReportFileName(packageData.getLastDownloadedReport());
 
+            if(packageData.getLastDownloadedReport() != null) {
+                log.info("Last downloaded report found for package {}. Last Downloaded Report Name: {}", packageData.getPackageName(), packageData.getLastDownloadedReport());
+            } else {
+                log.info("Last Downloaded Report Name is empty");
+            }
+
             OnlineDownloadReport report = null;
             if (packageData.getLastDownloadedReport() == null && newReport.isPresent()) {
                 report = loadReport(newReport.get()); // по этому пакету еще не было загруженных отчетов, продолжаем работу с полученным
@@ -83,12 +92,14 @@ public class MonitoringService {
                 }
             }
             if (report == null) {
+                log.info("Report loaded for package {}, Report name {}", packageData.getPackageName(), newReport.get());
                 continue;
             }
 
             MonitoringSignalResponse response = generateResponse(packageData, report.getPersons().getPersons());
             String fileName = createResponseFile(packageData, response);
             if (fileName != null) {
+                log.info("New report fileName: {}", fileName);
                 updateSignalHits(packageData, response, fileName);
                 signalService.updateLastDownloadedReport(packageData.getId(), newReport.get());
             }
@@ -161,6 +172,7 @@ public class MonitoringService {
     }
 
     private void updateSignalHits(PackageData packageData, MonitoringSignalResponse response, String reportFileName) {
+        log.info("Updating signal hits for {}", packageData.getPackageName());
         LocalDateTime responseSentAt = LocalDateTime.now();
         List<HitsData> hits = new ArrayList<>();
         response.getSubjects().getSubjects().forEach(subject -> {
@@ -175,6 +187,7 @@ public class MonitoringService {
             });
         });
         signalService.setHits(hits);
+        log.info("Signal hits updated for package {}", packageData.getPackageName());
     }
 
     private OnlineDownloadReport loadReport(String reportName) {