Merge pull request #212 from Yanol-Market/feature/14-negoFinalRefactor

Feature/14 nego final refactor
Yanol-Market · Jan 24, 2024 · f59dffa · f59dffa
2 parents ae800fc + 1d95344
commit f59dffa
Show file tree

Hide file tree

Showing 4 changed files with 71 additions and 41 deletions.
diff --git a/src/main/java/site/goldenticket/domain/nego/service/NegoSchedulerService.java b/src/main/java/site/goldenticket/domain/nego/service/NegoSchedulerService.java
@@ -1,26 +1,29 @@
 package site.goldenticket.domain.nego.service;
 
-import static site.goldenticket.common.response.ErrorCode.USER_NOT_FOUND;
-import static site.goldenticket.domain.nego.status.NegotiationStatus.NEGOTIATION_COMPLETED;
-import static site.goldenticket.domain.nego.status.NegotiationStatus.NEGOTIATION_TIMEOUT;
-import static site.goldenticket.domain.nego.status.NegotiationStatus.PAYMENT_PENDING;
-import static site.goldenticket.domain.nego.status.NegotiationStatus.TRANSFER_PENDING;
-
-import java.time.LocalDateTime;
-import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import site.goldenticket.common.exception.CustomException;
+import site.goldenticket.common.response.ErrorCode;
 import site.goldenticket.domain.alert.service.AlertService;
 import site.goldenticket.domain.nego.entity.Nego;
 import site.goldenticket.domain.nego.repository.NegoRepository;
+import site.goldenticket.domain.payment.model.Order;
+import site.goldenticket.domain.payment.repository.OrderRepository;
 import site.goldenticket.domain.product.constants.ProductStatus;
 import site.goldenticket.domain.product.model.Product;
 import site.goldenticket.domain.product.service.ProductService;
 import site.goldenticket.domain.user.entity.User;
 import site.goldenticket.domain.user.repository.UserRepository;
 
+import java.time.LocalDateTime;
+import java.util.List;
+
+import static site.goldenticket.common.constants.OrderStatus.COMPLETED_TRANSFER;
+import static site.goldenticket.common.constants.OrderStatus.WAITING_TRANSFER;
+import static site.goldenticket.common.response.ErrorCode.USER_NOT_FOUND;
+import static site.goldenticket.domain.nego.status.NegotiationStatus.*;
+
 @Service
 @RequiredArgsConstructor
 public class NegoSchedulerService {
@@ -29,12 +32,13 @@ public class NegoSchedulerService {
     private final ProductService productService;
     private final AlertService alertService;
     private final UserRepository userRepository;
+    private final OrderRepository orderRepository;
 
     @Scheduled(fixedDelay = 60000)
     public void changeStatus() {
         LocalDateTime currentTime = LocalDateTime.now();
         List<Nego> pendingNegos = negoRepository.findByStatus(PAYMENT_PENDING);
-        List<Nego> transferNegos = negoRepository.findByStatus(TRANSFER_PENDING);
+        List<Order> transferOrders = orderRepository.findByStatus(WAITING_TRANSFER);
 
         for (Nego nego : pendingNegos) {
             Product product = productService.getProduct(nego.getProductId());
@@ -47,45 +51,65 @@ public void changeStatus() {
 
                 //판매자에게 타임오버 알림 전송
                 alertService.createAlert(product.getUserId(),
-                    "구매자가 20분 이내에 결제를 완료하지 않아 거래가 이루어지지 않았습니다.");
+                        "구매자가 20분 이내에 결제를 완료하지 않아 거래가 이루어지지 않았습니다.");
                 //구매자에게 타임오버 알림 전송
                 alertService.createAlert(nego.getUser().getId(),
-                    "20분이 초과되었습니다. 아직 구매를 원하신다면, 재결제 버튼을 눌러 결제해주세요.");
+                        "20분이 초과되었습니다. 아직 구매를 원하신다면, 재결제 버튼을 눌러 결제해주세요.");
+                negoRepository.save(nego);
             }
         } //상품 상태 판매중
 
-        for (Nego transferNego : transferNegos) {
-            Product product = productService.getProduct(transferNego.getProductId());
-            LocalDateTime updatedAt = transferNego.getUpdatedAt();
-            if (updatedAt != null && currentTime.isAfter(updatedAt.plusMinutes(20))) {
-                transferNego.setStatus(NEGOTIATION_COMPLETED);
-                transferNego.setUpdatedAt(currentTime);
-                product.setProductStatus(ProductStatus.SOLD_OUT);
-                productService.updateProductForNego(product);
+        for (Order transferOrder : transferOrders) {
+            Product product = productService.getProduct(transferOrder.getProductId());
+            List<Nego> transferNegos = negoRepository.findAllByProduct(product);
+            LocalDateTime updatedAt = transferOrder.getUpdatedAt();
 
-                //구매자에게 양도 완료 알림 전송
-                alertService.createAlert(transferNego.getUser().getId(),
-                    "'" + product.getAccommodationName() + "(" + product.getRoomName()
-                        + ")'상품 양도가 완료되었습니다. "
-                        + "양도 완료에 따른 체크인 정보는 '마이페이지 > 구매내역 > 구매 완료'에서 확인하실 수 있습니다.");
-                //판매자에게 정산 요청 알림 전송
-                alertService.createAlert(product.getUserId(),
-                    "'" + product.getAccommodationName() + "(" + product.getRoomName()
-                        + ")'상품 양도가 완료되었습니다. 영업일 1일 이내 등록한 계좌 정보로 정산 금액이 입금됩니다."
-                        + "원활한 정산 진행을 위해 '마이페이지 - 나의 계좌'정보를 다시 한번 확인해주세요.");
-                //판매자에게 계좌 등록 알림 전송
-                User user = userRepository.findById(product.getUserId())
+            User user = userRepository.findById(product.getUserId())
                     .orElseThrow(() -> new CustomException(USER_NOT_FOUND));
-                if (user!=null && user.getAccountNumber() == null) {
+
+            checkAccountAndThrowException(user);
+
+            if (updatedAt != null && currentTime.isAfter(updatedAt.plusMinutes(20))) {
+                for (Nego transferNego : transferNegos) {
+                    // 각 네고의 현재 상태를 확인하고 처리
+                    if (transferNego.getStatus() == NEGOTIATION_COMPLETED) {
+                        continue;
+                    }
+                    transferOrder.setStatus(COMPLETED_TRANSFER);
+                    transferNego.setStatus(NEGOTIATION_COMPLETED);
+                    transferNego.setUpdatedAt(currentTime);
+
+                    // 상품의 상태를 변경하고 업데이트
+                    product.setProductStatus(ProductStatus.SOLD_OUT);
+                    productService.updateProductForNego(product);
+
+                    // 구매자에게 양도 완료 알림 전송
+                    alertService.createAlert(transferNego.getUser().getId(),
+                            "'" + product.getAccommodationName() + "(" + product.getRoomName()
+                                    + ")'상품 양도가 완료되었습니다. "
+                                    + "양도 완료에 따른 체크인 정보는 '마이페이지 > 구매내역 > 구매 완료'에서 확인하실 수 있습니다.");
+
+                    // 판매자에게 정산 요청 알림 전송
                     alertService.createAlert(product.getUserId(),
-                        "'" + product.getAccommodationName() + "(" + product.getRoomName()
-                            + ")'상품에 대한 원활한 정산을 위해 '마이페이지 > 내 계좌'에서 입금받으실 계좌를 등록해주세요.");
+                            "'" + product.getAccommodationName() + "(" + product.getRoomName()
+                                    + ")'상품 양도가 완료되었습니다. 영업일 1일 이내 등록한 계좌 정보로 정산 금액이 입금됩니다."
+                                    + "원활한 정산 진행을 위해 '마이페이지 - 나의 계좌'정보를 다시 한번 확인해주세요.");
+
+                    // 판매자에게 계좌 등록 알림 전송
+
+                    if (user != null && user.getAccountNumber() == null) {
+                        alertService.createAlert(product.getUserId(),
+                                "'" + product.getAccommodationName() + "(" + product.getRoomName()
+                                        + ")'상품에 대한 원활한 정산을 위해 '마이페이지 > 내 계좌'에서 입금받으실 계좌를 등록해주세요.");
+                    }
                 }
+                negoRepository.saveAll(transferNegos);
             }
-        }   // 20분 뒤 자동양도
-
-        negoRepository.saveAll(transferNegos);
-        negoRepository.saveAll(pendingNegos);
+        } // 20분 뒤 자동양도
+    }
+    private void checkAccountAndThrowException(User user) {
+        if (user.getAccountNumber() == null) {
+            throw new CustomException("등록된 계좌가 없습니다.", ErrorCode.NO_REGISTERED_ACCOUNT);
+        }
     }
-
 }
diff --git a/src/main/java/site/goldenticket/domain/nego/service/NegoServiceImpl.java b/src/main/java/site/goldenticket/domain/nego/service/NegoServiceImpl.java
@@ -241,15 +241,15 @@ public HandoverResponse handOverProduct(Long productId, PrincipalDetails princip
 
         if (transferPendingNego.isEmpty()) {
             Order order = orderRepository.findByProductId(productId);
-            //checkAccountAndThrowException(user);
+            checkAccountAndThrowException(user);
             product.setProductStatus(ProductStatus.SOLD_OUT);
             productService.updateProductForNego(product);
             handleNegos(allNegosForProduct);
             sendTransferCompleteAlertsForNotNego(order, product, user);
         }
 
         if (transferPendingNego.isPresent()) {
-            //checkAccountAndThrowException(user);
+            checkAccountAndThrowException(user);
             Nego nego = transferPendingNego.get();
             completeTransfer(product, nego);
             handleNegos(allNegosForProduct);

diff --git a/src/main/java/site/goldenticket/domain/payment/model/Order.java b/src/main/java/site/goldenticket/domain/payment/model/Order.java
@@ -58,4 +58,8 @@ public void paymentFailed() {
     public void changeViewCheck() {
         customerViewCheck = true;
     }
+
+    public void setStatus(OrderStatus status) {
+        this.status = status;
+    }
 }
diff --git a/src/main/java/site/goldenticket/domain/payment/repository/OrderRepository.java b/src/main/java/site/goldenticket/domain/payment/repository/OrderRepository.java
@@ -16,4 +16,6 @@ public interface OrderRepository extends JpaRepository<Order, Long> {
     Order findByProductId(Long productId);
 
     List<Order> findByUserIdAndStatus(Long userId, OrderStatus status);
+
+    List<Order> findByStatus(OrderStatus orderStatus);
 }