Merge pull request #204 from GoTogether-Inc/feature/#199

SimoKii · web-flow · commit 8c89465d933f · 2025-07-24T23:01:42.000+09:00
[feature] 성능 모니터링을 위한 커스텀 메트릭 구현
diff --git a/src/main/java/com/gotogether/domain/bookmark/service/BookmarkServiceImpl.java b/src/main/java/com/gotogether/domain/bookmark/service/BookmarkServiceImpl.java
@@ -16,6 +16,7 @@
 import com.gotogether.domain.user.entity.User;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -25,6 +26,7 @@ public class BookmarkServiceImpl implements BookmarkService {
 
 	private final BookmarkRepository bookmarkRepository;
 	private final EventFacade eventFacade;
+	private final MetricService metricService;
 
 	@Override
 	@Transactional
@@ -39,6 +41,8 @@ public Bookmark createBookmark(Long eventId, Long userId) {
 		Bookmark bookmark = BookmarkConverter.of(user, event);
 		bookmarkRepository.save(bookmark);
 
+		metricService.recordBookmarkCreation(eventId);
+
 		return bookmark;
 	}
 
diff --git a/src/main/java/com/gotogether/domain/event/service/EventServiceImpl.java b/src/main/java/com/gotogether/domain/event/service/EventServiceImpl.java
@@ -26,6 +26,7 @@
 import com.gotogether.global.apipayload.exception.GeneralException;
 import com.gotogether.global.common.service.S3UploadService;
 import com.gotogether.global.scheduler.EventScheduler;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -42,6 +43,7 @@ public class EventServiceImpl implements EventService {
 	private final ReferenceLinkService referenceLinkService;
 	private final S3UploadService s3UploadService;
 	private final EventScheduler eventScheduler;
+	private final MetricService metricService;
 
 	@Override
 	@Transactional
@@ -62,6 +64,9 @@ public Event createEvent(EventRequestDTO request) {
 		updateBannerImageToFinal(event, request.getBannerImageUrl());
 
 		eventScheduler.scheduleUpdateEventStatus(event.getId(), event.getEndDate());
+
+		metricService.recordEventCreation(event.getId(), event.getCategory().name());
+
 		return event;
 	}
 
diff --git a/src/main/java/com/gotogether/domain/hostchannel/service/HostChannelServiceImpl.java b/src/main/java/com/gotogether/domain/hostchannel/service/HostChannelServiceImpl.java
@@ -1,10 +1,10 @@
 package com.gotogether.domain.hostchannel.service;
 
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
-import java.util.LinkedHashSet;
 
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
@@ -34,17 +34,18 @@
 import com.gotogether.domain.order.repository.OrderRepository;
 import com.gotogether.domain.ticket.entity.Ticket;
 import com.gotogether.domain.ticket.repository.TicketRepository;
+import com.gotogether.domain.ticketoptionanswer.repository.TicketOptionAnswerRepository;
+import com.gotogether.domain.ticketoptionassignment.entity.TicketOptionAssignment;
+import com.gotogether.domain.ticketoptionassignment.repository.TicketOptionAssignmentRepository;
 import com.gotogether.domain.ticketqrcode.entity.TicketQrCode;
 import com.gotogether.domain.ticketqrcode.service.TicketQrCodeService;
 import com.gotogether.domain.user.entity.User;
 import com.gotogether.domain.user.repository.UserRepository;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
 import com.gotogether.global.common.service.S3UploadService;
+import com.gotogether.global.service.MetricService;
 import com.gotogether.global.util.ExcelGenerator;
-import com.gotogether.domain.ticketoptionassignment.entity.TicketOptionAssignment;
-import com.gotogether.domain.ticketoptionassignment.repository.TicketOptionAssignmentRepository;
-import com.gotogether.domain.ticketoptionanswer.repository.TicketOptionAnswerRepository;
 
 import lombok.RequiredArgsConstructor;
 
@@ -59,12 +60,15 @@ public class HostChannelServiceImpl implements HostChannelService {
 	private final OrderCustomRepository orderCustomRepository;
 	private final TicketRepository ticketRepository;
 	private final EventRepository eventRepository;
-	private final EventFacade eventFacade;
-	private final TicketQrCodeService ticketQrCodeService;
-	private final S3UploadService s3UploadService;
 	private final TicketOptionAssignmentRepository ticketOptionAssignmentRepository;
 	private final TicketOptionAnswerRepository ticketOptionAnswerRepository;
 
+	private final TicketQrCodeService ticketQrCodeService;
+	private final S3UploadService s3UploadService;
+	private final MetricService metricService;
+
+	private final EventFacade eventFacade;
+
 	@Override
 	@Transactional
 	public HostChannel createHostChannel(Long userId, HostChannelRequestDTO request) {
@@ -91,6 +95,8 @@ public HostChannel createHostChannel(Long userId, HostChannelRequestDTO request)
 
 		updateProfileImageToFinal(newHostChannel, request.getProfileImageUrl());
 
+		metricService.recordHostChannelCreation(newHostChannel.getId());
+
 		return newHostChannel;
 	}
 
diff --git a/src/main/java/com/gotogether/domain/order/service/OrderServiceImpl.java b/src/main/java/com/gotogether/domain/order/service/OrderServiceImpl.java
@@ -33,6 +33,7 @@
 import com.gotogether.domain.user.entity.User;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -46,6 +47,7 @@ public class OrderServiceImpl implements OrderService {
 	private final TicketQrCodeService ticketQrCodeService;
 	private final OrderCustomRepository orderCustomRepository;
 	private final TicketOptionAnswerService ticketOptionAnswerService;
+	private final MetricService metricService;
 
 	@Override
 	@Transactional
@@ -75,6 +77,9 @@ public List<Order> createOrder(OrderRequestDTO request, Long userId) {
 			ticketOptionAnswerService.createTicketOptionAnswers(user, answers, order);
 		}
 
+		double totalAmount = ticket.getPrice() * ticketCnt;
+		metricService.recordTicketPurchase(ticket.getEvent().getId(), ticket.getId(), ticketCnt, totalAmount);
+
 		return orders;
 	}
 
@@ -114,6 +119,8 @@ public void cancelOrder(OrderCancelRequestDTO request, Long userId) {
 
 			Ticket ticket = eventFacade.getTicketById(order.getTicket().getId());
 
+			metricService.recordOrderCancellation(ticket.getEvent().getId(), ticket.getPrice());
+
 			order.cancelOrder();
 			ticket.increaseAvailableQuantity();
 			ticketQrCodeService.deleteQrCode(orderId);
diff --git a/src/main/java/com/gotogether/domain/reservationemail/service/ReservationEmailServiceImpl.java b/src/main/java/com/gotogether/domain/reservationemail/service/ReservationEmailServiceImpl.java
@@ -20,6 +20,7 @@
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
 import com.gotogether.global.scheduler.EventScheduler;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -28,9 +29,13 @@
 public class ReservationEmailServiceImpl implements ReservationEmailService {
 
 	private final ReservationEmailRepository reservationEmailRepository;
-	private final ReservationEmailFacade reservationEmailFacade;
-	private final EventFacade eventFacade;
+
 	private final EmailService mailService;
+	private final MetricService metricService;
+
+	private final EventFacade eventFacade;
+	private final ReservationEmailFacade reservationEmailFacade;
+
 	private final EventScheduler eventScheduler;
 
 	@Override
@@ -48,6 +53,8 @@ public ReservationEmail createReservationEmail(ReservationEmailRequestDTO reques
 
 		eventScheduler.scheduleEmail(reservationEmail.getId(), reservationEmail.getReservationDate());
 
+		metricService.recordReservationEmailCreation(reservationEmail.getId());
+
 		return reservationEmail;
 	}
 
@@ -104,6 +111,9 @@ public void sendReservationEmail(Long reservationEmailId) {
 		);
 
 		reservationEmail.markAsSent();
+
+		metricService.recordReservationEmailDispatch(reservationEmail.getId());
+
 		reservationEmailRepository.save(reservationEmail);
 	}
 
diff --git a/src/main/java/com/gotogether/domain/ticketoption/service/TicketOptionServiceImpl.java b/src/main/java/com/gotogether/domain/ticketoption/service/TicketOptionServiceImpl.java
@@ -20,6 +20,7 @@
 import com.gotogether.domain.ticketoptionassignment.repository.TicketOptionAssignmentRepository;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -32,6 +33,7 @@ public class TicketOptionServiceImpl implements TicketOptionService {
 	private final TicketOptionAssignmentRepository ticketOptionAssignmentRepository;
 	private final TicketRepository ticketRepository;
 	private final TicketOptionAnswerRepository ticketOptionAnswerRepository;
+	private final MetricService metricService;
 
 	@Override
 	@Transactional
@@ -47,6 +49,8 @@ public TicketOption createTicketOption(TicketOptionRequestDTO request) {
 			ticketOptionChoiceRepository.saveAll(choices);
 		}
 
+		metricService.recordTicketOptionCreation(ticketOption.getId());
+
 		return ticketOption;
 	}
 
diff --git a/src/main/java/com/gotogether/domain/ticketoptionanswer/service/TicketOptionAnswerServiceImpl.java b/src/main/java/com/gotogether/domain/ticketoptionanswer/service/TicketOptionAnswerServiceImpl.java
@@ -28,6 +28,7 @@
 import com.gotogether.domain.user.repository.UserRepository;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -41,6 +42,8 @@ public class TicketOptionAnswerServiceImpl implements TicketOptionAnswerService
 	private final TicketOptionAssignmentRepository ticketOptionAssignmentRepository;
 	private final UserRepository userRepository;
 
+	private final MetricService metricService;
+
 	// 미사용
 	@Override
 	@Transactional
@@ -71,6 +74,8 @@ public void createTicketOptionAnswer(Long userId, TicketOptionAnswerRequestDTO r
 			.answerText(request.getAnswerText())
 			.build();
 
+		metricService.recordTicketOptionAnswerCreation(answer.getId());
+
 		ticketOptionAnswerRepository.save(answer);
 	}
 
diff --git a/src/main/java/com/gotogether/domain/ticketoptionassignment/service/TicketOptionAssignmentServiceImpl.java b/src/main/java/com/gotogether/domain/ticketoptionassignment/service/TicketOptionAssignmentServiceImpl.java
@@ -12,6 +12,7 @@
 import com.gotogether.domain.ticketoptionassignment.repository.TicketOptionAssignmentRepository;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import lombok.RequiredArgsConstructor;
 
@@ -22,6 +23,7 @@ public class TicketOptionAssignmentServiceImpl implements TicketOptionAssignment
 	private final TicketRepository ticketRepository;
 	private final TicketOptionRepository ticketOptionRepository;
 	private final TicketOptionAssignmentRepository ticketOptionAssignmentRepository;
+	private final MetricService metricService;
 
 	@Override
 	@Transactional
@@ -48,6 +50,8 @@ public void assignTicketOption(Long ticketId, Long ticketOptionId) {
 			.ticketOption(ticketOption)
 			.build();
 
+		metricService.recordTicketOptionAssignment(ticketOptionId, ticketId);
+
 		ticketOptionAssignmentRepository.save(assignment);
 	}
 
diff --git a/src/main/java/com/gotogether/domain/ticketqrcode/service/TicketQrCodeServiceImpl.java b/src/main/java/com/gotogether/domain/ticketqrcode/service/TicketQrCodeServiceImpl.java
@@ -23,6 +23,7 @@
 import com.gotogether.domain.ticketqrcode.repository.TicketQrCodeRepository;
 import com.gotogether.global.apipayload.code.status.ErrorStatus;
 import com.gotogether.global.apipayload.exception.GeneralException;
+import com.gotogether.global.service.MetricService;
 
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
@@ -33,6 +34,7 @@ public class TicketQrCodeServiceImpl implements TicketQrCodeService {
 
 	private final TicketQrCodeRepository ticketQrCodeRepository;
 	private final EventFacade eventFacade;
+	private final MetricService metricService;
 
 	@Value("${qr.secret-key}")
 	private String qrSecretKey;
@@ -67,6 +69,8 @@ public void validateSignedQrCode(Long orderId, String sig) {
 
 		TicketQrCode qrCode = getAvailableQrCode(order);
 		qrCode.updateStatus(TicketQrCodeStatus.USED);
+
+		metricService.recordTicketUsage(orderId, order.getTicket().getEvent().getId());
 	}
 
 	private String generateSignedQrCodeImage(Order order) {
diff --git a/src/main/java/com/gotogether/global/apipayload/code/status/ErrorStatus.java b/src/main/java/com/gotogether/global/apipayload/code/status/ErrorStatus.java
@@ -64,6 +64,7 @@ public enum ErrorStatus implements BaseErrorCode {
 	_TICKET_OPTION_ALREADY_ASSIGNED(HttpStatus.BAD_REQUEST, "TICKET_OPTION_ASSIGN4002", "이미 해당 티켓 옵션이 부착되어 있습니다."),
 	_TICKET_OPTION_CHOICE_NOT_FOUND(HttpStatus.NOT_FOUND, "TICKET_OPTION_CHOICE4001", "선택지를 찾을 수 없습니다."),
 	_TICKET_OPTION_ALREADY_ANSWERED(HttpStatus.BAD_REQUEST, "TICKET_OPTION_ANSWER4001", "이미 응답된 티켓 옵션입니다."),
+
 	// 미사용
 	_TICKET_OPTION_ANSWER_ALREADY_EXISTS(HttpStatus.BAD_REQUEST, "TICKET_OPTION_ANSWER4002", "해당 티켓 옵션에 대한 응답이 이미 존재합니다."),
 
@@ -74,7 +75,9 @@ public enum ErrorStatus implements BaseErrorCode {
 	_SMS_ALREADY_SEND(HttpStatus.BAD_REQUEST, "SMS4001", "이미 인증 코드가 발송되었습니다."),
 	_SMS_CERTIFICATION_EXPIRED(HttpStatus.BAD_REQUEST, "SMS4002", "인증 코드가 만료되었습니다."),
 	_SMS_CERTIFICATION_MISMATCH(HttpStatus.BAD_REQUEST, "SMS4003", "인증 코드가 일치하지 않습니다."),
-	_SMS_SEND_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "SMS5001", "SMS 전송에 실패했습니다.");
+	_SMS_SEND_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "SMS5001", "SMS 전송에 실패했습니다."),
+
+	_S3_URL_GENERATION_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "S35001", "S3 Pre-signed URL 생성에 실패했습니다.");
 
 	private final HttpStatus httpStatus;
 	private final String code;
diff --git a/src/main/java/com/gotogether/global/aspect/ApiMetricsAspect.java b/src/main/java/com/gotogether/global/aspect/ApiMetricsAspect.java
diff --git a/src/main/java/com/gotogether/global/common/service/S3UploadService.java b/src/main/java/com/gotogether/global/common/service/S3UploadService.java
diff --git a/src/main/java/com/gotogether/global/common/service/SmsService.java b/src/main/java/com/gotogether/global/common/service/SmsService.java
diff --git a/src/main/java/com/gotogether/global/oauth/service/CustomOAuth2UserService.java b/src/main/java/com/gotogether/global/oauth/service/CustomOAuth2UserService.java
diff --git a/src/main/java/com/gotogether/global/service/MetricService.java b/src/main/java/com/gotogether/global/service/MetricService.java
