treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added logs for MonitoringService

Browse source
This commit is contained in:
Mikhail Trofimov 2025-06-27 14:31:48 +03:00
parent 8938a99165
commit 78d7929342
1 changed files with 13 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java
View file

@ -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) {