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:49:49 +08:00
parent 90d926f545
commit f0d0c02900
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/OrderController.java
+3 -1
View File
@@ -41,7 +41,6 @@ public class OrderController {
.withIgnoreNullValues().withIgnorePaths("createAt", "last"); .withIgnoreNullValues().withIgnorePaths("createAt", "last");
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.count().subscribe(resList::setTotal);//c -> resList.setTotal(c)
flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add); flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add);
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();
@@ -49,7 +48,10 @@ public class OrderController {
// resList.setList(list); // resList.setList(list);
// return Mono.just(ResObj.ok(resList)); // return Mono.just(ResObj.ok(resList));
// }); // });
return flux.count().flatMap(count -> {
resList.setTotal(count);
return Mono.just(ResObj.ok(resList)); return Mono.just(ResObj.ok(resList));
});
} }
@PostMapping("/info/{orderId}") @PostMapping("/info/{orderId}")