etreschenkov 2026-05-18 15:52:53 +03:00
parent 5d402be015
commit 3bfab4ccdd

View file

@ -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);