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 53370a842..7138b4624 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 @@ -353,6 +353,10 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing for (Long orderId : payload.getIds()) { SOrders sOrder = sOrdersImdg.getSingleObjectByID(orderId); OrderCurrency orderCurrency = orderCurrencyImdg.getSingleObjectByID(orderId); + if (orderCurrency == null) { + log.warn("OrderCurrency[{}] not found", orderId); + continue; + } OrderStatus status = resolveStatusByImportState(sOrder.getState()); if (status == null) { continue;