From 01c22e449d1844cd2f1385296166de700c2527dd Mon Sep 17 00:00:00 2001 From: ialbert Date: Thu, 2 Feb 2023 17:40:53 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-189 NLP fix --- .../clearing/service/order/ExecutionDepositSorter.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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,