[FEATURE] : 토스페이먼츠 결제 API를 구현합니다.

.gitignore

@@ -35,3 +35,7 @@ out/
 
 ### VS Code ###
 .vscode/
+
+
+### yml file ###
+/src/main/resources/application-payment.yml

src/main/java/com/tasksprints/auction/AuctionApplication.java

@@ -4,10 +4,11 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 
+import java.util.Arrays;
+
 @EnableJpaAuditing
 @SpringBootApplication
 public class AuctionApplication {
-
     public static void main(String[] args) {
         SpringApplication.run(AuctionApplication.class, args);
     }

src/main/java/com/tasksprints/auction/api/payment/PaymentController.java

@@ -0,0 +1,90 @@
+package com.tasksprints.auction.api.payment;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.tasksprints.auction.common.config.PaymentConfig;
+import com.tasksprints.auction.common.constant.ApiResponseMessages;
+import com.tasksprints.auction.common.response.ApiResult;
+import com.tasksprints.auction.domain.payment.api.Response;
+import com.tasksprints.auction.domain.payment.dto.request.PaymentRequest;
+import com.tasksprints.auction.domain.payment.dto.response.PaymentErrorResponse;
+import com.tasksprints.auction.domain.payment.dto.response.PaymentResponse;
+import com.tasksprints.auction.domain.payment.exception.InvalidSessionException;
+import com.tasksprints.auction.domain.payment.exception.PaymentDataMismatchException;
+import com.tasksprints.auction.domain.payment.exception.PaymentUserNotFoundException;
+import com.tasksprints.auction.domain.payment.model.Payment;
+import com.tasksprints.auction.domain.payment.repository.PaymentRepository;
+import com.tasksprints.auction.domain.payment.service.PaymentService;
+import com.tasksprints.auction.domain.user.model.User;
+import com.tasksprints.auction.domain.user.repository.UserRepository;
+import com.tasksprints.auction.domain.user.service.UserServiceImpl;
+import com.tasksprints.auction.domain.wallet.model.Wallet;
+import com.tasksprints.auction.domain.wallet.service.WalletServiceImpl;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import jakarta.servlet.http.HttpSession;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.math.BigDecimal;
+import java.net.http.HttpClient;
+import java.net.http.HttpResponse;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/v1/payment")
+public class PaymentController {
+    private final PaymentService paymentService;
+
+    @PostMapping("/prepare")
+    @Operation(summary = "Temporarily stores the payment element", description = "Save orderID and amount in session")
+    @ApiResponse(responseCode = "200", description = "Payment prepared successfully")
+    public ResponseEntity<ApiResult<String>> preparePayment(HttpSession session, @RequestBody PaymentRequest.Prepare prepareRequest) {
+        paymentService.prepare(session, prepareRequest);
+        return ResponseEntity.ok(ApiResult.success(ApiResponseMessages.PAYMENT_PREPARED_SUCCESS));
+    }
+
+    @PostMapping("/confirm")
+    public ResponseEntity<?> confirmPayment(HttpSession session, @RequestBody PaymentRequest.Confirm confirmRequest, @RequestParam Long userId) throws IOException, InterruptedException {
+        validateSession(session);
+        validatePaymentConfirmRequest(confirmRequest, session);
+
+        Response<Object> response = paymentService.sendPaymentRequest(confirmRequest);
+        //토스페이먼츠로 보낸 결제 승인 요청에 대한 response 리턴
+        Response<Object> objectResponse = paymentService.handleTossPaymentResponse(userId, confirmRequest, response);
+
+        if (objectResponse.isSuccess()) {
+            PaymentResponse paymentResponse = (PaymentResponse) objectResponse.getBody();
+            return ResponseEntity.ok(ApiResult.success("결제가 성공적으로 처리되었습니다.", paymentResponse));
+        }
+        return ResponseEntity.status(response.getStatusCode()).body(response.getBody());
+    }
+
+
+    private void validatePaymentConfirmRequest(PaymentRequest.Confirm confirmRequest, HttpSession session) {
+        String savedOrderId = (String) session.getAttribute("orderId");
+        BigDecimal savedAmount = (BigDecimal) session.getAttribute("amount");
+
+        if (!confirmRequest.getOrderId().equals(savedOrderId) || !confirmRequest.getAmount().equals(savedAmount)) {
+            throw new PaymentDataMismatchException("Payment data mismatch");
+        }
+    }
+
+    private void validateSession(HttpSession session) {
+        if (session == null) {
+            throw new InvalidSessionException("Invalid session");
+        }
+
+        String savedOrderId = (String) session.getAttribute("orderId");
+        BigDecimal savedAmount = (BigDecimal) session.getAttribute("amount");
+
+        if (savedOrderId == null || savedAmount == null) {
+            throw new InvalidSessionException("Invalid session");
+        }
+    }
+
+
+}

src/main/java/com/tasksprints/auction/api/wallet/WalletController.java

@@ -0,0 +1,4 @@
+package com.tasksprints.auction.api.wallet;
+
+public class WalletController {
+}

src/main/java/com/tasksprints/auction/common/config/HttpClientConfig.java

@@ -0,0 +1,14 @@
+package com.tasksprints.auction.common.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.net.http.HttpClient;
+
+@Configuration
+public class HttpClientConfig {
+    @Bean
+    public HttpClient httpClient() {
+        return HttpClient.newHttpClient();
+    }
+}

src/main/java/com/tasksprints/auction/common/config/PaymentConfig.java

@@ -0,0 +1,31 @@
+package com.tasksprints.auction.common.config;
+
+import lombok.Getter;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.Base64;
+
+@Configuration
+@Getter
+public class PaymentConfig {
+    @Value("${payment.toss.test_client_api_key}")
+    private String testClientApiKey;
+
+    @Value("${payment.toss.test_secret_api_key}")
+    private String testSecretApiKey;
+
+    @Value("${payment.toss.success_url}")
+    private String successUrl;
+
+    @Value("${payment.toss.fail_url}")
+    private String failUrl;
+
+    public static final String CONFIRM_URL = "https://api.tosspayments.com/v1/payments/confirm";
+
+    public String getAuthorizations() {
+        String encodedKey = Base64.getEncoder().encodeToString((testSecretApiKey + ":").getBytes());
+        return "Basic " + encodedKey;
+    }
+}

src/main/java/com/tasksprints/auction/common/constant/ApiResponseMessages.java

@@ -31,4 +31,8 @@ public class ApiResponseMessages {
     public static final String REVIEW_RETRIEVED = "Review successfully retrieved";
 
     // Additional messages can be defined as needed
+
+    // PAYMENT
+    public static final String PAYMENT_PREPARED_SUCCESS = "Payment prepared successfully";
+    public static final String PAYMENT_SUCCESS = "Payment completed and wallet charged successfully";
 }

src/main/java/com/tasksprints/auction/common/handler/GlobalExceptionHandler.java

@@ -8,6 +8,8 @@
 import com.tasksprints.auction.domain.auction.exception.InvalidAuctionTimeException;
 import com.tasksprints.auction.domain.bid.exception.BidNotFoundException;
 import com.tasksprints.auction.domain.bid.exception.InvalidBidAmountException;
+import com.tasksprints.auction.domain.payment.exception.InvalidSessionException;
+import com.tasksprints.auction.domain.payment.exception.PaymentDataMismatchException;
 import com.tasksprints.auction.domain.product.exception.ProductNotFoundException;
 import com.tasksprints.auction.domain.user.exception.UserNotFoundException;
 import org.springframework.http.HttpStatus;
@@ -61,6 +63,18 @@ public ResponseEntity<ApiResult<String>> handleAuctionEndedException(AuctionEnde
         return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(ApiResult.failure(message));
     }
 
+    @ExceptionHandler(InvalidSessionException.class)
+    public ResponseEntity<ApiResult<String>> handleInvalidSessionException(InvalidSessionException ex) {
+        String message = "Invalid Session Error. ";
+        return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(ApiResult.failure(message));
+    }
+
+    @ExceptionHandler(PaymentDataMismatchException.class)
+    public ResponseEntity<ApiResult<String>> PaymentDataMismatchException(PaymentDataMismatchException ex) {
+        String message = "Session Data Mismatch Error. ";
+        return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(ApiResult.failure(message));
+    }
+
     @ExceptionHandler(IllegalArgumentException.class)
     public ResponseEntity<ApiResult<String>> handleIllegalArgumentException(IllegalArgumentException ex) {
         return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(ApiResult.failure(ex.getMessage()));

src/main/java/com/tasksprints/auction/common/initializer/AuctionInitializer.java

@@ -37,7 +37,7 @@ public AuctionInitializer(UserRepository userRepository, AuctionRepository aucti
     }
 
     private void createDummyUser() {
-        User user1 = User.create("name", "[email protected]", "password", "NickName");
+        User user1 = User.createWithWallet("name", "[email protected]", "password", "NickName");
         userRepository.save(user1);
     }
 
@@ -58,7 +58,7 @@ private void createDummyProduct(User user, Auction auction) {
     @Override
     @Transactional
     public void run(ApplicationArguments args) throws Exception {
-        User user = userRepository.save(User.create("name", "[email protected]", "password", "NickName"));
+        User user = userRepository.save(User.createWithWallet("name", "[email protected]", "password", "NickName"));
 
         // 각 제품에 대해 새로운 경매를 생성
         for (int i = 0; i < 100; i++) {

src/main/java/com/tasksprints/auction/domain/auction/model/Auction.java

@@ -56,14 +56,7 @@ public class Auction extends BaseEntity {
     private List<Bid> bids = new ArrayList<>();
 
     @Column(nullable = false)
-    private Long viewCount;
-
-    @PrePersist
-        protected void onCreate() {
-            if (viewCount == null) {
-                viewCount = 0L;  // 기본값 설정
-            }
-        }
+    private long viewCount = 0L;
 
     public static Auction create(LocalDateTime startTime, LocalDateTime endTime, BigDecimal startingBid, AuctionCategory auctionCategory, AuctionStatus auctionStatus, User seller) {
         Auction newAuction = Auction.builder()
@@ -88,9 +81,6 @@ public void addUser(User seller) {
     }
 
     public void incrementViewCount() {
-        if (viewCount == null) {
-            viewCount = 0L;
-        }
         this.viewCount += 1;
     }
 

src/main/java/com/tasksprints/auction/domain/auction/repository/support/AuctionCriteriaRepositoryImpl.java

@@ -29,12 +29,10 @@ public Page<Auction> getAuctionsByFilters(Pageable pageable, AuctionRequest.Sear
         List<Auction> result = buildQueryWithPaginationAndSorting(builder, pageable, sortOrder);
 
         // int 오버플로 주의
-//        int total = queryFactory
-//            .selectFrom(auction)
-//            .where(builder)
-//            .fetch().size();
-
-        long total = result.size();
+        int total = queryFactory
+            .selectFrom(auction)
+            .where(builder)
+            .fetch().size();
 
         return new PageImpl<>(result, pageable, total);
     }

src/main/java/com/tasksprints/auction/domain/payment/api/Response.java

@@ -0,0 +1,28 @@
+package com.tasksprints.auction.domain.payment.api;
+
+import lombok.Getter;
+
+@Getter
+public class Response<T> {
+    private final int statusCode;
+    private final T body;
+
+    public Response(int statusCode, T body) {
+        this.statusCode = statusCode;
+        this.body = body;
+
+    }
+
+    public static <T> Response<T> success(int statusCode, T body) {
+        return new Response<>(statusCode, body);
+    }
+
+    public static <T> Response<T> failure(int statusCode, T body) {
+        return new Response<>(statusCode, body);
+    }
+
+    public boolean isSuccess() {
+        return statusCode == 200;
+    }
+
+}

src/main/java/com/tasksprints/auction/domain/payment/client/ClientWrapper.java

@@ -0,0 +1,29 @@
+package com.tasksprints.auction.domain.payment.client;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.tasksprints.auction.domain.payment.api.Response;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+
+import java.io.IOException;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+
+@Component
+@RequiredArgsConstructor
+public class ClientWrapper implements HttpClientWrapper{
+    private final HttpClient httpClient;
+    private final ObjectMapper objectMapper;
+
+    @Override
+    public Response<String> send(HttpRequest request) throws IOException, InterruptedException {
+        HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
+
+        if (response.statusCode() == 200) {
+            return Response.success(response.statusCode(), response.body());
+        }
+        return Response.failure(response.statusCode(), response.body());
+    }
+}

src/main/java/com/tasksprints/auction/domain/payment/client/HttpClientWrapper.java

@@ -0,0 +1,10 @@
+package com.tasksprints.auction.domain.payment.client;
+
+import com.tasksprints.auction.domain.payment.api.Response;
+
+import java.io.IOException;
+import java.net.http.HttpRequest;
+
+public interface HttpClientWrapper {
+    Response<String> send(HttpRequest request) throws IOException, InterruptedException;
+}

src/main/java/com/tasksprints/auction/domain/payment/client/PaymentClient.java

@@ -0,0 +1,14 @@
+package com.tasksprints.auction.domain.payment.client;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.tasksprints.auction.domain.payment.api.Response;
+import com.tasksprints.auction.domain.payment.dto.request.PaymentRequest;
+import com.tasksprints.auction.domain.payment.dto.response.PaymentResponse;
+
+import java.io.IOException;
+import java.net.http.HttpResponse;
+
+public interface PaymentClient {
+    Response<Object> sendPaymentRequest(PaymentRequest.Confirm confirmRequest) throws IOException, InterruptedException;
+    Response<Object> cancelPaymentApproval(PaymentRequest.Cancel cancelRequest) throws IOException, InterruptedException;
+}