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

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

Browse source
This commit is contained in:
etreschenkov 2026-06-02 11:22:34 +03:00
parent 6430a3ef4d
commit 5e90047787
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -234,6 +234,7 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
var pair = new Pair<>(orderT0, orderT1); var pair = new Pair<>(orderT0, orderT1);
Pair.forEach(pair, o -> { Pair.forEach(pair, o -> {
copyCommonFields(swap, o); copyCommonFields(swap, o);
o.setStatus(swap.getStatus());
o.setOvernightType(OvernightType.SPOT.getKey()); o.setOvernightType(OvernightType.SPOT.getKey());
o.setMarket(market.getCode()); o.setMarket(market.getCode());
o.setCreated(Instant.now()); o.setCreated(Instant.now());
@ -277,6 +278,7 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
Rates rates = imdgQueryService.getRateOnNextWorkingDay(pair.getBaseCurrency()); Rates rates = imdgQueryService.getRateOnNextWorkingDay(pair.getBaseCurrency());
BigDecimal rateValue = null; BigDecimal rateValue = null;
copyCommonFields(order1, swap); copyCommonFields(order1, swap);
swap.setStatus(order1.getStatus());
swap.setSecurityId(listing.getSecurityId()); swap.setSecurityId(listing.getSecurityId());
swap.setSecuritySymbol(listing.getSymbolCode()); swap.setSecuritySymbol(listing.getSymbolCode());
swap.setListingId(listing.getId()); swap.setListingId(listing.getId());
@ -309,7 +311,6 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
target.setRate(source.getRate()); target.setRate(source.getRate());
target.setQuantityLot(source.getQuantityLot()); target.setQuantityLot(source.getQuantityLot());
target.setLotSize(source.getLotSize()); target.setLotSize(source.getLotSize());
target.setStatus(source.getStatus());
target.setComment(source.getComment()); target.setComment(source.getComment());
target.setRegistryId(source.getRegistryId()); target.setRegistryId(source.getRegistryId());
} }
@ -336,6 +337,7 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
primaryOrder.setQuantityLot(new BigDecimal(payload.getQuantityLot())); primaryOrder.setQuantityLot(new BigDecimal(payload.getQuantityLot()));
primaryOrder.setSide(oc.getSide()); primaryOrder.setSide(oc.getSide());
primaryOrder.setCreated(now); primaryOrder.setCreated(now);
primaryOrder.setStatus(OrderStatus.CREATED.getKey());
OrderCurrency counterOrder = new OrderCurrency(); OrderCurrency counterOrder = new OrderCurrency();
copyCommonFields(primaryOrder, counterOrder); copyCommonFields(primaryOrder, counterOrder);
@ -345,6 +347,7 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
counterOrder.setTradingCode(primaryOrder.getCounterTradingCode()); counterOrder.setTradingCode(primaryOrder.getCounterTradingCode());
counterOrder.setCounterPartyId(primaryOrder.getCompanyId()); counterOrder.setCounterPartyId(primaryOrder.getCompanyId());
counterOrder.setCounterTradingCode(primaryOrder.getTradingCode()); counterOrder.setCounterTradingCode(primaryOrder.getTradingCode());
counterOrder.setStatus(OrderStatus.CREATED.getKey());
if (Side.SELL.equalsByKey(primaryOrder.getSide())) { if (Side.SELL.equalsByKey(primaryOrder.getSide())) {
counterOrder.setSide(Side.BUY.getKey()); counterOrder.setSide(Side.BUY.getKey());
} else { } else {