From 318d8bba62ce71d3d598fa14c48b1cc927c6b2c9 Mon Sep 17 00:00:00 2001
From: AKurakin <akurakin@mfd.ru>
Date: Wed, 7 May 2025 14:43:02 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-839=20?=
 =?UTF-8?q?=D0=B8=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=B8=D0=BB=20=D0=B2=D1=8B?=
 =?UTF-8?q?=D0=B1=D0=BE=D1=80=D0=BA=D1=83=20=D0=BF=D0=BE=20=D0=BE=D1=82?=
 =?UTF-8?q?=D0=B4=D0=B5=D0=BB=D1=8C=D0=BD=D1=8B=D0=BC=20ID?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ru/spcex/clearing/utility/service/AmatAmafChecker.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java
index 2a82d8f5a..20a61f625 100644
--- a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java
+++ b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java
@@ -123,7 +123,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean {
                     log.trace("For Registry.id={} found {} other Registry's by query {}", am_tId, otherRegistry.size(), predicate);
                     for (Registry otherReg : otherRegistry) {
                         if (!am_tId.equals(otherReg.getId())) { // always true - предикат выше отфильтрует
-                            checkRegistries.add(am_tRegistry);
+                            checkRegistries.add(otherReg);
                         }
                     }
                 }
@@ -172,7 +172,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean {
         Map<Pair<String, String>, List<Registry>> regGroup = checkRegistries.stream().collect(Collectors.groupingBy(
                 r -> new Pair<>(r.getTradingClearingRegistry(), r.getSecuritySymbol())
         ));
-        log.trace("Make {} group of TradingClearingRegistry+SecuritySymbol from {} Registry", regGroup.size(), checkRegistries.size());
+        log.debug("Make {} group of TradingClearingRegistry+SecuritySymbol from {} Registry", regGroup.size(), checkRegistries.size());
         int equalsCount = 0;
         int mismatchCount = 0;
         for (Map.Entry<Pair<String, String>, List<Registry>> group : regGroup.entrySet()) {
@@ -206,7 +206,8 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean {
                         am_tSumm.subtract(am_fSumm)
                 );
                 resultMismatch.add(describe);
-                log.info("Balance not match (am_tSumm={}, am_fSumm={}) in register group: {}", am_tSumm, am_fSumm,
+                log.info("Balance not match (am_tSumm={}, am_fSumm={}) in register group (size {}): {}", am_tSumm, am_fSumm,
+                        group.getValue().size(),
                         group.getValue().stream()
                         .map(r->String.format("id=%d accountType=%s registryCode=%s balance=%s",
                                 r.getId(), r.getAccountType(), r.getRegistryCode(), r.getBalance()))