SCRUM-126 이메일 알림 기능

src/main/java/com/wellmeet/config/EmailConfig.java

@@ -0,0 +1,17 @@
+package com.wellmeet.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.JavaMailSenderImpl;
+
+@Configuration
+@Profile("!test")
+public class EmailConfig {
+
+    @Bean
+    public JavaMailSender javaMailSender() {
+        return new JavaMailSenderImpl();
+    }
+}

src/main/java/com/wellmeet/exception/ErrorCode.java

@@ -6,6 +6,7 @@
 @Getter
 public enum ErrorCode {
 
+    EMAIL_NOT_FOUND(HttpStatus.NOT_FOUND, "이메일 정보를 찾을 수 없습니다."),
     SUBSCRIPTION_NOT_FOUND(HttpStatus.NOT_FOUND, "구독 정보를 찾을 수 없습니다."),
 
     FIELD_ERROR(HttpStatus.BAD_REQUEST, "입력이 잘못되었습니다."),
@@ -16,6 +17,7 @@ public enum ErrorCode {
     INTERNAL_SERVER_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부 오류가 발생했습니다."),
     CORS_ORIGIN_EMPTY(HttpStatus.INTERNAL_SERVER_ERROR, "CORS Origin 은 적어도 한 개 있어야 합니다"),
     WEB_PUSH_SEND_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "웹 푸시 전송에 실패했습니다."),
+    EMAIL_SEND_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "이메일 전송에 실패했습니다."),
     SENDER_NOT_FOUND(HttpStatus.BAD_REQUEST, "알림을 발송할 수 없습니다."),
     TEMPLATE_NOT_FOUND(HttpStatus.INTERNAL_SERVER_ERROR, "알림 템플릿을 찾을 수 없습니다.");
 

src/main/java/com/wellmeet/notification/consumer/dto/NotificationInfo.java

@@ -9,4 +9,9 @@ public class NotificationInfo {
 
     private NotificationType type;
     private String recipient;
+
+    public NotificationInfo(NotificationType type, String recipient) {
+        this.type = type;
+        this.recipient = recipient;
+    }
 }

src/main/java/com/wellmeet/notification/consumer/dto/NotificationMessage.java

@@ -12,6 +12,12 @@ public class NotificationMessage {
     private NotificationInfo notification;
     private Map<String, Object> payload;
 
+    public NotificationMessage(MessageHeader header, NotificationInfo notification, Map<String, Object> payload) {
+        this.header = header;
+        this.notification = notification;
+        this.payload = payload;
+    }
+
     public String getRecipient() {
         return notification.getRecipient();
     }

src/main/java/com/wellmeet/notification/email/domain/EmailSubscription.java

@@ -0,0 +1,34 @@
+package com.wellmeet.notification.email.domain;
+
+import com.wellmeet.common.domain.BaseEntity;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.validation.constraints.Email;
+import jakarta.validation.constraints.NotNull;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class EmailSubscription extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @NotNull
+    private String userId;
+
+    @NotNull
+    @Email
+    private String email;
+
+    public EmailSubscription(String userId, String email) {
+        this.userId = userId;
+        this.email = email;
+    }
+}

src/main/java/com/wellmeet/notification/email/repository/EmailSubscriptionRepository.java

@@ -0,0 +1,10 @@
+package com.wellmeet.notification.email.repository;
+
+import com.wellmeet.notification.email.domain.EmailSubscription;
+import java.util.Optional;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface EmailSubscriptionRepository extends JpaRepository<EmailSubscription, Long> {
+
+    Optional<EmailSubscription> findByUserId(String userId);
+}

src/main/java/com/wellmeet/notification/email/sender/EmailSender.java

@@ -0,0 +1,58 @@
+package com.wellmeet.notification.email.sender;
+
+import com.wellmeet.exception.ErrorCode;
+import com.wellmeet.exception.WellMeetNotificationException;
+import com.wellmeet.notification.Sender;
+import com.wellmeet.notification.consumer.dto.NotificationMessage;
+import com.wellmeet.notification.domain.NotificationChannel;
+import com.wellmeet.notification.email.domain.EmailSubscription;
+import com.wellmeet.notification.email.repository.EmailSubscriptionRepository;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import com.wellmeet.notification.template.NotificationTemplateFactory;
+import java.util.Map;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class EmailSender implements Sender {
+
+    private final EmailSubscriptionRepository emailSubscriptionRepository;
+    private final NotificationTemplateFactory templateFactory;
+    private final MailViewRenderer mailViewRenderer;
+    private final MailTransport mailTransport;
+
+    @Override
+    public boolean isEnabled(NotificationChannel channel) {
+        return NotificationChannel.EMAIL == channel;
+    }
+
+    @Override
+    public void send(NotificationMessage message) {
+        String userId = message.getNotification().getRecipient();
+        EmailSubscription subscription = emailSubscriptionRepository.findByUserId(userId)
+                .orElseThrow(() -> new WellMeetNotificationException(ErrorCode.EMAIL_NOT_FOUND));
+
+        NotificationTemplateData templateData = templateFactory.createTemplateData(
+                message.getNotification().getType(),
+                message.getPayload()
+        );
+
+        String subject = templateData.title();
+        String htmlContent = buildHtmlContent(templateData);
+        sendEmail(subscription.getEmail(), subject, htmlContent);
+    }
+
+    private String buildHtmlContent(NotificationTemplateData templateData) {
+        Map<String, String> variables = Map.of(
+                "title", templateData.title(),
+                "body", templateData.body(),
+                "url", templateData.url()
+        );
+        return mailViewRenderer.render("email-notification.html", variables);
+    }
+
+    private void sendEmail(String to, String subject, String htmlContent) {
+        mailTransport.send(to, subject, htmlContent);
+    }
+}

src/main/java/com/wellmeet/notification/email/sender/MailTransport.java

@@ -0,0 +1,34 @@
+package com.wellmeet.notification.email.sender;
+
+import com.wellmeet.exception.ErrorCode;
+import com.wellmeet.exception.WellMeetNotificationException;
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class MailTransport {
+
+    private final JavaMailSender javaMailSender;
+
+    public void send(String to, String subject, String htmlContent) {
+        try {
+            MimeMessage mimeMessage = javaMailSender.createMimeMessage();
+            MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true, "UTF-8");
+
+            helper.setTo(to);
+            helper.setSubject(subject);
+            helper.setText(htmlContent, true);
+
+            javaMailSender.send(mimeMessage);
+        } catch (Exception e) {
+            log.error("이메일 전송에 실패했습니다. to: {}, subject: {}", to, subject, e);
+            throw new WellMeetNotificationException(ErrorCode.EMAIL_SEND_FAILED);
+        }
+    }
+}

src/main/java/com/wellmeet/notification/email/sender/MailViewRenderer.java

@@ -0,0 +1,51 @@
+package com.wellmeet.notification.email.sender;
+
+import com.wellmeet.exception.ErrorCode;
+import com.wellmeet.exception.WellMeetNotificationException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StreamUtils;
+
+@Slf4j
+@Component
+public class MailViewRenderer {
+
+    private static final String TEMPLATE_BASE_PATH = "templates/";
+    private static final Pattern PLACEHOLDER_PATTERN = Pattern.compile("\\{([^}]+)\\}");
+
+    public String render(String templateName, Map<String, String> variables) {
+        String template = loadTemplate(templateName);
+        return replacePlaceholders(template, variables);
+    }
+
+    private String loadTemplate(String templateName) {
+        ClassPathResource resource = new ClassPathResource(TEMPLATE_BASE_PATH + templateName);
+        try (InputStream inputStream = resource.getInputStream()) {
+            return StreamUtils.copyToString(inputStream, StandardCharsets.UTF_8);
+        } catch (IOException e) {
+            log.error("이메일 템플릿 로딩에 실패했습니다. templateName: {}", templateName, e);
+            throw new WellMeetNotificationException(ErrorCode.EMAIL_SEND_FAILED);
+        }
+    }
+
+    private String replacePlaceholders(String template, Map<String, String> variables) {
+        Matcher matcher = PLACEHOLDER_PATTERN.matcher(template);
+        StringBuilder result = new StringBuilder();
+
+        while (matcher.find()) {
+            String key = matcher.group(1);
+            String value = variables.getOrDefault(key, matcher.group(0));
+            matcher.appendReplacement(result, Matcher.quoteReplacement(value));
+        }
+        matcher.appendTail(result);
+
+        return result.toString();
+    }
+}

src/main/java/com/wellmeet/notification/webpush/domain/PushSubscription.java

@@ -31,14 +31,11 @@ public class PushSubscription extends BaseEntity {
     @NotNull
     private String auth;
 
-    private boolean active;
-
     public PushSubscription(String userId, String endpoint, String p256dh, String auth) {
         this.userId = userId;
         this.endpoint = endpoint;
         this.p256dh = p256dh;
         this.auth = auth;
-        this.active = true;
     }
 
     public void update(PushSubscription updatedSubscription) {

src/main/resources/templates/email-notification.html

@@ -0,0 +1,77 @@
+<!DOCTYPE html>
+<html lang="ko">
+<head>
+    <meta charset="UTF-8">
+    <style>
+        body {
+            font-family: 'Helvetica Neue', Arial, sans-serif;
+            line-height: 1.6;
+            color: #333;
+            max-width: 600px;
+            margin: 0 auto;
+            padding: 20px;
+        }
+
+        .container {
+            background-color: #ffffff;
+            border-radius: 8px;
+            padding: 30px;
+            box-shadow: 0 2px 4px rgba(0, 0, 0, 0.1);
+        }
+
+        .header {
+            border-bottom: 3px solid #4A90E2;
+            padding-bottom: 20px;
+            margin-bottom: 30px;
+        }
+
+        .title {
+            color: #4A90E2;
+            font-size: 24px;
+            font-weight: bold;
+            margin: 0;
+        }
+
+        .content {
+            font-size: 16px;
+            color: #555;
+            margin-bottom: 30px;
+        }
+
+        .action-button {
+            display: inline-block;
+            padding: 12px 30px;
+            background-color: #4A90E2;
+            color: #ffffff;
+            text-decoration: none;
+            border-radius: 5px;
+            font-weight: bold;
+        }
+
+        .footer {
+            margin-top: 30px;
+            padding-top: 20px;
+            border-top: 1px solid #e0e0e0;
+            font-size: 12px;
+            color: #999;
+            text-align: center;
+        }
+    </style>
+</head>
+<body>
+<div class="container">
+    <div class="header">
+        <h1 class="title">{title}</h1>
+    </div>
+    <div class="content">
+        <p>{body}</p>
+    </div>
+    <div style="text-align: center;">
+        <a href="{url}" class="action-button">자세히 보기</a>
+    </div>
+    <div class="footer">
+        <p>이 이메일은 WellMeet 알림 서비스에서 자동으로 발송되었습니다.</p>
+    </div>
+</div>
+</body>
+</html>

src/test/java/com/wellmeet/BaseControllerTest.java

@@ -1,5 +1,6 @@
 package com.wellmeet;
 
+import com.wellmeet.config.EmailTestConfig;
 import com.wellmeet.config.WebPushTestConfig;
 import com.wellmeet.notification.webpush.repository.PushSubscriptionRepository;
 import io.restassured.RestAssured;
@@ -18,7 +19,7 @@
 @ExtendWith(DataBaseCleaner.class)
 @ActiveProfiles("test")
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
-@Import(WebPushTestConfig.class)
+@Import({WebPushTestConfig.class, EmailTestConfig.class})
 public abstract class BaseControllerTest {
 
     @Autowired

src/test/java/com/wellmeet/BaseServiceTest.java

@@ -1,5 +1,6 @@
 package com.wellmeet;
 
+import com.wellmeet.config.EmailTestConfig;
 import com.wellmeet.config.WebPushTestConfig;
 import com.wellmeet.notification.webpush.repository.PushSubscriptionRepository;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -11,7 +12,7 @@
 @ExtendWith(DataBaseCleaner.class)
 @ActiveProfiles("test")
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
-@Import(WebPushTestConfig.class)
+@Import({WebPushTestConfig.class, EmailTestConfig.class})
 public abstract class BaseServiceTest {
 
     @Autowired

src/test/java/com/wellmeet/WellmeetNotificationApplicationTests.java

@@ -1,5 +1,6 @@
 package com.wellmeet;
 
+import com.wellmeet.config.EmailTestConfig;
 import com.wellmeet.config.WebPushTestConfig;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
@@ -8,7 +9,7 @@
 
 @SpringBootTest
 @ActiveProfiles("test")
-@Import(WebPushTestConfig.class)
+@Import({WebPushTestConfig.class, EmailTestConfig.class})
 class WellmeetNotificationApplicationTests {
 
     @Test