From 5b94202c1a32f628619b744efb8832a29d213eb6 Mon Sep 17 00:00:00 2001
From: etreschenkov <ETreschenkov@mfd.ru>
Date: Wed, 22 Apr 2026 12:32:42 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-958=20[3=3F?=
 =?UTF-8?q?=20=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D0=BA=D0=B0=20?=
 =?UTF-8?q?=D0=BE=D1=82=D0=B2=D0=B5=D1=82=D0=B0=20=D0=BE=D1=82=20=D0=A2?=
 =?UTF-8?q?=D0=A1=20=D0=B8=20=D0=BE=D1=82=D0=BF=D1=80=D0=B0=D0=B2=D0=BA?=
 =?UTF-8?q?=D0=B0=20=D0=B7=D0=B0=D0=BF=D1=80=D0=BE=D1=81=D0=B0=20=D0=B4?=
 =?UTF-8?q?=D0=BB=D1=8F=20=D0=BE=D0=B1=D0=BD=D0=BE=D0=B2=D0=BB=D0=B5=D0=BD?=
 =?UTF-8?q?=D0=B8=D1=8F=20=D1=81=D1=82=D0=B0=D1=82=D1=83=D1=81=D0=B0=20ord?=
 =?UTF-8?q?erCurrency]?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../clearing/fix/quickfix/Application.java      | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git a/clearing-parent/fix-service/src/main/java/ru/spcex/clearing/fix/quickfix/Application.java b/clearing-parent/fix-service/src/main/java/ru/spcex/clearing/fix/quickfix/Application.java
index 1e8585ddf..f2d81baf2 100644
--- a/clearing-parent/fix-service/src/main/java/ru/spcex/clearing/fix/quickfix/Application.java
+++ b/clearing-parent/fix-service/src/main/java/ru/spcex/clearing/fix/quickfix/Application.java
@@ -13,6 +13,9 @@ import quickfix.fix44.NewOrderSingle;
 import ru.clearing.classes.statics.data.misc.OrderCurrency;
 import ru.clearing.classes.statics.data.misc.SOrders;
 import ru.spcex.clearing.imdg.IMDGDistributedNames;
+import ru.spcex.clearing.platform.messaging.domain.Consts;
+import ru.spcex.clearing.platform.messaging.domain.cud.order.OrderCurrencyStatusUpdateRequest;
+import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
 import ru.spcex.platform.imdg.api.Imdg;
 import ru.spcex.platform.imdg.api.ImdgProvider;
 import ru.spcex.platform.imdg.api.ImdgTransaction;
@@ -29,13 +32,20 @@ public class Application extends MessageCracker implements quickfix.Application,
     private final ImdgProvider imdgProvider;
     
     private final SocketInitiator initiator;
+    private final KafkaSender kafkaSender;
 
     private SessionID fixSessionID;
     private SessionID fdcSessionID;
 
     @Autowired
-    public Application(ImdgProvider imdgProvider, MessageStoreFactory storeFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError {
+    public Application(ImdgProvider imdgProvider,
+                       MessageStoreFactory storeFactory,
+                       SessionSettings settings,
+                       LogFactory logFactory,
+                       MessageFactory messageFactory,
+                       KafkaSender kafkaSender) throws ConfigError {
         this.imdgProvider = imdgProvider;
+        this.kafkaSender = kafkaSender;
         initiator = new SocketInitiator(this, storeFactory, settings, logFactory, messageFactory);
     }
 
@@ -156,6 +166,11 @@ public class Application extends MessageCracker implements quickfix.Application,
 
                         sOrdersImdg.update(sOrders);
                     }
+
+                    //send message to df for update orderCurrency status
+                    OrderCurrencyStatusUpdateRequest updateRequest = new OrderCurrencyStatusUpdateRequest();
+                    updateRequest.addId(sOrders.getId());
+                    kafkaSender.sendRequestToQueue(Consts.ORDER_CURRENCY_STATUS_UPDATE_FIX, updateRequest);
                 }
             }
             transaction.commitTransaction();