流拍记录表

src/main/java/com/izouma/nineth/repo/AuctionPassRecordRepo.java

@@ -0,0 +1,19 @@
+package com.izouma.nineth.repo;
+
+import com.izouma.nineth.domain.AuctionPassRecord;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+
+import javax.transaction.Transactional;
+import java.util.List;
+
+public interface AuctionPassRecordRepo extends JpaRepository<AuctionPassRecord, Long>, JpaSpecificationExecutor<AuctionPassRecord> {
+    @Query("update AuctionRecord t set t.del = true where t.id = ?1")
+    @Modifying
+    @Transactional
+    void softDelete(Long id);
+
+    List<AuctionPassRecord> findAllByAuctionId(Long auctionId);
+}

src/main/java/com/izouma/nineth/service/AuctionActivityService.java

@@ -47,7 +47,7 @@ public class AuctionActivityService {
     private final Environment                   env;
     private final TokenHistoryRepo              tokenHistoryRepo;
     private final SysConfigService              sysConfigService;
-    private final AuctionRecordRepo             auctionRecordRepo;
+    private final AuctionPassRecordRepo         auctionPassRecordRepo;
 
     private final Map<Long, ScheduledFuture<?>> tasks = new HashMap<>();
 
@@ -224,11 +224,11 @@ public class AuctionActivityService {
                     } else {
                         auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PASS);
                         //添加到流拍记录表里
-                        AuctionPassRecord.builder()
+                        auctionPassRecordRepo.save(AuctionPassRecord.builder()
                                 .auctionId(record.getId())
                                 .userId(recordNew1.getPurchaserId())
                                 .purchasePrice(recordNew1.getPurchasePrice())
-                                .build();
+                                .build());
 
                         if (record.getAuctionType().equals(AuctionType.NFT)) {
                             Asset asset = assetRepo.findById(recordNew1.getAssetId())
@@ -248,11 +248,11 @@ public class AuctionActivityService {
                 } else {
                     auctionActivityRepo.scheduleOffShelf(recordNew1.getId(), AuctionStatus.PASS);
                     //添加到流拍记录表里
-                    AuctionPassRecord.builder()
+                    auctionPassRecordRepo.save(AuctionPassRecord.builder()
                             .auctionId(record.getId())
                             .userId(recordNew1.getPurchaserId())
                             .purchasePrice(recordNew1.getPurchasePrice())
-                            .build();
+                            .build());
 
                     if (record.getAuctionType().equals(AuctionType.NFT)) {
                         Asset asset = assetRepo.findById(recordNew1.getAssetId())

src/main/java/com/izouma/nineth/service/AuctionOrderService.java

@@ -41,6 +41,7 @@ public class AuctionOrderService {
     private AuctionActivityService        auctionActivityService;
     private RedisTemplate<String, Object> redisTemplate;
     private SnowflakeIdWorker             snowflakeIdWorker;
+    private AuctionPassRecordRepo         auctionPassRecordRepo;
 
     public Page<AuctionOrder> all(PageQuery pageQuery) {
         return auctionOrderRepo
@@ -280,11 +281,11 @@ public class AuctionOrderService {
 //                  auctionActivityRepo.save(auction);
                     auctionActivityService.changeStatus(order.getAuctionId(), AuctionStatus.PASS);
                     //添加到流拍记录表里
-                    AuctionPassRecord.builder()
+                    auctionPassRecordRepo.save(AuctionPassRecord.builder()
                             .auctionId(auction.getId())
                             .userId(auction.getPurchaserId())
                             .purchasePrice(auction.getPurchasePrice())
-                            .build();
+                            .build());
 
                     //退其余保证金
                     List<AuctionOrder> orders = auctionOrderRepo
@@ -328,11 +329,11 @@ public class AuctionOrderService {
 //              auctionActivityRepo.save(auction);
                 auctionActivityService.changeStatus(order.getAuctionId(), AuctionStatus.PASS);
                 //添加到流拍记录表里
-                AuctionPassRecord.builder()
+                auctionPassRecordRepo.save(AuctionPassRecord.builder()
                         .auctionId(auction.getId())
                         .userId(auction.getPurchaserId())
                         .purchasePrice(auction.getPurchasePrice())
-                        .build();
+                        .build());
 
             }
 
@@ -375,11 +376,11 @@ public class AuctionOrderService {
                 act.setStatus(AuctionStatus.PASS);
                 auctionActivityRepo.save(act);
                 //添加到流拍记录表里
-                AuctionPassRecord.builder()
+                auctionPassRecordRepo.save(AuctionPassRecord.builder()
                         .auctionId(act.getId())
                         .userId(act.getPurchaserId())
                         .purchasePrice(act.getPurchasePrice())
-                        .build();
+                        .build());
             });
         }
     }