[FEAT] AWS SES 메일 발송 기능 구현 (#26)

Author: kyukong

pom.xml

@@ -65,6 +65,13 @@
             <version>6.0.2.RELEASE</version>
         </dependency>
 
+        <!-- aws ses -->
+        <dependency>
+            <groupId>com.amazonaws</groupId>
+            <artifactId>aws-java-sdk-ses</artifactId>
+            <version>1.11.227</version>
+        </dependency>
+
 
         <!-- Spring -->
         <dependency>

src/main/java/com/oya/kr/global/support/MailSender.java

@@ -0,0 +1,12 @@
+package com.oya.kr.global.support;
+
+import com.oya.kr.global.support.dto.request.SenderRequest;
+
+/**
+ * @author 김유빈
+ * @since 2024.02.28
+ */
+public interface MailSender {
+
+    void send(SenderRequest request);
+}

src/main/java/com/oya/kr/global/support/SESSender.java

@@ -0,0 +1,49 @@
+package com.oya.kr.global.support;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.services.simpleemail.AmazonSimpleEmailService;
+import com.amazonaws.services.simpleemail.AmazonSimpleEmailServiceClientBuilder;
+import com.oya.kr.global.support.dto.request.SenderRequest;
+
+/**
+ * @author 김유빈
+ * @since 2024.02.28
+ */
+@Qualifier("SESSender")
+@Component
+public class SESSender implements MailSender {
+
+    private final String accessKey;
+    private final String secretKey;
+    private final String region;
+
+    public SESSender(
+        @Value("${aws.ses.access-key}") String accessKey,
+        @Value("${aws.ses.secret-key}") String secretKey,
+        @Value("${aws.ses.region}") String region) {
+        this.accessKey = accessKey;
+        this.secretKey = secretKey;
+        this.region = region;
+    }
+
+    /**
+     * AWS SES 를 이용하여 메일 발송
+     *
+     * @author 김유빈
+     * @since 2024.02.28
+     */
+    @Override
+    public void send(SenderRequest request) {
+        BasicAWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
+        AmazonSimpleEmailService client = AmazonSimpleEmailServiceClientBuilder
+            .standard()
+            .withCredentials(new AWSStaticCredentialsProvider(credentials))
+            .withRegion(region).build();
+        client.sendEmail(request.toSendRequestDto());
+    }
+}

src/main/java/com/oya/kr/global/support/dto/request/SenderRequest.java

@@ -0,0 +1,47 @@
+package com.oya.kr.global.support.dto.request;
+
+import java.util.List;
+
+import com.amazonaws.services.simpleemail.model.Body;
+import com.amazonaws.services.simpleemail.model.Content;
+import com.amazonaws.services.simpleemail.model.Destination;
+import com.amazonaws.services.simpleemail.model.Message;
+import com.amazonaws.services.simpleemail.model.SendEmailRequest;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+/**
+ * @author 김유빈
+ * @since 2024.02.28
+ */
+@Getter
+@RequiredArgsConstructor
+public class SenderRequest {
+
+    private final String from;
+    private final List<String> to;
+    private final String subject;
+    private final String content;
+
+    public SendEmailRequest toSendRequestDto() {
+        Destination destination = new Destination()
+            .withToAddresses(this.to);
+
+        Message message = new Message()
+            .withSubject(createContent(this.subject))
+            .withBody(new Body()
+                .withHtml(createContent(this.content)));
+
+        return new SendEmailRequest()
+            .withSource(this.from)
+            .withDestination(destination)
+            .withMessage(message);
+    }
+
+    private Content createContent(String text) {
+        return new Content()
+            .withCharset("UTF-8")
+            .withData(text);
+    }
+}

src/main/java/com/oya/kr/popup/service/PlanService.java

@@ -4,11 +4,14 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 
+import com.oya.kr.global.support.MailSender;
 import com.oya.kr.global.support.StorageConnector;
+import com.oya.kr.global.support.dto.request.SenderRequest;
 import com.oya.kr.popup.controller.dto.request.PlanSaveRequest;
 import com.oya.kr.popup.controller.dto.response.AllPlanResponse;
 import com.oya.kr.popup.controller.dto.response.AllPlansResponse;
@@ -41,12 +44,23 @@
  */
 @Service
 @Transactional
-@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
 public class PlanService {
 
     private final UserRepository userRepository;
     private final PlanRepository planRepository;
     private final StorageConnector s3Connector;
+    private final MailSender sesSender;
+
+    public PlanService(
+        UserRepository userRepository,
+        PlanRepository planRepository,
+        StorageConnector s3Connector,
+        @Qualifier("SESSender") MailSender sesSender) {
+        this.userRepository = userRepository;
+        this.planRepository = planRepository;
+        this.s3Connector = s3Connector;
+        this.sesSender = sesSender;
+    }
 
     /**
      * 카테고리 리스트 조회 기능 구현
@@ -231,6 +245,19 @@ public void wait(String email, Long planId) {
         Plan savedPlan = planRepository.findById(planId, savedUser);
         savedPlan.waiting();
         planRepository.updateEntranceStatus(savedPlan);
+
+        String title = "[THEPOP] 제안해주신 사업계획서가 대기 상태로 전환되었습니다.";
+        String content = String.format(
+            "%s 고객님, 안녕하세요.\n"
+                + "제안해주신 사업계획서가 대기 상태로 전환되었습니다.\n"
+                + "대기 상태에는 커뮤니티 게시글을 자유롭게 작성하실 수 있습니다.\n"
+                + "이후 제안이 승인되면 팝업스토어 게시글을 올려 팝업스토어를 홍보하실 수 있습니다.\n"
+                + "팝업스토어 제안에 감사드립니다.\n"
+                + "THEPOP 드림", savedUser.getNickname());
+
+        SenderRequest request = new SenderRequest(
+            savedUser.getEmail(), List.of(savedPlan.getUser().getEmail()), title, content);
+        sesSender.send(request);
     }
 
     /**
@@ -247,6 +274,18 @@ public void approve(String email, Long planId) {
         Plan savedPlan = planRepository.findById(planId, savedUser);
         savedPlan.approve();
         planRepository.updateEntranceStatus(savedPlan);
+
+        String title = "[THEPOP] 제안해주신 사업계획서가 승인되었습니다.";
+        String content = String.format(
+            "%s 고객님, 안녕하세요.\n"
+                + "팝업스토어 입점을 축하드립니다!\n"
+                + "사업계획서가 승인되어 팝업스토어 게시글을 올려 팝업스토어를 홍보하실 수 있습니다.\n"
+                + "팝업스토어 제안에 감사드립니다.\n"
+                + "THEPOP 드림", savedUser.getNickname());
+
+        SenderRequest request = new SenderRequest(
+            savedUser.getEmail(), List.of(savedPlan.getUser().getEmail()), title, content);
+        sesSender.send(request);
     }
 
     /**
@@ -263,5 +302,17 @@ public void deny(String email, Long planId) {
         Plan savedPlan = planRepository.findById(planId, savedUser);
         savedPlan.deny();
         planRepository.updateEntranceStatus(savedPlan);
+
+        String title = "[THEPOP] 제안해주신 사업계획서가 거절되었습니다.";
+        String content = String.format(
+            "%s 고객님, 안녕하세요.\n"
+                + "안타깝지만 제안해주신 사업계획서는 현대백화점과 함께하지 못하게 되었습니다.\n"
+                + "이후에 더 좋은 사업계획서가 있다면 언제든 연락 바랍니다.\n"
+                + "팝업스토어 제안에 감사드립니다.\n"
+                + "THEPOP 드림", savedUser.getNickname());
+
+        SenderRequest request = new SenderRequest(
+            savedUser.getEmail(), List.of(savedPlan.getUser().getEmail()), title, content);
+        sesSender.send(request);
     }
 }