diff --git a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java index c569bf460..4b2172031 100644 --- a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java +++ b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java @@ -23,7 +23,6 @@ import ru.clearing.classes.statics.data.company.Company; import ru.clearing.classes.statics.data.misc.Listing; import ru.clearing.classes.statics.data.misc.Market; import ru.clearing.classes.statics.data.misc.OrderCurrency; -import ru.clearing.classes.statics.data.misc.OvernightSettings; import ru.clearing.classes.statics.data.misc.SOrders; import ru.clearing.classes.statics.data.registry.Registry; import ru.clearing.classes.statics.data.registry.TradingClearingRegistry; @@ -59,8 +58,6 @@ import ru.spcex.platform.utils.validation.IValidator; @Service public class OrderCurrencyListener extends QueueConsumer implements InitializingBean { protected final Logger log = LoggerFactory.getLogger(getClass()); - private final Imdg registryImdg; - private final Imdg overnightSettingsImdg; private final Imdg orderCurrencyImdg; private final Imdg sOrdersImdg; private final Function orderCurrencyUpdateValidator; @@ -71,7 +68,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing private final Function orderCompanyDeleteValidator; private final ImdgQueryService imdgQueryService; private final IMessageResolver msgResolver; - private final TransferDateService transferDateService; @Autowired public OrderCurrencyListener(Consumer kafkaQueue, @@ -92,8 +88,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing IMessageResolver msgResolver, TransferDateService transferDateService) { super(kafkaQueue, kafkaProducer); - this.registryImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Registry, Registry.class); - this.overnightSettingsImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_OvernightSettings, OvernightSettings.class); this.sOrdersImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SOrders, SOrders.class); this.orderCurrencyUpdateValidator = orderCurrencyUpdateValidator; this.orderCurrencyUpdateStatusValidator = orderCurrencyUpdateStatusValidator; @@ -104,7 +98,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing this.imdgQueryService = imdgQueryService; this.msgResolver = msgResolver; this.orderCurrencyImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_OrderCurrency, OrderCurrency.class); - this.transferDateService = transferDateService; } @Override 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 9597577d9..6181687b9 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 @@ -101,9 +101,13 @@ public class TaskListener extends QueueConsumer implements InitializingBean { log.info("CROR createOrder started, request={}", newReq); Collection registryIds = imdgQueryService.getCurrencyRegistry(); - //todo очередность создания if (registryIds == null || registryIds.isEmpty()) { log.info("No registries found for CROR processing"); + NotificationNewRequest notification = new NotificationNewRequest(); + notification.setObjectType(ObjectType.rgst.getKey()); + notification.setPriority(Priority.HIGH.getKey()); + notification.setComment("При создании заявок для заключения сделок переноса заявки не созданы: не найдены регистры учета дефицита активов"); + kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, notification); return; }