generated from pricelees/issue-pr-template
refactor: 로그 레벨 재조정
This commit is contained in:
parent
162e5bbc79
commit
0756e21b63
@ -4,9 +4,13 @@ import org.springframework.boot.Banner
|
|||||||
import org.springframework.boot.SpringApplication
|
import org.springframework.boot.SpringApplication
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication
|
import org.springframework.boot.autoconfigure.SpringBootApplication
|
||||||
import org.springframework.cache.annotation.EnableCaching
|
import org.springframework.cache.annotation.EnableCaching
|
||||||
|
import org.springframework.scheduling.annotation.EnableAsync
|
||||||
|
import org.springframework.scheduling.annotation.EnableScheduling
|
||||||
import java.util.*
|
import java.util.*
|
||||||
|
|
||||||
|
@EnableAsync
|
||||||
@EnableCaching
|
@EnableCaching
|
||||||
|
@EnableScheduling
|
||||||
@SpringBootApplication(
|
@SpringBootApplication(
|
||||||
scanBasePackages = ["com.sangdol.roomescape", "com.sangdol.common"]
|
scanBasePackages = ["com.sangdol.roomescape", "com.sangdol.common"]
|
||||||
)
|
)
|
||||||
|
|||||||
@ -20,7 +20,7 @@ class AdminService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findCredentialsByAccount(account: String): AdminLoginCredentials {
|
fun findCredentialsByAccount(account: String): AdminLoginCredentials {
|
||||||
log.info { "[findCredentialsByAccount] 관리자 조회 시작: account=${account}" }
|
log.debug { "[findCredentialsByAccount] 관리자 조회 시작: account=${account}" }
|
||||||
|
|
||||||
return adminRepository.findByAccount(account)
|
return adminRepository.findByAccount(account)
|
||||||
?.let {
|
?.let {
|
||||||
@ -28,14 +28,14 @@ class AdminService(
|
|||||||
it.toCredentials()
|
it.toCredentials()
|
||||||
}
|
}
|
||||||
?: run {
|
?: run {
|
||||||
log.info { "[findCredentialsByAccount] 관리자 조회 실패: account=${account}" }
|
log.debug { "[findCredentialsByAccount] 관리자 조회 실패: account=${account}" }
|
||||||
throw AdminException(AdminErrorCode.ADMIN_NOT_FOUND)
|
throw AdminException(AdminErrorCode.ADMIN_NOT_FOUND)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findOperatorOrUnknown(id: Long): Auditor {
|
fun findOperatorOrUnknown(id: Long): Auditor {
|
||||||
log.info { "[findOperatorById] 작업자 정보 조회 시작: id=${id}" }
|
log.debug { "[findOperatorById] 작업자 정보 조회 시작: id=${id}" }
|
||||||
|
|
||||||
return adminRepository.findByIdOrNull(id)?.let { admin ->
|
return adminRepository.findByIdOrNull(id)?.let { admin ->
|
||||||
Auditor(admin.id, admin.name).also {
|
Auditor(admin.id, admin.name).also {
|
||||||
|
|||||||
@ -33,7 +33,7 @@ class AuthService(
|
|||||||
request: LoginRequest,
|
request: LoginRequest,
|
||||||
context: LoginContext
|
context: LoginContext
|
||||||
): LoginSuccessResponse {
|
): LoginSuccessResponse {
|
||||||
log.info { "[login] 로그인 시작: account=${request.account}, type=${request.principalType}, context=${context}" }
|
log.debug { "[login] 로그인 시작: account=${request.account}, type=${request.principalType}, context=${context}" }
|
||||||
val (credentials, extraClaims) = getCredentials(request)
|
val (credentials, extraClaims) = getCredentials(request)
|
||||||
|
|
||||||
val event = LoginHistoryEvent(
|
val event = LoginHistoryEvent(
|
||||||
@ -56,10 +56,7 @@ class AuthService(
|
|||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
eventPublisher.publishEvent(event.onFailure())
|
eventPublisher.publishEvent(event.onFailure())
|
||||||
when (e) {
|
when (e) {
|
||||||
is AuthException -> {
|
is AuthException -> { throw e }
|
||||||
log.info { "[login] 로그인 실패: account = ${request.account}" }
|
|
||||||
throw e
|
|
||||||
}
|
|
||||||
|
|
||||||
else -> {
|
else -> {
|
||||||
log.warn { "[login] 로그인 실패: message=${e.message} account = ${request.account}" }
|
log.warn { "[login] 로그인 실패: message=${e.message} account = ${request.account}" }
|
||||||
@ -74,7 +71,7 @@ class AuthService(
|
|||||||
credentials: LoginCredentials
|
credentials: LoginCredentials
|
||||||
) {
|
) {
|
||||||
if (credentials.password != request.password) {
|
if (credentials.password != request.password) {
|
||||||
log.info { "[login] 비밀번호 불일치로 인한 로그인 실패: account = ${request.account}" }
|
log.debug { "[login] 비밀번호 불일치로 인한 로그인 실패: account = ${request.account}" }
|
||||||
throw AuthException(AuthErrorCode.LOGIN_FAILED)
|
throw AuthException(AuthErrorCode.LOGIN_FAILED)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -11,8 +11,6 @@ import jakarta.annotation.PreDestroy
|
|||||||
import org.springframework.beans.factory.annotation.Value
|
import org.springframework.beans.factory.annotation.Value
|
||||||
import org.springframework.context.event.EventListener
|
import org.springframework.context.event.EventListener
|
||||||
import org.springframework.scheduling.annotation.Async
|
import org.springframework.scheduling.annotation.Async
|
||||||
import org.springframework.scheduling.annotation.EnableAsync
|
|
||||||
import org.springframework.scheduling.annotation.EnableScheduling
|
|
||||||
import org.springframework.scheduling.annotation.Scheduled
|
import org.springframework.scheduling.annotation.Scheduled
|
||||||
import org.springframework.stereotype.Component
|
import org.springframework.stereotype.Component
|
||||||
import java.util.concurrent.ConcurrentLinkedQueue
|
import java.util.concurrent.ConcurrentLinkedQueue
|
||||||
@ -21,8 +19,6 @@ import java.util.concurrent.TimeUnit
|
|||||||
private val log: KLogger = KotlinLogging.logger {}
|
private val log: KLogger = KotlinLogging.logger {}
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
@EnableAsync
|
|
||||||
@EnableScheduling
|
|
||||||
class LoginHistoryEventListener(
|
class LoginHistoryEventListener(
|
||||||
private val idGenerator: IDGenerator,
|
private val idGenerator: IDGenerator,
|
||||||
private val loginHistoryRepository: LoginHistoryRepository,
|
private val loginHistoryRepository: LoginHistoryRepository,
|
||||||
@ -35,7 +31,7 @@ class LoginHistoryEventListener(
|
|||||||
@Async
|
@Async
|
||||||
@EventListener(classes = [LoginHistoryEvent::class])
|
@EventListener(classes = [LoginHistoryEvent::class])
|
||||||
fun onLoginCompleted(event: LoginHistoryEvent) {
|
fun onLoginCompleted(event: LoginHistoryEvent) {
|
||||||
log.info { "[onLoginCompleted] 로그인 이력 저장 이벤트 수신: id=${event.id}, type=${event.type}" }
|
log.debug { "[onLoginCompleted] 로그인 이력 저장 이벤트 수신: id=${event.id}, type=${event.type}" }
|
||||||
|
|
||||||
queue.add(event.toEntity(idGenerator.create())).also {
|
queue.add(event.toEntity(idGenerator.create())).also {
|
||||||
log.info { "[onLoginCompleted] 로그인 이력 저장 이벤트 큐 저장 완료: id=${event.id}, type=${event.type}" }
|
log.info { "[onLoginCompleted] 로그인 이력 저장 이벤트 큐 저장 완료: id=${event.id}, type=${event.type}" }
|
||||||
@ -48,10 +44,10 @@ class LoginHistoryEventListener(
|
|||||||
|
|
||||||
@Scheduled(fixedRate = 30, timeUnit = TimeUnit.SECONDS)
|
@Scheduled(fixedRate = 30, timeUnit = TimeUnit.SECONDS)
|
||||||
fun flushScheduled() {
|
fun flushScheduled() {
|
||||||
log.info { "[flushScheduled] 큐에 저장된 로그인 이력 저장 시작: size=${queue.size}" }
|
log.debug { "[flushScheduled] 큐에 저장된 로그인 이력 저장 시작: size=${queue.size}" }
|
||||||
|
|
||||||
if (queue.isEmpty()) {
|
if (queue.isEmpty()) {
|
||||||
log.info { "[flushScheduled] 큐에 있는 로그인 이력이 없음." }
|
log.debug { "[flushScheduled] 큐에 있는 로그인 이력이 없음." }
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
flush()
|
flush()
|
||||||
@ -60,7 +56,7 @@ class LoginHistoryEventListener(
|
|||||||
|
|
||||||
@PreDestroy
|
@PreDestroy
|
||||||
fun flushAll() {
|
fun flushAll() {
|
||||||
log.info { "[flushAll] 애플리케이션 종료. 큐에 있는 모든 이력 저장 시작: size=${queue.size}" }
|
log.debug { "[flushAll] 애플리케이션 종료. 큐에 있는 모든 이력 저장 시작: size=${queue.size}" }
|
||||||
while (!queue.isEmpty()) {
|
while (!queue.isEmpty()) {
|
||||||
flush()
|
flush()
|
||||||
}
|
}
|
||||||
@ -68,10 +64,10 @@ class LoginHistoryEventListener(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun flush() {
|
private fun flush() {
|
||||||
log.info { "[flush] 큐에 저장된 로그인 이력 저장 시작: size=${queue.size}" }
|
log.debug { "[flush] 큐에 저장된 로그인 이력 저장 시작: size=${queue.size}" }
|
||||||
|
|
||||||
if (queue.isEmpty()) {
|
if (queue.isEmpty()) {
|
||||||
log.info { "[flush] 큐에 있는 로그인 이력이 없음." }
|
log.debug { "[flush] 큐에 있는 로그인 이력이 없음." }
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -50,7 +50,7 @@ class JwtUtils(
|
|||||||
val claims = extractAllClaims(token)
|
val claims = extractAllClaims(token)
|
||||||
|
|
||||||
return claims.subject ?: run {
|
return claims.subject ?: run {
|
||||||
log.info { "[JwtUtils.extractSubject] subject를 찾을 수 없음.: token = ${token}" }
|
log.debug { "[JwtUtils.extractSubject] subject를 찾을 수 없음.: token = ${token}" }
|
||||||
throw AuthException(AuthErrorCode.INVALID_TOKEN)
|
throw AuthException(AuthErrorCode.INVALID_TOKEN)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -32,7 +32,7 @@ class OrderService(
|
|||||||
fun confirm(reservationId: Long, paymentConfirmRequest: PaymentConfirmRequest) {
|
fun confirm(reservationId: Long, paymentConfirmRequest: PaymentConfirmRequest) {
|
||||||
val paymentKey = paymentConfirmRequest.paymentKey
|
val paymentKey = paymentConfirmRequest.paymentKey
|
||||||
|
|
||||||
log.info { "[confirm] 결제 및 예약 확정 시작: reservationId=${reservationId}, paymentKey=${paymentKey}" }
|
log.debug { "[confirm] 결제 및 예약 확정 시작: reservationId=${reservationId}, paymentKey=${paymentKey}" }
|
||||||
try {
|
try {
|
||||||
transactionExecutionUtil.withNewTransaction(isReadOnly = false) {
|
transactionExecutionUtil.withNewTransaction(isReadOnly = false) {
|
||||||
validateCanConfirm(reservationId)
|
validateCanConfirm(reservationId)
|
||||||
@ -42,7 +42,7 @@ class OrderService(
|
|||||||
paymentService.requestConfirm(reservationId, paymentConfirmRequest)
|
paymentService.requestConfirm(reservationId, paymentConfirmRequest)
|
||||||
eventPublisher.publishEvent(ReservationConfirmEvent(reservationId))
|
eventPublisher.publishEvent(ReservationConfirmEvent(reservationId))
|
||||||
|
|
||||||
log.info { "[confirm] 결제 처리 및 예약 확정 이벤트 발행 완료" }
|
log.info { "[confirm] 결제 처리 및 예약 확정 이벤트 발행 완료: reservationId=${reservationId}, paymentKey=${paymentKey}" }
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
val errorCode: ErrorCode = if (e is RoomescapeException) {
|
val errorCode: ErrorCode = if (e is RoomescapeException) {
|
||||||
e.errorCode
|
e.errorCode
|
||||||
@ -55,7 +55,7 @@ class OrderService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun validateCanConfirm(reservationId: Long) {
|
private fun validateCanConfirm(reservationId: Long) {
|
||||||
log.info { "[validateAndMarkInProgress] 예약 확정 가능 여부 검증 시작: reservationId=${reservationId}" }
|
log.debug { "[validateAndMarkInProgress] 예약 확정 가능 여부 검증 시작: reservationId=${reservationId}" }
|
||||||
val reservation: ReservationStateResponse = reservationService.findStatusWithLock(reservationId)
|
val reservation: ReservationStateResponse = reservationService.findStatusWithLock(reservationId)
|
||||||
val schedule: ScheduleStateResponse = scheduleService.findStateWithLock(reservation.scheduleId)
|
val schedule: ScheduleStateResponse = scheduleService.findStateWithLock(reservation.scheduleId)
|
||||||
|
|
||||||
|
|||||||
@ -27,15 +27,12 @@ class OrderValidator {
|
|||||||
private fun validateReservationStatus(reservation: ReservationStateResponse) {
|
private fun validateReservationStatus(reservation: ReservationStateResponse) {
|
||||||
when (reservation.status) {
|
when (reservation.status) {
|
||||||
ReservationStatus.CONFIRMED -> {
|
ReservationStatus.CONFIRMED -> {
|
||||||
log.info { "[validateCanConfirm] 이미 확정된 예약: id=${reservation.id}" }
|
|
||||||
throw OrderException(OrderErrorCode.ORDER_ALREADY_CONFIRMED)
|
throw OrderException(OrderErrorCode.ORDER_ALREADY_CONFIRMED)
|
||||||
}
|
}
|
||||||
ReservationStatus.EXPIRED -> {
|
ReservationStatus.EXPIRED -> {
|
||||||
log.info { "[validateCanConfirm] 만료된 예약: id=${reservation.id}" }
|
|
||||||
throw OrderException(OrderErrorCode.EXPIRED_RESERVATION)
|
throw OrderException(OrderErrorCode.EXPIRED_RESERVATION)
|
||||||
}
|
}
|
||||||
ReservationStatus.CANCELED -> {
|
ReservationStatus.CANCELED -> {
|
||||||
log.info { "[validateCanConfirm] 취소된 예약: id=${reservation.id}" }
|
|
||||||
throw OrderException(OrderErrorCode.CANCELED_RESERVATION)
|
throw OrderException(OrderErrorCode.CANCELED_RESERVATION)
|
||||||
}
|
}
|
||||||
else -> {}
|
else -> {}
|
||||||
@ -44,14 +41,14 @@ class OrderValidator {
|
|||||||
|
|
||||||
private fun validateScheduleStatus(schedule: ScheduleStateResponse) {
|
private fun validateScheduleStatus(schedule: ScheduleStateResponse) {
|
||||||
if (schedule.status != ScheduleStatus.HOLD) {
|
if (schedule.status != ScheduleStatus.HOLD) {
|
||||||
log.info { "[validateScheduleStatus] 일정 상태 오류: status=${schedule.status}" }
|
log.debug { "[validateScheduleStatus] 일정 상태 오류: status=${schedule.status}" }
|
||||||
throw OrderException(OrderErrorCode.EXPIRED_RESERVATION)
|
throw OrderException(OrderErrorCode.EXPIRED_RESERVATION)
|
||||||
}
|
}
|
||||||
|
|
||||||
val scheduleDateTime = LocalDateTime.of(schedule.date, schedule.startFrom)
|
val scheduleDateTime = LocalDateTime.of(schedule.date, schedule.startFrom)
|
||||||
val nowDateTime = KoreaDateTime.now()
|
val nowDateTime = KoreaDateTime.now()
|
||||||
if (scheduleDateTime.isBefore(nowDateTime)) {
|
if (scheduleDateTime.isBefore(nowDateTime)) {
|
||||||
log.info { "[validateScheduleStatus] 과거 시간인 일정으로 인한 실패: scheduleDateTime=${scheduleDateTime}(KST), now=${nowDateTime}(KST)" }
|
log.debug { "[validateScheduleStatus] 과거 시간인 일정으로 인한 실패: scheduleDateTime=${scheduleDateTime}(KST), now=${nowDateTime}(KST)" }
|
||||||
throw OrderException(OrderErrorCode.PAST_SCHEDULE)
|
throw OrderException(OrderErrorCode.PAST_SCHEDULE)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -31,7 +31,7 @@ class PaymentService(
|
|||||||
private val eventPublisher: ApplicationEventPublisher
|
private val eventPublisher: ApplicationEventPublisher
|
||||||
) {
|
) {
|
||||||
fun requestConfirm(reservationId: Long, request: PaymentConfirmRequest): PaymentGatewayResponse {
|
fun requestConfirm(reservationId: Long, request: PaymentConfirmRequest): PaymentGatewayResponse {
|
||||||
log.info { "[requestConfirm] 결제 요청 시작: paymentKey=${request.paymentKey}" }
|
log.debug { "[requestConfirm] 결제 요청 시작: paymentKey=${request.paymentKey}" }
|
||||||
try {
|
try {
|
||||||
return paymentClient.confirm(request.paymentKey, request.orderId, request.amount).also {
|
return paymentClient.confirm(request.paymentKey, request.orderId, request.amount).also {
|
||||||
eventPublisher.publishEvent(it.toEvent(reservationId))
|
eventPublisher.publishEvent(it.toEvent(reservationId))
|
||||||
@ -90,7 +90,7 @@ class PaymentService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findDetailByReservationId(reservationId: Long): PaymentResponse? {
|
fun findDetailByReservationId(reservationId: Long): PaymentResponse? {
|
||||||
log.info { "[findDetailByReservationId] 예약 결제 정보 조회 시작: reservationId=$reservationId" }
|
log.debug { "[findDetailByReservationId] 예약 결제 정보 조회 시작: reservationId=$reservationId" }
|
||||||
|
|
||||||
val payment: PaymentEntity? = findByReservationIdOrNull(reservationId)
|
val payment: PaymentEntity? = findByReservationIdOrNull(reservationId)
|
||||||
val paymentDetail: PaymentDetailEntity? = payment?.let { findDetailByPaymentIdOrNull(it.id) }
|
val paymentDetail: PaymentDetailEntity? = payment?.let { findDetailByPaymentIdOrNull(it.id) }
|
||||||
@ -99,11 +99,13 @@ class PaymentService(
|
|||||||
return payment?.toResponse(
|
return payment?.toResponse(
|
||||||
detail = paymentDetail?.toResponse(),
|
detail = paymentDetail?.toResponse(),
|
||||||
cancel = cancelDetail?.toResponse()
|
cancel = cancelDetail?.toResponse()
|
||||||
)
|
).also {
|
||||||
|
log.info { "[findDetailByReservationId] 예약 결제 정보 조회 완료: reservationId=$reservationId" }
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun findByReservationIdOrThrow(reservationId: Long): PaymentEntity {
|
private fun findByReservationIdOrThrow(reservationId: Long): PaymentEntity {
|
||||||
log.info { "[findByReservationIdOrThrow] 결제 정보 조회 시작: reservationId=: $reservationId" }
|
log.debug { "[findByReservationIdOrThrow] 결제 정보 조회 시작: reservationId=: $reservationId" }
|
||||||
|
|
||||||
return paymentRepository.findByReservationId(reservationId)
|
return paymentRepository.findByReservationId(reservationId)
|
||||||
?.also { log.info { "[findByReservationIdOrThrow] 결제 정보 조회 완료: reservationId=$reservationId, paymentId=${it.id}" } }
|
?.also { log.info { "[findByReservationIdOrThrow] 결제 정보 조회 완료: reservationId=$reservationId, paymentId=${it.id}" } }
|
||||||
@ -114,7 +116,7 @@ class PaymentService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findByReservationIdOrNull(reservationId: Long): PaymentEntity? {
|
private fun findByReservationIdOrNull(reservationId: Long): PaymentEntity? {
|
||||||
log.info { "[findByReservationIdOrThrow] 결제 정보 조회 시작: reservationId=: $reservationId" }
|
log.debug { "[findByReservationIdOrThrow] 결제 정보 조회 시작: reservationId=: $reservationId" }
|
||||||
|
|
||||||
return paymentRepository.findByReservationId(reservationId)
|
return paymentRepository.findByReservationId(reservationId)
|
||||||
.also {
|
.also {
|
||||||
@ -127,7 +129,7 @@ class PaymentService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findDetailByPaymentIdOrNull(paymentId: Long): PaymentDetailEntity? {
|
private fun findDetailByPaymentIdOrNull(paymentId: Long): PaymentDetailEntity? {
|
||||||
log.info { "[findDetailByPaymentIdOrThrow] 결제 상세 정보 조회 시작: paymentId=$paymentId" }
|
log.debug { "[findDetailByPaymentIdOrThrow] 결제 상세 정보 조회 시작: paymentId=$paymentId" }
|
||||||
|
|
||||||
return paymentDetailRepository.findByPaymentId(paymentId).also {
|
return paymentDetailRepository.findByPaymentId(paymentId).also {
|
||||||
if (it != null) {
|
if (it != null) {
|
||||||
@ -139,7 +141,7 @@ class PaymentService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findCancelByPaymentIdOrNull(paymentId: Long): CanceledPaymentEntity? {
|
private fun findCancelByPaymentIdOrNull(paymentId: Long): CanceledPaymentEntity? {
|
||||||
log.info { "[findDetailByReservationId] 취소 결제 정보 조회 시작: paymentId=${paymentId}" }
|
log.debug { "[findDetailByReservationId] 취소 결제 정보 조회 시작: paymentId=${paymentId}" }
|
||||||
|
|
||||||
return canceledPaymentRepository.findByPaymentId(paymentId).also {
|
return canceledPaymentRepository.findByPaymentId(paymentId).also {
|
||||||
if (it == null) {
|
if (it == null) {
|
||||||
|
|||||||
@ -29,20 +29,16 @@ class PaymentEventListener(
|
|||||||
fun handlePaymentEvent(event: PaymentEvent) {
|
fun handlePaymentEvent(event: PaymentEvent) {
|
||||||
val reservationId = event.reservationId
|
val reservationId = event.reservationId
|
||||||
|
|
||||||
log.info { "[handlePaymentEvent] 결제 정보 저장 이벤트 수신: reservationId=${reservationId}, paymentKey=${event.paymentKey}" }
|
log.debug { "[handlePaymentEvent] 결제 정보 저장 이벤트 수신: reservationId=${reservationId}, paymentKey=${event.paymentKey}" }
|
||||||
|
|
||||||
val paymentId = idGenerator.create()
|
val paymentId = idGenerator.create()
|
||||||
val paymentEntity: PaymentEntity = event.toEntity(paymentId)
|
val paymentEntity: PaymentEntity = event.toEntity(paymentId)
|
||||||
paymentRepository.save(paymentEntity).also {
|
paymentRepository.save(paymentEntity)
|
||||||
log.info { "[handlePaymentEvent] 결제 정보 저장 완료: paymentId=${paymentId}" }
|
|
||||||
}
|
|
||||||
|
|
||||||
val paymentDetailId = idGenerator.create()
|
val paymentDetailId = idGenerator.create()
|
||||||
val paymentDetailEntity: PaymentDetailEntity = event.toDetailEntity(id = paymentDetailId, paymentId = paymentId)
|
val paymentDetailEntity: PaymentDetailEntity = event.toDetailEntity(id = paymentDetailId, paymentId = paymentId)
|
||||||
paymentDetailRepository.save(paymentDetailEntity).also {
|
paymentDetailRepository.save(paymentDetailEntity)
|
||||||
log.info { "[handlePaymentEvent] 결제 상세 저장 완료: paymentDetailId=${paymentDetailId}" }
|
|
||||||
}
|
|
||||||
|
|
||||||
log.info { "[handlePaymentEvent] 결제 정보 저장 이벤트 처리 완료" }
|
log.info { "[handlePaymentEvent] 결제 정보 저장 이벤트 처리 완료: reservationId=${reservationId}, paymentId=${paymentId}, paymentDetailId=${paymentDetailId}" }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -33,7 +33,7 @@ class TosspayClient(
|
|||||||
amount: Int,
|
amount: Int,
|
||||||
): PaymentGatewayResponse {
|
): PaymentGatewayResponse {
|
||||||
val startTime = System.currentTimeMillis()
|
val startTime = System.currentTimeMillis()
|
||||||
log.info { "[TosspayClient.confirm] 결제 승인 요청: paymentKey=$paymentKey, orderId=$orderId, amount=$amount" }
|
log.debug { "[TosspayClient.confirm] 결제 승인 요청: paymentKey=$paymentKey, orderId=$orderId, amount=$amount" }
|
||||||
|
|
||||||
return confirmClient.request(paymentKey, orderId, amount)
|
return confirmClient.request(paymentKey, orderId, amount)
|
||||||
.also {
|
.also {
|
||||||
@ -47,7 +47,7 @@ class TosspayClient(
|
|||||||
cancelReason: String
|
cancelReason: String
|
||||||
): PaymentGatewayCancelResponse {
|
): PaymentGatewayCancelResponse {
|
||||||
val startTime = System.currentTimeMillis()
|
val startTime = System.currentTimeMillis()
|
||||||
log.info { "[TosspayClient.cancel] 결제 취소 요청: paymentKey=$paymentKey, amount=$amount, cancelReason=$cancelReason" }
|
log.debug { "[TosspayClient.cancel] 결제 취소 요청: paymentKey=$paymentKey, amount=$amount, cancelReason=$cancelReason" }
|
||||||
|
|
||||||
return cancelClient.request(paymentKey, amount, cancelReason).also {
|
return cancelClient.request(paymentKey, amount, cancelReason).also {
|
||||||
log.info { "[TosspayClient.cancel] 결제 취소 완료: duration_ms=${System.currentTimeMillis() - startTime}ms, paymentKey=$paymentKey" }
|
log.info { "[TosspayClient.cancel] 결제 취소 완료: duration_ms=${System.currentTimeMillis() - startTime}ms, paymentKey=$paymentKey" }
|
||||||
|
|||||||
@ -17,7 +17,7 @@ class RegionService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun readAllSido(): SidoListResponse {
|
fun readAllSido(): SidoListResponse {
|
||||||
log.info { "[readAllSido] 모든 시/도 조회 시작" }
|
log.debug { "[readAllSido] 모든 시/도 조회 시작" }
|
||||||
val result: List<Pair<String, String>> = regionRepository.readAllSido()
|
val result: List<Pair<String, String>> = regionRepository.readAllSido()
|
||||||
|
|
||||||
if (result.isEmpty()) {
|
if (result.isEmpty()) {
|
||||||
@ -32,7 +32,7 @@ class RegionService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findSigunguBySido(sidoCode: String): SigunguListResponse {
|
fun findSigunguBySido(sidoCode: String): SigunguListResponse {
|
||||||
log.info { "[findSigunguBySido] 시/군/구 조회 시작: sidoCode=${sidoCode}" }
|
log.debug { "[findSigunguBySido] 시/군/구 조회 시작: sidoCode=${sidoCode}" }
|
||||||
val result: List<Pair<String, String>> = regionRepository.findAllSigunguBySido(sidoCode)
|
val result: List<Pair<String, String>> = regionRepository.findAllSigunguBySido(sidoCode)
|
||||||
|
|
||||||
if (result.isEmpty()) {
|
if (result.isEmpty()) {
|
||||||
@ -47,7 +47,7 @@ class RegionService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findRegionCode(sidoCode: String, sigunguCode: String): RegionCodeResponse {
|
fun findRegionCode(sidoCode: String, sigunguCode: String): RegionCodeResponse {
|
||||||
log.info { "[findRegionCode] 지역 코드 조회 시작: sidoCode=${sidoCode} / sigunguCode=${sigunguCode}" }
|
log.debug { "[findRegionCode] 지역 코드 조회 시작: sidoCode=${sidoCode} / sigunguCode=${sigunguCode}" }
|
||||||
|
|
||||||
return regionRepository.findRegionCode(sidoCode, sigunguCode)?.let {
|
return regionRepository.findRegionCode(sidoCode, sigunguCode)?.let {
|
||||||
log.info { "[findRegionCode] 지역 코드 조회 완료: code=${it} sidoCode=${sidoCode} / sigunguCode=${sigunguCode}" }
|
log.info { "[findRegionCode] 지역 코드 조회 완료: code=${it} sidoCode=${sidoCode} / sigunguCode=${sigunguCode}" }
|
||||||
@ -60,7 +60,7 @@ class RegionService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findRegionInfo(regionCode: String): RegionInfoResponse {
|
fun findRegionInfo(regionCode: String): RegionInfoResponse {
|
||||||
log.info { "[findRegionInfo] 지역 정보 조회 시작: regionCode=${regionCode}" }
|
log.debug { "[findRegionInfo] 지역 정보 조회 시작: regionCode=${regionCode}" }
|
||||||
|
|
||||||
return regionRepository.findByCode(regionCode)?.let {
|
return regionRepository.findByCode(regionCode)?.let {
|
||||||
log.info { "[findRegionInfo] 지역 정보 조회 완료: code=${it} regionCode=${regionCode}" }
|
log.info { "[findRegionInfo] 지역 정보 조회 완료: code=${it} regionCode=${regionCode}" }
|
||||||
|
|||||||
@ -45,7 +45,7 @@ class ReservationService(
|
|||||||
user: CurrentUserContext,
|
user: CurrentUserContext,
|
||||||
request: PendingReservationCreateRequest
|
request: PendingReservationCreateRequest
|
||||||
): PendingReservationCreateResponse {
|
): PendingReservationCreateResponse {
|
||||||
log.info { "[createPendingReservation] Pending 예약 생성 시작: schedule=${request.scheduleId}" }
|
log.debug { "[createPendingReservation] Pending 예약 생성 시작: schedule=${request.scheduleId}" }
|
||||||
|
|
||||||
run {
|
run {
|
||||||
val schedule: ScheduleStateResponse = scheduleService.findStateWithLock(request.scheduleId)
|
val schedule: ScheduleStateResponse = scheduleService.findStateWithLock(request.scheduleId)
|
||||||
@ -64,7 +64,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun confirmReservation(id: Long) {
|
fun confirmReservation(id: Long) {
|
||||||
log.info { "[confirmReservation] Pending 예약 확정 시작: reservationId=${id}" }
|
log.debug { "[confirmReservation] Pending 예약 확정 시작: reservationId=${id}" }
|
||||||
val reservation: ReservationEntity = findOrThrow(id)
|
val reservation: ReservationEntity = findOrThrow(id)
|
||||||
|
|
||||||
run {
|
run {
|
||||||
@ -81,7 +81,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun cancelReservation(user: CurrentUserContext, reservationId: Long, request: ReservationCancelRequest) {
|
fun cancelReservation(user: CurrentUserContext, reservationId: Long, request: ReservationCancelRequest) {
|
||||||
log.info { "[cancelReservation] 예약 취소 시작: userId=${user.id}, reservationId=${reservationId}" }
|
log.debug { "[cancelReservation] 예약 취소 시작: userId=${user.id}, reservationId=${reservationId}" }
|
||||||
|
|
||||||
val reservation: ReservationEntity = findOrThrow(reservationId)
|
val reservation: ReservationEntity = findOrThrow(reservationId)
|
||||||
|
|
||||||
@ -100,7 +100,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findAllUserReservationOverview(user: CurrentUserContext): ReservationOverviewListResponse {
|
fun findAllUserReservationOverview(user: CurrentUserContext): ReservationOverviewListResponse {
|
||||||
log.info { "[findSummaryByMemberId] 예약 조회 시작: userId=${user.id}" }
|
log.debug { "[findSummaryByMemberId] 예약 조회 시작: userId=${user.id}" }
|
||||||
|
|
||||||
val reservations: List<ReservationEntity> = reservationRepository.findAllByUserIdAndStatusIsIn(
|
val reservations: List<ReservationEntity> = reservationRepository.findAllByUserIdAndStatusIsIn(
|
||||||
userId = user.id,
|
userId = user.id,
|
||||||
@ -125,7 +125,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findDetailById(id: Long): ReservationAdditionalResponse {
|
fun findDetailById(id: Long): ReservationAdditionalResponse {
|
||||||
log.info { "[findDetailById] 예약 상세 조회 시작: reservationId=${id}" }
|
log.debug { "[findDetailById] 예약 상세 조회 시작: reservationId=${id}" }
|
||||||
|
|
||||||
val reservation: ReservationEntity = findOrThrow(id)
|
val reservation: ReservationEntity = findOrThrow(id)
|
||||||
val user: UserContactResponse = userService.findContactById(reservation.userId)
|
val user: UserContactResponse = userService.findContactById(reservation.userId)
|
||||||
@ -141,7 +141,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findStatusWithLock(id: Long): ReservationStateResponse {
|
fun findStatusWithLock(id: Long): ReservationStateResponse {
|
||||||
log.info { "[findStatusWithLock] 예약 LOCK + 상태 조회 시작: reservationId=${id}" }
|
log.debug { "[findStatusWithLock] 예약 LOCK + 상태 조회 시작: reservationId=${id}" }
|
||||||
|
|
||||||
return reservationRepository.findByIdForUpdate(id)?.let {
|
return reservationRepository.findByIdForUpdate(id)?.let {
|
||||||
log.info { "[findStatusWithLock] 예약 LOCK + 상태 조회 완료: reservationId=${id}" }
|
log.info { "[findStatusWithLock] 예약 LOCK + 상태 조회 완료: reservationId=${id}" }
|
||||||
@ -154,7 +154,7 @@ class ReservationService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun markInProgress(reservationId: Long) {
|
fun markInProgress(reservationId: Long) {
|
||||||
log.info { "[markInProgress] 예약 상태 ${ReservationStatus.PAYMENT_IN_PROGRESS} 변경 시작." }
|
log.debug { "[markInProgress] 예약 상태 ${ReservationStatus.PAYMENT_IN_PROGRESS} 변경 시작." }
|
||||||
|
|
||||||
findOrThrow(reservationId).apply {
|
findOrThrow(reservationId).apply {
|
||||||
this.status = ReservationStatus.PAYMENT_IN_PROGRESS
|
this.status = ReservationStatus.PAYMENT_IN_PROGRESS
|
||||||
@ -164,7 +164,7 @@ class ReservationService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findOrThrow(id: Long): ReservationEntity {
|
private fun findOrThrow(id: Long): ReservationEntity {
|
||||||
log.info { "[findOrThrow] 예약 조회 시작: reservationId=${id}" }
|
log.debug { "[findOrThrow] 예약 조회 시작: reservationId=${id}" }
|
||||||
|
|
||||||
return reservationRepository.findByIdOrNull(id)
|
return reservationRepository.findByIdOrNull(id)
|
||||||
?.also { log.info { "[findOrThrow] 예약 조회 완료: reservationId=${id}" } }
|
?.also { log.info { "[findOrThrow] 예약 조회 완료: reservationId=${id}" } }
|
||||||
|
|||||||
@ -1,17 +1,15 @@
|
|||||||
package com.sangdol.roomescape.reservation.business
|
package com.sangdol.roomescape.reservation.business
|
||||||
|
|
||||||
import com.sangdol.common.utils.KoreaDateTime
|
import com.sangdol.common.utils.KoreaDateTime
|
||||||
import com.sangdol.common.utils.toKoreaDateTime
|
import com.sangdol.roomescape.reservation.dto.PendingReservationCreateRequest
|
||||||
import com.sangdol.roomescape.reservation.exception.ReservationErrorCode
|
import com.sangdol.roomescape.reservation.exception.ReservationErrorCode
|
||||||
import com.sangdol.roomescape.reservation.exception.ReservationException
|
import com.sangdol.roomescape.reservation.exception.ReservationException
|
||||||
import com.sangdol.roomescape.reservation.dto.PendingReservationCreateRequest
|
|
||||||
import com.sangdol.roomescape.schedule.dto.ScheduleStateResponse
|
import com.sangdol.roomescape.schedule.dto.ScheduleStateResponse
|
||||||
import com.sangdol.roomescape.schedule.infrastructure.persistence.ScheduleStatus
|
import com.sangdol.roomescape.schedule.infrastructure.persistence.ScheduleStatus
|
||||||
import com.sangdol.roomescape.theme.dto.ThemeInfoResponse
|
import com.sangdol.roomescape.theme.dto.ThemeInfoResponse
|
||||||
import io.github.oshai.kotlinlogging.KLogger
|
import io.github.oshai.kotlinlogging.KLogger
|
||||||
import io.github.oshai.kotlinlogging.KotlinLogging
|
import io.github.oshai.kotlinlogging.KotlinLogging
|
||||||
import org.springframework.stereotype.Component
|
import org.springframework.stereotype.Component
|
||||||
import java.time.Instant
|
|
||||||
import java.time.LocalDateTime
|
import java.time.LocalDateTime
|
||||||
|
|
||||||
private val log: KLogger = KotlinLogging.logger {}
|
private val log: KLogger = KotlinLogging.logger {}
|
||||||
|
|||||||
@ -22,7 +22,7 @@ class ReservationEventListener(
|
|||||||
fun handleReservationConfirmEvent(event: ReservationConfirmEvent) {
|
fun handleReservationConfirmEvent(event: ReservationConfirmEvent) {
|
||||||
val reservationId = event.reservationId
|
val reservationId = event.reservationId
|
||||||
|
|
||||||
log.info { "[handleReservationConfirmEvent] 예약 확정 이벤트 수신: reservationId=${reservationId}" }
|
log.debug { "[handleReservationConfirmEvent] 예약 확정 이벤트 수신: reservationId=${reservationId}" }
|
||||||
val modifiedRows = reservationRepository.confirmReservation(Instant.now(), reservationId)
|
val modifiedRows = reservationRepository.confirmReservation(Instant.now(), reservationId)
|
||||||
|
|
||||||
if (modifiedRows == 0) {
|
if (modifiedRows == 0) {
|
||||||
|
|||||||
@ -5,7 +5,6 @@ import com.sangdol.roomescape.schedule.infrastructure.persistence.ScheduleReposi
|
|||||||
import com.sangdol.roomescape.schedule.infrastructure.persistence.ScheduleStatus
|
import com.sangdol.roomescape.schedule.infrastructure.persistence.ScheduleStatus
|
||||||
import io.github.oshai.kotlinlogging.KLogger
|
import io.github.oshai.kotlinlogging.KLogger
|
||||||
import io.github.oshai.kotlinlogging.KotlinLogging
|
import io.github.oshai.kotlinlogging.KotlinLogging
|
||||||
import org.springframework.scheduling.annotation.EnableScheduling
|
|
||||||
import org.springframework.scheduling.annotation.Scheduled
|
import org.springframework.scheduling.annotation.Scheduled
|
||||||
import org.springframework.stereotype.Component
|
import org.springframework.stereotype.Component
|
||||||
import org.springframework.transaction.annotation.Transactional
|
import org.springframework.transaction.annotation.Transactional
|
||||||
@ -15,7 +14,6 @@ import java.util.concurrent.TimeUnit
|
|||||||
private val log: KLogger = KotlinLogging.logger {}
|
private val log: KLogger = KotlinLogging.logger {}
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
@EnableScheduling
|
|
||||||
class IncompletedReservationScheduler(
|
class IncompletedReservationScheduler(
|
||||||
private val scheduleRepository: ScheduleRepository,
|
private val scheduleRepository: ScheduleRepository,
|
||||||
private val reservationRepository: ReservationRepository
|
private val reservationRepository: ReservationRepository
|
||||||
@ -24,10 +22,10 @@ class IncompletedReservationScheduler(
|
|||||||
@Scheduled(initialDelay = 1, fixedRate = 1, timeUnit = TimeUnit.MINUTES)
|
@Scheduled(initialDelay = 1, fixedRate = 1, timeUnit = TimeUnit.MINUTES)
|
||||||
@Transactional
|
@Transactional
|
||||||
fun processExpiredHoldSchedule() {
|
fun processExpiredHoldSchedule() {
|
||||||
log.info { "[processExpiredHoldSchedule] 만료 시간이 지난 ${ScheduleStatus.HOLD} 상태의 일정 재활성화 시작" }
|
log.debug { "[processExpiredHoldSchedule] 만료 시간이 지난 ${ScheduleStatus.HOLD} 상태의 일정 재활성화 시작" }
|
||||||
|
|
||||||
val targets: List<Long> = scheduleRepository.findAllExpiredHeldSchedules(Instant.now()).also {
|
val targets: List<Long> = scheduleRepository.findAllExpiredHeldSchedules(Instant.now()).also {
|
||||||
log.info { "[processExpiredHoldSchedule] ${it.size} 개의 일정 조회 완료" }
|
log.debug { "[processExpiredHoldSchedule] ${it.size} 개의 일정 조회 완료" }
|
||||||
}
|
}
|
||||||
|
|
||||||
scheduleRepository.releaseHeldSchedules(targets).also {
|
scheduleRepository.releaseHeldSchedules(targets).also {
|
||||||
@ -38,7 +36,7 @@ class IncompletedReservationScheduler(
|
|||||||
@Scheduled(initialDelay = 1, fixedRate = 1, timeUnit = TimeUnit.MINUTES)
|
@Scheduled(initialDelay = 1, fixedRate = 1, timeUnit = TimeUnit.MINUTES)
|
||||||
@Transactional
|
@Transactional
|
||||||
fun processExpiredReservation() {
|
fun processExpiredReservation() {
|
||||||
log.info { "[processExpiredReservation] 결제되지 않은 예약 만료 처리 시작" }
|
log.debug { "[processExpiredReservation] 결제되지 않은 예약 만료 처리 시작" }
|
||||||
|
|
||||||
val targets: List<Long> = reservationRepository.findAllExpiredReservation().also {
|
val targets: List<Long> = reservationRepository.findAllExpiredReservation().also {
|
||||||
log.info { "[processExpiredReservation] ${it.size} 개의 예약 조회 완료" }
|
log.info { "[processExpiredReservation] ${it.size} 개의 예약 조회 완료" }
|
||||||
|
|||||||
@ -34,7 +34,7 @@ class AdminScheduleService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun searchSchedules(storeId: Long, date: LocalDate?, themeId: Long?): AdminScheduleSummaryListResponse {
|
fun searchSchedules(storeId: Long, date: LocalDate?, themeId: Long?): AdminScheduleSummaryListResponse {
|
||||||
log.info { "[searchSchedules] 일정 검색 시작: storeId=$storeId, date=$date, themeId=$themeId" }
|
log.debug { "[searchSchedules] 일정 검색 시작: storeId=$storeId, date=$date, themeId=$themeId" }
|
||||||
|
|
||||||
val searchDate = date ?: KoreaDate.today()
|
val searchDate = date ?: KoreaDate.today()
|
||||||
|
|
||||||
@ -44,14 +44,12 @@ class AdminScheduleService(
|
|||||||
.sortedBy { it.time }
|
.sortedBy { it.time }
|
||||||
|
|
||||||
return schedules.toAdminSummaryResponse()
|
return schedules.toAdminSummaryResponse()
|
||||||
.also {
|
.also { log.info { "[searchSchedules] ${it.schedules.size} 개의 일정 조회 완료" } }
|
||||||
log.info { "[searchSchedules] ${it.schedules.size} 개의 일정 조회 완료" }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findScheduleAudit(id: Long): AuditingInfo {
|
fun findScheduleAudit(id: Long): AuditingInfo {
|
||||||
log.info { "[findDetail] 일정 감사 정보 조회 시작: id=$id" }
|
log.debug { "[findDetail] 일정 감사 정보 조회 시작: id=$id" }
|
||||||
|
|
||||||
val schedule: ScheduleEntity = findOrThrow(id)
|
val schedule: ScheduleEntity = findOrThrow(id)
|
||||||
|
|
||||||
@ -64,7 +62,7 @@ class AdminScheduleService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun createSchedule(storeId: Long, request: ScheduleCreateRequest): ScheduleCreateResponse {
|
fun createSchedule(storeId: Long, request: ScheduleCreateRequest): ScheduleCreateResponse {
|
||||||
log.info { "[createSchedule] 일정 생성 시작: storeId=${storeId}, date=${request.date}, time=${request.time}, themeId=${request.themeId}" }
|
log.debug { "[createSchedule] 일정 생성 시작: storeId=${storeId}, date=${request.date}, time=${request.time}, themeId=${request.themeId}" }
|
||||||
|
|
||||||
scheduleValidator.validateCanCreate(storeId, request)
|
scheduleValidator.validateCanCreate(storeId, request)
|
||||||
|
|
||||||
@ -79,14 +77,12 @@ class AdminScheduleService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
return ScheduleCreateResponse(schedule.id)
|
return ScheduleCreateResponse(schedule.id)
|
||||||
.also {
|
.also { log.info { "[createSchedule] 일정 생성 완료: id=${it.id}" } }
|
||||||
log.info { "[createSchedule] 일정 생성 완료: id=${it.id}" }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun updateSchedule(id: Long, request: ScheduleUpdateRequest) {
|
fun updateSchedule(id: Long, request: ScheduleUpdateRequest) {
|
||||||
log.info { "[updateSchedule] 일정 수정 시작: id=$id, request=${request}" }
|
log.debug { "[updateSchedule] 일정 수정 시작: id=$id, request=${request}" }
|
||||||
|
|
||||||
if (request.isAllParamsNull()) {
|
if (request.isAllParamsNull()) {
|
||||||
log.info { "[updateSchedule] 일정 변경 사항 없음: id=$id" }
|
log.info { "[updateSchedule] 일정 변경 사항 없음: id=$id" }
|
||||||
@ -104,7 +100,7 @@ class AdminScheduleService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun deleteSchedule(id: Long) {
|
fun deleteSchedule(id: Long) {
|
||||||
log.info { "[deleteSchedule] 일정 삭제 시작: id=$id" }
|
log.debug { "[deleteSchedule] 일정 삭제 시작: id=$id" }
|
||||||
|
|
||||||
val schedule: ScheduleEntity = findOrThrow(id).also {
|
val schedule: ScheduleEntity = findOrThrow(id).also {
|
||||||
scheduleValidator.validateCanDelete(it)
|
scheduleValidator.validateCanDelete(it)
|
||||||
@ -116,7 +112,7 @@ class AdminScheduleService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findOrThrow(id: Long): ScheduleEntity {
|
private fun findOrThrow(id: Long): ScheduleEntity {
|
||||||
log.info { "[findOrThrow] 일정 조회 시작: id=$id" }
|
log.debug { "[findOrThrow] 일정 조회 시작: id=$id" }
|
||||||
|
|
||||||
return scheduleRepository.findByIdOrNull(id)
|
return scheduleRepository.findByIdOrNull(id)
|
||||||
?.also { log.info { "[findOrThrow] 일정 조회 완료: id=$id" } }
|
?.also { log.info { "[findOrThrow] 일정 조회 완료: id=$id" } }
|
||||||
|
|||||||
@ -30,13 +30,12 @@ class ScheduleService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun getStoreScheduleByDate(storeId: Long, date: LocalDate): ScheduleWithThemeListResponse {
|
fun getStoreScheduleByDate(storeId: Long, date: LocalDate): ScheduleWithThemeListResponse {
|
||||||
log.info { "[getStoreScheduleByDate] 매장 일정 조회: storeId=${storeId}, date=$date" }
|
log.debug { "[getStoreScheduleByDate] 매장 일정 조회 시작: storeId=${storeId}, date=$date" }
|
||||||
|
|
||||||
val currentDate: LocalDate = KoreaDate.today()
|
val currentDate: LocalDate = KoreaDate.today()
|
||||||
val currentTime: LocalTime = KoreaTime.now()
|
val currentTime: LocalTime = KoreaTime.now()
|
||||||
|
|
||||||
if (date.isBefore(currentDate)) {
|
if (date.isBefore(currentDate)) {
|
||||||
log.warn { "[getStoreScheduleByDate] 이전 날짜 선택으로 인한 실패: date=${date}" }
|
|
||||||
throw ScheduleException(ScheduleErrorCode.PAST_DATE_TIME)
|
throw ScheduleException(ScheduleErrorCode.PAST_DATE_TIME)
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -44,6 +43,7 @@ class ScheduleService(
|
|||||||
scheduleRepository.findStoreSchedulesWithThemeByDate(storeId, date)
|
scheduleRepository.findStoreSchedulesWithThemeByDate(storeId, date)
|
||||||
.filter { it.date.isAfter(currentDate) || it.time.isAfter(currentTime) }
|
.filter { it.date.isAfter(currentDate) || it.time.isAfter(currentTime) }
|
||||||
|
|
||||||
|
|
||||||
return schedules.toResponseWithTheme()
|
return schedules.toResponseWithTheme()
|
||||||
.also {
|
.also {
|
||||||
log.info { "[getStoreScheduleByDate] storeId=${storeId}, date=$date 인 ${it.schedules.size}개 일정 조회 완료" }
|
log.info { "[getStoreScheduleByDate] storeId=${storeId}, date=$date 인 ${it.schedules.size}개 일정 조회 완료" }
|
||||||
@ -52,7 +52,7 @@ class ScheduleService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun holdSchedule(id: Long) {
|
fun holdSchedule(id: Long) {
|
||||||
log.info { "[holdSchedule] 일정 Holding 시작: id=$id" }
|
log.debug { "[holdSchedule] 일정 Holding 시작: id=$id" }
|
||||||
|
|
||||||
val schedule = findForUpdateOrThrow(id).also {
|
val schedule = findForUpdateOrThrow(id).also {
|
||||||
scheduleValidator.validateCanHold(it)
|
scheduleValidator.validateCanHold(it)
|
||||||
@ -69,7 +69,7 @@ class ScheduleService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findStateWithLock(id: Long): ScheduleStateResponse {
|
fun findStateWithLock(id: Long): ScheduleStateResponse {
|
||||||
log.info { "[findDateTimeById] 일정 개요 조회 시작 : id=$id" }
|
log.debug { "[findDateTimeById] 일정 개요 조회 시작 : id=$id" }
|
||||||
|
|
||||||
val schedule: ScheduleEntity = scheduleRepository.findByIdForUpdate(id)
|
val schedule: ScheduleEntity = scheduleRepository.findByIdForUpdate(id)
|
||||||
?: run {
|
?: run {
|
||||||
@ -95,7 +95,7 @@ class ScheduleService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun changeStatus(scheduleId: Long, currentStatus: ScheduleStatus, changeStatus: ScheduleStatus) {
|
fun changeStatus(scheduleId: Long, currentStatus: ScheduleStatus, changeStatus: ScheduleStatus) {
|
||||||
log.info { "[reserveSchedule] 일정 상태 변경 시작: id=${scheduleId}, currentStatus=${currentStatus}, changeStatus=${changeStatus}" }
|
log.debug { "[reserveSchedule] 일정 상태 변경 시작: id=${scheduleId}, currentStatus=${currentStatus}, changeStatus=${changeStatus}" }
|
||||||
|
|
||||||
scheduleRepository.changeStatus(scheduleId, currentStatus, changeStatus).also {
|
scheduleRepository.changeStatus(scheduleId, currentStatus, changeStatus).also {
|
||||||
log.info { "[reserveSchedule] 일정 상태 변경 완료: id=${scheduleId}, currentStatus=${currentStatus}, changeStatus=${changeStatus}" }
|
log.info { "[reserveSchedule] 일정 상태 변경 완료: id=${scheduleId}, currentStatus=${currentStatus}, changeStatus=${changeStatus}" }
|
||||||
@ -103,7 +103,7 @@ class ScheduleService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findForUpdateOrThrow(id: Long): ScheduleEntity {
|
private fun findForUpdateOrThrow(id: Long): ScheduleEntity {
|
||||||
log.info { "[findForUpdateOrThrow] 일정 LOCK + 조회 시작: id=$id" }
|
log.debug { "[findForUpdateOrThrow] 일정 LOCK + 조회 시작: id=$id" }
|
||||||
|
|
||||||
return scheduleRepository.findByIdForUpdate(id)
|
return scheduleRepository.findByIdForUpdate(id)
|
||||||
?.also { log.info { "[findForUpdateOrThrow] 일정 조회 완료: id=$id" } }
|
?.also { log.info { "[findForUpdateOrThrow] 일정 조회 완료: id=$id" } }
|
||||||
|
|||||||
@ -59,7 +59,7 @@ class ScheduleValidator(
|
|||||||
|
|
||||||
private fun validateAlreadyExists(storeId: Long, date: LocalDate, themeId: Long, time: LocalTime) {
|
private fun validateAlreadyExists(storeId: Long, date: LocalDate, themeId: Long, time: LocalTime) {
|
||||||
if (scheduleRepository.existsDuplicate(storeId, date, themeId, time)) {
|
if (scheduleRepository.existsDuplicate(storeId, date, themeId, time)) {
|
||||||
log.info {
|
log.debug {
|
||||||
"[validateAlreadyExists] 동일한 날짜, 테마, 시간 존재로 인한 실패: date=${date} / themeId=${themeId} / time=${time}"
|
"[validateAlreadyExists] 동일한 날짜, 테마, 시간 존재로 인한 실패: date=${date} / themeId=${themeId} / time=${time}"
|
||||||
}
|
}
|
||||||
throw ScheduleException(ScheduleErrorCode.SCHEDULE_ALREADY_EXISTS)
|
throw ScheduleException(ScheduleErrorCode.SCHEDULE_ALREADY_EXISTS)
|
||||||
@ -71,7 +71,7 @@ class ScheduleValidator(
|
|||||||
val inputDateTime = LocalDateTime.of(date, time).truncatedTo(ChronoUnit.MINUTES)
|
val inputDateTime = LocalDateTime.of(date, time).truncatedTo(ChronoUnit.MINUTES)
|
||||||
|
|
||||||
if (inputDateTime.isBefore(now)) {
|
if (inputDateTime.isBefore(now)) {
|
||||||
log.info {
|
log.debug {
|
||||||
"[validateDateTime] 이전 시간 선택으로 인한 실패: date=${date} / time=${time}"
|
"[validateDateTime] 이전 시간 선택으로 인한 실패: date=${date} / time=${time}"
|
||||||
}
|
}
|
||||||
throw ScheduleException(ScheduleErrorCode.PAST_DATE_TIME)
|
throw ScheduleException(ScheduleErrorCode.PAST_DATE_TIME)
|
||||||
@ -82,7 +82,7 @@ class ScheduleValidator(
|
|||||||
scheduleRepository.findStoreSchedulesWithThemeByDate(storeId, date, themeId)
|
scheduleRepository.findStoreSchedulesWithThemeByDate(storeId, date, themeId)
|
||||||
.firstOrNull { it.containsTime(time) }
|
.firstOrNull { it.containsTime(time) }
|
||||||
?.let {
|
?.let {
|
||||||
log.info { "[validateTimeNotConflict] 시간이 겹치는 일정 존재: conflictSchedule(Id=${it.id}, time=${it.time}~${it.getEndAt()})" }
|
log.debug { "[validateTimeNotConflict] 시간이 겹치는 일정 존재: conflictSchedule(Id=${it.id}, time=${it.time}~${it.getEndAt()})" }
|
||||||
throw ScheduleException(ScheduleErrorCode.SCHEDULE_TIME_CONFLICT)
|
throw ScheduleException(ScheduleErrorCode.SCHEDULE_TIME_CONFLICT)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -35,7 +35,7 @@ class StoreService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun getDetail(id: Long): StoreDetailResponse {
|
fun getDetail(id: Long): StoreDetailResponse {
|
||||||
log.info { "[getDetail] 매장 상세 조회 시작: id=${id}" }
|
log.debug { "[getDetail] 매장 상세 조회 시작: id=${id}" }
|
||||||
|
|
||||||
val store: StoreEntity = findOrThrow(id)
|
val store: StoreEntity = findOrThrow(id)
|
||||||
val region = regionService.findRegionInfo(store.regionCode)
|
val region = regionService.findRegionInfo(store.regionCode)
|
||||||
@ -47,7 +47,7 @@ class StoreService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun register(request: StoreRegisterRequest): StoreRegisterResponse {
|
fun register(request: StoreRegisterRequest): StoreRegisterResponse {
|
||||||
log.info { "[register] 매장 등록 시작: name=${request.name}" }
|
log.debug { "[register] 매장 등록 시작: name=${request.name}" }
|
||||||
|
|
||||||
storeValidator.validateCanRegister(request)
|
storeValidator.validateCanRegister(request)
|
||||||
|
|
||||||
@ -70,7 +70,7 @@ class StoreService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun update(id: Long, request: StoreUpdateRequest) {
|
fun update(id: Long, request: StoreUpdateRequest) {
|
||||||
log.info { "[update] 매장 수정 시작: id=${id}, request=${request}" }
|
log.debug { "[update] 매장 수정 시작: id=${id}, request=${request}" }
|
||||||
|
|
||||||
storeValidator.validateCanUpdate(request)
|
storeValidator.validateCanUpdate(request)
|
||||||
|
|
||||||
@ -83,7 +83,7 @@ class StoreService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun disableById(id: Long) {
|
fun disableById(id: Long) {
|
||||||
log.info { "[inactive] 매장 비활성화 시작: id=${id}" }
|
log.debug { "[inactive] 매장 비활성화 시작: id=${id}" }
|
||||||
|
|
||||||
findOrThrow(id).apply {
|
findOrThrow(id).apply {
|
||||||
this.disable()
|
this.disable()
|
||||||
@ -94,7 +94,7 @@ class StoreService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun getAllActiveStores(sidoCode: String?, sigunguCode: String?): StoreNameListResponse {
|
fun getAllActiveStores(sidoCode: String?, sigunguCode: String?): StoreNameListResponse {
|
||||||
log.info { "[getAllActiveStores] 전체 매장 조회 시작" }
|
log.debug { "[getAllActiveStores] 전체 매장 조회 시작" }
|
||||||
|
|
||||||
val regionCode: String? = when {
|
val regionCode: String? = when {
|
||||||
sidoCode == null && sigunguCode != null -> throw StoreException(StoreErrorCode.SIDO_CODE_REQUIRED)
|
sidoCode == null && sigunguCode != null -> throw StoreException(StoreErrorCode.SIDO_CODE_REQUIRED)
|
||||||
@ -108,7 +108,7 @@ class StoreService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findStoreInfo(id: Long): StoreInfoResponse {
|
fun findStoreInfo(id: Long): StoreInfoResponse {
|
||||||
log.info { "[findStoreInfo] 매장 정보 조회 시작: id=${id}" }
|
log.debug { "[findStoreInfo] 매장 정보 조회 시작: id=${id}" }
|
||||||
|
|
||||||
val store: StoreEntity = findOrThrow(id)
|
val store: StoreEntity = findOrThrow(id)
|
||||||
|
|
||||||
@ -117,7 +117,7 @@ class StoreService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun getAuditInfo(store: StoreEntity): AuditingInfo {
|
private fun getAuditInfo(store: StoreEntity): AuditingInfo {
|
||||||
log.info { "[getAuditInfo] 감사 정보 조회 시작: storeId=${store.id}" }
|
log.debug { "[getAuditInfo] 감사 정보 조회 시작: storeId=${store.id}" }
|
||||||
val createdBy = adminService.findOperatorOrUnknown(store.createdBy)
|
val createdBy = adminService.findOperatorOrUnknown(store.createdBy)
|
||||||
val updatedBy = adminService.findOperatorOrUnknown(store.updatedBy)
|
val updatedBy = adminService.findOperatorOrUnknown(store.updatedBy)
|
||||||
|
|
||||||
@ -132,7 +132,7 @@ class StoreService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findOrThrow(id: Long): StoreEntity {
|
private fun findOrThrow(id: Long): StoreEntity {
|
||||||
log.info { "[findOrThrow] 매장 조회 시작: id=${id}" }
|
log.debug { "[findOrThrow] 매장 조회 시작: id=${id}" }
|
||||||
|
|
||||||
return storeRepository.findActiveStoreById(id)
|
return storeRepository.findActiveStoreById(id)
|
||||||
?.also {
|
?.also {
|
||||||
|
|||||||
@ -31,21 +31,21 @@ class StoreValidator(
|
|||||||
|
|
||||||
private fun validateDuplicateNameExist(name: String) {
|
private fun validateDuplicateNameExist(name: String) {
|
||||||
if (storeRepository.existsByName(name)) {
|
if (storeRepository.existsByName(name)) {
|
||||||
log.info { "[StoreValidator.validateDuplicateNameExist] 이름 중복: name=${name}" }
|
log.debug { "[StoreValidator.validateDuplicateNameExist] 이름 중복: name=${name}" }
|
||||||
throw StoreException(StoreErrorCode.STORE_NAME_DUPLICATED)
|
throw StoreException(StoreErrorCode.STORE_NAME_DUPLICATED)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun validateDuplicateContactExist(contact: String) {
|
private fun validateDuplicateContactExist(contact: String) {
|
||||||
if (storeRepository.existsByContact(contact)) {
|
if (storeRepository.existsByContact(contact)) {
|
||||||
log.info { "[StoreValidator.validateDuplicateContact] 연락처 중복: contact=${contact}" }
|
log.debug { "[StoreValidator.validateDuplicateContact] 연락처 중복: contact=${contact}" }
|
||||||
throw StoreException(StoreErrorCode.STORE_CONTACT_DUPLICATED)
|
throw StoreException(StoreErrorCode.STORE_CONTACT_DUPLICATED)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun validateDuplicateAddressExist(address: String) {
|
private fun validateDuplicateAddressExist(address: String) {
|
||||||
if (storeRepository.existsByAddress(address)) {
|
if (storeRepository.existsByAddress(address)) {
|
||||||
log.info { "[StoreValidator.validateDuplicateAddress] 주소 중복: address=${address}" }
|
log.debug { "[StoreValidator.validateDuplicateAddress] 주소 중복: address=${address}" }
|
||||||
throw StoreException(StoreErrorCode.STORE_ADDRESS_DUPLICATED)
|
throw StoreException(StoreErrorCode.STORE_ADDRESS_DUPLICATED)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -30,7 +30,7 @@ class AdminThemeService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findThemeSummaries(): ThemeSummaryListResponse {
|
fun findThemeSummaries(): ThemeSummaryListResponse {
|
||||||
log.info { "[findAdminThemes] 관리자 페이지에서의 테마 목록 조회 시작" }
|
log.debug { "[findAdminThemes] 관리자 페이지에서의 테마 목록 조회 시작" }
|
||||||
|
|
||||||
return themeRepository.findAll()
|
return themeRepository.findAll()
|
||||||
.toSummaryListResponse()
|
.toSummaryListResponse()
|
||||||
@ -39,7 +39,7 @@ class AdminThemeService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findThemeDetail(id: Long): ThemeDetailResponse {
|
fun findThemeDetail(id: Long): ThemeDetailResponse {
|
||||||
log.info { "[findAdminThemeDetail] 관리자 페이지에서의 테마 상세 정보 조회 시작: id=${id}" }
|
log.debug { "[findAdminThemeDetail] 관리자 페이지에서의 테마 상세 정보 조회 시작: id=${id}" }
|
||||||
|
|
||||||
val theme: ThemeEntity = findOrThrow(id)
|
val theme: ThemeEntity = findOrThrow(id)
|
||||||
|
|
||||||
@ -53,7 +53,7 @@ class AdminThemeService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findActiveThemes(): ThemeNameListResponse {
|
fun findActiveThemes(): ThemeNameListResponse {
|
||||||
log.info { "[findActiveThemes] open 상태인 모든 테마 조회 시작" }
|
log.debug { "[findActiveThemes] open 상태인 모든 테마 조회 시작" }
|
||||||
|
|
||||||
return themeRepository.findActiveThemes()
|
return themeRepository.findActiveThemes()
|
||||||
.toNameListResponse()
|
.toNameListResponse()
|
||||||
@ -65,7 +65,7 @@ class AdminThemeService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun createTheme(request: ThemeCreateRequest): ThemeCreateResponse {
|
fun createTheme(request: ThemeCreateRequest): ThemeCreateResponse {
|
||||||
log.info { "[createTheme] 테마 생성 시작: name=${request.name}" }
|
log.debug { "[createTheme] 테마 생성 시작: name=${request.name}" }
|
||||||
|
|
||||||
themeValidator.validateCanCreate(request)
|
themeValidator.validateCanCreate(request)
|
||||||
|
|
||||||
@ -80,7 +80,7 @@ class AdminThemeService(
|
|||||||
@CacheEvict(cacheNames = ["theme-details"], key = "#id")
|
@CacheEvict(cacheNames = ["theme-details"], key = "#id")
|
||||||
@Transactional
|
@Transactional
|
||||||
fun deleteTheme(id: Long) {
|
fun deleteTheme(id: Long) {
|
||||||
log.info { "[deleteTheme] 테마 삭제 시작: id=${id}" }
|
log.debug { "[deleteTheme] 테마 삭제 시작: id=${id}" }
|
||||||
|
|
||||||
val theme: ThemeEntity = findOrThrow(id)
|
val theme: ThemeEntity = findOrThrow(id)
|
||||||
|
|
||||||
@ -92,7 +92,7 @@ class AdminThemeService(
|
|||||||
@CacheEvict(cacheNames = ["theme-details"], key = "#id")
|
@CacheEvict(cacheNames = ["theme-details"], key = "#id")
|
||||||
@Transactional
|
@Transactional
|
||||||
fun updateTheme(id: Long, request: ThemeUpdateRequest) {
|
fun updateTheme(id: Long, request: ThemeUpdateRequest) {
|
||||||
log.info { "[updateTheme] 테마 수정 시작: id=${id}, request=${request}" }
|
log.debug { "[updateTheme] 테마 수정 시작: id=${id}, request=${request}" }
|
||||||
|
|
||||||
if (request.isAllParamsNull()) {
|
if (request.isAllParamsNull()) {
|
||||||
log.info { "[updateTheme] 테마 변경 사항 없음: id=${id}" }
|
log.info { "[updateTheme] 테마 변경 사항 없음: id=${id}" }
|
||||||
@ -121,7 +121,7 @@ class AdminThemeService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun findOrThrow(id: Long): ThemeEntity {
|
private fun findOrThrow(id: Long): ThemeEntity {
|
||||||
log.info { "[findOrThrow] 테마 조회 시작: id=$id" }
|
log.debug { "[findOrThrow] 테마 조회 시작: id=$id" }
|
||||||
|
|
||||||
return themeRepository.findByIdOrNull(id)
|
return themeRepository.findByIdOrNull(id)
|
||||||
?.also { log.info { "[findOrThrow] 테마 조회 완료: id=$id" } }
|
?.also { log.info { "[findOrThrow] 테마 조회 완료: id=$id" } }
|
||||||
|
|||||||
@ -31,7 +31,7 @@ class ThemeService(
|
|||||||
@Cacheable(cacheNames = ["theme-details"], key="#id")
|
@Cacheable(cacheNames = ["theme-details"], key="#id")
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findInfoById(id: Long): ThemeInfoResponse {
|
fun findInfoById(id: Long): ThemeInfoResponse {
|
||||||
log.info { "[findInfoById] 테마 조회 시작: id=$id" }
|
log.debug { "[findInfoById] 테마 조회 시작: id=$id" }
|
||||||
|
|
||||||
val theme = themeRepository.findByIdOrNull(id)?.also {
|
val theme = themeRepository.findByIdOrNull(id)?.also {
|
||||||
themeDetailQueryRequestCount.increment()
|
themeDetailQueryRequestCount.increment()
|
||||||
@ -46,7 +46,7 @@ class ThemeService(
|
|||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findMostReservedThemeLastWeek(count: Int): ThemeInfoListResponse {
|
fun findMostReservedThemeLastWeek(count: Int): ThemeInfoListResponse {
|
||||||
log.info { "[findMostReservedThemeLastWeek] 인기 테마 조회 시작: count=$count" }
|
log.debug { "[findMostReservedThemeLastWeek] 인기 테마 조회 시작: count=$count" }
|
||||||
|
|
||||||
val previousWeekSunday = DateUtils.getSundayOfPreviousWeek(KoreaDate.today())
|
val previousWeekSunday = DateUtils.getSundayOfPreviousWeek(KoreaDate.today())
|
||||||
val previousWeekSaturday = previousWeekSunday.plusDays(6)
|
val previousWeekSaturday = previousWeekSunday.plusDays(6)
|
||||||
|
|||||||
@ -29,7 +29,7 @@ class UserService(
|
|||||||
) {
|
) {
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findCredentialsByAccount(email: String): UserLoginCredentials {
|
fun findCredentialsByAccount(email: String): UserLoginCredentials {
|
||||||
log.info { "[findCredentialsByAccount] 회원 조회 시작: email=${email}" }
|
log.debug { "[findCredentialsByAccount] 회원 조회 시작: email=${email}" }
|
||||||
|
|
||||||
return userRepository.findByEmail(email)
|
return userRepository.findByEmail(email)
|
||||||
?.let {
|
?.let {
|
||||||
@ -37,14 +37,13 @@ class UserService(
|
|||||||
it.toCredentials()
|
it.toCredentials()
|
||||||
}
|
}
|
||||||
?: run {
|
?: run {
|
||||||
log.info { "[findCredentialsByAccount] 회원 조회 실패" }
|
|
||||||
throw UserException(UserErrorCode.USER_NOT_FOUND)
|
throw UserException(UserErrorCode.USER_NOT_FOUND)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional(readOnly = true)
|
@Transactional(readOnly = true)
|
||||||
fun findContactById(id: Long): UserContactResponse {
|
fun findContactById(id: Long): UserContactResponse {
|
||||||
log.info { "[findContactById] 회원 연락 정보 조회 시작: id=${id}" }
|
log.debug { "[findContactById] 회원 연락 정보 조회 시작: id=${id}" }
|
||||||
|
|
||||||
val user = findOrThrow(id)
|
val user = findOrThrow(id)
|
||||||
|
|
||||||
@ -56,7 +55,7 @@ class UserService(
|
|||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun signup(request: UserCreateRequest): UserCreateResponse {
|
fun signup(request: UserCreateRequest): UserCreateResponse {
|
||||||
log.info { "[signup] 회원가입 시작: request:$request" }
|
log.debug { "[signup] 회원가입 시작: request:$request" }
|
||||||
|
|
||||||
userValidator.validateCanSignup(request.email, request.phone)
|
userValidator.validateCanSignup(request.email, request.phone)
|
||||||
|
|
||||||
|
|||||||
@ -15,14 +15,14 @@ class UserValidator(
|
|||||||
) {
|
) {
|
||||||
|
|
||||||
fun validateCanSignup(email: String, phone: String) {
|
fun validateCanSignup(email: String, phone: String) {
|
||||||
log.info { "[UserValidator.validateCanSignup] 회원가입 가능 여부 검증 시작: email:$email / phone:$phone" }
|
log.debug { "[UserValidator.validateCanSignup] 회원가입 가능 여부 검증 시작: email:$email / phone:$phone" }
|
||||||
|
|
||||||
if (userRepository.existsByEmail(email)) {
|
if (userRepository.existsByEmail(email)) {
|
||||||
log.info { "[UserValidator.validateCanSignup] 중복된 이메일 입력으로 인한 실패: email:$email" }
|
log.debug { "[UserValidator.validateCanSignup] 중복된 이메일 입력으로 인한 실패: email:$email" }
|
||||||
throw UserException(UserErrorCode.EMAIL_ALREADY_EXISTS)
|
throw UserException(UserErrorCode.EMAIL_ALREADY_EXISTS)
|
||||||
}
|
}
|
||||||
if (userRepository.existsByPhone(phone)) {
|
if (userRepository.existsByPhone(phone)) {
|
||||||
log.info { "[UserValidator.validateCanSignup] 중복된 휴대폰 번호 입력으로 인한 실패: phone:$phone" }
|
log.debug { "[UserValidator.validateCanSignup] 중복된 휴대폰 번호 입력으로 인한 실패: phone:$phone" }
|
||||||
throw UserException(UserErrorCode.PHONE_ALREADY_EXISTS)
|
throw UserException(UserErrorCode.PHONE_ALREADY_EXISTS)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user