|
@@ -399,6 +399,7 @@ public class OrderService {
|
|
|
if (collection.getSource() == CollectionSource.TRANSFER) {
|
|
if (collection.getSource() == CollectionSource.TRANSFER) {
|
|
|
Asset asset = assetRepo.findById(collection.getAssetId()).orElse(null);
|
|
Asset asset = assetRepo.findById(collection.getAssetId()).orElse(null);
|
|
|
assetService.transfer(asset, order.getPrice(), user, "转让", order.getId());
|
|
assetService.transfer(asset, order.getPrice(), user, "转让", order.getId());
|
|
|
|
|
+ log.info("删除collection {}", collection.getId());
|
|
|
collectionRepo.delete(collection);
|
|
collectionRepo.delete(collection);
|
|
|
} else {
|
|
} else {
|
|
|
orderRepo.save(order);
|
|
orderRepo.save(order);
|
|
@@ -429,6 +430,7 @@ public class OrderService {
|
|
|
|
|
|
|
|
@EventListener
|
|
@EventListener
|
|
|
public void onTransferAsset(TransferAssetEvent event) {
|
|
public void onTransferAsset(TransferAssetEvent event) {
|
|
|
|
|
+ log.info("藏品转让成功 assetId={}", event.getAsset().getId());
|
|
|
Asset asset = event.getAsset();
|
|
Asset asset = event.getAsset();
|
|
|
Order order = orderRepo.findById(asset.getOrderId()).orElseThrow(new BusinessException("订单不存在"));
|
|
Order order = orderRepo.findById(asset.getOrderId()).orElseThrow(new BusinessException("订单不存在"));
|
|
|
if (event.isSuccess()) {
|
|
if (event.isSuccess()) {
|