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

Added logs for SignalFacade

Browse source
This commit is contained in:
Mikhail Trofimov 2025-06-27 14:36:36 +03:00
parent 78d7929342
commit a56d6a2712
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java
View file

@ -166,7 +166,7 @@ public class SignalFacade {
} }
// в отдельном потоке запускаем поиск фидов и расчет флагов просрочек // в отдельном потоке запускаем поиск фидов и расчет флагов просрочек
registerFidsAndDebts(packageId); registerFidsAndDebts(packageId, monitoringRequest.getPackageName());
return ResponseEntity.ok().body(new MonitoringResponse()); 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(() -> { executor.execute(() -> {
try { try {
List<PhoneService.FidsPhoneData> phoneFidsData = signalService.registerSubjectsFidAndDebts(packageId); List<PhoneService.FidsPhoneData> phoneFidsData = signalService.registerSubjectsFidAndDebts(packageId);
@ -231,8 +231,10 @@ public class SignalFacade {
Signals signals = signalService.buildSignals(packageId, phoneFidsData); Signals signals = signalService.buildSignals(packageId, phoneFidsData);
// TODO validate xsd? // TODO validate xsd?
if (signalRestService.update(signals)) { if (signalRestService.update(signals)) {
log.info("Package was successfully registered in signal service. PackageId: {} PackageName: {}", packageId, packageName);
signalService.setPackageStatus(packageId, Status.ON_MONITORING); signalService.setPackageStatus(packageId, Status.ON_MONITORING);
} else { } else {
log.info("Package registration was rejected by signal service. PackageId: {} PackageName: {}", packageId, packageName);
signalService.setPackageStatus(packageId, Status.ERROR); signalService.setPackageStatus(packageId, Status.ERROR);
} }
} }
@ -278,6 +280,7 @@ public class SignalFacade {
MonitoringPackageDeleteResponse response = signalService.deletePackage(username, packageName); MonitoringPackageDeleteResponse response = signalService.deletePackage(username, packageName);
signalRestService.deletePackage(username, packageName); signalRestService.deletePackage(username, packageName);
log.info("Package {} deleted", packageName);
return ResponseEntity.ok(response); return ResponseEntity.ok(response);
} catch (Exception e) { } catch (Exception e) {
if (e instanceof SignalErrorException) { if (e instanceof SignalErrorException) {