feat(可回溯): 可回溯

修改分页查询
This commit is contained in:
BrandWang
2023-03-27 17:41:53 +08:00
parent d55689ac64
commit a03220ec7b
@@ -36,9 +36,9 @@ public class OrderController {
OrderList resList = new OrderList(); OrderList resList = new OrderList();
List<Order> list = new ArrayList<>(); List<Order> list = new ArrayList<>();
Sort s = Sort.by("createAt"); Sort s = Sort.by("createAt");
PageRequest pageRequest = PageRequest.of(order.getPage(), order.getPageSize(), s); PageRequest pageRequest = PageRequest.of(order.getPage() - 1, order.getPageSize(), s);
ExampleMatcher matcher = ExampleMatcher.matching() ExampleMatcher matcher = ExampleMatcher.matching()
.withIgnoreNullValues().withIgnorePaths("createAt", "last","page","pageSize"); .withIgnoreNullValues().withIgnorePaths("createAt", "last", "page", "pageSize");
Example<Order> ep = Example.of(order, matcher); Example<Order> ep = Example.of(order, matcher);
Flux<Order> flux = orderRepository.findAll(ep, s); Flux<Order> flux = orderRepository.findAll(ep, s);
flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add); flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add);