diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java index cfdd8c317..4d225ecde 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java @@ -272,6 +272,11 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini tradingClearingRegistry.setUpdated(now); tradingClearingRegistryImdg.insert(tradingClearingRegistry); + log.debug("New TCR.id={} was created", tradingClearingRegistry.getId()); + + sendNotificationToCompanySvc(tradingClearingRegistry); + sendNotificationToClearingSvc(tradingClearingRegistry); + sendNotificationToReportSvc(tradingClearingRegistry); log.debug("successfully processed, id {}", id); return null; @@ -408,11 +413,11 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini */ protected void sendNotificationToCompanySvc(TradingClearingRegistry tradingClearingRegistry) { ClientCodeNewRequest request = new ClientCodeNewRequest(); - request.setMoneyAccountId(tradingClearingRegistry.getId()); + request.setTradingClearingRegistryId(tradingClearingRegistry.getId()); request.setCompanyId(tradingClearingRegistry.getCompanyId()); request.setCode(tradingClearingRegistry.getCode()); -// request.setMoneyAccountId(tradingClearingRegistry.getMoneyAccountId()); -// request.setDepoAccountId(tradingClearingRegistry.getDepoAccountId()); + request.setMoneyAccountId(tradingClearingRegistry.getMoneyAccountId()); + request.setDepoAccountId(tradingClearingRegistry.getDepoAccountId()); 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); } @@ -433,7 +438,7 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini * todo report-service сообщение на формирование уведомления о создании нового ТКР */ protected void sendNotificationToReportSvc(TradingClearingRegistry tradingClearingRegistry) { - log.debug("Todo report destination: new TCR"); + log.debug("Todo report destination: new TCR (не реализовано)"); // ReportRequest request = new ReportRequest(); // request.setReportId(ReportType.NEW_TRADING_CLEARING_REGISTRY); // request.setTradingClearingRegistryId(tradingClearingRegistry.getId());