Explorar el Código

停止自动空投

wangqifan hace 3 años
padre
commit
ec530e7cca

+ 21 - 21
src/main/java/com/izouma/nineth/service/TradeAuctionOrderService.java

@@ -305,27 +305,27 @@ public class TradeAuctionOrderService {
 //        releaseOrderLock(order.getId());
     }
 
-    @Scheduled(fixedRate = 30000)
-    public void batchAirdrop() {
-        List<TradeAuctionOrder> tradeAuctionOrders = tradeAuctionOrderRepo
-                .findByStatusAndDelFalse(AuctionOrderStatus.AIR_DROP);
-        tradeAuctionOrders.parallelStream().forEach(o -> {
-            try {
-                TradeAuctionOrder order = tradeAuctionOrderRepo.findById(o.getId())
-                        .orElseThrow(new BusinessException("订单不存在"));
-                TradeAuction tradeAuction = tradeAuctionRepo.findById(order.getTradeAuctionId())
-                        .orElseThrow(new BusinessException("未找到易拍活动"));
-                User owner = userRepo.findById(order.getUserId())
-                        .orElseThrow(new BusinessException("暂无用户"));
-                assetService.createAsset(tradeAuction, owner, order.getId(), tradeAuction
-                        .getCurrentPrice(), "空投", 1, false);
-                order.setStatus(AuctionOrderStatus.FINISH);
-                tradeAuctionOrderRepo.save(order);
-            } catch (Exception e) {
-                log.error("取消易拍订单错误 " + o.getId(), e);
-            }
-        });
-    }
+//    @Scheduled(fixedRate = 30000)
+//    public void batchAirdrop() {
+//        List<TradeAuctionOrder> tradeAuctionOrders = tradeAuctionOrderRepo
+//                .findByStatusAndDelFalse(AuctionOrderStatus.AIR_DROP);
+//        tradeAuctionOrders.parallelStream().forEach(o -> {
+//            try {
+//                TradeAuctionOrder order = tradeAuctionOrderRepo.findById(o.getId())
+//                        .orElseThrow(new BusinessException("订单不存在"));
+//                TradeAuction tradeAuction = tradeAuctionRepo.findById(order.getTradeAuctionId())
+//                        .orElseThrow(new BusinessException("未找到易拍活动"));
+//                User owner = userRepo.findById(order.getUserId())
+//                        .orElseThrow(new BusinessException("暂无用户"));
+//                assetService.createAsset(tradeAuction, owner, order.getId(), tradeAuction
+//                        .getCurrentPrice(), "空投", 1, false);
+//                order.setStatus(AuctionOrderStatus.FINISH);
+//                tradeAuctionOrderRepo.save(order);
+//            } catch (Exception e) {
+//                log.error("取消易拍订单错误 " + o.getId(), e);
+//            }
+//        });
+//    }
 
     @Scheduled(fixedRate = 30000)
     public void batchPayEarning() {