This commit is contained in:
parent
434089c005
commit
532093f872
1 changed files with 4 additions and 0 deletions
|
|
@ -353,6 +353,10 @@ public class OrderCurrencyListener extends QueueConsumer implements Initializing
|
||||||
for (Long orderId : payload.getIds()) {
|
for (Long orderId : payload.getIds()) {
|
||||||
SOrders sOrder = sOrdersImdg.getSingleObjectByID(orderId);
|
SOrders sOrder = sOrdersImdg.getSingleObjectByID(orderId);
|
||||||
OrderCurrency orderCurrency = orderCurrencyImdg.getSingleObjectByID(orderId);
|
OrderCurrency orderCurrency = orderCurrencyImdg.getSingleObjectByID(orderId);
|
||||||
|
if (orderCurrency == null) {
|
||||||
|
log.warn("OrderCurrency[{}] not found", orderId);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
OrderStatus status = resolveStatusByImportState(sOrder.getState());
|
OrderStatus status = resolveStatusByImportState(sOrder.getState());
|
||||||
if (status == null) {
|
if (status == null) {
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue