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

http://jira.mfd.msk:8088/browse/CLS-813

Browse source
This commit is contained in:
ialbert 2025-01-28 14:01:57 +03:00
parent 2566140140
commit 25090d5499
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java
View file

@ -61,12 +61,12 @@ public class MoneyExporterService extends AbstractExporterService {
pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()), pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()),
pb.equals("securityId", registry.getSecurityId()) pb.equals("securityId", registry.getSecurityId())
); );
BiFunction<Registry, LocalDate, ImdgPredicate> prdctOM_T = (registry, date) -> pb.and( BiFunction<Registry, ImdgPredicate, ImdgPredicate> prdctOM_T = (registry, stlmntDtPrdct) -> pb.and(
pb.sql(RegistryCodeSqlBuilder.getInstance(OM_T).build()), pb.sql(RegistryCodeSqlBuilder.getInstance(OM_T).build()),
pb.in("registryStatus", RegistryStatus.PROC.getKey(), RegistryStatus.MNG.getKey()), pb.in("registryStatus", RegistryStatus.PROC.getKey(), RegistryStatus.MNG.getKey()),
pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()), pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()),
pb.equals("securityId", registry.getSecurityId()), pb.equals("securityId", registry.getSecurityId()),
pb.equals("settlementDate", date) stlmntDtPrdct
); );
BiFunction<Registry, LocalDate, ImdgPredicate> prdctTM_T = (registry, date) -> pb.and( BiFunction<Registry, LocalDate, ImdgPredicate> prdctTM_T = (registry, date) -> pb.and(
pb.sql(RegistryCodeSqlBuilder.getInstance(TM_T).build()), pb.sql(RegistryCodeSqlBuilder.getInstance(TM_T).build()),
@ -89,7 +89,7 @@ public class MoneyExporterService extends AbstractExporterService {
dmtSumElement = dmtSumElement.add(sum(regsDMT)).negate(); dmtSumElement = dmtSumElement.add(sum(regsDMT)).negate();
if (includeCK) { if (includeCK) {
ImdgPredicate queryOM_T_today = prdctOM_T.apply(registry, LocalDate.now()); ImdgPredicate queryOM_T_today = prdctOM_T.apply(registry, pb.equals("settlementDate", LocalDate.now()));
Collection<Registry> regsOMT_today = registryImdg.getCollectionObjectsByPredicate(queryOM_T_today); Collection<Registry> regsOMT_today = registryImdg.getCollectionObjectsByPredicate(queryOM_T_today);
log.trace("Found {} OM_T today registries for registry AM_F {}", regsOMT_today.size(), queryOM_T_today); log.trace("Found {} OM_T today registries for registry AM_F {}", regsOMT_today.size(), queryOM_T_today);
omtSumElementToday = omtSumElementToday.add(sum(regsOMT_today)).negate(); omtSumElementToday = omtSumElementToday.add(sum(regsOMT_today)).negate();
@ -99,7 +99,7 @@ public class MoneyExporterService extends AbstractExporterService {
log.trace("Found {} TM_T today registries for registry AM_F {}", regsTMT_today.size(), queryTM_T_today); log.trace("Found {} TM_T today registries for registry AM_F {}", regsTMT_today.size(), queryTM_T_today);
tmtSumElementToday = tmtSumElementToday.add(sum(regsTMT_today)); tmtSumElementToday = tmtSumElementToday.add(sum(regsTMT_today));
ImdgPredicate queryOM_T_tomorrow = prdctOM_T.apply(registry, LocalDate.now().plusDays(1)); ImdgPredicate queryOM_T_tomorrow = prdctOM_T.apply(registry, pb.greatEqual("settlementDate", LocalDate.now().plusDays(1)));
Collection<Registry> regsOMT_tomorrow = registryImdg.getCollectionObjectsByPredicate(queryOM_T_tomorrow); Collection<Registry> regsOMT_tomorrow = registryImdg.getCollectionObjectsByPredicate(queryOM_T_tomorrow);
log.trace("Found {} OM_T tomorrow registries for registry AM_F {}", regsOMT_tomorrow.size(), queryOM_T_tomorrow); log.trace("Found {} OM_T tomorrow registries for registry AM_F {}", regsOMT_tomorrow.size(), queryOM_T_tomorrow);
omtSumElementTomorrow = omtSumElementTomorrow.add(sum(regsOMT_tomorrow)).negate(); omtSumElementTomorrow = omtSumElementTomorrow.add(sum(regsOMT_tomorrow)).negate();