treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-822

Browse source
This commit is contained in:
etreschenkov 2025-04-22 14:45:58 +03:00
parent fa696013ce
commit 059872518e
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/execution/ExecutionCurrencyController.java
View file

@ -63,15 +63,21 @@ public class ExecutionCurrencyController extends AbstractQueueController {
@RequestMapping(value = "/filter", method = RequestMethod.GET)
@ResponseBody
public CommonGetAllResponse getByFilter(@RequestParam(name = "pageSize", required = false) Optional<Integer> pageSize,
@RequestParam(name = "pageIndex", required = false) Optional<Integer> pageIndex) {
ImdgPredicate filter = imdgPredicateBuilder.and(
imdgPredicateBuilder.greatEqual("settlementDate", LocalDate.now()),
imdgPredicateBuilder.equals("side", Side.SELL.getKey()));
AtomicReference<Collection<Map<String, Object>>> all = new AtomicReference<>();
pageIndex.ifPresentOrElse(index ->
all.set(stateLoader.getAllMetaTransformWithPagination(IMDGDistributedNames.Map_ExecutionCurrency, ExecutionCurrency.class, filter,
pageSize.orElse(10_000), index)),
() -> all.set(stateLoader.getAllMetaTransform(IMDGDistributedNames.Map_ExecutionCurrency, ExecutionCurrency.class, filter)));
@RequestParam(name = "pageIndex", required = false) Optional<Integer> pageIndex,
@RequestParam(name = "ccp", required = false) Optional<Boolean> ccp) {
ImdgPredicate settlementDateFilter = imdgPredicateBuilder.greatEqual("settlementDate", LocalDate.now());
ImdgPredicate sideFilter;
if (ccp.isPresent() && ccp.get()) {
sideFilter = imdgPredicateBuilder.alwaysTrue();
} else {
sideFilter = imdgPredicateBuilder.equals("side", Side.SELL.getKey());
}
ImdgPredicate filter = imdgPredicateBuilder.and(settlementDateFilter, sideFilter);
AtomicReference<Collection<Map<String, Object>>> all = new AtomicReference<>();
pageIndex.ifPresentOrElse(index ->
all.set(stateLoader.getAllMetaTransformWithPagination(IMDGDistributedNames.Map_ExecutionCurrency, ExecutionCurrency.class, filter,
pageSize.orElse(10_000), index)),
() -> all.set(stateLoader.getAllMetaTransform(IMDGDistributedNames.Map_ExecutionCurrency, ExecutionCurrency.class, filter)));
CommonGetAllResponse response = new CommonGetAllResponse();
response.fromEntity(all.get());
return response;