lim-exporter CLS-262 поправил условие выборки
This commit is contained in:
parent
eda01f2a15
commit
67a1bcede0
2 changed files with 15 additions and 13 deletions
|
|
@ -36,14 +36,16 @@ public class MoneyExporterService extends AbstractExporterService {
|
||||||
log.debug("Started loading and formation of money file lines");
|
log.debug("Started loading and formation of money file lines");
|
||||||
LocalDate currentDate = LocalDate.now();
|
LocalDate currentDate = LocalDate.now();
|
||||||
List<String> limFileRows = new ArrayList<>();
|
List<String> limFileRows = new ArrayList<>();
|
||||||
Collection<Registry> registriesA = registryImdg.getCollectionObjectsByFieldValues(
|
Collection<Registry> registriesA = registryImdg.getCollectionObjectsByFieldValues(Map.of(
|
||||||
Map.of("registryDesignation", "A",
|
"registryDesignation", "A",
|
||||||
"registryInstrumentType", "M",
|
"registryInstrumentType", "M",
|
||||||
"registryUnit", "F"));
|
"registryUnit", "F"
|
||||||
Collection<Registry> registriesD = registryImdg.getCollectionObjectsByFieldValues(
|
));
|
||||||
Map.of("registryDesignation", "D",
|
Collection<Registry> registriesD = registryImdg.getCollectionObjectsByFieldValues(Map.of(
|
||||||
"registryInstrumentType", "M",
|
"registryDesignation", "D",
|
||||||
"registryUnit", "T"));
|
"registryInstrumentType", "M",
|
||||||
|
"registryUnit", "T"
|
||||||
|
));
|
||||||
Map<String, List<Registry>> byTcrA = registriesA.stream()
|
Map<String, List<Registry>> byTcrA = registriesA.stream()
|
||||||
.collect(Collectors.groupingBy(Registry::getTradingClearingRegistry));
|
.collect(Collectors.groupingBy(Registry::getTradingClearingRegistry));
|
||||||
Map<String, List<Registry>> byTcrD = registriesD.stream()
|
Map<String, List<Registry>> byTcrD = registriesD.stream()
|
||||||
|
|
|
||||||
|
|
@ -35,11 +35,11 @@ public class SecurityExporterService extends AbstractExporterService {
|
||||||
log.debug("Started loading and formation of DEPO file lines");
|
log.debug("Started loading and formation of DEPO file lines");
|
||||||
LocalDate currentDate = LocalDate.now();
|
LocalDate currentDate = LocalDate.now();
|
||||||
List<String> limFileRows = new ArrayList<>();
|
List<String> limFileRows = new ArrayList<>();
|
||||||
Collection<Registry> registries = registryImdg.getCollectionObjectsByFieldValues(
|
Collection<Registry> registries = registryImdg.getCollectionObjectsByFieldValues(Map.of(
|
||||||
Map.of("registryDesignation", "A",
|
"registryDesignation", "A",
|
||||||
"registryInstrumentType", "S",
|
"registryInstrumentType", "S",
|
||||||
"registryCode", "T",
|
"registryUnit", "T"
|
||||||
"clearingDate", currentDate));
|
));
|
||||||
for (Registry registry : registries) {
|
for (Registry registry : registries) {
|
||||||
if (checkNotBlocked(registry)) {
|
if (checkNotBlocked(registry)) {
|
||||||
limFileRows.add(getRow(registry));
|
limFileRows.add(getRow(registry));
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue