[TIL] 프로젝트 24일차.. 전체적인 로직 마무리하기!!

🌞 오늘은 어떤 하루였지..

우선 팀원의 피드백부터 코드에 반영했다.
Kafka로 재고 복원 요청 메시지를 보내는 부분이 중복되어서 메서드로 추출하는 것이 나아 보인다는 의견에 수긍하고 메서드를 추출했다.

private void sendInventoryRestoreMessage(CreateDeliveryRequest request) {
    String payload = JsonHelper.toJson(request);
    OperationWrapperDto wrapper = OperationWrapperDto.from(OperationType.DELIVERY_FAIL_INVENTORY_RESTORE, payload);
    String wrappedMessage = JsonHelper.toJson(wrapper);

    kafkaTemplate.send(productTopic, request.orderId().toString(), wrappedMessage);

    log.info("\uD83D\uDCE4 Kafka 재고 복원 메시지 전송: {}", wrappedMessage);
}

@Transactional
public CreateDeliveryResponse createDelivery(CreateDeliveryRequest request) {
    if (!orderRepository.existsById(request.orderId())) {
        sendInventoryRestoreMessage(request);

        slackNotifier.sendDeliveryCreateFailureAlert(
            request.orderId(),
            "ORDER_NOT_FOUND",
            "ID가 " + request.orderId() + "인 주문이 존재하지 않아 배송 생성에 실패했습니다.");

        throw new NotFoundException(ErrorCode.ORDER_NOT_FOUND);
    }

    // 해당 주문에 대한 배송이 존재할 경우 예외 처리
    if (deliveryRepository.existsByOrderId(request.orderId())) {
        sendInventoryRestoreMessage(request);

        slackNotifier.sendDeliveryCreateFailureAlert(
            request.orderId(),
            "DELIVERY_ALREADY_EXISTS",
            "ID가 " + request.orderId() + "인 주문에 대한 배송이 이미 존재하여 배송 생성에 실패했습니다.");

        throw new ConflictException(ErrorCode.DELIVERY_ALREADY_EXISTS);
    }

    if (!sellerRepository.existsById(request.sellerId())) {
        sendInventoryRestoreMessage(request);

        slackNotifier.sendDeliveryCreateFailureAlert(
            request.orderId(),
            "SELLER_NOT_FOUND",
            "ID가 " + request.sellerId() + "인 판매자가 존재하지 않아 배송 생성에 실패했습니다.");

        throw new NotFoundException(ErrorCode.SELLER_NOT_FOUND);
    }

    if (!senderRepository.existsById(request.senderId())) {
        sendInventoryRestoreMessage(request);

        slackNotifier.sendDeliveryCreateFailureAlert(
            request.orderId(),
            "SENDER_NOT_FOUND",
            "ID가 " + request.senderId() + "인 출고지(물류센터)가 존재하지 않아 배송 생성에 실패했습니다.");

        throw new NotFoundException(ErrorCode.SENDER_NOT_FOUND);
    }

    if (!addressRepository.existsById(request.addressId())) {
        sendInventoryRestoreMessage(request);

        slackNotifier.sendDeliveryCreateFailureAlert(
            request.orderId(),
            "ADDRESS_NOT_FOUND",
            "ID가 " + request.addressId() + "인 주소가 존재하지 않아 배송 생성에 실패했습니다.");

        throw new NotFoundException(ErrorCode.ADDRESS_NOT_FOUND);
    }

    Order order = orderRepository.getReferenceById(request.orderId());
    Seller seller = sellerRepository.getReferenceById(request.sellerId());
    Sender sender = senderRepository.getReferenceById(request.senderId());

    Address address = addressRepository.findById(request.addressId())
        .orElseThrow(() -> new NotFoundException(ErrorCode.ADDRESS_NOT_FOUND));

    Delivery delivery = Delivery.of(order, seller, sender, address, request.deliveryRequest());

    deliveryRepository.save(delivery);

    // 슬랙 알림 메시지 전송
    slackNotifier.sendDeliveryCreateAlert(
        request.orderId(),
        delivery.getOrder().getMember().getName(),
        delivery.getOrder().getMember().getPhoneNumber(),
        delivery.getReceiverName(),
        delivery.getReceiverPhone(),
        delivery.getReceiverAddress(),
        delivery.getReceiverDetailAddress());

    return CreateDeliveryResponse.from(delivery);
}

그다음 카카오톡 알림 메시지 전송에서 배송 중과 배송 완료의 상황에 맞게 카카오톡 알림 메시지가 전송될 수 있도록 구현했다.

@Transactional
public UpdateDeliveryResponse updateTrackingNumber(Long deliveryId, UpdateDeliveryRequest request) {
    Delivery delivery = getDelivery(deliveryId);

    delivery.updateTrackingNumber(request.trackingNumber());

    // 카카오톡 출고 완료 알림 메시지 전송
    UserNotification userNotification = UserNotification.from(delivery);
    kakaoMessageService.sendShippedMessage(userNotification);

    return UpdateDeliveryResponse.from(delivery);
}

배송 상태가 변경될 때 카카오톡 알림 메시지가 전송될 수 있도록 했다!

그 후에 결제에서 넘어오는 데이터를 활용해서 재고 감소를 진행하고 배송 생성까지 이어질 수 있도록 로직을 완성했다.

CreateDeliveryRequest request = (CreateDeliveryRequest) session.getAttribute("delivery");
String payload = JsonHelper.toJson(request);
String key = "";
String value = JsonHelper.toJson(OperationWrapperDto.from(OperationType.ORDER_PAYMENT_INVENTORY_DECREASE, payload));

stringKafkaTemplate.send("order_make_topic", key, value);

return ResponseEntity.status(code).body(jsonObject);

// 재고 관련 Kafka Listener
@KafkaListener(topics = "${kafka.topic.product}", groupId = "${spring.kafka.consumer.product-combination.group-id}")
public void listenInventory(@Header(KafkaHeaders.RECEIVED_KEY) String key, String value) {
    try {
        OperationWrapperDto wrapperDto = JsonHelper.fromJson(value, OperationWrapperDto.class);
        OperationType type = wrapperDto.operationType();
        String payload = wrapperDto.payload();

        switch (type) {
            case ORDER_PAYMENT_INVENTORY_DECREASE -> routeInventoryDecreaseMessage(key, payload);
            case DELIVERY_FAIL_INVENTORY_RESTORE -> routeInventoryRestoreMessage(key, payload);
            default -> log.error("❌ 지원하지 않는 메시지 타입 수신: {}", type);
        }
    } catch (ConflictException e) {
        log.warn("⚠️ 재고 부족으로 재고 감소 메시지 처리 실패: {}", e.getMessage());
    } catch (NotFoundException e) {
        log.warn("⚠️ 필수 데이터 누락으로 재고 감소 메시지 처리 실패 ({}): {}", e.getErrorCode(), e.getMessage());
    } catch (NumberFormatException e) {
        log.warn("⚠️ 잘못된 orderId 형식입니다. key: {}, message: {}", key, e.getMessage());
    } catch (Exception e) {
        log.error("❌ 예기치 못한 오류로 재고 감소 메시지 처리 실패: {}", e.getMessage());
    }
}

private void routeInventoryDecreaseMessage(String key, String value) {
    // 결제 파트에서 전달되는 value 확인 후 DTO 정의
    log.info("📥 Kafka 재고 감소 메시지 수신: key: {}, value: {}", key, value);

    CreateDeliveryRequest request = JsonHelper.fromJson(value, CreateDeliveryRequest.class);

    // 재고 감소 로직 진행
     productOptionCombinationService.decreaseProductOptionCombinationInventory(Long.valueOf(key));
     log.info("👉 재고 감소 성공! 모든 상품의 재고 차감이 정상적으로 처리되었습니다.");

    // 배송 생성 요청 메시지 발행
    String payload = JsonHelper.toJson(request);
    String message = JsonHelper.toJson(OperationWrapperDto.from(OperationType.DELIVERY_CREATE, payload));

    kafkaTemplate.send(deliveryTopic, key, message);

    log.info("\uD83D\uDCE4 Kafka 배송 생성 메시지 전송: {}", request);
}

private void routeInventoryRestoreMessage(String key, String value) {
    log.info("📥 Kafka 재고 복원 메시지 수신: key={}, value={}", key, value);

    // 재고 복원 로직 진행
    Long orderId = Long.valueOf(key);
    productOptionCombinationService.restoreProductOptionCombinationInventory(orderId);
}

이렇게 결제 완료 후 넘어오는 데이터로 재고 감소 진행 후 배송 생성까지 마무리될 수 있도록 구현했다!

마지막으로 가격 변동을 어떻게 처리할 수 있을지 고민을 하다가 하루가 끝나버렸다..

 

🗓️ 내일은 뭐 하지?!

✔️ 가격 변동 로직 마무리하기
✔️ API 명세서 수정하기
✔️ TIL 작성하기