From 2716196bf7091d06f0773f53acce2944690b1202 Mon Sep 17 00:00:00 2001 From: akulikov Date: Mon, 24 Apr 2023 16:44:39 +0300 Subject: [PATCH] AccountServiceTest (block) --- .../account/service/AccountServiceTest.java | 26 +++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/AccountServiceTest.java b/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/AccountServiceTest.java index 6f58dae0c..6e661b11b 100644 --- a/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/AccountServiceTest.java +++ b/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/AccountServiceTest.java @@ -35,6 +35,7 @@ import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdf0 import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdfRequestPart; import ru.spcex.clearing.platform.messaging.domain.cud.balance.AccountSdfToStatementRequestPart; import ru.spcex.clearing.platform.messaging.domain.cud.balance.StatementRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.common.CommonDeleteRequest; import ru.spcex.clearing.platform.messaging.service.RequestInfo; import ru.spcex.clearing.platform.messaging.service.Status; import ru.spcex.platform.enumeration.*; @@ -199,7 +200,32 @@ class AccountServiceTest { @Test void accountCorrespondentBlock() { + Account existAccount = new Account(); + existAccount.setAccount(account); + existAccount.setAccountType(AccountType.Corr.getKey()); + existAccount.setStatus(AccountStatus.ACTIVE.getKey()); + existAccount.setCompanyId(companyId); + Long accountId = accountImdg.insert(existAccount); + CommonDeleteRequest commonDeleteRequest = new CommonDeleteRequest(); + commonDeleteRequest.setId(accountId); + + String jsonString = getJsonStringForDELETE(commonDeleteRequest, 0); + + //ACT + addRecordToKafka((MockConsumer) accountService.getConsumer(), + Consts.DESTINATION_ACCOUNT_CORRESPONDENT_BLOCK, + PARTITION, + 0, + jsonString); + + //ASSERT + waitingWhenAddedRecordAndCheckIt(0L, producer, producerRecord); + + Account resultBlock = accountImdg.getSingleObjectByID(accountId); + existAccount.setStatus(AccountStatus.BLOCKED.getKey()); + + ACCOUNT_MATCHER.assertMatch(existAccount, resultBlock); } /**