From 986fa4201bf506a9222c98081b60449a9b588720 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Mon, 19 Jan 2026 13:26:51 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/BKI-3217 --- credit-tracker.properties | 3 ++- .../config/settings/CreditTrackerSettings.java | 1 + .../service/task/impl/KickRecalcPipeLine.java | 6 +++--- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/credit-tracker.properties b/credit-tracker.properties index 4547704..805c183 100644 --- a/credit-tracker.properties +++ b/credit-tracker.properties @@ -67,8 +67,9 @@ ct.load-dir=D:\\folder_name\\signals ct.monitoring-interval=${MONITORING_INTERVAL:15} # days ct.update-flags-cron-expression=${UPDATE_FLAGS_CRON_EXPRESSION:0 25 18 * * *} -ct.update-fid-cron-expression=${UPDATE_FLAGS_CRON_EXPRESSION:0 10 12 * * *} ct.days-to-update-flags=${DAYS_TO_UPDATE_FLAGS:30} +ct.update-fid-cron-expression=${UPDATE_FLAGS_CRON_EXPRESSION:0 10 12 * * *} +ct.days-to-update-fids=${DAYS_TO_UPDATE_FIDS:30} ct.db-version=${DB_VERSION:1234} diff --git a/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java b/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java index e107c85..22ee245 100644 --- a/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java +++ b/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java @@ -35,6 +35,7 @@ public class CreditTrackerSettings { private Long monitoringInterval; private String updateFlagsCronExpression; private Long daysToUpdateFlags; + private Long daysToUpdateFids; private String encoding; private String dbVersion; private Integer saverSubjectBatchSize; diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickRecalcPipeLine.java b/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickRecalcPipeLine.java index 078b5f6..f066860 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickRecalcPipeLine.java +++ b/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickRecalcPipeLine.java @@ -29,7 +29,7 @@ public class KickRecalcPipeLine implements IPipeLineStarter { protected final PackageRecordsService packageRecordsService; protected final CreditTrackerSettings creditTrackerSettings; private final int BATCH_SIZE; - private final Long daysToUpdateFlags; + private final Long daysToUpdateFids; private boolean isInterrupted = false; private PipelineContext context; @@ -45,7 +45,7 @@ public class KickRecalcPipeLine implements IPipeLineStarter { this.packageRecordsService = packageRecordsService; this.creditTrackerSettings = creditTrackerSettings; this.BATCH_SIZE = creditTrackerSettings.getPipeline().subjectBatchSize(); - this.daysToUpdateFlags = creditTrackerSettings.getDaysToUpdateFlags() != null ? creditTrackerSettings.getDaysToUpdateFlags() : 1; + this.daysToUpdateFids = creditTrackerSettings.getDaysToUpdateFids() != null ? creditTrackerSettings.getDaysToUpdateFids() : 1; } private static class PipelineStarterException extends SignalClientException { @@ -116,6 +116,6 @@ public class KickRecalcPipeLine implements IPipeLineStarter { return PipelineMode.REPEATED_RESTORE; } protected List nextPage(int offset) { - return phonesMapMapper.searchedAtLessThan(daysToUpdateFlags.intValue(), BATCH_SIZE, offset); + return phonesMapMapper.searchedAtLessThan(daysToUpdateFids.intValue(), BATCH_SIZE, offset); } }