💳 결제 서비스

build.gradle

@@ -9,9 +9,6 @@ version = '0.0.1-SNAPSHOT'
 sourceCompatibility = '11'
 
 configurations {
-    all {
-        exclude group: 'org.springframework.boot', module: 'spring-boot-starter-logging'
-    }
     compileOnly {
         extendsFrom annotationProcessor
     }
@@ -57,6 +54,7 @@ dependencies {
     implementation 'org.webjars.bower:vue:2.5.16'
     implementation 'org.webjars.bower:axios:0.17.1'
     implementation 'org.webjars:sockjs-client:1.1.2'
+    implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
 
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-mail'
@@ -68,7 +66,6 @@ dependencies {
     runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.2', 'io.jsonwebtoken:jjwt-jackson:0.11.2'
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
-    implementation 'org.springframework.boot:spring-boot-starter-log4j2:2.6.0'
     runtimeOnly 'mysql:mysql-connector-java:8.0.22'
     annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
     annotationProcessor 'org.projectlombok:lombok'

src/main/java/com/dhmall/auction/dto/AuctionWinnerDto.java

@@ -0,0 +1,16 @@
+package com.dhmall.auction.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class AuctionWinnerDto {
+
+    private String userId;
+
+    private String productCode;
+
+    private String amount;
+
+}

src/main/java/com/dhmall/auction/dto/ProductDto.java

@@ -0,0 +1,30 @@
+package com.dhmall.auction.dto;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.math.BigInteger;
+
+@Getter
+@RequiredArgsConstructor
+public class ProductDto {
+
+    private final BigInteger id;
+
+    private final String code;
+
+    private final String name;
+
+    private final String category;
+
+    private final String owner;
+
+    private final int auctionStatus;
+
+    private final String description;
+
+    private final String createdAt;
+
+    private final String updatedAt;
+
+}

src/main/java/com/dhmall/auction/mapper/AuctionMapper.java

@@ -1,11 +1,19 @@
 package com.dhmall.auction.mapper;
 
 import com.dhmall.auction.dto.ChatMessageDto;
+import com.dhmall.auction.dto.ProductDto;
+import com.dhmall.user.dto.UserDto;
 import org.apache.ibatis.annotations.Mapper;
 import org.springframework.stereotype.Repository;
 
+import java.math.BigInteger;
+
 @Mapper
 @Repository
 public interface AuctionMapper {
     void insertChatMessage(ChatMessageDto chatMessage);
+
+    UserDto findUserById(BigInteger id);
+
+    ProductDto findProductByCode(String productCode);
 }

src/main/java/com/dhmall/auction/service/AuctionService.java

@@ -2,8 +2,10 @@
 
 import com.dhmall.auction.dto.ChatMessageDto;
 import com.dhmall.auction.dto.ChatRoomDto;
+import com.dhmall.auction.dto.ProductDto;
 import com.dhmall.auction.mapper.AuctionMapper;
 import com.dhmall.auction.pubsub.RedisSubscriber;
+import com.dhmall.user.dto.UserDto;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.HashOperations;
@@ -14,6 +16,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.PostConstruct;
+import java.math.BigInteger;
 import java.time.ZoneId;
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
@@ -65,4 +68,12 @@ public void enterChatRoom(String roomId) {
     public ChannelTopic getTopic(String roomId) {
         return topics.get(roomId);
     }
+
+    public UserDto getAuctionWinner(BigInteger id) {
+        return auctionMapper.findUserById(id);
+    }
+
+    public ProductDto getAuctionProduct(String productCode) {
+        return auctionMapper.findProductByCode(productCode);
+    }
 }

src/main/java/com/dhmall/config/SecurityConfig.java

@@ -66,6 +66,7 @@ protected void configure(HttpSecurity http) throws Exception {
                 .antMatchers("/auctions/**").permitAll()
                 .antMatchers("/chat/**").permitAll()
                 .antMatchers("/ws-stomp/**").permitAll()
+                .antMatchers("/payments/**").permitAll()
                 .anyRequest().authenticated()
 
                 .and()

src/main/java/com/dhmall/config/SpringWebEngineConfig.java

@@ -1,7 +1,9 @@
 package com.dhmall.config;
 
+import org.springframework.boot.web.client.RestTemplateBuilder;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
 import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 import org.springframework.web.servlet.view.freemarker.FreeMarkerConfigurer;
 
@@ -14,4 +16,9 @@ public FreeMarkerConfigurer freemarkerConfig() {
         freeMarkerConfigurer.setTemplateLoaderPath("classpath:templates/");
         return freeMarkerConfigurer;
     }
+
+    @Bean
+    public RestTemplate restTemplate(RestTemplateBuilder restTemplateBuilder) {
+        return restTemplateBuilder.build();
+    }
 }

src/main/java/com/dhmall/payment/controller/PaymentController.java

@@ -0,0 +1,54 @@
+package com.dhmall.payment.controller;
+
+import com.dhmall.auction.dto.AuctionDto;
+import com.dhmall.payment.dto.PaymentDto;
+import com.dhmall.payment.dto.TossPayDto;
+import com.dhmall.payment.service.PaymentService;
+import com.dhmall.util.SagoApiResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.math.BigDecimal;
+import java.net.URI;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/payments/")
+public class PaymentController {
+
+    private final PaymentService paymentService;
+    @Value("${redirect.url}")
+    private final String serverUrl;
+
+    @GetMapping("request")
+    public SagoApiResponse<AuctionDto> requestPayment(@RequestParam String chatRoomId) {
+        // TODO: Auction 채팅방에서 Redis에다가 userId, productCode, amount 저장하기
+        AuctionDto auctionResult = paymentService.confirmAuction(chatRoomId);
+        return new SagoApiResponse<>(HttpStatus.ACCEPTED, auctionResult);
+    }
+
+    @PostMapping("/redirect")
+    @ResponseBody
+    public String paySuccess(TossPayDto payResult) {
+        // TODO: API 결과값 redirect 처리
+        return "Success!";
+    }
+
+    @GetMapping("success")
+    public ResponseEntity<TossPayDto> confirmPayment(@RequestParam String paymentKey, @RequestParam String orderId, @RequestParam BigDecimal amount) throws Exception {
+        TossPayDto payResult = paymentService.approvePayment(paymentKey, amount, orderId);
+        URI redirectUri = new URI( serverUrl + "payments/redirect");
+        HttpHeaders httpHeaders = new HttpHeaders();
+        httpHeaders.setLocation(redirectUri);
+        return new ResponseEntity<>(payResult, httpHeaders, HttpStatus.OK);
+    }
+
+    @GetMapping("fail")
+    public SagoApiResponse<String> failRequestPayment() {
+        return new SagoApiResponse<>(HttpStatus.BAD_REQUEST, "결제요청이 실패하였습니다. 다시 시도해주세요.");
+    }
+}

src/main/java/com/dhmall/payment/dto/PaymentDto.java

@@ -0,0 +1,34 @@
+package com.dhmall.payment.dto;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.time.ZonedDateTime;
+
+@Getter
+@RequiredArgsConstructor
+public class PaymentDto {
+    private final BigInteger id;
+
+    private final BigInteger userId;
+
+    private final String nickname;
+
+    private final String productCode;
+
+    private final String productName;
+
+    private final BigDecimal amount;
+
+    private final BigDecimal taxFreeAmount;
+
+    private final BigDecimal vatAmount;
+
+    private final String paymentCode;
+
+    private final ZonedDateTime createdAt;
+
+    private final ZonedDateTime updatedAt;
+}

src/main/java/com/dhmall/payment/dto/TossPayDto.java

@@ -0,0 +1,23 @@
+package com.dhmall.payment.dto;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+
+@Getter
+@Setter
+@Builder
+public class TossPayDto {
+
+    private String paymentKey;
+
+    private BigDecimal amount;
+
+    private BigDecimal taxFreeAmount;
+
+    private BigDecimal vatAmount;
+
+    private String message;
+}

src/main/java/com/dhmall/payment/mapper/PaymentMapper.java

@@ -0,0 +1,11 @@
+package com.dhmall.payment.mapper;
+
+import com.dhmall.payment.dto.PaymentDto;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+@Mapper
+@Repository
+public interface PaymentMapper {
+    void insertPayment(PaymentDto paymentDto);
+}

src/main/java/com/dhmall/payment/service/PaymentService.java

@@ -0,0 +1,99 @@
+package com.dhmall.payment.service;
+
+import com.dhmall.auction.dto.AuctionDto;
+import com.dhmall.auction.dto.AuctionWinnerDto;
+import com.dhmall.auction.dto.ProductDto;
+import com.dhmall.auction.service.AuctionService;
+import com.dhmall.payment.dto.TossPayDto;
+import com.dhmall.payment.mapper.PaymentMapper;
+import com.dhmall.user.dto.UserDto;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.*;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+@RequiredArgsConstructor
+public class PaymentService {
+
+    private final PaymentMapper paymentMapper;
+    private final AuctionService auctionService;
+    private final RedisTemplate redisTemplate;
+    private final RestTemplate restTemplate;
+    private final ObjectMapper objectMapper;
+
+    @Value("${toss.secret}")
+    private final String TOSS_SECRET_KEY;
+
+    public TossPayDto approvePayment(String paymentKey, BigDecimal amount, String orderId) throws Exception {
+        HttpHeaders headers = new HttpHeaders();
+         headers.setBasicAuth(TOSS_SECRET_KEY, ""); // spring framework 5.2 이상 버전에서 지원
+        headers.setContentType(MediaType.APPLICATION_JSON);
+
+        Map<String, String> payloadMap = new HashMap<>();
+        payloadMap.put("orderId", orderId);
+        payloadMap.put("amount", String.valueOf(amount));
+
+        HttpEntity<String> request = new HttpEntity<>(objectMapper.writeValueAsString(payloadMap), headers);
+
+        ResponseEntity<JsonNode> responseEntity = restTemplate.postForEntity(
+                "https://api.tosspayments.com/v1/payments/" + paymentKey, request, JsonNode.class);
+
+        if(responseEntity.getStatusCode() == HttpStatus.OK) {
+
+            JsonNode body = responseEntity.getBody();
+
+            TossPayDto payResult = TossPayDto.builder()
+                    .paymentKey(body.get("paymentKey").asText())
+                    .amount(new BigDecimal(body.get("totalAmount").asText()))
+                    // TEST api key로는 해당 index json response 값이 존재하지 않음(null).
+//                    .taxFreeAmount(new BigDecimal(body.get("suppliedAmount").asText()))
+//                    .vatAmount(new BigDecimal(body.get("vat").asText()))
+                    .message("결제가 성공적으로 이루어졌습니다.")
+                    .build();
+
+            return payResult;
+        }
+
+        TossPayDto payResult = TossPayDto.builder()
+                .paymentKey("")
+                .amount(new BigDecimal(0))
+                .taxFreeAmount(new BigDecimal(0))
+                .vatAmount(new BigDecimal(0))
+                .message("결제 실패하였습니다. 다시 시도해주세요.")
+                .build();
+
+        return payResult;
+    }
+
+    public AuctionDto confirmAuction(String chatRoomId) {
+        // TODO: Auction 채팅방에서 Redis에다가 userId, productCode, amount 저장하기
+        AuctionWinnerDto winner = (AuctionWinnerDto) redisTemplate.opsForValue().get(chatRoomId);
+
+        UserDto user = auctionService.getAuctionWinner(new BigInteger(winner.getUserId()));
+        ProductDto product = auctionService.getAuctionProduct(winner.getProductCode());
+
+        AuctionDto auctionInfo = new AuctionDto();
+        auctionInfo.setUserId(user.getId());
+        auctionInfo.setNickname(user.getNickname());
+        auctionInfo.setProductCode(product.getCode());
+        auctionInfo.setProductName(product.getName());
+        auctionInfo.setAmount(new BigDecimal(winner.getAmount()));
+        auctionInfo.setDescription(product.getDescription());
+        auctionInfo.setCreatedAt(ZonedDateTime.now(ZoneId.of("UTC")));
+        auctionInfo.setUpdatedAt(ZonedDateTime.now(ZoneId.of("UTC")));
+
+        return auctionInfo;
+    }
+}