DepositSuccessEventHandler.java

package life.mosu.mosuserver.application.virtualaccount.event;


import life.mosu.mosuserver.application.virtualaccount.VirtualAccountLogService;
import life.mosu.mosuserver.domain.application.entity.ApplicationStatus;
import life.mosu.mosuserver.domain.application.repository.ApplicationJpaRepository;
import life.mosu.mosuserver.domain.examapplication.repository.ExamApplicationJpaRepository;
import life.mosu.mosuserver.domain.virtualaccount.DepositStatus;
import life.mosu.mosuserver.domain.virtualaccount.VirtualAccountLogJpaEntity;
import life.mosu.mosuserver.global.exception.CustomRuntimeException;
import life.mosu.mosuserver.global.exception.ErrorCode;
import life.mosu.mosuserver.infra.notify.MailNotifier;
import life.mosu.mosuserver.infra.notify.dto.luna.LunaNotificationEvent;
import life.mosu.mosuserver.infra.notify.dto.luna.LunaNotificationStatus;
import life.mosu.mosuserver.infra.notify.dto.mail.DepositSuccessMailRequest;
import life.mosu.mosuserver.infra.notify.support.NotifyEventPublisher;
import life.mosu.mosuserver.presentation.virtualaccount.dto.event.DepositSuccessEvent;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@RequiredArgsConstructor
public class DepositSuccessEventHandler implements DepositEventHandler<DepositSuccessEvent> {

    private final VirtualAccountLogService virtualAccountLogService;
    private final MailNotifier<DepositSuccessMailRequest> mailer;
    private final NotifyEventPublisher notifier;
    private final ExamApplicationJpaRepository examApplicationJpaRepository;
    private final ApplicationJpaRepository applicationJpaRepository;
    @Override
    @Transactional
    public void handle(DepositSuccessEvent event) {
        var log = virtualAccountLogService.updateVirtualAccountLog(
                event.getOrderId(),
                DepositStatus.DONE
        );
        var exam = examApplicationJpaRepository.findByApplicationId(log.getApplicationId())
                .stream().findFirst()
                .orElseThrow(
                        () -> new CustomRuntimeException(ErrorCode.EXAM_APPLICATION_NOT_FOUND));

        var application = applicationJpaRepository.findById(log.getApplicationId())
                .orElseThrow(
                        () -> new CustomRuntimeException(ErrorCode.APPLICATION_LIST_NOT_FOUND));
        if (application.getStatus() == ApplicationStatus.PENDING) {
            application.changeStatus(ApplicationStatus.APPROVED);
        }
        LunaNotificationEvent lunaNotificationEvent = LunaNotificationEvent.create(
                LunaNotificationStatus.APPLICATION_GUEST_SUCCESS,
                exam.getUserId(), exam.getId());

        notifier.notify(lunaNotificationEvent);
        sendMail(log, event.getFormattedCreatedAt());
    }

    /**
     * 이벤트 핸들러에서 가상계좌 입금 성공 시 메일을 발송합니다. ( 관리자 확인 용)
     *
     * @param log
     * @param createdAt
     */
    private void sendMail(VirtualAccountLogJpaEntity log, String createdAt) {
        DepositSuccessMailRequest request = DepositSuccessMailRequest.of(
                log.getOrderId(),
                log.getAccountNumber(),
                log.getBankName(),
                log.getCustomerName(),
                createdAt
        );
        mailer.send(request);
    }
}