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-05-05 17:17:59 +08:00
parent d19a4b4df6
commit abdce58be2
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/RecallController.java
+1 -2
View File
@@ -32,7 +32,6 @@ public class RecallController {
@PostMapping("/save") @PostMapping("/save")
public Mono<ResObj> save(@RequestBody Record record) { public Mono<ResObj> save(@RequestBody Record record) {
log.info("请求数据：{}", JSON.toJSONString(record));
if (record.getOrderId() != null && !record.getOrderId().isEmpty()) { if (record.getOrderId() != null && !record.getOrderId().isEmpty()) {
Mono<Order> order = orderRepository.findByOrderId(record.getOrderId()); Mono<Order> order = orderRepository.findByOrderId(record.getOrderId());
order.hasElement().subscribe(exit -> { order.hasElement().subscribe(exit -> {
@@ -99,7 +98,7 @@ public class RecallController {
} }
} }
record.setCreateAt(System.currentTimeMillis()); record.setCreateAt(System.currentTimeMillis());
log.info("保存数据：{}", JSON.toJSONString(record));
return recordRepository.save(record).flatMap(ss -> { return recordRepository.save(record).flatMap(ss -> {
ss.setEvents(null); ss.setEvents(null);
return Mono.just(ResObj.ok(ss)); return Mono.just(ResObj.ok(ss));