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 16:02:48 +08:00
parent 0436a7a399
commit a30661b564
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/RecallController.java
+3 -1
View File
@@ -1,5 +1,6 @@
package com.wabestway.recall.web; package com.wabestway.recall.web;
import com.alibaba.fastjson.JSON;
import com.wabestway.recall.model.Order; import com.wabestway.recall.model.Order;
import com.wabestway.recall.model.Record; import com.wabestway.recall.model.Record;
import com.wabestway.recall.model.ResObj; import com.wabestway.recall.model.ResObj;
@@ -11,6 +12,7 @@ import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import java.util.UUID; import java.util.UUID;
@Slf4j @Slf4j
@RestController @RestController
@RequestMapping("/track") @RequestMapping("/track")
@@ -30,7 +32,7 @@ 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 -> {