diff --git a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java index 6181687b9..f89a99d2b 100644 --- a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java +++ b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java @@ -111,6 +111,16 @@ public class TaskListener extends QueueConsumer implements InitializingBean { return; } + Rates rates = imdgQueryService.getRateOnNextWorkingDay(CurrencyCode.CNY.getKey()); + if (rates == null) { + log.warn("No Rates found on nextWorkingDay"); + NotificationNewRequest notification = new NotificationNewRequest(); + notification.setObjectType(ObjectType.rgst.getKey()); + notification.setPriority(Priority.HIGH.getKey()); + notification.setComment("Ошибка при создании заявки: не определен Базовый курс"); + kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, notification); + return; + } for (Long registryId : registryIds) { try { rejectByRegistryId(registryId);