diff --git a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/CurrencyExporterService.java b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/CurrencyExporterService.java index 0fe1ac4e1..e7361cfda 100644 --- a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/CurrencyExporterService.java +++ b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/CurrencyExporterService.java @@ -60,8 +60,9 @@ public class CurrencyExporterService extends AbstractExporterService { if (checkNotBlocked(registry)) { BigDecimal sumPositive = BigDecimal.ZERO; if (registry.getTradingClearingRegistry() != null && registry.getSecurityId() != null) { - Collection regsDMT = registryImdg.getCollectionObjectsByPredicate(prdctDM_T.apply(registry)); - log.trace("Found {} DM_T registries for registry AM_F {}", regsDMT.size(), registry); + ImdgPredicate query = prdctDM_T.apply(registry); + Collection regsDMT = registryImdg.getCollectionObjectsByPredicate(query); + log.trace("Found {} DM_T registries for registry AM_F {}", regsDMT.size(), query); sumPositive = sumPositive.add(sum(regsDMT)); } limFileRows.add(getRow(registry, sumPositive)); diff --git a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java index 051842768..48fb4934b 100644 --- a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java +++ b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java @@ -61,8 +61,9 @@ public class MoneyExporterService extends AbstractExporterService { if (checkNotBlocked(registry)) { BigDecimal sumPositive = BigDecimal.ZERO; if (registry.getTradingClearingRegistry() != null && registry.getSecurityId() != null) { - Collection regsDMT = registryImdg.getCollectionObjectsByPredicate(prdctDM_T.apply(registry)); - log.trace("Found {} DM_T registries for registry AM_F {}", regsDMT.size(), registry); + ImdgPredicate query = prdctDM_T.apply(registry); + Collection regsDMT = registryImdg.getCollectionObjectsByPredicate(query); + log.trace("Found {} DM_T registries for registry AM_F {}", regsDMT.size(), query); sumPositive = sumPositive.add(sum(regsDMT)); } limFileRows.add(getRow(registry, sumPositive));