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

http://jira.mfd.msk:8088/browse/CLS-839 формат переноса строк (надо на ВЭБ доделать)

Browse source
This commit is contained in:
AKurakin 2025-05-12 13:32:57 +03:00
parent 5c4161968b
commit 911dfba6f8
2 changed files with 22 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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); log.debug("Select {} Registry and hi's pairs by ID collection. Time {} ms.", checkRegistries.size(), timer);
if (log.isTraceEnabled()) if (log.isTraceEnabled())
log.trace("Selected registries id: {}", log.trace("Selected registries id: {}",
checkRegistries.stream().map(o->String.valueOf(o.getId())) checkRegistries.stream().map(o -> String.valueOf(o.getId()))
.collect(Collectors.joining(","))); .collect(Collectors.joining(",")));
} }
@ -151,20 +151,14 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean {
String makeSuccessMessage(LocalDateTime checkTime) { String makeSuccessMessage(LocalDateTime checkTime) {
return String.format(""" return String.format("Проведена сверка по регистрам AMAT/AMAF.\r\n%s.\r\nРезультат сверки: расхождения отсутствуют.",
Проведена сверка по регистрам AMAT/AMAF.
%s.
Результат сверки: расхождения отсутствуют.""",
MESSAGE_TIME_FORMATTER.format(checkTime)); MESSAGE_TIME_FORMATTER.format(checkTime));
} }
String makeErrorMessage(LocalDateTime checkTime, List<String> mismatch) { String makeErrorMessage(LocalDateTime checkTime, List<String> mismatch) {
assert !mismatch.isEmpty(); assert !mismatch.isEmpty();
String msgItems = mismatch.stream().collect(Collectors.joining("; ")); String msgItems = mismatch.stream().collect(Collectors.joining("; \r\n"));
return String.format(""" return String.format("Проведена сверка по регистрам AMAT/AMAF.\r\n%s.\r\nРезультат сверки: %s.",
Проведена сверка по регистрам AMAT/AMAF.
%s.
Результат сверки: %s.""",
MESSAGE_TIME_FORMATTER.format(checkTime), msgItems); MESSAGE_TIME_FORMATTER.format(checkTime), msgItems);
} }
@ -180,7 +174,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean {
BigDecimal am_tSumm = BigDecimal.ZERO; BigDecimal am_tSumm = BigDecimal.ZERO;
BigDecimal am_fSumm = BigDecimal.ZERO; BigDecimal am_fSumm = BigDecimal.ZERO;
for (Registry r : group.getValue()) { for (Registry r : group.getValue()) {
short accumulated=0; short accumulated = 0;
if (match(RegistryTradingParams.AM_T, r)) { if (match(RegistryTradingParams.AM_T, r)) {
am_tSumm = am_tSumm.add(BigDecimalUtil.safeBD(r.getBalance())); am_tSumm = am_tSumm.add(BigDecimalUtil.safeBD(r.getBalance()));
accumulated++; 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, log.info("Balance not match (am_tSumm={}, am_fSumm={}) in register group (size {}): {}", am_tSumm, am_fSumm,
group.getValue().size(), 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()))
.collect(Collectors.joining("; "))); .collect(Collectors.joining("; ")));
} }
} }
log.debug("Check result: equalsCount = {}, mismatchCount = {}", equalsCount, mismatchCount); log.debug("Check result: equalsCount = {}, mismatchCount = {}", equalsCount, mismatchCount);

27
clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/AmatAmafCheckerTest.java
View file

@ -81,9 +81,9 @@ class AmatAmafCheckerTest {
errors.toString()); errors.toString());
// next test makeErrorMessage: // next test makeErrorMessage:
assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" +
"2025.05.05 12:37:56.\n" + "2025.05.05 12:37:56.\r\n" +
"Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; \r\nпо ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.",
checker.makeErrorMessage( checker.makeErrorMessage(
LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors)); LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors));
} }
@ -210,12 +210,12 @@ class AmatAmafCheckerTest {
List<String> errors = checker.checkRegisters(regSrc); List<String> errors = checker.checkRegisters(regSrc);
// assertEquals(2, errors.size()); // assertEquals(2, errors.size());
assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" +
"2025.05.05 12:37:56.\n" + "2025.05.05 12:37:56.\r\n" +
"Результат сверки:" + "Результат сверки:" +
" по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по CNY на сумму 678.00;" + " по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по CNY на сумму 678.00; \r\n" +
" по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по BYN на сумму 95.00;" + "по ТКР 0620CAV00001 выявлено расхождение на регистрах AMAT/AMAF по BYN на сумму 95.00; \r\n" +
" по ТКР null выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 233184292.44.", "по ТКР null выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 233184292.44.",
checker.makeErrorMessage( checker.makeErrorMessage(
LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors)); LocalDateTime.of(2025, 5, 5, 12, 37, 56), errors));
} }
@ -223,8 +223,8 @@ class AmatAmafCheckerTest {
@Test @Test
void makeSuccessMessage() { void makeSuccessMessage() {
AmatAmafChecker checker = instance(); AmatAmafChecker checker = instance();
assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" +
"2025.05.05 12:37:56.\n" + "2025.05.05 12:37:56.\r\n" +
"Результат сверки: расхождения отсутствуют.", "Результат сверки: расхождения отсутствуют.",
checker.makeSuccessMessage(LocalDateTime.of(2025, 5, 5, 12, 37, 56))); checker.makeSuccessMessage(LocalDateTime.of(2025, 5, 5, 12, 37, 56)));
} }
@ -233,9 +233,10 @@ class AmatAmafCheckerTest {
void makeErrorMessage() { void makeErrorMessage() {
AmatAmafChecker checker = instance(); AmatAmafChecker checker = instance();
assertEquals("Проведена сверка по регистрам AMAT/AMAF.\n" + assertEquals("Проведена сверка по регистрам AMAT/AMAF.\r\n" +
"2025.05.05 12:37:56.\n" + "2025.05.05 12:37:56.\r\n" +
"Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.", "Результат сверки: по ТКР 0004CAV00003 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму 100; \r\n" +
"по ТКР 0482CAT00001 выявлено расхождение на регистрах AMAT/AMAF по RUB на сумму -89.75.",
checker.makeErrorMessage( checker.makeErrorMessage(
LocalDateTime.of(2025, 5, 5, 12, 37, 56), LocalDateTime.of(2025, 5, 5, 12, 37, 56),
Arrays.asList( Arrays.asList(