|
@@ -217,12 +217,15 @@ public class AuctionActivityService {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- AuctionActivity recordNew1 = auctionActivityRepo.findById(record.getId())
|
|
|
|
|
- .orElseThrow(new BusinessException("无数据"));
|
|
|
|
|
- if (recordNew1.getStatus().equals(AuctionStatus.ONGOING)) {
|
|
|
|
|
- if (recordNew1.getEndTime().minusSeconds(2).isAfter(LocalDateTime.now())) {
|
|
|
|
|
|
|
+// AuctionActivity recordNew1 = auctionActivityRepo.findById(record.getId())
|
|
|
|
|
+// .orElseThrow(new BusinessException("无数据"));
|
|
|
|
|
+ if (record.getStatus().equals(AuctionStatus.ONGOING)) {
|
|
|
|
|
+ if (record.getEndTime().minusSeconds(2).isAfter(LocalDateTime.now())) {
|
|
|
Date date = Date.from(record.getEndTime().atZone(ZoneId.systemDefault()).toInstant());
|
|
Date date = Date.from(record.getEndTime().atZone(ZoneId.systemDefault()).toInstant());
|
|
|
ScheduledFuture<?> future = taskScheduler.schedule(() -> {
|
|
ScheduledFuture<?> future = taskScheduler.schedule(() -> {
|
|
|
|
|
+ AuctionActivity recordNew1 = auctionActivityRepo.findById(record.getId())
|
|
|
|
|
+ .orElseThrow(new BusinessException("无数据"));
|
|
|
|
|
+
|
|
|
if (ObjectUtils.isNotEmpty(recordNew1.getPurchasePrice())) {
|
|
if (ObjectUtils.isNotEmpty(recordNew1.getPurchasePrice())) {
|
|
|
log.info("拍卖成交{}", recordNew1.getId());
|
|
log.info("拍卖成交{}", recordNew1.getId());
|
|
|
auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PURCHASED);
|
|
auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PURCHASED);
|
|
@@ -244,15 +247,15 @@ public class AuctionActivityService {
|
|
|
}, date);
|
|
}, date);
|
|
|
tasks.put(record.getId(), future);
|
|
tasks.put(record.getId(), future);
|
|
|
} else {
|
|
} else {
|
|
|
- if (ObjectUtils.isNotEmpty(recordNew1.getPurchasePrice())) {
|
|
|
|
|
- log.info("拍卖成交{}", recordNew1.getId());
|
|
|
|
|
- auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PURCHASED);
|
|
|
|
|
|
|
+ if (ObjectUtils.isNotEmpty(record.getPurchasePrice())) {
|
|
|
|
|
+ log.info("拍卖成交{}", record.getId());
|
|
|
|
|
+ auctionActivityRepo.scheduleOffShelf(record.getId(), AuctionStatus.PURCHASED);
|
|
|
} else {
|
|
} else {
|
|
|
- log.info("拍卖流拍Task-else{}", recordNew1.getId());
|
|
|
|
|
- auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PASS);
|
|
|
|
|
|
|
+ log.info("拍卖流拍Task-else-else{}", record.getId());
|
|
|
|
|
+ auctionActivityRepo.scheduleOffShelf(record.getId(), AuctionStatus.PASS);
|
|
|
|
|
|
|
|
if (record.getAuctionType().equals(AuctionType.NFT)) {
|
|
if (record.getAuctionType().equals(AuctionType.NFT)) {
|
|
|
- Asset asset = assetRepo.findById(recordNew1.getAssetId())
|
|
|
|
|
|
|
+ Asset asset = assetRepo.findById(record.getAssetId())
|
|
|
.orElseThrow(new BusinessException("暂无"));
|
|
.orElseThrow(new BusinessException("暂无"));
|
|
|
asset.setStatus(AssetStatus.NORMAL);
|
|
asset.setStatus(AssetStatus.NORMAL);
|
|
|
asset.setConsignment(false);
|
|
asset.setConsignment(false);
|