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

fix hit progression bug

Browse source
This commit is contained in:
etreschenkov 2026-02-10 15:18:37 +03:00
parent 7266400169
commit f9e3af2dd6
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/MonitoringService.java
View file

@ -91,6 +91,9 @@ public class MonitoringService {
List<UserPackage> packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name(), List<UserPackage> packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name(),
Status.PROCESSING_REPEATED.name()); Status.PROCESSING_REPEATED.name());
for (UserPackage userPackage : packages) { for (UserPackage userPackage : packages) {
if (!userPackage.getPackageName().equals("MY_BATCH_TEST_0209_01")) {
continue;
}
MDC.put("ru.nbch.credit_tracker.log.mdc.key", "[" + userPackage.getPackageName() + "]"); MDC.put("ru.nbch.credit_tracker.log.mdc.key", "[" + userPackage.getPackageName() + "]");
processPackage(userPackage); processPackage(userPackage);
MDC.remove("ru.nbch.credit_tracker.log.mdc.key"); MDC.remove("ru.nbch.credit_tracker.log.mdc.key");
@ -296,6 +299,7 @@ public class MonitoringService {
}); });
if (!hits.isEmpty()) { if (!hits.isEmpty()) {
hitsService.insertHits(hits); hitsService.insertHits(hits);
hits.clear();
} }
}); });
response.getSubjects().getSubjects().clear(); // чистим список для экономии памяти response.getSubjects().getSubjects().clear(); // чистим список для экономии памяти