|
@@ -44,7 +44,7 @@ public interface ReactiveQueryController<E, K> {
|
|
|
@QueryAction
|
|
|
@QueryOperation(summary = "使用GET方式分页动态查询(不返回总数)",
|
|
|
description = "此操作不返回分页总数,如果需要获取全部数据,请设置参数paging=false")
|
|
|
- default Flux<E> query(@Parameter(hidden = true) QueryParamEntity query) {
|
|
|
+ default Flux<E> query(@Parameter(hidden = true) QueryParamEntity query) {
|
|
|
return getRepository()
|
|
|
.createQuery()
|
|
|
.setParam(query)
|
|
@@ -109,11 +109,12 @@ public interface ReactiveQueryController<E, K> {
|
|
|
.map(list -> PagerResult.of(query.getTotal(), list, query));
|
|
|
}
|
|
|
|
|
|
- return Mono.zip(
|
|
|
- getRepository().createQuery().setParam(query).count(),
|
|
|
- query(query.clone()).collectList(),
|
|
|
- (total, data) -> PagerResult.of(total, data, query)
|
|
|
- );
|
|
|
+ return Mono
|
|
|
+ .zip(
|
|
|
+ getRepository().createQuery().setParam(query.clone()).count(),
|
|
|
+ query(query.clone()).collectList(),
|
|
|
+ (total, data) -> PagerResult.of(total, data, query)
|
|
|
+ );
|
|
|
|
|
|
}
|
|
|
|