This commit is contained in:
parent
894fdf7625
commit
01c22e449d
1 changed files with 6 additions and 4 deletions
|
|
@ -61,10 +61,12 @@ public class ExecutionDepositSorter {
|
||||||
|
|
||||||
//метод для дополнительной сортировки внутри групп по категории и компании
|
//метод для дополнительной сортировки внутри групп по категории и компании
|
||||||
BiConsumer<ClearingCategory, Comparator<ExecutionDeposit>> additionalSorting =
|
BiConsumer<ClearingCategory, Comparator<ExecutionDeposit>> additionalSorting =
|
||||||
(clearingCategory, comparator) -> byCategoryByCompany
|
(clearingCategory, comparator) -> {
|
||||||
.get(clearingCategory)
|
List<List<ExecutionDeposit>> allExecDepositsForCategory = byCategoryByCompany.get(clearingCategory);
|
||||||
.stream().filter(Objects::nonNull)
|
if (allExecDepositsForCategory != null) {
|
||||||
.forEach(singleCompanyBatch -> singleCompanyBatch.sort(comparator));
|
allExecDepositsForCategory.forEach(singleCompanyBatch -> singleCompanyBatch.sort(comparator));
|
||||||
|
}
|
||||||
|
};
|
||||||
//применяем дополнительные сортировки
|
//применяем дополнительные сортировки
|
||||||
//для V сначала Sell, потом Buy, в первую очередь должны обрабатываться новые сделки с наименьшими объемами
|
//для V сначала Sell, потом Buy, в первую очередь должны обрабатываться новые сделки с наименьшими объемами
|
||||||
additionalSorting.accept(ClearingCategory.V,
|
additionalSorting.accept(ClearingCategory.V,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue