[KakaoPay] 카카오페이 단건 결제 컨트롤러 예시

안내글

• 결제 흐름을 보기 위해 debug 모드의 로그 출력이 많습니다
• 구현 초기의 코드라 부족한 부분이 있을 수 있습니다. 양해해주세요!
• 흐름을 이해하기 위해 메서드 안에서 모든 처리를 직접 하도록 코드를 단순화함

 

 

카카오페이 결제 준비 요청 처리를 위한
REST 컨트롤러 메서드 구현

• @RestController 
• public class KakaoPayController
  
  • @PostMapping("/api/pay/kakaopay")
    public ResponseEntity<?> processKakaoPayRequest(@RequestBody OrderInfoDTO orderInfoDTO)

@Transactional
@PostMapping("/api/pay/kakaopay")
public ResponseEntity<?> processKakaoPayRequest(@RequestBody OrderInfoDTO orderInfoDTO) {
    try {
        // 사용자 정보
        String userEmail = SecurityUtils.getCurrentUserEmail();
        Long userId = SecurityUtils.getCurrentUserId();

        // 포인트 및 결제 금액 계산
        int total_amount = orderInfoDTO.getPoint_100_Quantity() * 110 + orderInfoDTO.getPoint_1000_Quantity() * 1000;
        int totalPointAmount = orderInfoDTO.getPoint_100_Quantity() * 100 + orderInfoDTO.getPoint_1000_Quantity() * 1000;

        // 결제 요청 객체 준비
        KakaoPaymentReadyRequestDTO requestDTO = KakaoPaymentReadyRequestDTO.builder()
            .cid(kakaoPayConfig.getCid())
            .partner_order_id(orderInfoDTO.getPaymentId())
            .partner_user_id(userEmail)
            .item_name("RiddleBox 포인트")
            .item_code("RB-Point")
            .quantity(1)
            .total_amount(total_amount)
            .tax_free_amount(500)
            .approval_url("http://localhost:8080/kakaopay/approval_url")
            .cancel_url("http://localhost:8080/kakaopay/approval_url")
            .fail_url("http://localhost:8080/kakaopay/approval_url")
            .build();

        // 결제 정보 생성
        PaymentInfo paymentInfo = new PaymentInfo();
        RBUser user = userRepository.findById(userId).orElseThrow(() -> new EntityNotFoundException("User not found"));
        paymentInfo.firstPaymentInformation(user, orderInfoDTO.getPaymentId(), userEmail, "RiddleBox 포인트", "RB-Point", total_amount, totalPointAmount);
        paymentInfo.updatePaymentStatus(PaymentStatus.INITIATED);
        paymentInfoRepository.save(paymentInfo);

        // 카카오페이 API 호출
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        headers.set("Authorization", "SECRET_KEY " + kakaoPayConfig.getSecretKeyDev());

        String jsonRequest;
        try {
            jsonRequest = objectMapper.writeValueAsString(requestDTO);
        } catch (JsonProcessingException e) {
            throw new RuntimeException("Error converting PaymentRequestDTO to JSON", e);
        }

        String kakaopayReadyRequestUrl = kakaoPayConfig.getReadyRequestUriCompletion();
        HttpEntity<String> entity = new HttpEntity<>(jsonRequest, headers);

        ResponseEntity<String> response = restTemplate.postForEntity(kakaopayReadyRequestUrl, entity, String.class);

        if (!response.getStatusCode().is2xxSuccessful()) {
            throw new RuntimeException("카카오페이 호출 실패");
        }

        // 응답 처리
        KakaoPaymentReadyResponseDTO responseDTO = objectMapper.readValue(response.getBody(), KakaoPaymentReadyResponseDTO.class);
        paymentInfo.secondPaymentInformation(responseDTO.getTid(), responseDTO.getCreated_at());
        paymentInfo.updatePaymentStatus(PaymentStatus.AWAITING_PAYMENT);
        paymentInfoRepository.save(paymentInfo);

        // 사용자에게 카카오 결제 QR 링크 전달
        return ResponseEntity.ok(Collections.singletonMap("nextRedirectPcUrl", responseDTO.getNext_redirect_pc_url()));
    } catch (EntityNotFoundException e) {
        return new ResponseEntity<>("사용자를 찾을 수 없습니다.", HttpStatus.NOT_FOUND);
    } catch (JsonProcessingException e) {
        return new ResponseEntity<>("서버 오류로 인해 처리할 수 없습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
    } catch (RuntimeException e) {
        return new ResponseEntity<>("내부 서버 오류가 발생했습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
    }
}

 

 

 

 

 

카카오페이 결제 승인 요청 처리를 위한
컨트롤러 메서드 구현

• @Controller
• public class PointController
  • //카카오페이의 응답(성공, 취소, 실패)을 다루
  • public String handleKakaoPayResponse(@RequestParam(value = "pg_token", required = false) String pgToken, HttpServletRequest request, Model model) 

@Transactional
@GetMapping("/kakaopay/approval_url")
public String handleKakaoPayResponse(@RequestParam(value = "pg_token", required = false) String pgToken,
HttpServletRequest request, Model model) throws JsonProcessingException {

    // 현재 로그인한 사용자 ID를 통해 대기 중인 결제 정보 조회
    Long currentUserId = SecurityUtils.getCurrentUserId();
    PaymentInfo paymentInfo = kakaoPayService.findAwaitingPaymentPaymentInfo(currentUserId);
    
    // pg_token 유무 확인
    if (pgToken == null || pgToken.isEmpty()) {
        paymentInfo.updatePaymentStatus(PaymentStatus.FAILED);
        paymentInfoRepository.save(paymentInfo);
        // pg_token이 없는 경우, 결제 실패로 간주하고 사용자에게 안내
        model.addAttribute("pageType", "paymentCompleted");
        model.addAttribute("title", "paymentCompleted");
        model.addAttribute("paymentResult", "Fail");
        return "layout/layout_base"; // 결제 실패 페이지로 리다이렉트
    }
    
    // pg_token이 있는 경우, 결제 승인 처리 진행
    String tid = paymentInfo.getTid();
    String partner_order_id = paymentInfo.getPartnerOrderId();
    String partner_user_id = paymentInfo.getPartnerUserId();
    String cid = kakaoPayConfig.getCid(); 
    
    paymentInfo.updatePaymentStatus(PaymentStatus.AUTHORIZED);
    paymentInfoRepository.save(paymentInfo);
    
    String pg_token = request.getParameter("pg_token");
    logger.debug("\n");
    logger.debug(" ===================  4  =================== ");
    logger.debug("pg_token: {}", pg_token);
    logger.debug("\n");
    
    // 카카오페이 결제 승인 요청
    KakaoPaymentApproveRequestDTO approvalDTO = new KakaoPaymentApproveRequestDTO(cid, tid, partner_order_id, partner_user_id, pg_token);
    RestTemplate restTemplate2 = new RestTemplate();
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.APPLICATION_JSON);
    headers.set("Authorization", "SECRET_KEY " + kakaoPayConfig.getSecretKeyDev());
    
    HttpEntity<KakaoPaymentApproveRequestDTO> entity = new HttpEntity<>(approvalDTO, headers);
    
    logger.debug("\n");
    logger.debug(" ===================  5  =================== ");
    logger.debug("HttpEntity<String> entity: {}", entity);
    logger.debug("\n");
    
    ResponseEntity<String> response = restTemplate2.postForEntity(kakaoPayConfig.getApproveRequestUriCompletion(), entity, String.class);
    
    logger.debug("\n");
    logger.debug(" ===================  6  =================== ");
    logger.debug("Response Status Code: {}", response.getStatusCode());
    logger.debug("Response Body: {}", response.getBody());
    logger.debug("\n");
    
    String responseBody = response.getBody();
    
    if (response.getStatusCode().is2xxSuccessful() && response.getBody() != null) {
        // 결제 승인 성공, 결제 정보 업데이트
        KakaoPaymentApproveResponseDTO completionDTO = objectMapper.readValue(responseBody, KakaoPaymentApproveResponseDTO.class);
        paymentInfo.thirdPaymentInformation(completionDTO.getAid(), completionDTO.getAmount(), completionDTO.getCardInfo(), completionDTO.getApprovedAt());
        paymentInfo.updatePaymentStatus(PaymentStatus.APPROVED);
        paymentInfoRepository.save(paymentInfo);
        
        //포인트 저장
        kakaoPayService.updateAccountBalanceAfterPurchase(currentUserId, paymentInfo.getTotalPointAmount());
        
        model.addAttribute("pageType", "paymentCompleted");
        model.addAttribute("title", "paymentCompleted");
        model.addAttribute("newPoint", paymentInfo.getTotalPointAmount());
        model.addAttribute("paymentResult", "Success");
        return "layout/layout_base";  // 결제 성공 페이지로 리다이렉트
    } else {
        // 결제 승인 실패 처리
        paymentInfo.updatePaymentStatus(PaymentStatus.FAILED);
        paymentInfoRepository.save(paymentInfo);
        
        model.addAttribute("pageType", "paymentCompleted");
        model.addAttribute("title", "paymentCompleted");
        model.addAttribute("paymentResult", "Fail");
        return "layout/layout_base"; // 결제 실패 페이지로 리다이렉트
    }
}