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

http://jira.mfd.msk:8088/browse/CLS-839 исправил выборку по отдельным ID

Browse source
This commit is contained in:
AKurakin 2025-05-07 14:43:02 +03:00
parent 6d86fa44f1
commit 318d8bba62
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java
View file

@ -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); log.trace("For Registry.id={} found {} other Registry's by query {}", am_tId, otherRegistry.size(), predicate);
for (Registry otherReg : otherRegistry) { for (Registry otherReg : otherRegistry) {
if (!am_tId.equals(otherReg.getId())) { // always true - предикат выше отфильтрует 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( Map<Pair<String, String>, List<Registry>> regGroup = checkRegistries.stream().collect(Collectors.groupingBy(
r -> new Pair<>(r.getTradingClearingRegistry(), r.getSecuritySymbol()) 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 equalsCount = 0;
int mismatchCount = 0; int mismatchCount = 0;
for (Map.Entry<Pair<String, String>, List<Registry>> group : regGroup.entrySet()) { 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) am_tSumm.subtract(am_fSumm)
); );
resultMismatch.add(describe); 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() group.getValue().stream()
.map(r->String.format("id=%d accountType=%s registryCode=%s balance=%s", .map(r->String.format("id=%d accountType=%s registryCode=%s balance=%s",
r.getId(), r.getAccountType(), r.getRegistryCode(), r.getBalance())) r.getId(), r.getAccountType(), r.getRegistryCode(), r.getBalance()))