[TIL] 프로젝트 18일차.. 슬랙 알림 마무리하기!!

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

우선 재고 감소 실패 관련 Slack 알림을 마무리했다!

// 재고 감소 실패 알림 메시지 생성
public String formatInventoryDecreaseFailureMessage(Long orderId, String memberName, String productId, String productName, String reason, LocalDateTime time) {
    Map<String, Object> payload = getPayload();
    List<Object> blocks = new ArrayList<>();

    blocks.add(Map.of(
        "type", "header",
        "text", Map.of("type", "plain_text", "text", "❌ 재고 감소 실패 알림")
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*주문 ID:*", orderId.toString()),
            markdownField("*회원명:*", memberName)
        )
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*상품 ID:*", productId),
            markdownField("*상품명:*", productName)
        )
    ));

    blocks.add(Map.of(
        "type", "section",
        "text", markdownField("*\uD83D\uDD0D 사유:*", reason)
    ));

    blocks.add(Map.of(
        "type", "context",
        "elements", List.of(
            Map.of("type", "mrkdwn", "text", "\uD83D\uDD52 *시간:* " + time.format(formatter))
        )
    ));

    payload.put("blocks", blocks);

    return JsonHelper.toJson(payload);
}

public void sendInventoryDecreaseFailureAlert(Long orderId, String memberName, String productId, String productName, String reason) {
    String message = slackFormatter.formatInventoryDecreaseFailureMessage(orderId, memberName, productId, productName, reason, LocalDateTime.now());

    sendPayload(message);
}

@Transactional
public void decreaseProductOptionCombinationInventory(Long orderId) {
    List<OrderItem> orderItemList = orderItemRepository.findAllByOrderId(orderId);

    for (OrderItem orderItem : orderItemList) {
        Long productOptionCombinationId = orderItem.getProductOptionCombination().getId();
        Integer quantity = orderItem.getQuantity();

        ProductOptionCombination productOptionCombination = productOptionCombinationRepository
            .findByIdWithPessimisticLock(productOptionCombinationId)
            .orElseThrow(() -> new NotFoundException(ErrorCode.PRODUCT_OPTION_COMBINATION_NOT_FOUND));

        if (productOptionCombination.getInventory() < quantity) {
            slackNotifier.sendInventoryDecreaseFailureAlert(
                orderId,
                orderItem.getOrder().getMember().getName(),
                productOptionCombination.getProduct().getId().toString(),
                productOptionCombination.getProduct().getName(),
                ErrorCode.PRODUCT_OPTION_COMBINATION_OUT_OF_INVENTORY.getMessage());

            throw new ConflictException(ErrorCode.PRODUCT_OPTION_COMBINATION_OUT_OF_INVENTORY);
        }

        productOptionCombination.decreaseInventory(quantity);
    }
}

재고 감소 실패 Slack 알림 메시지

정상적으로 알림 메시지가 도착하는 것을 확인할 수 있다!

그다음으로는 배송 생성 성공했을 때 Slack 알림 메시지가 도착할 수 있도록 구현했다.

// 배송 생성 성공 알림 메시지 생성
public String formatDeliveryCreateMessage(Long orderId, String memberName, String phoneNumber, String receiver, String receiverPhone, String address, String detailAddress, LocalDateTime time) {
    Map<String, Object> payload = getPayload();
    List<Object> blocks = new ArrayList<>();

    blocks.add(Map.of(
        "type", "header",
        "text", Map.of("type", "plain_text", "text", "✅ 배송 생성 성공 알림")
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*주문 ID:*", orderId.toString())
        )
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*회원명:*", memberName),
            markdownField("*연락처:*", phoneNumber)
        )
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*수령인:*", receiver),
            markdownField("*수령인 연락처:*", receiverPhone),
            markdownField("*주소:*", address),
            markdownField("*상세주소:*", detailAddress)
        )
    ));

    blocks.add(Map.of(
        "type", "section",
        "fields", List.of(
            markdownField("*상태:*", "배송 생성 완료 ✅")
        )
    ));

    blocks.add(Map.of(
        "type", "context",
        "elements", List.of(
            Map.of("type", "mrkdwn", "text", "\uD83D\uDCE6 배송 정보가 정상적으로 등록되었습니다.\n"),
            Map.of("type", "mrkdwn", "text", "\uD83D\uDD52 *시간:* " + time.format(formatter))
        )
    ));

    payload.put("blocks", blocks);

    return JsonHelper.toJson(payload);
}

public void sendDeliveryCreateAlert(Long orderId, String memberName, String phoneNumber, String receiver, String receiverPhone, String address, String detailAddress) {
    String message = slackFormatter.formatDeliveryCreateMessage(orderId, memberName, phoneNumber, receiver, receiverPhone, address, detailAddress, LocalDateTime.now());

    sendPayload(message);
}

@Transactional
public CreateDeliveryResponse createDelivery(CreateDeliveryRequest request) {
    if (!orderRepository.existsById(request.orderId())) {
        throw new NotFoundException(ErrorCode.ORDER_NOT_FOUND);
    }
    if (!sellerRepository.existsById(request.sellerId())) {
        throw new NotFoundException(ErrorCode.SELLER_NOT_FOUND);
    }
    if (!senderRepository.existsById(request.senderId())) {
        throw new NotFoundException(ErrorCode.SENDER_NOT_FOUND);
    }
    if (!addressRepository.existsById(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);
}

이렇게 하면 Slack 알림 메시지가 어떻게 오느냐?!

배송 생성 성공 Slack 알림 메시지

마지막으로 배송 생성 실패했을 때 관련해서 Slack 알림을 고민했다.
정보 필요 없이 예외 관련 내용만 메시지로 보여주면 된다고 생각했고, 그렇게 구현했지만 정작 실행해서 테스트해 보니 Kafka의 재시도로 인해서 메시지가 재시도 횟수만큼 전송되는 것이었다......

그래서 재시도하지 않고 Slack 알림 메시지 한 번만 전송할 수 있도록 수정했고 결과적으로 메시지가 한 번만 전송되는 것을 확인할 수 있었다.

 

🗓️ 내일은 뭐 하지?!

✔️ 프로젝트 고도화
✔️ 로직 내 문제점 수정
✔️ TIL 작성하기