diff --git a/clearing-parent/securities-service/src/test/java/ru/spcex/clearing/securities/service/MoneyMarketSecurityServiceTest.java b/clearing-parent/securities-service/src/test/java/ru/spcex/clearing/securities/service/MoneyMarketSecurityServiceTest.java index 77933d442..c85ea01e8 100644 --- a/clearing-parent/securities-service/src/test/java/ru/spcex/clearing/securities/service/MoneyMarketSecurityServiceTest.java +++ b/clearing-parent/securities-service/src/test/java/ru/spcex/clearing/securities/service/MoneyMarketSecurityServiceTest.java @@ -44,9 +44,9 @@ import java.util.HashMap; HazelcastInstanceTestConfiguration.class}) public class MoneyMarketSecurityServiceTest { static final ObjectMapper objectMapper = new ObjectMapper(); - private MockConsumer kafkaMockQueue; private final int TIMEOUT = 1000; - + boolean isUsed; + private MockConsumer kafkaMockQueue; @Autowired @Qualifier("hazelcastServiceTest") private HazelcastService hazelcastService; @@ -54,8 +54,6 @@ public class MoneyMarketSecurityServiceTest { @Qualifier("hazelcastInstance") private HazelcastInstance hz; - boolean isUsed; - private void setIsUsed(boolean isUsed) { this.isUsed = isUsed; } @@ -91,6 +89,18 @@ public class MoneyMarketSecurityServiceTest { keyRateService.afterPropertiesSet(); } + /** + * {@link MoneyMarketSecurityService#newMoneyMarket(BaseRequest)}
+ * Тест проверяет генерацию сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link MoneyMarketSecurityNewRequest}:
+ * {@link MoneyMarketSecurityNewRequest#lotSize} - 1.0
+ * {@link MoneyMarketSecurityNewRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.
+ * {@link MoneyMarketSecurityNewRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.
+ * {@link MoneyMarketSecurityNewRequest#nominalValue} - 1.0
+ * {@link MoneyMarketSecurityNewRequest#nominalCurrencyId} - 1L
+ * {@link MoneyMarketSecurityNewRequest#instrumentType} - "sdgaga"
+ * {@link MoneyMarketSecurityNewRequest#fullName} - "estat"
+ */ @Test public void testNewMoneyMarketSecurity() throws InterruptedException { final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW; @@ -154,6 +164,12 @@ public class MoneyMarketSecurityServiceTest { iMap.removeEntryListener(listenerID); } + /** + * {@link MoneyMarketSecurityService#deleteMoneyMarket(BaseRequest)}
+ * Тест проверяет удаление сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link CommonDeleteRequest}:
+ * {@link CommonDeleteRequest#id} - Идентификатор записи
+ */ @Test public void testDeleteKeyRate() throws InterruptedException { final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_DELETE; @@ -215,7 +231,16 @@ public class MoneyMarketSecurityServiceTest { iMap.removeEntryListener(listenerID); } - + /** + * {@link MoneyMarketSecurityService#updateMoneyMarket(BaseRequest)} + * Тест проверяет обновление сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link MoneyMarketSecurityUpdateRequest}:
+ * {@link MoneyMarketSecurityUpdateRequest#fullName} - sfgsdfg
+ * {@link MoneyMarketSecurityUpdateRequest#instrumentType} - qwerqwe
+ * {@link MoneyMarketSecurityUpdateRequest#nominalCurrencyId} - 2L
+ * {@link MoneyMarketSecurityUpdateRequest#nominalValue} - 2.0
+ * {@link MoneyMarketSecurityUpdateRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)
+ */ @Test public void testUpdateKeyRate() throws InterruptedException { final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_UPDATE; diff --git a/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/KeyRateServiceTest.java b/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/KeyRateServiceTest.java index 6a3996f71..def1e762a 100644 --- a/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/KeyRateServiceTest.java +++ b/clearing-parent/utility-service/src/test/java/ru/spcex/clearing/utility/service/KeyRateServiceTest.java @@ -41,9 +41,9 @@ import java.util.HashMap; HazelcastInstanceTestConfiguration.class}) public class KeyRateServiceTest { static final ObjectMapper objectMapper = new ObjectMapper(); - private MockConsumer kafkaMockQueue; private final int TIMEOUT = 1000; - + boolean isUsed; + private MockConsumer kafkaMockQueue; @Autowired @Qualifier("hazelcastServiceTest") private HazelcastService hazelcastService; @@ -51,8 +51,6 @@ public class KeyRateServiceTest { @Qualifier("hazelcastInstance") private HazelcastInstance hz; - boolean isUsed; - private void setIsUsed(boolean isUsed) { this.isUsed = isUsed; } @@ -88,6 +86,15 @@ public class KeyRateServiceTest { keyRateService.afterPropertiesSet(); } + /** + * {@link KeyRateService#newKeyRate(BaseRequest)} + * Тест проверяет генерацию сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link KeyRateNewRequest}:
+ * {@link KeyRateNewRequest#keyRate} - 0.5
+ * {@link KeyRateNewRequest#document} - "Test"
+ * {@link KeyRateNewRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.
+ * {@link KeyRateNewRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.
+ */ @Test public void testNewKeyRate() throws InterruptedException { final String TOPIC = Consts.DESTINATION_KEY_RATE_NEW; @@ -150,6 +157,12 @@ public class KeyRateServiceTest { iMap.removeEntryListener(listenerID); } + /** + * {@link KeyRateService#deleteKeyRate(BaseRequest)}
+ * Тест проверяет удаление сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link CommonDeleteRequest}:
+ * {@link CommonDeleteRequest#id} - Идентификатор записи
+ */ @Test public void testDeleteKeyRate() throws InterruptedException { final String TOPIC = Consts.DESTINATION_KEY_RATE_DELETE; @@ -209,6 +222,15 @@ public class KeyRateServiceTest { iMap.removeEntryListener(listenerID); } + /** + * {@link KeyRateService#updateKeyRate(BaseRequest)} + * Тест проверяет генерацию сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.
+ * Входной запрос {@link KeyRateUpdateRequest}:
+ * {@link KeyRateUpdateRequest#keyRate} - 5
+ * {@link KeyRateUpdateRequest#document} - "Update"
+ * {@link KeyRateUpdateRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)
+ * {@link KeyRateUpdateRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)
+ */ @Test public void testUpdateKeyRate() throws InterruptedException { final String TOPIC = Consts.DESTINATION_KEY_RATE_UPDATE;