diff --git a/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/BankAccountServiceTest.java b/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/BankAccountServiceTest.java index 5638b8213..4614bf02a 100644 --- a/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/BankAccountServiceTest.java +++ b/clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/service/BankAccountServiceTest.java @@ -55,16 +55,17 @@ public class BankAccountServiceTest { /** * {@link BankAccountService#bankAccountNew(BaseRequest request)} - * Тест проверяет генерацию сущности {@link BankAccount} в Hazelcast при передаче в Apache Kafka. + * Тест проверяет генерацию сущности {@link BankAccount} в Hazelcast при передаче из Apache Kafka. * Входной запрос {@link BankAccountNewRequest}: * {@link BankAccountNewRequest#bankIdentificationCode} - 99999 * {@link BankAccountNewRequest#bankName} - ооо тинькофф * {@link BankAccountNewRequest#correspondentAccount} - 9294189285498598598 * {@link BankAccountNewRequest#correspondentAccountName} - BIK OF * {@link BankAccountNewRequest#currency} - RUB - * {@link BankAccountNewRequest#destination} - OOO ROGA + * {@link BankAccountNewRequest#destination} - OOO ROGA I KOPITA * {@link BankAccountNewRequest#taxpayerIdentificationNumber} - 848484848484 * {@link BankAccountNewRequest#taxRegistrationReasonCode} - 886886 + * {@link BankAccountNewRequest#account} - 123456789123 */ @Test public void bankAccountNew() throws InterruptedException { @@ -134,6 +135,20 @@ public class BankAccountServiceTest { currentId++; } + /** + * {@link BankAccountService#bankAccountUpdate(BaseRequest)} + * Тест проверяет обновление сущности {@link BankAccount} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link BankAccountUpdateRequest}: + * {@link BankAccountUpdateRequest#bankIdentificationCode} - NEW BUNK NAME + * {@link BankAccountUpdateRequest#bankName} - 88888 + * {@link BankAccountUpdateRequest#correspondentAccount} - 894984646541316 + * {@link BankAccountUpdateRequest#correspondentAccountName} - BIK OF NEW BUNK + * {@link BankAccountUpdateRequest#currency} - EU + * {@link BankAccountUpdateRequest#destination} - OOO NEW BUNK + * {@link BankAccountUpdateRequest#taxpayerIdentificationNumber} - 65468461321 + * {@link BankAccountUpdateRequest#taxRegistrationReasonCode} - 532137 + * {@link BankAccountUpdateRequest#account} - 326984656514 + */ @Test void bankAccountUpdate() throws InterruptedException { //arrange @@ -233,6 +248,12 @@ public class BankAccountServiceTest { currentId++; } + /** + * {@link BankAccountService#bankAccountDelete(BaseRequest)} + * Тест проверяет удаление сущности {@link BankAccount} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link CommonDeleteRequest}: + * {@link CommonDeleteRequest#id} - Идентификатор записи + */ @Test void bankAccountDelete() throws InterruptedException { //arrange diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java index 6fb3d09e9..d5592644c 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java @@ -55,6 +55,13 @@ class ClearingMemberCategoryServiceTest { mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); } + /** + * {@link ClearingMemberCategoryService#clearingMemberCategoryUpdate(BaseRequest)} + * Тест проверяет обновление сущности {@link ClearingMemberCategory} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link ClearingMemberCategoryUpdateRequest}: + * {@link ClearingMemberCategoryUpdateRequest#id} - Идентификатор записи + * {@link ClearingMemberCategoryUpdateRequest#clearingMemberCategory} - 1234 + */ @Test void clearingMemberCategoryUpdate() throws InterruptedException { //ARRANGE @@ -128,6 +135,12 @@ class ClearingMemberCategoryServiceTest { iMap.removeEntryListener(listenerID); } + /** + * {@link ClearingMemberCategoryService#clearingMemberCategoryDelete(BaseRequest)} + * Тест проверяет удаление сущности {@link ClearingMemberCategory} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link CommonDeleteRequest}: + * {@link CommonDeleteRequest#id} - Идентификатор записи + */ @Test void clearingMemberCategoryDelete() throws InterruptedException { //ARRANGE diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java index 83c3e92e7..1bab878e4 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java @@ -51,6 +51,24 @@ class CompanyInfoServiceTest { mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); } + /** + * {@link CompanyInfoService#companyInfoUpdate(BaseRequest)} + * Тест проверяет обновление сущности {@link CompanyInfo} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link CompanyInfoUpdateRequest}: + * {@link CompanyInfoUpdateRequest#id} - Идентификатор записи + * {@link CompanyInfoUpdateRequest#corporationSoleType} - 1234 + * {@link CompanyInfoUpdateRequest#countryCode} - 1234 + * {@link CompanyInfoUpdateRequest#description} - updated description + * {@link CompanyInfoUpdateRequest#professionalSign} - 1234 + * {@link CompanyInfoUpdateRequest#legalKind} - 1234 + * {@link CompanyInfoUpdateRequest#organizationType} - 1234 + * {@link CompanyInfoUpdateRequest#residence} - 1234 + * {@link CompanyInfoUpdateRequest#shortNameEng} - updated shortNameEng + * {@link CompanyInfoUpdateRequest#fullNameEng} - updated fullNameEng + * {@link CompanyInfoUpdateRequest#shortName} - updated shortName + * {@link CompanyInfoUpdateRequest#fullName} - updated fullName + * {@link CompanyInfoUpdateRequest#} - + */ @Test void companyInfoUpdate() throws InterruptedException { //ARRANGE diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java index f9b9f73aa..88e7b3c0d 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java @@ -53,6 +53,12 @@ class CompanyServiceTest { mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); } + /** + * {@link CompanyService#deleteCompany(BaseRequest)} + * Тест проверяет удаление сущности {@link Company} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link CommonDeleteRequest}: + * {@link CommonDeleteRequest#id} - Идентификатор записи + */ @Test void deleteCompany() throws InterruptedException { //ARRANGE diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java index 15654ba28..d77c5e583 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java @@ -51,6 +51,15 @@ class CompanySymbolServiceTest { mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); } + /** + * {@link CompanySymbolService#companySymbolUpdate(BaseRequest)} + * Тест проверяет обновление сущности {@link CompanySymbols} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link CompanySymbolUpdateRequest}: + * {@link CompanySymbolUpdateRequest#id} - Идентификатор записи + * {@link CompanySymbolUpdateRequest#companyId} - Идентификатор записи + * {@link CompanySymbolUpdateRequest#companySymbol} - 1234 + * {@link CompanySymbolUpdateRequest#companySymbolValue} - new companySymbolValue + */ @Test void companySymbolUpdate() throws InterruptedException { //ARRANGE diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java index bc7d93160..28cc138b7 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java @@ -50,6 +50,15 @@ class ContactServiceTest { mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); } + /** + * {@link ContactService#contactUpdate(BaseRequest)} + * Тест проверяет обновление сущности {@link Contact} в Hazelcast при передаче из Apache Kafka. + * Входной запрос {@link ContactUpdateRequest}: + * {@link ContactUpdateRequest#id} - Идентификатор записи + * {@link ContactUpdateRequest#companyId} - Идентификатор записи + * {@link ContactUpdateRequest#contactType} - 1234 + * {@link ContactUpdateRequest#contactValue} - new ContactValue + */ @Test void contactUpdate() throws InterruptedException { //ARRANGE