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

http://jira.mfd.msk:8088/browse/CLS-958 [3? обработка ответа от ТС и отправка запроса для обновления статуса orderCurrency]

Browse source
This commit is contained in:
etreschenkov 2026-04-22 12:32:42 +03:00
parent 4ad5a13710
commit 5b94202c1a
1 changed files with 16 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
clearing-parent/fix-service/src/main/java/ru/spcex/clearing/fix/quickfix/Application.java
View file

@ -13,6 +13,9 @@ import quickfix.fix44.NewOrderSingle;
import ru.clearing.classes.statics.data.misc.OrderCurrency;
import ru.clearing.classes.statics.data.misc.SOrders;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.platform.messaging.domain.Consts;
import ru.spcex.clearing.platform.messaging.domain.cud.order.OrderCurrencyStatusUpdateRequest;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider;
import ru.spcex.platform.imdg.api.ImdgTransaction;
@ -29,13 +32,20 @@ public class Application extends MessageCracker implements quickfix.Application,
private final ImdgProvider imdgProvider;
private final SocketInitiator initiator;
private final KafkaSender kafkaSender;
private SessionID fixSessionID;
private SessionID fdcSessionID;
@Autowired
public Application(ImdgProvider imdgProvider, MessageStoreFactory storeFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError {
public Application(ImdgProvider imdgProvider,
MessageStoreFactory storeFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory,
KafkaSender kafkaSender) throws ConfigError {
this.imdgProvider = imdgProvider;
this.kafkaSender = kafkaSender;
initiator = new SocketInitiator(this, storeFactory, settings, logFactory, messageFactory);
}
@ -156,6 +166,11 @@ public class Application extends MessageCracker implements quickfix.Application,
sOrdersImdg.update(sOrders);
}
//send message to df for update orderCurrency status
OrderCurrencyStatusUpdateRequest updateRequest = new OrderCurrencyStatusUpdateRequest();
updateRequest.addId(sOrders.getId());
kafkaSender.sendRequestToQueue(Consts.ORDER_CURRENCY_STATUS_UPDATE_FIX, updateRequest);
}
}
transaction.commitTransaction();