wanghao/afis-recall
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(可回溯): 可回溯

Browse Source 
修改分页查询
This commit is contained in:
BrandWang
2023-03-27 16:45:41 +08:00
parent 2f33b6c2db
commit 90d926f545
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/OrderController.java
+4 -8
View File
@@ -35,18 +35,14 @@ public class OrderController {
public Mono<ResObj> list(@RequestBody Order order) { public Mono<ResObj> list(@RequestBody Order order) {
OrderList resList = new OrderList(); OrderList resList = new OrderList();
List<Order> list = new ArrayList<>(); List<Order> list = new ArrayList<>();
PageRequest pageRequest = PageRequest.of(order.getPage(), order.getPageSize()); Sort s = Sort.by("createAt");
PageRequest pageRequest = PageRequest.of(order.getPage(), order.getPageSize(), s);
ExampleMatcher matcher = ExampleMatcher.matching() ExampleMatcher matcher = ExampleMatcher.matching()
.withIgnoreNullValues().withIgnorePaths("createAt", "last"); .withIgnoreNullValues().withIgnorePaths("createAt", "last");
Example<Order> ep = Example.of(order, matcher); Example<Order> ep = Example.of(order, matcher);
Sort s = Sort.by("createAt");
Flux<Order> flux = orderRepository.findAll(ep, s); Flux<Order> flux = orderRepository.findAll(ep, s);
flux.count().subscribe(c -> resList.setTotal(c)); flux.count().subscribe(resList::setTotal);//c -> resList.setTotal(c)
flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(f -> { flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add);
list.add(f);
});
resList.setList(list); resList.setList(list);
// Mono<List<Order>> listMono = flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).collectList(); // Mono<List<Order>> listMono = flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).collectList();
// return listMono.flatMap(list -> { // return listMono.flatMap(list -> {