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, List> 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, List> 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()))