|
|
@@ -287,4 +287,28 @@ public class AssetService {
|
|
|
Thread.sleep(1000);
|
|
|
log.info("" + i);
|
|
|
}
|
|
|
+
|
|
|
+ public void setHistory() {
|
|
|
+ List<Asset> assets = assetRepo.findByCreatedAtBefore(LocalDateTime.of(2021, 11, 22, 23, 59, 59));
|
|
|
+ assets.parallelStream().forEach(asset -> {
|
|
|
+ try {
|
|
|
+ User owner = userRepo.findById(asset.getUserId()).orElseThrow(new BusinessException(""));
|
|
|
+ Order order = orderRepo.findById(asset.getOrderId()).orElseThrow(new BusinessException(""));
|
|
|
+ TokenHistory t = TokenHistory.builder()
|
|
|
+ .tokenId(asset.getTokenId())
|
|
|
+ .fromUser(asset.getMinter())
|
|
|
+ .fromUserId(asset.getMinterId())
|
|
|
+ .fromAvatar(asset.getMinterAvatar())
|
|
|
+ .toUser(owner.getNickname())
|
|
|
+ .toUserId(owner.getId())
|
|
|
+ .toAvatar(owner.getAvatar())
|
|
|
+ .operation("出售")
|
|
|
+ .price(order.getPrice())
|
|
|
+ .build();
|
|
|
+ t.setCreatedAt(asset.getCreatedAt());
|
|
|
+ tokenHistoryRepo.save(t);
|
|
|
+ } catch (Exception e) {
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
}
|