From f0b7149b05a59a3f301d903a15721076a01fe51a Mon Sep 17 00:00:00 2001 From: Mikhail Trofimov Date: Fri, 27 Jun 2025 14:41:15 +0300 Subject: [PATCH] Added logs for UpdatingFlagsService --- .../credit_tracker/service/UpdatingFlagsService.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java b/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java index 0688b78..b0d5c00 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java @@ -41,25 +41,32 @@ public class UpdatingFlagsService { } private void update() { + log.info("Start updating flags"); List packages = signalService.findPackagesOnMonitoring(); for (PackageData packageData : packages) { + log.info("Updating flags for Package {}", packageData.getPackageName()); List subjects = signalService.findFullSubjectsData(packageData.getId()) .stream().filter(subject -> subject.getCalculatedAt() != null && hasDaysPassed(subject.getCalculatedAt())).toList(); - updateFlags(packageData.getId(), subjects); + updateFlags(packageData.getId(), subjects, packageData.getPackageName()); } } - private void updateFlags(Integer packageId, List subjects) { + private void updateFlags(Integer packageId, List subjects, String packageName) { try { signalService.setPackageStatus(packageId, Status.PROCESSING); List phoneFidsData = signalService.updateFlags(subjects); if (!phoneFidsData.isEmpty()) { Signals signals = signalService.buildSignals(packageId, phoneFidsData); if (signalRestService.update(signals)) { + log.info("Flags were updated successfully. PackageId: {} PackageName: {}. Package status changed to ON_MONITORING", packageId, packageName); signalService.setPackageStatus(packageId, Status.ON_MONITORING); } else { + log.info("Updated package registration was rejected by signal service. PackageId: {} PackageName: {}", packageId, packageName); signalService.setPackageStatus(packageId, Status.ERROR); } + } else { + log.info("No flags were updated for package id {}. Package status changed to ON_MONITORING", packageId); + signalService.setPackageStatus(packageId, Status.ON_MONITORING); } } catch (Exception e) { log.error("Ошибка при поиске фидов или перерасчете флагов просрочек. Package_id {}", packageId, e);