From b30f01e3ebba3671879f81fe4a46e1cf58850a7f Mon Sep 17 00:00:00 2001 From: AKurakin Date: Fri, 2 Jun 2023 10:02:09 +0300 Subject: [PATCH] =?UTF-8?q?account-service=20http://jira.mfd.msk:8088/brow?= =?UTF-8?q?se/CLS-271=20=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD?= =?UTF-8?q?=D0=B8=D0=B5=20=D0=BE=D0=BF=D0=BE=D0=B2=D0=B5=D1=89=D0=B5=D0=BD?= =?UTF-8?q?=D0=B8=D0=B9=20=D0=BE=20TradingClearingRegistryService?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/TradingClearingRegistryService.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) 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());