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-30 10:23:46 +08:00
parent 7986b42384
commit f6b53f228e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/OrderController.java
+4 -4
View File
@@ -91,8 +91,7 @@ public class OrderController {
Sort s = Sort.by("createAt"); Sort s = Sort.by("createAt");
Flux<Order> flux = orderRepository.findAll(ep, s); Flux<Order> flux = orderRepository.findAll(ep, s);
flux.filter(fo -> fo.getFileId() == null).subscribe(fo -> { flux.filter(fo -> fo.getFileId() == null).subscribe(fo -> {
Flux<Record> rs = recordRepository.findAllByTraceIdOrderByCreateAtAsc(fo.getTraceId()); Mono<List<List<String>>> es = recordRepository.findAllByTraceIdOrderByCreateAtAsc(fo.getTraceId()).map(rr -> rr.getEvents()).collectList();
Mono<List<List<String>>> es = rs.map(rr -> rr.getEvents()).collectList();
Mono<List<String>> events = es.flatMapIterable(lists -> lists).flatMapIterable(list -> list).collectList(); Mono<List<String>> events = es.flatMapIterable(lists -> lists).flatMapIterable(list -> list).collectList();
events.subscribe(e -> { events.subscribe(e -> {
JSONArray array = JSONArray.parseArray(JSON.toJSONString(e)); JSONArray array = JSONArray.parseArray(JSON.toJSONString(e));
@@ -145,9 +144,10 @@ public class OrderController {
File file = new File(tempDir.toFile(), "video.mp4"); File file = new File(tempDir.toFile(), "video.mp4");
if (file.exists()) { if (file.exists()) {
log.info(String.valueOf(file.length()));
byte[] fileBytes = Files.readAllBytes(file.toPath()); byte[] fileBytes = Files.readAllBytes(file.toPath());
String titles = fo.getOrderId() + ".mp4"; String titles = fo.getOrderId() + ".mp4";
UploadFileDTO uploadFileDTO = new UploadFileDTO(fileBytes, "contractExcel", titles); UploadFileDTO uploadFileDTO = new UploadFileDTO(fileBytes, "RECALL", titles);
ResObj<UploadRespVO> uploadResObj = storageFeignClient.uploadBytes(uploadFileDTO); ResObj<UploadRespVO> uploadResObj = storageFeignClient.uploadBytes(uploadFileDTO);
log.info(JSON.toJSONString(uploadResObj)); log.info(JSON.toJSONString(uploadResObj));
@@ -157,7 +157,7 @@ public class OrderController {
orderRepository.save(fo).subscribe(); orderRepository.save(fo).subscribe();
} }
} }
} catch (IOException | InterruptedException e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
// 删除临时目录 // 删除临时目录