treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-1014

Browse source
This commit is contained in:
etreschenkov 2026-05-18 11:19:48 +03:00
parent 12343604a5
commit d4f7db60f8
2 changed files with 5 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java
View file

@ -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.Listing;
import ru.clearing.classes.statics.data.misc.Market; import ru.clearing.classes.statics.data.misc.Market;
import ru.clearing.classes.statics.data.misc.OrderCurrency; 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.misc.SOrders;
import ru.clearing.classes.statics.data.registry.Registry; import ru.clearing.classes.statics.data.registry.Registry;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistry; import ru.clearing.classes.statics.data.registry.TradingClearingRegistry;
@ -59,8 +58,6 @@ import ru.spcex.platform.utils.validation.IValidator;
@Service @Service
public class OrderCurrencyListener extends QueueConsumer implements InitializingBean { public class OrderCurrencyListener extends QueueConsumer implements InitializingBean {
protected final Logger log = LoggerFactory.getLogger(getClass()); protected final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<Registry> registryImdg;
private final Imdg<OvernightSettings> overnightSettingsImdg;
private final Imdg<OrderCurrency> orderCurrencyImdg; private final Imdg<OrderCurrency> orderCurrencyImdg;
private final Imdg<SOrders> sOrdersImdg; private final Imdg<SOrders> sOrdersImdg;
private final Function<OrderCurrencyUpdateRequest, IValidator> orderCurrencyUpdateValidator; private final Function<OrderCurrencyUpdateRequest, IValidator> orderCurrencyUpdateValidator;
@ -71,7 +68,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
private final Function<CommonDeleteRequest, IValidator> orderCompanyDeleteValidator; private final Function<CommonDeleteRequest, IValidator> orderCompanyDeleteValidator;
private final ImdgQueryService imdgQueryService; private final ImdgQueryService imdgQueryService;
private final IMessageResolver msgResolver; private final IMessageResolver msgResolver;
private final TransferDateService transferDateService;
@Autowired @Autowired
public OrderCurrencyListener(Consumer<String, Object> kafkaQueue, public OrderCurrencyListener(Consumer<String, Object> kafkaQueue,
@ -92,8 +88,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
IMessageResolver msgResolver, IMessageResolver msgResolver,
TransferDateService transferDateService) { TransferDateService transferDateService) {
super(kafkaQueue, kafkaProducer); 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.sOrdersImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SOrders, SOrders.class);
this.orderCurrencyUpdateValidator = orderCurrencyUpdateValidator; this.orderCurrencyUpdateValidator = orderCurrencyUpdateValidator;
this.orderCurrencyUpdateStatusValidator = orderCurrencyUpdateStatusValidator; this.orderCurrencyUpdateStatusValidator = orderCurrencyUpdateStatusValidator;
@ -104,7 +98,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
this.imdgQueryService = imdgQueryService; this.imdgQueryService = imdgQueryService;
this.msgResolver = msgResolver; this.msgResolver = msgResolver;
this.orderCurrencyImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_OrderCurrency, OrderCurrency.class); this.orderCurrencyImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_OrderCurrency, OrderCurrency.class);
this.transferDateService = transferDateService;
} }
@Override @Override

6
clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java
View file

@ -101,9 +101,13 @@ public class TaskListener extends QueueConsumer implements InitializingBean {
log.info("CROR createOrder started, request={}", newReq); log.info("CROR createOrder started, request={}", newReq);
Collection<Long> registryIds = imdgQueryService.getCurrencyRegistry(); Collection<Long> registryIds = imdgQueryService.getCurrencyRegistry();
//todo очередность создания
if (registryIds == null || registryIds.isEmpty()) { if (registryIds == null || registryIds.isEmpty()) {
log.info("No registries found for CROR processing"); 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; return;
} }