From 659604651337ce2279cc3431c67049837ccc34c9 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Wed, 29 May 2024 12:46:39 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-684 // http://jira.mfd.msk:8088/browse/CLS-685 --- .../account/service/ClientCodeService.java | 134 +++++++++++++----- .../TradingClearingRegistryService.java | 8 +- .../gatewayapi/service/TkrService.java | 26 +++- .../platform/messaging/domain/Consts.java | 1 + .../cud/account/ClientCodeNewRequest.java | 3 +- ...st.java => TkrAccountsGatewayRequest.java} | 2 +- 6 files changed, 124 insertions(+), 50 deletions(-) rename platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/{TkrAccountsCheckRequest.java => TkrAccountsGatewayRequest.java} (93%) diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClientCodeService.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClientCodeService.java index 226e41430..d84aed951 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClientCodeService.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClientCodeService.java @@ -1,5 +1,13 @@ package ru.spcex.clearing.account.service; +import java.time.Instant; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.Future; +import java.util.function.Function; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; @@ -11,7 +19,10 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.ConfigurableApplicationContext; import org.springframework.stereotype.Service; +import org.springframework.util.StringUtils; +import ru.clearing.classes.statics.data.account.Account; import ru.clearing.classes.statics.data.account.ClientCode; +import ru.clearing.classes.statics.data.company.CompanySymbols; import ru.clearing.classes.statics.data.registry.TradingClearingRegistry; import ru.spcex.clearing.account.errors.AccountError; import ru.spcex.clearing.imdg.IMDGDistributedNames; @@ -20,7 +31,10 @@ import ru.spcex.clearing.platform.messaging.domain.BaseRequest; import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.cud.account.ClientCodeNewRequest; import ru.spcex.clearing.platform.messaging.domain.cud.account.ClientCodeUpdateRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccount; +import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccountsGatewayRequest; import ru.spcex.clearing.platform.messaging.domain.cud.common.CommonDeleteRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.gateway.MoneyAccountMsg; import ru.spcex.clearing.platform.messaging.domain.cud.registry.TradingClearingRegistryListNewRequest; import ru.spcex.clearing.platform.messaging.domain.cud.registry.TradingClearingRegistryListUpdateRequest; import ru.spcex.clearing.platform.messaging.domain.cud.registry.TradingClearingRegistryNewRequest; @@ -32,6 +46,9 @@ import ru.spcex.clearing.platform.messaging.service.Status; import ru.spcex.clearing.util.security.UserRoleVerification; import ru.spcex.clearing.util.services.RequestHelper; import ru.spcex.clearing.validation.common.ValidationHelper; +import ru.spcex.platform.enumeration.AccountType; +import ru.spcex.platform.enumeration.CompanySymbol; +import ru.spcex.platform.enumeration.CurrencyCode; import ru.spcex.platform.enumeration.TradingClearingRegistryType; import ru.spcex.platform.enumeration.WorkflowStatus; import ru.spcex.platform.imdg.api.Imdg; @@ -42,15 +59,6 @@ import ru.spcex.platform.utils.enumeration.IMessageResolver; import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.validation.IValidator; -import java.time.Instant; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.Future; -import java.util.function.Function; - @Service public class ClientCodeService extends QueueConsumer implements InitializingBean { private final Logger log = LoggerFactory.getLogger(getClass()); @@ -59,8 +67,8 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean private final ImdgProvider imdgProvider; private final Imdg clientCodeMap; private final Imdg tradingClearingRegistryMap; - - + private final Imdg companySymbolsImdg; + private final Imdg accountImdg; private final Function clientCodeNewRequestValidator; private final Function clientCodeUpdateRequestValidator; private final Function clientCodeDeleteRequestValidator; @@ -92,6 +100,8 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean this.idGenerator = imdgProvider.getImdgIdGenerator(); this.clientCodeMap = imdgProvider.getImdg(IMDGDistributedNames.Map_ClientCode, ClientCode.class); this.tradingClearingRegistryMap = imdgProvider.getImdg(IMDGDistributedNames.Map_TradingClearingRegistry, TradingClearingRegistry.class); + this.companySymbolsImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_CompanySymbols, CompanySymbols.class); + this.accountImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Account, Account.class); this.clientCodeNewRequestValidator = clientCodeNewRequestValidator; this.clientCodeUpdateRequestValidator = clientCodeUpdateRequestValidator; this.clientCodeDeleteRequestValidator = clientCodeDeleteRequestValidator; @@ -108,18 +118,21 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean imdgProvider.waitAvailable(); callback(ClientCodeNewRequest.class) - .setFunction(this::clientCodeNew) - .forDestination(Consts.DESTINATION_CLIENT_CODE_NEW, callbacks::put); + .setFunction(this::clientCodeNew) + .forDestination(Consts.DESTINATION_CLIENT_CODE_NEW, callbacks::put); + callback(TkrAccountsGatewayRequest.class) + .setFunction(this::clientCodeNewFromGateway) + .forDestination(Consts.DESTINATION_CLIENT_CODE_NEW_FROM_GATEWAY, callbacks::put); callback(ClientCodeNewRequest.class) - .setFunction(this::clientCodeNewFromApiUmCompany) - .forDestination(Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, callbacks::put); + .setFunction(this::clientCodeNewFromApiUmCompany) + .forDestination(Consts.DESTINATION_CLIENT_CODE_NEW_UM_COMPANY, callbacks::put); callback(ClientCodeUpdateRequest.class) - .setFunction(this::clientCodeUpdate) - .forDestination(Consts.DESTINATION_CLIENT_CODE_UPDATE, callbacks::put); + .setFunction(this::clientCodeUpdate) + .forDestination(Consts.DESTINATION_CLIENT_CODE_UPDATE, callbacks::put); callback(CommonDeleteRequest.class) - .setFunction(this::clientCodeDelete) - .forDestination(Consts.DESTINATION_CLIENT_CODE_DELETE, callbacks::put); + .setFunction(this::clientCodeDelete) + .forDestination(Consts.DESTINATION_CLIENT_CODE_DELETE, callbacks::put); init(); } @@ -157,6 +170,55 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean return clientCodeNew0(userRequest, false); } + protected RequestInfoUpdate clientCodeNewFromGateway(BaseRequest tkrRequest) { + TkrAccountsGatewayRequest tkr = tkrRequest.getRequestPayload(); + for (TkrAccount tkrAccount : tkr.getAccounts()) { + ClientCodeNewRequest clientCodeNewRequest = new ClientCodeNewRequest(); + clientCodeNewRequest.setCode(tkrAccount.getClientCode()); + if (tkrAccount.getCompanyId() != null) { + CompanySymbols companySymbols = companySymbolsImdg.getFirstObjectByFieldValues( + Map.of( + "companySymbol", CompanySymbol.UUID.getKey(), + "companySymbolValue", tkrAccount.getCompanyId() + ) + ); + if (companySymbols != null) { + clientCodeNewRequest.setCompanyId(companySymbols.getCompanyId()); + } + } + if (StringUtils.hasText(tkrAccount.getDepoAccount())) { + Account account = accountImdg.getFirstObjectByFieldValues( + Map.of( + "account", tkrAccount.getDepoAccount(), + "accountType", AccountType.Depo.getKey() + ) + ); + if (account != null) { + clientCodeNewRequest.setDepoAccountId(account.getId()); + } + } + for (MoneyAccountMsg moneyAccountMsg : tkrAccount.getMoneyAccounts()) { + if (moneyAccountMsg.getCurrCode().equals(CurrencyCode.RUB.getKey())) { + Account account = accountImdg.getFirstObjectByFieldValues( + Map.of( + "account", moneyAccountMsg.getAccount() + ) + ); + if (account != null) { + clientCodeNewRequest.setMoneyAccountId(account.getId()); + } + } + } + BaseRequest request = new BaseRequest<>(); + request.setRequestPayload(clientCodeNewRequest); + RequestInfoUpdate requestInfoUpdate = clientCodeNew0(request, false); + if (requestInfoUpdate != null) { + log.debug("processing result is: {}", requestInfoUpdate.getMessage()); + } + } + return null; + } + protected RequestInfoUpdate clientCodeNew0(BaseRequest userRequest, boolean fromTCRList) { log.debug("ClientCodeNewRequest received {}", userRequest.getId()); @@ -175,12 +237,12 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean if (doCreateTCR) { try { requestInfoUpdate = createAndWaitTCR(userRequest.getId(), null, - req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); + req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); if (requestInfoUpdate != null) return requestInfoUpdate; } catch (Exception e) { log.error("Can not wait creation of TCR. request id={};CompanyId={}, MoneyAccountId={}, DepoAccountId={}; {}", - userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), - e.toString()); + userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), + e.toString()); return makeErrorResponse(userRequest, AccountError.GeneralError, "Can not create TCR: " + e.getMessage()); } } @@ -211,8 +273,8 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean if (requestInfoUpdate != null) return requestInfoUpdate; } catch (Exception e) { log.error("Can not wait creation of tradingClearingRegistryList. request id={}; {}", - userRequest.getId(), - ExceptionUtils.getStackTrace(e)); + userRequest.getId(), + ExceptionUtils.getStackTrace(e)); return makeErrorResponse(userRequest, AccountError.GeneralError, "Can not create TCR: " + e.getMessage()); } } @@ -254,12 +316,12 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean if (doCreateTCR) { try { requestInfoUpdate = createAndWaitTCR(userRequest.getId(), null, - req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); + req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); if (requestInfoUpdate != null) return requestInfoUpdate; } catch (Exception e) { log.error("Can not wait creation of TCR. request id={};CompanyId={}, MoneyAccountId={}, DepoAccountId={}; {}", - userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), - e.toString()); + userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), + e.toString()); return makeErrorResponse(userRequest, AccountError.GeneralError, "Can not create TCR at this moment" + e.getMessage()); } } @@ -289,8 +351,8 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean if (requestInfoUpdate != null) return requestInfoUpdate; } catch (Exception e) { log.error("Can not wait creation of tradingClearingRegistryList. request id={}; {}", - userRequest.getId(), - ExceptionUtils.getStackTrace(e)); + userRequest.getId(), + ExceptionUtils.getStackTrace(e)); return makeErrorResponse(userRequest, AccountError.GeneralError, "Can not create TCR: " + e.getMessage()); } } @@ -333,12 +395,12 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean if (doCreateTCR) { try { requestInfoUpdate = createAndWaitTCR(userRequest.getId(), clientCode.getId(), - req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); + req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); if (requestInfoUpdate != null) return requestInfoUpdate; } catch (Exception e) { log.error("Can not wait creation of TCR. request id={};CompanyId={}, MoneyAccountId={}, DepoAccountId={}; {}", - userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), - e.toString()); + userRequest.getId(), req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId(), + e.toString()); return makeErrorResponse(userRequest, AccountError.GeneralError, "Can not create TCR: " + e.getMessage()); } } @@ -407,8 +469,8 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean protected RequestInfoUpdate createAndWaitTCR(Long reqId, Long clientCode, Long companyId, Long moneyAccountId, Long depoAccountId) { log.debug("For request {}, clientCode={} need create TCR: companyId={}, moneyAccountId={}, depoAccountId={}", - reqId, clientCode == null ? "new" : clientCode, - companyId, moneyAccountId, depoAccountId); + reqId, clientCode == null ? "new" : clientCode, + companyId, moneyAccountId, depoAccountId); BaseRequest request = new BaseRequest<>(); request.setId(idGenerator.nextId()); request.setActionType(ActionType.NEW); @@ -495,7 +557,7 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean TradingClearingRegistry tradingClearingRegistry = selectTradingClearingRegistry(req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); if (tradingClearingRegistry == null) { log.warn("TCR not found: CompanyId {}, MoneyAccountId {}, DepoAccountId {}", - req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); + req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); } else { clientCode.setTradingClearingRegistryId(tradingClearingRegistry.getId()); } @@ -518,7 +580,7 @@ public class ClientCodeService extends QueueConsumer implements InitializingBean TradingClearingRegistry tradingClearingRegistry = selectTradingClearingRegistry(req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); if (tradingClearingRegistry == null) { log.warn("TCR not found: CompanyId {}, MoneyAccountId {}, DepoAccountId {}", - req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); + req.getCompanyId(), req.getMoneyAccountId(), req.getDepoAccountId()); } else { clientCode.setTradingClearingRegistryId(tradingClearingRegistry.getId()); } 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 1c6d47af2..6ca292696 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 @@ -31,7 +31,7 @@ import ru.spcex.clearing.platform.messaging.domain.BaseRequest; import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.cud.account.ClientCodeNewRequest; import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccount; -import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccountsCheckRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccountsGatewayRequest; import ru.spcex.clearing.platform.messaging.domain.cud.clearing.CreateRegistryRequest; import ru.spcex.clearing.platform.messaging.domain.cud.common.CommonIdRequest; import ru.spcex.clearing.platform.messaging.domain.cud.gateway.MoneyAccountMsg; @@ -139,7 +139,7 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini callback(CommonIdRequest.class) .setFunction(this::tradingClearingRegistryBlock) .forDestination(Consts.DESTINATION_TRADING_CLEARING_REGISTRY_BLOCK, callbacks::put); - callback(TkrAccountsCheckRequest.class) + callback(TkrAccountsGatewayRequest.class) .setFunction(this::tradingClearingRegistryCheck) .forDestination(Consts.DESTINATION_TRADING_CLEARING_REGISTRY_CHECK, callbacks::put); init(); @@ -495,8 +495,8 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini return null; } - public RequestInfoUpdate tradingClearingRegistryCheck(BaseRequest gatewayRequest) { - TkrAccountsCheckRequest req = gatewayRequest.getRequestPayload(); + public RequestInfoUpdate tradingClearingRegistryCheck(BaseRequest gatewayRequest) { + TkrAccountsGatewayRequest req = gatewayRequest.getRequestPayload(); log.debug("TradingClearingRegistryCheckRequest received with requestId : {}", req.getRequestId()); for (TkrAccount accountForCheck : req.getAccounts()) { log.debug("Checking TKR with code: {}", accountForCheck.getTkrCode()); diff --git a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/TkrService.java b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/TkrService.java index d0d86599c..fb9253b04 100644 --- a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/TkrService.java +++ b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/TkrService.java @@ -7,7 +7,7 @@ import ru.spcex.clearing.gatewayapi.controller.inbound.request.tkr.request.TkrRe import ru.spcex.clearing.gatewayapi.service.adapter.TkrAdapter; import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccount; -import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccountsCheckRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.account.TkrAccountsGatewayRequest; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; @Service @@ -22,14 +22,26 @@ public class TkrService { } public void processedTkrRequest(TkrRequest tkrRequest) { - List tkrAccounts = tkrRequest.getInfoAccount() + List tkrAccountsForCheck = tkrRequest.getInfoAccount() .stream().filter(infoAccount -> !StringUtils.hasText(infoAccount.getClientCode())) .map(tkrAdapter::toTkrResponse).toList(); - if (!tkrAccounts.isEmpty()) { - TkrAccountsCheckRequest tkrAccountsCheckRequest = new TkrAccountsCheckRequest(); - tkrAccountsCheckRequest.setRequestId(tkrRequest.getId()); - tkrAccountsCheckRequest.setAccounts(tkrAccounts); - kafkaSender.sendRequestToQueue(Consts.DESTINATION_TRADING_CLEARING_REGISTRY_CHECK, tkrAccountsCheckRequest); + + List tkrAccountsForNew = tkrRequest.getInfoAccount() + .stream().filter(infoAccount -> !StringUtils.hasText(infoAccount.getTkrCode())) + .map(tkrAdapter::toTkrResponse).toList(); + + if (!tkrAccountsForCheck.isEmpty()) { + TkrAccountsGatewayRequest tkrAccountsRequest = new TkrAccountsGatewayRequest(); + tkrAccountsRequest.setRequestId(tkrRequest.getId()); + tkrAccountsRequest.setAccounts(tkrAccountsForCheck); + kafkaSender.sendRequestToQueue(Consts.DESTINATION_TRADING_CLEARING_REGISTRY_CHECK, tkrAccountsRequest); + } + + if (!tkrAccountsForNew.isEmpty()) { + TkrAccountsGatewayRequest tkrAccountsRequest = new TkrAccountsGatewayRequest(); + tkrAccountsRequest.setRequestId(tkrRequest.getId()); + tkrAccountsRequest.setAccounts(tkrAccountsForNew); + kafkaSender.sendRequestToQueue(Consts.DESTINATION_CLIENT_CODE_NEW_FROM_GATEWAY, tkrAccountsRequest); } } } diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java index 76ab66230..aa858290f 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java @@ -101,6 +101,7 @@ public interface Consts { String DESTINATION_PROFILE_DOCUMENT_DELETE = "profile-document-delete"; String DESTINATION_CLIENT_CODE_NEW = "client-code-new"; + String DESTINATION_CLIENT_CODE_NEW_FROM_GATEWAY = "client-code-new-from-gateway"; String DESTINATION_CLIENT_CODE_NEW_UM_COMPANY = "client-code-new-from-api-um-company"; String DESTINATION_CLIENT_CODE_UPDATE = "client-code-update"; String DESTINATION_CLIENT_CODE_DELETE = "client-code-delete"; diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/ClientCodeNewRequest.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/ClientCodeNewRequest.java index ed883bd8a..44c904b10 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/ClientCodeNewRequest.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/ClientCodeNewRequest.java @@ -1,8 +1,7 @@ package ru.spcex.clearing.platform.messaging.domain.cud.account; -import com.fasterxml.jackson.annotation.JsonProperty; - import java.util.List; +import com.fasterxml.jackson.annotation.JsonProperty; public class ClientCodeNewRequest { @JsonProperty diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsCheckRequest.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsGatewayRequest.java similarity index 93% rename from platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsCheckRequest.java rename to platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsGatewayRequest.java index c7a1d9fcf..00870335c 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsCheckRequest.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/account/TkrAccountsGatewayRequest.java @@ -4,7 +4,7 @@ import java.util.List; import java.util.UUID; import com.fasterxml.jackson.annotation.JsonProperty; -public class TkrAccountsCheckRequest { +public class TkrAccountsGatewayRequest { @JsonProperty private UUID requestId; @JsonProperty