diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/order/ExecutionDepositSorter.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/order/ExecutionDepositSorter.java index a396f5b90..4a17cba7e 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/order/ExecutionDepositSorter.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/order/ExecutionDepositSorter.java @@ -61,10 +61,12 @@ public class ExecutionDepositSorter { //метод для дополнительной сортировки внутри групп по категории и компании BiConsumer> additionalSorting = - (clearingCategory, comparator) -> byCategoryByCompany - .get(clearingCategory) - .stream().filter(Objects::nonNull) - .forEach(singleCompanyBatch -> singleCompanyBatch.sort(comparator)); + (clearingCategory, comparator) -> { + List> allExecDepositsForCategory = byCategoryByCompany.get(clearingCategory); + if (allExecDepositsForCategory != null) { + allExecDepositsForCategory.forEach(singleCompanyBatch -> singleCompanyBatch.sort(comparator)); + } + }; //применяем дополнительные сортировки //для V сначала Sell, потом Buy, в первую очередь должны обрабатываться новые сделки с наименьшими объемами additionalSorting.accept(ClearingCategory.V,