From c676be8f0d9717ffafd08e686efa99c66592abf9 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Fri, 16 Jun 2023 19:52:04 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-357 --- .../spcex/clearing/gatewayapi/service/GatewayService.java | 2 +- .../domain/cud/clearing/AssetOperationRequest.java | 8 ++++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/GatewayService.java b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/GatewayService.java index f74df3fed..37db4afbd 100644 --- a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/GatewayService.java +++ b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/GatewayService.java @@ -143,7 +143,7 @@ public class GatewayService extends QueueConsumer implements InitializingBean { if (requestInfoUpdate != null) return; AssetOperationRequest assetOperationRequest = request.getRequestPayload(); - Map content = Map.of("direction", "IN", + Map content = Map.of("direction", assetOperationRequest.getDirection(), "amount", assetOperationRequest.getAmount(), "code", assetOperationRequest.getCode(), "asset", assetOperationRequest.getSecuritySymbol(), diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/clearing/AssetOperationRequest.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/clearing/AssetOperationRequest.java index cedd62cb1..77dcabb6f 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/clearing/AssetOperationRequest.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/clearing/AssetOperationRequest.java @@ -57,4 +57,12 @@ public class AssetOperationRequest { public void setTradingCode(String tradingCode) { this.tradingCode = tradingCode; } + + public String getDirection() { + return direction; + } + + public void setDirection(String direction) { + this.direction = direction; + } }