From f0d0c02900e20098b5ff00a67356a5a15cdcee67 Mon Sep 17 00:00:00 2001 From: BrandWang Date: Mon, 27 Mar 2023 16:49:49 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E5=8F=AF=E5=9B=9E=E6=BA=AF):=20=E5=8F=AF?= =?UTF-8?q?=E5=9B=9E=E6=BA=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修改分页查询 --- src/main/java/com/wabestway/recall/web/OrderController.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/wabestway/recall/web/OrderController.java b/src/main/java/com/wabestway/recall/web/OrderController.java index 621191f..bd2a3a3 100644 --- a/src/main/java/com/wabestway/recall/web/OrderController.java +++ b/src/main/java/com/wabestway/recall/web/OrderController.java @@ -41,7 +41,6 @@ public class OrderController { .withIgnoreNullValues().withIgnorePaths("createAt", "last"); Example ep = Example.of(order, matcher); Flux flux = orderRepository.findAll(ep, s); - flux.count().subscribe(resList::setTotal);//c -> resList.setTotal(c) flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).subscribe(list::add); resList.setList(list); // Mono> listMono = flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).collectList(); @@ -49,7 +48,10 @@ public class OrderController { // 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)); + }); } @PostMapping("/info/{orderId}")