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-27 14:33:21 +08:00
parent bf99c092fd
commit 1d9d91dd1f
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/wabestway/recall/web/RecallController.java
+16 -16
View File
@@ -67,23 +67,23 @@ public class RecallController {
}); });
} }
}); });
} else {
if (record.getTraceId() == null || record.getTraceId().isEmpty()) {
record.setTraceId(UUID.randomUUID().toString().replace("-", ""));
Order order = new Order();
order.setTraceId(record.getTraceId());
order.setProductCode(record.getProductCode());
order.setProductName(record.getProductName());
order.setCreateAt(System.currentTimeMillis());
order.setAppKey(record.getAppKey());
order.setArchived("0");
order.setComplete("0");
if (record.isLast()) {
order.setComplete("1");
}
orderRepository.save(order).subscribe();
}
} }
if (record.getTraceId() == null || record.getTraceId().isEmpty()) {
record.setTraceId(UUID.randomUUID().toString().replace("-", ""));
Order order = new Order();
order.setTraceId(record.getTraceId());
order.setProductCode(record.getProductCode());
order.setProductName(record.getProductName());
order.setCreateAt(System.currentTimeMillis());
order.setAppKey(record.getAppKey());
order.setArchived("0");
order.setComplete("0");
if (record.isLast()) {
order.setComplete("1");
}
orderRepository.save(order).subscribe();
}
record.setCreateAt(System.currentTimeMillis()); record.setCreateAt(System.currentTimeMillis());
return recordRepository.save(record).flatMap(ss -> { return recordRepository.save(record).flatMap(ss -> {