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 e08c15b37..695d8f519 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 @@ -3,6 +3,7 @@ package ru.spcex.clearing.lim.exporter.services; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Service; +import org.springframework.util.StringUtils; import ru.clearing.classes.statics.data.registry.Registry; import ru.spcex.clearing.lim.exporter.config.LimFormat; import ru.spcex.clearing.lim.exporter.config.SFTPConfig; @@ -47,9 +48,9 @@ public class MoneyExporterService extends AbstractExporterService { "registryInstrumentType", "M", "registryUnit", "T" )); - Map> byTcrA = registriesA.stream() + Map> byTcrA = registriesA.stream().filter(r -> StringUtils.hasText(r.getTradingClearingRegistry())) .collect(Collectors.groupingBy(Registry::getTradingClearingRegistry)); - Map> byTcrD = registriesD.stream() + Map> byTcrD = registriesD.stream().filter(r -> StringUtils.hasText(r.getTradingClearingRegistry())) .collect(Collectors.groupingBy(Registry::getTradingClearingRegistry)); log.debug("Selected {} registriesA, {} registriesD. {} groups of A, {} groups of D.", registriesA.size(), registriesD.size(), byTcrA.size(), byTcrD.size());