Feature/mosu 28 : 알림톡 플로우 개선 (Luna Soft)

src/main/java/life/mosu/mosuserver/MosuServerApplication.java

@@ -1,13 +1,22 @@
 package life.mosu.mosuserver;
 
+import life.mosu.mosuserver.infra.notify.NotifyEventPublisher;
+import lombok.RequiredArgsConstructor;
+import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
-public class MosuServerApplication {
+@RequiredArgsConstructor
+public class MosuServerApplication implements CommandLineRunner {
+
+    private final NotifyEventPublisher publisher;
 
     public static void main(String[] args) {
         SpringApplication.run(MosuServerApplication.class, args);
     }
 
+    @Override
+    public void run(String... args) throws Exception {
+    }
 }

src/main/java/life/mosu/mosuserver/application/notify/NotifyService.java

@@ -1,41 +1,37 @@
 package life.mosu.mosuserver.application.notify;
 
-import life.mosu.mosuserver.domain.profile.ProfileJpaEntity;
 import life.mosu.mosuserver.domain.profile.ProfileJpaRepository;
 import life.mosu.mosuserver.global.exception.CustomRuntimeException;
 import life.mosu.mosuserver.global.exception.ErrorCode;
-import life.mosu.mosuserver.infra.notify.NotifyClientAdapter;
-import life.mosu.mosuserver.infra.notify.dto.NotifyEvent;
-import life.mosu.mosuserver.infra.notify.dto.NotifyEventRequest;
-import life.mosu.mosuserver.infra.notify.strategy.NotifyStrategy;
+import life.mosu.mosuserver.infra.notify.component.NotifySender;
+import life.mosu.mosuserver.infra.notify.dto.NotificationEvent;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+import life.mosu.mosuserver.infra.notify.resolver.NotifySenderResolver;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Service;
 
 @Slf4j
 @Service
 @RequiredArgsConstructor
 public class NotifyService {
 
-    private final NotifyClientAdapter notifier;
     private final ProfileJpaRepository profileJpaRepository;
-    private final ApplicationContext applicationContext;
+    private final NotifySenderResolver senderResolver;
+    private final NotifyVariableFactory notifyVariableFactory;
 
-    public void notify(NotifyEvent event) {
-        NotifyStrategy strategy = getNotifyStrategy(event.status().getStrategyName());
+    public void notify(NotificationEvent event) {
+        String phone = retrievePhoneNumberByUserId(event.userId());
+        NotificationVariable notifyVariable = notifyVariableFactory.create(event);
+        NotifySender<NotificationVariable> sender = senderResolver.resolve(
+                event.status());
 
-        ProfileJpaEntity profile = profileJpaRepository.findByUserId(event.targetId())
-                .orElseThrow(() -> new CustomRuntimeException(ErrorCode.PROFILE_NOT_FOUND));
-        String parsedPhoneNumber = profile.getPhoneNumber().replaceAll("-", "");
-
-        NotifyEventRequest request = strategy.apply(parsedPhoneNumber, event);
-
-        notifier.send(request);
+        sender.send(phone, event, notifyVariable);
     }
 
-    private NotifyStrategy getNotifyStrategy(String strategyName) {
-        return (NotifyStrategy) applicationContext.getBean(strategyName);
+    private String retrievePhoneNumberByUserId(Long userId) {
+        return profileJpaRepository.findByUserId(userId)
+                .orElseThrow(() -> new CustomRuntimeException(ErrorCode.PROFILE_NOT_FOUND))
+                .getPhoneNumberWithoutHyphen();
     }
-
 }

src/main/java/life/mosu/mosuserver/application/notify/NotifyVariableFactory.java

@@ -0,0 +1,96 @@
+package life.mosu.mosuserver.application.notify;
+
+import life.mosu.mosuserver.application.notify.dto.ApplicationNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.Exam1DayBeforeNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.Exam1WeekBeforeNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.Exam3DayBeforeNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.InquiryAnswerNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.RefundNotifyRequest;
+import life.mosu.mosuserver.application.notify.dto.SignUpNotifyRequest;
+import life.mosu.mosuserver.domain.applicationschool.ApplicationSchoolJpaEntity;
+import life.mosu.mosuserver.domain.applicationschool.ApplicationSchoolJpaRepository;
+import life.mosu.mosuserver.domain.applicationschool.ApplicationSchoolNotifyProjection;
+import life.mosu.mosuserver.domain.applicationschool.OneWeekNotifyProjection;
+import life.mosu.mosuserver.domain.inquiry.InquiryJpaEntity;
+import life.mosu.mosuserver.domain.inquiry.InquiryJpaRepository;
+import life.mosu.mosuserver.domain.refund.RefundJpaRepository;
+import life.mosu.mosuserver.domain.refund.RefundNotifyProjection;
+import life.mosu.mosuserver.global.exception.CustomRuntimeException;
+import life.mosu.mosuserver.global.exception.ErrorCode;
+import life.mosu.mosuserver.infra.notify.dto.NotificationEvent;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class NotifyVariableFactory {
+
+    private final InquiryJpaRepository inquiryJpaRepository;
+    private final ApplicationSchoolJpaRepository applicationSchoolJpaRepository;
+    private final RefundJpaRepository refundJpaRepository;
+
+    public NotificationVariable create(NotificationEvent event) {
+        return switch (event.status()) {
+            case INQUIRY_ANSWER_SUCCESS -> createInquiryAnswerVariable(event.targetId());
+            case REFUND_SUCCESS -> createRefundVariable(event.targetId());
+            case APPLICATION_SUCCESS -> createApplicationVariable(event.targetId());
+            case EXAM_1WEEK_BEFORE_REMINDER_INFO -> createExam1WeekBeforeVariable(event.targetId());
+            case EXAM_3DAY_BEFORE_REMINDER_INFO -> createExam3DayBeforeVariable(event.targetId());
+            case EXAM_1DAY_BEFORE_REMINDER_INFO -> createExam1DayBeforeVariable(event.targetId());
+            case SIGN_UP_SUCCESS -> createSignUpVariable();
+            default ->
+                    throw new IllegalArgumentException("지원하지 않는 NotifyStatus: " + event.status());
+        };
+    }
+
+    private NotificationVariable createSignUpVariable() {
+        return new SignUpNotifyRequest();
+    }
+
+    private NotificationVariable createInquiryAnswerVariable(Long targetId) {
+        InquiryJpaEntity inquiry = inquiryJpaRepository.findById(targetId)
+                .orElseThrow(() -> new CustomRuntimeException(ErrorCode.INQUIRY_NOT_FOUND));
+        return new InquiryAnswerNotifyRequest(inquiry.getTitle());
+    }
+
+    private NotificationVariable createRefundVariable(Long targetId) {
+        RefundNotifyProjection projection = refundJpaRepository.findRefundByApplicationSchoolId(
+                        targetId)
+                .orElseThrow(
+                        () -> new CustomRuntimeException(ErrorCode.APPLICATION_SCHOOL_NOT_FOUND));
+        return new RefundNotifyRequest(
+                projection.paymentKey(), projection.examDate(), projection.schoolName(),
+                projection.paymentMethod().getName(), projection.reason()
+        );
+    }
+
+    private NotificationVariable createApplicationVariable(Long targetId) {
+        ApplicationSchoolNotifyProjection projection = applicationSchoolJpaRepository.findPaymentByApplicationSchoolId(
+                targetId);
+        return ApplicationNotifyRequest.from(projection);
+    }
+
+    private NotificationVariable createExam1WeekBeforeVariable(Long targetId) {
+        OneWeekNotifyProjection projection = applicationSchoolJpaRepository.findOneWeekNotifyByApplicationSchoolId(
+                targetId);
+        return new Exam1WeekBeforeNotifyRequest(projection.examDate(), projection.paymentKey(),
+                projection.schoolName());
+    }
+
+    private NotificationVariable createExam3DayBeforeVariable(Long targetId) {
+        ApplicationSchoolJpaEntity entity = applicationSchoolJpaRepository.findById(targetId)
+                .orElseThrow(
+                        () -> new CustomRuntimeException(ErrorCode.APPLICATION_SCHOOL_NOT_FOUND));
+        return new Exam3DayBeforeNotifyRequest(entity.getExamDate(), entity.getExaminationNumber(),
+                entity.getSchoolName());
+    }
+
+    private NotificationVariable createExam1DayBeforeVariable(Long targetId) {
+        ApplicationSchoolJpaEntity entity = applicationSchoolJpaRepository.findById(targetId)
+                .orElseThrow(
+                        () -> new CustomRuntimeException(ErrorCode.APPLICATION_SCHOOL_NOT_FOUND));
+        return new Exam1DayBeforeNotifyRequest(entity.getExamDate(), entity.getExaminationNumber(),
+                entity.getSchoolName());
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/ApplicationNotifyRequest.java

@@ -0,0 +1,47 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.MY_PAGE;
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.WARNING_PAGE;
+
+import java.time.LocalDate;
+import java.util.Map;
+import life.mosu.mosuserver.domain.applicationschool.ApplicationSchoolNotifyProjection;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record ApplicationNotifyRequest(
+        String paymentKey,
+        LocalDate examDate,
+        String schoolName,
+        String lunch
+) implements NotificationVariable {
+
+    public static ApplicationNotifyRequest from(
+            ApplicationSchoolNotifyProjection applicationSchool) {
+        return new ApplicationNotifyRequest(
+                applicationSchool.paymentKey(),
+                applicationSchool.examDate(),
+                applicationSchool.schoolName(),
+                applicationSchool.lunch() != null ? applicationSchool.lunch().getLunchName() : ""
+        );
+    }
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(WARNING_PAGE, WARNING_PAGE),
+                NotificationButtonUrl.of(MY_PAGE, MY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "paymentKey", paymentKey,
+                "examDate", examDate.toString(),
+                "schoolName", schoolName,
+                "lunch", lunch
+        );
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/Exam1DayBeforeNotifyRequest.java

@@ -0,0 +1,34 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.INQUIRY_PAGE;
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.MY_PAGE;
+
+import java.time.LocalDate;
+import java.util.Map;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record Exam1DayBeforeNotifyRequest(
+        LocalDate examDate,
+        String examinationNumber,
+        String schoolName
+) implements NotificationVariable {
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(INQUIRY_PAGE, INQUIRY_PAGE),
+                NotificationButtonUrl.of(MY_PAGE, MY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "examDate", examDate.toString(),
+                "examinationNumber", examinationNumber,
+                "schoolName", schoolName
+        );
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/Exam1WeekBeforeNotifyRequest.java

@@ -0,0 +1,32 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.INQUIRY_PAGE;
+
+import java.time.LocalDate;
+import java.util.Map;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record Exam1WeekBeforeNotifyRequest(
+        LocalDate examDate,
+        String paymentKey,
+        String schoolName
+) implements NotificationVariable {
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(INQUIRY_PAGE, INQUIRY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "examDate", examDate.toString(),
+                "paymentKey", paymentKey,
+                "schoolName", schoolName
+        );
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/Exam3DayBeforeNotifyRequest.java

@@ -0,0 +1,34 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.INQUIRY_PAGE;
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.MY_PAGE;
+
+import java.time.LocalDate;
+import java.util.Map;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record Exam3DayBeforeNotifyRequest(
+        LocalDate examDate,
+        String examinationNumber,
+        String schoolName
+) implements NotificationVariable {
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(INQUIRY_PAGE, INQUIRY_PAGE),
+                NotificationButtonUrl.of(MY_PAGE, MY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "examDate", examDate.toString(),
+                "examinationNumber", examinationNumber,
+                "schoolName", schoolName
+        );
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/InquiryAnswerNotifyRequest.java

@@ -0,0 +1,27 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.INQUIRY_PAGE;
+
+import java.util.Map;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record InquiryAnswerNotifyRequest(
+        String title
+) implements NotificationVariable {
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(INQUIRY_PAGE, INQUIRY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "inquiryTitle", title
+        );
+    }
+}

src/main/java/life/mosu/mosuserver/application/notify/dto/RefundNotifyRequest.java

@@ -0,0 +1,38 @@
+package life.mosu.mosuserver.application.notify.dto;
+
+import static life.mosu.mosuserver.infra.notify.constant.NotifyRedirectUrlConstants.MY_PAGE;
+
+import java.time.LocalDate;
+import java.util.Map;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls;
+import life.mosu.mosuserver.infra.notify.dto.NotificationButtonUrls.NotificationButtonUrl;
+import life.mosu.mosuserver.infra.notify.dto.NotificationVariable;
+
+public record RefundNotifyRequest(
+        String paymentKey,
+        LocalDate examDate,
+        String schoolName,
+//        String amount,
+        String paymentMethod,
+        String reason
+) implements NotificationVariable {
+
+    @Override
+    public NotificationButtonUrls getNotificationButtonUrls() {
+        return NotificationButtonUrls.of(
+                NotificationButtonUrl.of(MY_PAGE, MY_PAGE)
+        );
+    }
+
+    @Override
+    public Map<String, String> toMap() {
+        return Map.of(
+                "paymentKey", paymentKey,
+                "examDate", examDate.toString(),
+                "schoolName", schoolName,
+                "amount", String.valueOf(1000),
+                "paymentMethod", paymentMethod,
+                "reason", reason
+        );
+    }
+}