treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-952

Browse source
This commit is contained in:
ialbert 2026-04-30 13:11:48 +03:00
parent 1849665f80
commit 34b0b4c097
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/OrderCurrencyListener.java
View file

@ -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();