결제 관련 고민한 것들 — 멱등성, 상품 지급 방식, 잔액 부족

POST /api/kakao-pay/approve
Content-Type: application/json
Authorization: Bearer <ACCESS_TOKEN>
Idempotency-Key: 550e8400-e29b-41d4-a716-446655440000

{
  "orderId": "ORDER_20241207_0001",
  "pgToken": "token_a1b2c3d4"
}
// 여기서 동일 Idempotency-Key지만, 요청 본문이 다를 경우 422로 차단

@Id
@Column(name = "idempotency_key", nullable = false, unique = true)
private String key;

@Transactional(propagation = Propagation.REQUIRES_NEW)
public <T> IdempotencyValidationResult validate(String key, String payload, Class<T> responseType) {
    var recordOpt = repository.findByKey(key);
		
		// 1. 기존 멱등 레코드 조회
    if (recordOpt.isPresent()) {       
        var record = recordOpt.get();

				// 2. payload가 다르면 멱등키 재사용 오류 반환
        if (!record.getPayload().equals(payload)) {  
            throw new BusinessException(Code.IDEMPOTENCY_PAYLOAD_MISMATCH);
        }
				// 3. 이미 완료된 요청이면 저장된 응답 재사용
        if (record.getStatus() == IdempotencyStatus.DONE) {
            T cached = objectMapper.readValue(record.getResponse(), responseType);
            return IdempotencyValidationResult.cached(cached);
        }
				// 4. 아직 처리 중이면 중복 요청으로 간주해 충돌 반환 (다른 서버/스레드가 처리 중)
        throw new BusinessException(Code.IDEMPOTENCY_CONFLICT);
    }

    try {
		    // 5. 레코드가 없으면 PROCESSING 상태로 신규 저장하여 선점 
        repository.save(new IdempotencyRecord(key, payload, IdempotencyStatus.PROCESSING));
        return IdempotencyValidationResult.processing();
    } catch (DataIntegrityViolationException e) {
        throw new BusinessException(Code.IDEMPOTENCY_CONFLICT);
    }
}

idempotency:{key}:payload

Key: processing:100:550e8400-e29b-41d4-a716-446655440000
Value: "processing"

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveResponse(String key, Object response) {
    var record = repository.findByKey(key)
            .orElseThrow(() -> new BusinessException(Code.IDEMPOTENCY_CONFLICT));

    try {
        record.complete(objectMapper.writeValueAsString(response));
    } catch (JsonProcessingException e) {
        throw new BusinessException(Code.INTERNAL_SERVER_ERROR);
    }
}