|
@@ -423,15 +423,17 @@ public class OrderService {
|
|
|
@EventListener
|
|
@EventListener
|
|
|
public void onCreateAsset(CreateAssetEvent event) {
|
|
public void onCreateAsset(CreateAssetEvent event) {
|
|
|
Asset asset = event.getAsset();
|
|
Asset asset = event.getAsset();
|
|
|
- Order order = orderRepo.findById(asset.getOrderId()).orElseThrow(new BusinessException("订单不存在"));
|
|
|
|
|
- if (event.isSuccess()) {
|
|
|
|
|
- order.setTxHash(asset.getTxHash());
|
|
|
|
|
- order.setGasUsed(asset.getGasUsed());
|
|
|
|
|
- order.setBlockNumber(asset.getBlockNumber());
|
|
|
|
|
- order.setStatus(OrderStatus.FINISH);
|
|
|
|
|
- orderRepo.save(order);
|
|
|
|
|
- } else {
|
|
|
|
|
- log.error("创建asset失败");
|
|
|
|
|
|
|
+ if (asset.getOrderId() != null) {
|
|
|
|
|
+ Order order = orderRepo.findById(asset.getOrderId()).orElseThrow(new BusinessException("订单不存在"));
|
|
|
|
|
+ if (event.isSuccess()) {
|
|
|
|
|
+ order.setTxHash(asset.getTxHash());
|
|
|
|
|
+ order.setGasUsed(asset.getGasUsed());
|
|
|
|
|
+ order.setBlockNumber(asset.getBlockNumber());
|
|
|
|
|
+ order.setStatus(OrderStatus.FINISH);
|
|
|
|
|
+ orderRepo.save(order);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ log.error("创建asset失败");
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|