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

BidRepository: 상품 모든 입찰 내역 조회 추가
AuctionSchedulerService: 낙찰/유찰 개인알림 추가

Author: Jiwoo-Seo

src/main/java/com/backend/domain/bid/repository/BidRepository.java

@@ -61,4 +61,8 @@ SELECT MAX(b2.bidPrice)
             ORDER BY b.createDate DESC
             """)
     List<Bid> findWinningBids(@Param("memberId") Long memberId);
+
+    // 특정 상품의 모든 입찰 내역 (입찰가 내림차순)
+    @Query("SELECT b FROM Bid b JOIN FETCH b.member WHERE b.product.id = :productId AND b.status = 'BIDDING' ORDER BY b.bidPrice DESC")
+    List<Bid> findAllBidsByProductOrderByPriceDesc(@Param("productId") Long productId);
 }

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

@@ -1,7 +1,9 @@
 package com.backend.global.scheduler;
 
+import com.backend.domain.bid.entity.Bid;
 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 +28,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 +121,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 +144,41 @@ private void processAuctionEnd(Product product) {
         }
     }
 
+    // 경매 종료 시 개인 알림 전송
+    private void sendAuctionEndNotifications(Product product, Long finalPrice) {
+        try {
+            List<Bid> bids = bidRepository.findAllBidsByProductOrderByPriceDesc(product.getId());
+
+            if (bids.isEmpty()) {
+                return;
+            }
+
+            // 낙찰자
+            Bid winningBid = bids.get(0);
+            
+            // 낙찰자에게 낙찰 알림
+            bidNotificationService.notifyAuctionWon(winningBid.getMember().getId(), product, finalPrice);
+            
+            // 나머지 입찰자들에게 낙찰 실패 알림
+            for (int i = 1; i < bids.size(); i++) {
+                Bid losingBid = bids.get(i);
+                bidNotificationService.notifyAuctionLost(
+                    losingBid.getMember().getId(), 
+                    product, 
+                    finalPrice, 
+                    losingBid.getBidPrice()
+                );
+            }
+            
+            log.info("상품 ID: {}에 대한 경매 종료 개인 알림 전송 완료. 낙찰자: {}, 탈락자: {}명",
+                    product.getId(), winningBid.getMember().getId(), bids.size() - 1);
+                    
+        } catch (Exception e) {
+            log.error("경매 종료 개인 알림 전송 중 오류 발생. 상품 ID: {}, 오류: {}",
+                    product.getId(), e.getMessage(), e);
+        }
+    }
+
     // 개별 경매 시작 처리
     private void processAuctionStart(Product product) {
         try {