diff --git a/src/main/java/ru/nbch/credit_tracker/service/SignalService.java b/src/main/java/ru/nbch/credit_tracker/service/SignalService.java index 5c4f2f0..bccf1d4 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/SignalService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/SignalService.java @@ -89,8 +89,6 @@ public class SignalService { public UpdateResult updateFlags2(UserPackage userPackage) { log.debug("updating flags for package [{} {}]", userPackage.getPackageName(), userPackage.getId()); - boolean updated = false; - boolean noFidsFound = true; Long packageId = userPackage.getId(); int offset = 0; List page = phoneService2.pageByPackageId(packageId, batchSize, offset); @@ -111,7 +109,7 @@ public class SignalService { log.debug("loading next page..."); page = phoneService2.pageByPackageId(packageId, batchSize, offset); } - return new UpdateResult(updated, noFidsFound); + return new UpdateResult(true, false); } /** 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 25715d0..cac9915 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java @@ -63,7 +63,7 @@ public class UpdatingFlagsService { String packageName = userPackage.getPackageName(); try { signalService.updatePackageStatus(packageId, Status.PROCESSING); - SignalService.UpdateResult updateResult = signalService.updateSubjects(packageId, null); + SignalService.UpdateResult updateResult = signalService.updateFlags2(userPackage); if (updateResult.isUpdated()) { if (signalRestService.setupMonitoring(packageId)) { // LocalDateTime monitoringAt = userPackage.getMonitoringAt() != null ? userPackage.getMonitoringAt() : LocalDateTime.now();