From 34b0b4c0976c1e647b33f8675c4e32696cd410a0 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Thu, 30 Apr 2026 13:11:48 +0300
Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-952

---
 .../management/listener/OrderCurrencyListener.java   | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java
index 9f9d0b267..78d1ee01a 100644
--- a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java
+++ b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java
@@ -182,7 +182,7 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
         if (OvernightType.SWAP.equalsByKey(order.getOvernightType())) {
             Pair<OrderCurrency, OrderCurrency> newSpotPair = swapToSpotSplit(order, rgs);
             log.info("deleting old OrderCurrency.id={}", order.getId());
-            orderCurrencyImdg.delete(order);
+            reject(order);
             orderCurrencyImdg.insert(newSpotPair.getFirst());
             orderCurrencyImdg.insert(newSpotPair.getSecond());
             log.info("created OrderCurrency[{}, {}]",
@@ -191,14 +191,20 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
             OrderCurrency pairOrder = validator.getStored(OrderCurrencyValidationStored.OrderCurrencySpotPair);
             OrderCurrency newSwapOrder = spotToSwap(order, pairOrder, rgs);
             log.info("deleting old records OrderCurrency[{}, {}]", order.getId(), pairOrder.getId());
-            orderCurrencyImdg.delete(order);
-            orderCurrencyImdg.delete(pairOrder);
+            reject(order);
+            reject(pairOrder);
             orderCurrencyImdg.insert(newSwapOrder);
             log.info("created OrderCurrency.id={}", newSwapOrder.getId());
         }
         return null;
     }
 
+    private void reject(OrderCurrency o) {
+        o.setStatus(OrderStatus.REJECTED.getKey());
+        o.setUpdated(Instant.now());
+        orderCurrencyImdg.update(o);
+    }
+
     private Pair<OrderCurrency, OrderCurrency> swapToSpotSplit(OrderCurrency swap, Registry rgs) {
         OrderCurrency orderT0 = new OrderCurrency();
         OrderCurrency orderT1 = new OrderCurrency();