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 dd04a245c..682bfa1f0 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 @@ -133,7 +133,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean { log.debug("Select {} Registry and hi's pairs by ID collection. Time {} ms.", checkRegistries.size(), timer); if (log.isTraceEnabled()) log.trace("Selected registries id: {}", - checkRegistries.stream().map(o->String.valueOf(o.getId())) + checkRegistries.stream().map(o -> String.valueOf(o.getId())) .collect(Collectors.joining(","))); } @@ -151,20 +151,14 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean { String makeSuccessMessage(LocalDateTime checkTime) { - return String.format(""" - Проведена сверка по регистрам AMAT/AMAF. - %s. - Результат сверки: расхождения отсутствуют.""", + return String.format("Проведена сверка по регистрам AMAT/AMAF.\r\n%s.\r\nРезультат сверки: расхождения отсутствуют.", MESSAGE_TIME_FORMATTER.format(checkTime)); } String makeErrorMessage(LocalDateTime checkTime, List mismatch) { assert !mismatch.isEmpty(); - String msgItems = mismatch.stream().collect(Collectors.joining("; ")); - return String.format(""" - Проведена сверка по регистрам AMAT/AMAF. - %s. - Результат сверки: %s.""", + String msgItems = mismatch.stream().collect(Collectors.joining("; \r\n")); + return String.format("Проведена сверка по регистрам AMAT/AMAF.\r\n%s.\r\nРезультат сверки: %s.", MESSAGE_TIME_FORMATTER.format(checkTime), msgItems); } @@ -180,7 +174,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean { BigDecimal am_tSumm = BigDecimal.ZERO; BigDecimal am_fSumm = BigDecimal.ZERO; for (Registry r : group.getValue()) { - short accumulated=0; + short accumulated = 0; if (match(RegistryTradingParams.AM_T, r)) { am_tSumm = am_tSumm.add(BigDecimalUtil.safeBD(r.getBalance())); accumulated++; @@ -213,9 +207,9 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean { 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())) - .collect(Collectors.joining("; "))); + .map(r -> String.format("id=%d accountType=%s registryCode=%s balance=%s", + r.getId(), r.getAccountType(), r.getRegistryCode(), r.getBalance())) + .collect(Collectors.joining("; "))); } } log.debug("Check result: equalsCount = {}, mismatchCount = {}", equalsCount, mismatchCount); diff --git a/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/AmatAmafCheckerTest.java b/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/AmatAmafCheckerTest.java index 18fd9737d..8adb28990 100644 --- a/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/AmatAmafCheckerTest.java +++ b/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/AmatAmafCheckerTest.java @@ -81,9 +81,9 @@ class AmatAmafCheckerTest { errors.toString()); // next test makeErrorMessage: - assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + - "2025.05.05 12:37:56.\n" + - "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" + + "2025.05.05 12:37:56.\r\n" + + "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; \r\nпо ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", checker.makeErrorMessage( LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors)); } @@ -210,12 +210,12 @@ class AmatAmafCheckerTest { List errors = checker.checkRegisters(regSrc); // assertEquals(2, errors.size()); - assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + - "2025.05.05 12:37:56.\n" + + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" + + "2025.05.05 12:37:56.\r\n" + "Результат сверки:" + - " по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по CNY на сумму 678.00;" + - " по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по BYN на сумму 95.00;" + - " по ТКР null выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 233184292.44.", + " по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по CNY на сумму 678.00; \r\n" + + "по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по BYN на сумму 95.00; \r\n" + + "по ТКР null выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 233184292.44.", checker.makeErrorMessage( LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors)); } @@ -223,8 +223,8 @@ class AmatAmafCheckerTest { @Test void makeSuccessMessage() { AmatAmafChecker checker = instance(); - assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + - "2025.05.05 12:37:56.\n" + + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" + + "2025.05.05 12:37:56.\r\n" + "Результат сверки: расхождения отсутствуют.", checker.makeSuccessMessage(LocalDateTime.of(2025, 5, 5, 12, 37, 56))); } @@ -233,9 +233,10 @@ class AmatAmafCheckerTest { void makeErrorMessage() { AmatAmafChecker checker = instance(); - assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + - "2025.05.05 12:37:56.\n" + - "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" + + "2025.05.05 12:37:56.\r\n" + + "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; \r\n" + + "по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", checker.makeErrorMessage( LocalDateTime.of(2025, 5, 5, 12, 37, 56), Arrays.asList(