From fecb4d467f7dacb03a3c909d33ecd50387f8482f Mon Sep 17 00:00:00 2001 From: Mikhail Trofimov Date: Mon, 7 Jul 2025 12:18:12 +0300 Subject: [PATCH] Added batchs for updating hits --- .../ru/nbch/credit_tracker/service/MonitoringService.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 cb1b905..f82e8c7 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java @@ -37,6 +37,7 @@ public class MonitoringService { private final SignalService signalService; private final IXmlProcessor xmlProcessor; private final CreditTrackerSettings config; + private final Integer batchSize = 10000; public MonitoringService(SignalRestService signalRestService, SignalService signalService, @@ -192,7 +193,10 @@ public class MonitoringService { hits.add(hit); }); }); - signalService.insertHits(hits); + for (int i = 0; i < hits.size(); i += batchSize) { + int end = Math.min(i + batchSize, hits.size()); + signalService.insertHits(hits.subList(i, end)); + } log.info("Signal hits updated for package {}", userPackage.getPackageName()); }