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

account-service http://jira.mfd.msk:8088/browse/CLS-271 добавление оповещений о TradingClearingRegistryService

Browse source
This commit is contained in:
AKurakin 2023-06-02 10:02:09 +03:00
parent d62829f3b1
commit b30f01e3eb
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java
View file

@ -272,6 +272,11 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini
tradingClearingRegistry.setUpdated(now); tradingClearingRegistry.setUpdated(now);
tradingClearingRegistryImdg.insert(tradingClearingRegistry); tradingClearingRegistryImdg.insert(tradingClearingRegistry);
log.debug("New TCR.id={} was created", tradingClearingRegistry.getId());
sendNotificationToCompanySvc(tradingClearingRegistry);
sendNotificationToClearingSvc(tradingClearingRegistry);
sendNotificationToReportSvc(tradingClearingRegistry);
log.debug("successfully processed, id {}", id); log.debug("successfully processed, id {}", id);
return null; return null;
@ -408,11 +413,11 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini
*/ */
protected void sendNotificationToCompanySvc(TradingClearingRegistry tradingClearingRegistry) { protected void sendNotificationToCompanySvc(TradingClearingRegistry tradingClearingRegistry) {
ClientCodeNewRequest request = new ClientCodeNewRequest(); ClientCodeNewRequest request = new ClientCodeNewRequest();
request.setMoneyAccountId(tradingClearingRegistry.getId()); request.setTradingClearingRegistryId(tradingClearingRegistry.getId());
request.setCompanyId(tradingClearingRegistry.getCompanyId()); request.setCompanyId(tradingClearingRegistry.getCompanyId());
request.setCode(tradingClearingRegistry.getCode()); request.setCode(tradingClearingRegistry.getCode());
// request.setMoneyAccountId(tradingClearingRegistry.getMoneyAccountId()); request.setMoneyAccountId(tradingClearingRegistry.getMoneyAccountId());
// request.setDepoAccountId(tradingClearingRegistry.getDepoAccountId()); request.setDepoAccountId(tradingClearingRegistry.getDepoAccountId());
log.debug("Send message to kafka \"{}\": {}", Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, LogFormatter.toStringWrapper(request)); log.debug("Send message to kafka \"{}\": {}", Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, LogFormatter.toStringWrapper(request));
kafkaSender.sendRequestToQueue(Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, request); kafkaSender.sendRequestToQueue(Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, request);
} }
@ -433,7 +438,7 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini
* todo report-service сообщение на формирование уведомления о создании нового ТКР * todo report-service сообщение на формирование уведомления о создании нового ТКР
*/ */
protected void sendNotificationToReportSvc(TradingClearingRegistry tradingClearingRegistry) { protected void sendNotificationToReportSvc(TradingClearingRegistry tradingClearingRegistry) {
log.debug("Todo report destination: new TCR"); log.debug("Todo report destination: new TCR (не реализовано)");
// ReportRequest request = new ReportRequest(); // ReportRequest request = new ReportRequest();
// request.setReportId(ReportType.NEW_TRADING_CLEARING_REGISTRY); // request.setReportId(ReportType.NEW_TRADING_CLEARING_REGISTRY);
// request.setTradingClearingRegistryId(tradingClearingRegistry.getId()); // request.setTradingClearingRegistryId(tradingClearingRegistry.getId());