[Feat]: 개인알림으로 낙찰/유찰

Author: Jiwoo-Seo

src/main/java/com/backend/global/scheduler/AuctionSchedulerService.java

@@ -2,6 +2,7 @@
 
 import com.backend.domain.bid.repository.BidRepository;
 import com.backend.domain.notification.service.AuctionNotificationService;
+import com.backend.domain.notification.service.BidNotificationService;
 import com.backend.domain.product.entity.Product;
 import com.backend.domain.product.enums.AuctionStatus;
 import com.backend.domain.product.event.helper.ProductChangeTracker;
@@ -26,6 +27,7 @@ public class AuctionSchedulerService {
     private final BidRepository bidRepository;
     private final WebSocketService webSocketService;
     private final AuctionNotificationService auctionNotificationService;
+    private final BidNotificationService bidNotificationService;
     private final ApplicationEventPublisher eventPublisher;
 
     //  매분마다 실행되어 종료된 경매들을 확인하고 낙찰 처리
@@ -118,15 +120,18 @@ private void processAuctionEnd(Product product) {
                 log.info("상품 ID: {}, 낙찰가: {}원으로 낙찰 처리되었습니다.", 
                     product.getId(), highestBidPrice);
 
-                // 구독자들에게 낙찰 알림 전송
+                // 구독자들에게 낙찰 알림 전송 (브로드캐스트)
                 webSocketService.broadcastAuctionEnd(product.getId(), true, highestBidPrice);
 
+                // 개인 알림 전송
+                sendAuctionEndNotifications(product, highestBidPrice);
+                
             } else {
                 // 입찰이 없었던 경우 - 유찰 처리
                 updateProduct(product, AuctionStatus.FAILED, null);
                 log.info("상품 ID: {}, 입찰이 없어 유찰 처리되었습니다.", product.getId());
 
-                // 구독자들에게 유찰 알림 전송
+                // 구독자들에게 유찰 알림 전송 (브로드캐스트)
                 webSocketService.broadcastAuctionEnd(product.getId(), false, 0L);
             }
 
@@ -138,6 +143,42 @@ private void processAuctionEnd(Product product) {
         }
     }
 
+    // 경매 종료 시 개인 알림 전송
+    private void sendAuctionEndNotifications(Product product, Long finalPrice) {
+        try {
+            // 이 상품에 입찰한 모든 사람들 조회
+            List<Object[]> bidders = entityManager.createQuery(
+                    "SELECT b.member.id, b.bidPrice FROM Bid b WHERE b.product.id = :productId AND b.status = 'BIDDING' ORDER BY b.bidPrice DESC",
+                    Object[].class)
+                    .setParameter("productId", product.getId())
+                    .getResultList();
+
+            if (bidders.isEmpty()) {
+                return;
+            }
+
+            // 최고 입찰자 (낙찰자)
+            Long winnerId = (Long) bidders.get(0)[0];
+            
+            // 낙찰자에게 낙찰 알림
+            bidNotificationService.notifyAuctionWon(winnerId, product, finalPrice);
+            
+            // 나머지 입찰자들에게 낙찰 실패 알림
+            for (int i = 1; i < bidders.size(); i++) {
+                Long loserId = (Long) bidders.get(i)[0];
+                Long loserBidPrice = ((Number) bidders.get(i)[1]).longValue();
+                bidNotificationService.notifyAuctionLost(loserId, product, finalPrice, loserBidPrice);
+            }
+            
+            log.info("상품 ID: {}에 대한 경매 종료 개인 알림 전송 완료. 낙찰자: {}, 탈락자: {}명",
+                    product.getId(), winnerId, bidders.size() - 1);
+                    
+        } catch (Exception e) {
+            log.error("경매 종료 개인 알림 전송 중 오류 발생. 상품 ID: {}, 오류: {}",
+                    product.getId(), e.getMessage(), e);
+        }
+    }
+
     // 개별 경매 시작 처리
     private void processAuctionStart(Product product) {
         try {