Поправил ошибку.
This commit is contained in:
psemenkov 2023-06-08 18:02:21 +03:00
parent 420bfca7d1
commit 754b915aed

View file

@ -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<String, List<Registry>> byTcrA = registriesA.stream()
Map<String, List<Registry>> byTcrA = registriesA.stream().filter(r -> StringUtils.hasText(r.getTradingClearingRegistry()))
.collect(Collectors.groupingBy(Registry::getTradingClearingRegistry));
Map<String, List<Registry>> byTcrD = registriesD.stream()
Map<String, List<Registry>> 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());