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-04 17:02:45 +08:00
parent 04c1f0bda6
commit 075ac68744
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/RecallController.java
+8 -6
View File
@@ -5,12 +5,13 @@ import com.wabestway.recall.model.Record;
import com.wabestway.recall.model.ResObj; import com.wabestway.recall.model.ResObj;
import com.wabestway.recall.repository.OrderRepository; import com.wabestway.recall.repository.OrderRepository;
import com.wabestway.recall.repository.RecordRepository; import com.wabestway.recall.repository.RecordRepository;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import java.util.UUID; import java.util.UUID;
@Slf4j
@RestController @RestController
@RequestMapping("/track") @RequestMapping("/track")
public class RecallController { public class RecallController {
@@ -29,6 +30,7 @@ public class RecallController {
@PostMapping("/save") @PostMapping("/save")
public Mono<ResObj> save(@RequestBody Record record) { public Mono<ResObj> save(@RequestBody Record 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 -> {
@@ -53,11 +55,11 @@ public class RecallController {
forder.setAppKey(record.getAppKey()); forder.setAppKey(record.getAppKey());
forder.setArchived("0"); forder.setArchived("0");
forder.setComplete("0"); forder.setComplete("0");
forder.setHolderName("王五"); // forder.setHolderName("王五");
forder.setHolderPhone("18515064530"); // forder.setHolderPhone("18515064530");
forder.setSupplierName("阳光保险"); // forder.setSupplierName("阳光保险");
forder.setStartDate("2023-01-01"); // forder.setStartDate("2023-01-01");
forder.setEndDate("2035-01-01"); // forder.setEndDate("2035-01-01");
if (record.isLast()) { if (record.isLast()) {
forder.setComplete("1"); forder.setComplete("1");
} }