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 f9ac8d7..5eae5f9 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java @@ -85,7 +85,8 @@ public class MonitoringService { private void monitor() { try { log.info("Start monitoring"); - List packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name()); + List packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name(), + Status.PROCESSING_REPEATED.name()); for (UserPackage userPackage : packages) { MDC.put("ru.nbch.credit_tracker.log.mdc.key", "[" + userPackage.getPackageName() + "]"); processPackage(userPackage); @@ -103,7 +104,7 @@ public class MonitoringService { log.info("Package has no fids. Package will be skipped."); return; } - SgnlOnlineReport onlineReports = signalRestService.getReports(userPackage.getUserId() + "_" + userPackage.getPackageName()); + SgnlOnlineReport onlineReports = signalRestService.getReports(userPackage.getUserId().substring(0, 6) + "_" + userPackage.getPackageName()); if (onlineReports == null) { log.info("No reports found for package");