feat(可回溯): 可回溯

取消索引
This commit is contained in:
BrandWang
2023-05-06 15:19:27 +08:00
parent 45ff862c8e
commit ba094c7008
3 changed files with 16 additions and 8 deletions
-1
View File
@@ -48,7 +48,6 @@
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId> <artifactId>spring-boot-starter-webflux</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.projectlombok</groupId> <groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId> <artifactId>lombok</artifactId>
@@ -22,7 +22,6 @@ import java.io.*;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Comparator;
import java.util.List; import java.util.List;
@Slf4j @Slf4j
@@ -57,11 +56,6 @@ public class OrderController {
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);
resList.setList(list); resList.setList(list);
// Mono<List<Order>> listMono = flux.skip(pageRequest.getOffset()).limitRequest(pageRequest.getPageSize()).collectList();
// return listMono.flatMap(list -> {
// resList.setList(list);
// return Mono.just(ResObj.ok(resList));
// });
return flux.count().flatMap(count -> { return flux.count().flatMap(count -> {
resList.setTotal(count); resList.setTotal(count);
return Mono.just(ResObj.ok(resList)); return Mono.just(ResObj.ok(resList));
@@ -93,7 +87,7 @@ public class OrderController {
fo.setEvents(e); fo.setEvents(e);
return Mono.just(ResObj.ok(fo)); return Mono.just(ResObj.ok(fo));
}); });
}); }).defaultIfEmpty(ResObj.fail("订单不存在"));
} }
@GetMapping("/ffmpeg") @GetMapping("/ffmpeg")
@@ -0,0 +1,15 @@
package com.wabestway.recall;
import org.junit.Test;
import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
public class JSEngine {
@Test
public void TestEngine(){
ScriptEngineManager manager = new ScriptEngineManager();
ScriptEngine engine = manager.getEngineByName("js");
System.out.printf(engine.toString());
}
}