diff --git a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java index b7b96c6..af9571a 100644 --- a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java +++ b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java @@ -166,7 +166,7 @@ public class SignalFacade { } // в отдельном потоке запускаем поиск фидов и расчет флагов просрочек - registerFidsAndDebts(packageId); + registerFidsAndDebts(packageId, monitoringRequest.getPackageName()); return ResponseEntity.ok().body(new MonitoringResponse()); } @@ -223,7 +223,7 @@ public class SignalFacade { } } - private void registerFidsAndDebts(Integer packageId) { + private void registerFidsAndDebts(Integer packageId, String packageName) { executor.execute(() -> { try { List phoneFidsData = signalService.registerSubjectsFidAndDebts(packageId); @@ -231,8 +231,10 @@ public class SignalFacade { Signals signals = signalService.buildSignals(packageId, phoneFidsData); // TODO validate xsd? if (signalRestService.update(signals)) { + log.info("Package was successfully registered in signal service. PackageId: {} PackageName: {}", packageId, packageName); signalService.setPackageStatus(packageId, Status.ON_MONITORING); } else { + log.info("Package registration was rejected by signal service. PackageId: {} PackageName: {}", packageId, packageName); signalService.setPackageStatus(packageId, Status.ERROR); } } @@ -278,6 +280,7 @@ public class SignalFacade { MonitoringPackageDeleteResponse response = signalService.deletePackage(username, packageName); signalRestService.deletePackage(username, packageName); + log.info("Package {} deleted", packageName); return ResponseEntity.ok(response); } catch (Exception e) { if (e instanceof SignalErrorException) {