From 25090d54990257bec226f90228f8a83c86847466 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Tue, 28 Jan 2025 14:01:57 +0300
Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-813

---
 .../lim/exporter/services/MoneyExporterService.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 845dd926d..9bdc8e93b 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,12 +61,12 @@ public class MoneyExporterService extends AbstractExporterService {
                 pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()),
                 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.in("registryStatus", RegistryStatus.PROC.getKey(), RegistryStatus.MNG.getKey()),
             pb.equals("tradingClearingRegistry", registry.getTradingClearingRegistry()),
             pb.equals("securityId", registry.getSecurityId()),
-            pb.equals("settlementDate", date)
+            stlmntDtPrdct
         );
         BiFunction<Registry, LocalDate, ImdgPredicate> prdctTM_T = (registry, date) -> pb.and(
             pb.sql(RegistryCodeSqlBuilder.getInstance(TM_T).build()),
@@ -89,7 +89,7 @@ public class MoneyExporterService extends AbstractExporterService {
                     dmtSumElement = dmtSumElement.add(sum(regsDMT)).negate();
 
                     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);
                         log.trace("Found {} OM_T today registries for registry AM_F {}", regsOMT_today.size(), queryOM_T_today);
                         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);
                         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);
                         log.trace("Found {} OM_T tomorrow registries for registry AM_F {}", regsOMT_tomorrow.size(), queryOM_T_tomorrow);
                         omtSumElementTomorrow = omtSumElementTomorrow.add(sum(regsOMT_tomorrow)).negate();