개발 한 스푼

// @Order(1)인 DistributedLockAdvisor의 메서드
fun atTarget(joinPoint: ProceedingJoinPoint): Any? {
    val lockAnnotation = getAnnotation(joinPoint)
    val lockKeyList = getLockKeyList(joinPoint.args, lockAnnotation.keyClass)
    return lockRepository.withAllLock(lockKeyList) {
        joinPoint.proceed()
    }
}

@Transactional
@DistributedLock(keyClass = [GetTodayQuestion::class])
fun getOrCreateTodayQuestion(request: GetTodayQuestion): QuestionInfo {
    val user = getMember(request.memberId)
    val latestIssuedQuestion = questionOpenRepository.findLatestWithQuestionAndAnswer(user)
    val isTodayQuestion = latestIssuedQuestion?.openDate?.isToday() ?: false
    return if (isTodayQuestion) makeQuestionInfo(latestIssuedQuestion!!)
    else questionOpenDomainService.issueQuestion(request.memberId, request.today)
}

// 신고를 저장하는 @Transactional 메서드 안에서 실행되는 AOP
private fun bugReportEventPublish(result: Any?) {
    val event = (result as? ReportEvent) ?: throw ReportEventInvalidReturnException()
    val outbox = reportOutboxService.createPending(
        report = event.report,
        slackPayload = objectMapper.writeValueAsString(event.toSpecificMap())
    )
    eventPublisher.publishEvent(ReportOutboxCreatedEvent(outbox.id))
}

// 커밋 이후 최초 전송. 스케줄러 재처리도 같은 attemptSend를 거친다.
@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
fun sendReportAlarm(event: ReportOutboxCreatedEvent) {
    reportOutboxService.attemptSend(event.reportOutboxId)
}