[COT-264] Feature: 메일 전송 API 구현

build.gradle

@@ -51,6 +51,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 
     implementation 'org.springframework.boot:spring-boot-starter-mail'
+    implementation 'com.amazonaws:aws-java-sdk-ses:1.12.3'
 
     implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.2.0'
     implementation 'org.springframework.boot:spring-boot-starter-websocket'

src/main/java/org/cotato/csquiz/api/recruitment/controller/RecruitmentController.java

@@ -7,15 +7,18 @@
 import lombok.extern.slf4j.Slf4j;
 import org.cotato.csquiz.api.recruitment.dto.ChangeRecruitmentInfoRequest;
 import org.cotato.csquiz.api.recruitment.dto.RecruitmentInfoResponse;
+import org.cotato.csquiz.api.recruitment.dto.RequestNotificationRequest;
+import org.cotato.csquiz.api.recruitment.dto.RequestRecruitmentNotificationRequest;
 import org.cotato.csquiz.common.role.RoleAuthority;
+import org.cotato.csquiz.domain.auth.entity.Member;
 import org.cotato.csquiz.domain.auth.enums.MemberRole;
-import org.cotato.csquiz.api.recruitment.dto.RequestRecruitmentNotificationRequest;
 import org.cotato.csquiz.domain.recruitment.service.RecruitmentInformationService;
 import org.cotato.csquiz.domain.recruitment.service.RecruitmentNotificationService;
 import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -42,7 +45,7 @@ public ResponseEntity<RecruitmentInfoResponse> findRecruitmentInfo() {
     public ResponseEntity<Void> changeRecruitmentInfo(@RequestBody @Valid ChangeRecruitmentInfoRequest request) {
         recruitmentInformationService.changeRecruitmentInfo(request.isOpened(), request.startDate(), request.endDate(),
                 request.recruitmentUrl());
-      return ResponseEntity.noContent().build();
+        return ResponseEntity.noContent().build();
     }
 
     @PostMapping("/notification")
@@ -52,4 +55,13 @@ public ResponseEntity<Void> requestRecruitmentNotification(
         recruitmentNotificationService.requestRecruitmentNotification(request.email(), request.policyCheck());
         return ResponseEntity.noContent().build();
     }
+
+    @Operation(summary = "모집 알림 전송 API")
+    @RoleAuthority(MemberRole.ADMIN)
+    @PostMapping("/notification/requester")
+    public ResponseEntity<Void> requestRecruitmentNotification(@RequestBody @Valid RequestNotificationRequest request,
+                                                               @AuthenticationPrincipal Member member) {
+        recruitmentNotificationService.sendRecruitmentNotificationMail(request.generationNumber(), member);
+        return ResponseEntity.noContent().build();
+    }
 }

src/main/java/org/cotato/csquiz/api/recruitment/dto/RequestNotificationRequest.java

@@ -0,0 +1,9 @@
+package org.cotato.csquiz.api.recruitment.dto;
+
+import jakarta.validation.constraints.NotNull;
+
+public record RequestNotificationRequest(
+        @NotNull
+        Integer generationNumber
+) {
+}

src/main/java/org/cotato/csquiz/common/config/AwsSesConfig.java

@@ -0,0 +1,34 @@
+package org.cotato.csquiz.common.config;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.services.simpleemail.AmazonSimpleEmailService;
+import com.amazonaws.services.simpleemail.AmazonSimpleEmailServiceClientBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class AwsSesConfig {
+
+    @Value("${cloud.aws.credentials.accessKey}")
+    private String accessKey;
+    @Value("${cloud.aws.credentials.secretKey}")
+    private String secretKey;
+    @Value("${cloud.aws.region.static}")
+    private String region;
+
+
+    @Bean
+    public AmazonSimpleEmailService amazonSimpleEmailService() {
+        final BasicAWSCredentials basicAWSCredentials = new BasicAWSCredentials(accessKey, secretKey);
+        final AWSStaticCredentialsProvider awsStaticCredentialsProvider = new AWSStaticCredentialsProvider(
+                basicAWSCredentials
+        );
+
+        return AmazonSimpleEmailServiceClientBuilder.standard()
+                .withCredentials(awsStaticCredentialsProvider)
+                .withRegion(region)
+                .build();
+    }
+}

src/main/java/org/cotato/csquiz/common/config/CotatoConfiguration.java

@@ -20,4 +20,15 @@ public Executor quizSendThreadPoolExecutor() {
         taskExecutor.initialize();
         return taskExecutor;
     }
+
+    @Bean("emailSendThreadPoolExecutor")
+    public Executor emailSendThreadPoolExecutor() {
+        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
+        taskExecutor.setCorePoolSize(20);
+        taskExecutor.setMaxPoolSize(100);
+        taskExecutor.setQueueCapacity(10000);
+        taskExecutor.setThreadNamePrefix("email-send-thread-");
+        taskExecutor.initialize();
+        return taskExecutor;
+    }
 }

src/main/java/org/cotato/csquiz/common/email/AwsMailSender.java

@@ -0,0 +1,49 @@
+package org.cotato.csquiz.common.email;
+
+import com.amazonaws.services.simpleemail.AmazonSimpleEmailService;
+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 java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class AwsMailSender {
+
+    private final AmazonSimpleEmailService ses;
+
+    @Value("${cloud.aws.ses.emailAddress}")
+    private String from;
+
+    public void sendRawMessageBody(String recipient, String htmlBody, String subject) {
+        Content subjectContent = new Content(subject);
+        subjectContent.setCharset("UTF-8");
+
+        Content bodyContent = new Content(htmlBody);
+        bodyContent.setCharset("UTF-8");
+        Body messageBody = createHtmlBody(bodyContent);
+
+        SendEmailRequest req = new SendEmailRequest(
+                from,
+                new Destination(List.of(recipient)),
+                new Message(
+                        new Content(subject),
+                        messageBody
+                )
+        );
+        ses.sendEmail(req);
+    }
+
+    private Body createHtmlBody(Content content) {
+        Body messageBody = new Body();
+        messageBody.setHtml(content);
+        return messageBody;
+    }
+}

src/main/java/org/cotato/csquiz/domain/recruitment/email/EmailContent.java

@@ -0,0 +1,7 @@
+package org.cotato.csquiz.domain.recruitment.email;
+
+public record EmailContent(
+        String subject,
+        String htmlBody
+) {
+}

src/main/java/org/cotato/csquiz/domain/recruitment/email/RecruitmentEmailFactory.java

@@ -0,0 +1,47 @@
+package org.cotato.csquiz.domain.recruitment.email;
+
+public class RecruitmentEmailFactory {
+    private static final String LINK_URL = "https://www.cotato.kr";
+
+    public static EmailContent createForGeneration(int generation) {
+        String subject = generation + "기 모집이 시작됐습니다.";
+
+        String htmlBody = """
+                <html>
+                  <body style="margin:0;padding:0;font-family:Arial,sans-serif;background:#f9f9f9;">
+                    <!-- HEADER -->
+                    <div style="background:#004cab;color:#fff;padding:20px;text-align:center;">
+                      <h1>코테이토 %d기 모집 안내</h1>
+                    </div>
+                    <!-- BODY -->
+                    <div style="padding:20px;background:#fff;">
+                      <p style="font-size:16px;line-height:1.5;">
+                        코테이토 %d기 모집이 시작됐습니다!
+                      </p>
+                      <p style="font-size:14px;">
+                        아래 버튼을 눌러 모집 신청을 진행해주세요.
+                      </p>
+                      <div style="text-align:center;margin:30px 0;">
+                        <a href="%s"
+                           style="display:inline-block;
+                                  padding:12px 24px;
+                                  background:#0066cc;
+                                  color:#fff;
+                                  text-decoration:none;
+                                  border-radius:4px;
+                                  font-weight:bold;">
+                          모집 신청하러 가기
+                        </a>
+                      </div>
+                    </div>
+                    <!-- FOOTER -->
+                    <div style="background:#f1f1f1;color:#777;padding:10px;text-align:center;font-size:12px;">
+                      &copy; 2025 코테이토. All rights reserved.
+                    </div>
+                  </body>
+                </html>
+                """.formatted(generation, generation, LINK_URL);
+
+        return new EmailContent(subject, htmlBody);
+    }
+}

src/main/java/org/cotato/csquiz/domain/recruitment/entity/RecruitmentNotification.java

@@ -34,4 +34,18 @@ public class RecruitmentNotification extends BaseTimeEntity {
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "sender")
     private Member sender;
+
+    private RecruitmentNotification(int generationNumber, LocalDateTime sendTime, Member sender) {
+        this.generationNumber = generationNumber;
+        this.sendTime = sendTime;
+        this.sender = sender;
+    }
+
+    public static RecruitmentNotification of(Member member, int generationNumber) {
+        return new RecruitmentNotification(
+                generationNumber,
+                LocalDateTime.now(),
+                member
+        );
+    }
 }

src/main/java/org/cotato/csquiz/domain/recruitment/entity/RecruitmentNotificationEmailLog.java

@@ -33,4 +33,16 @@ public class RecruitmentNotificationEmailLog extends BaseTimeEntity {
 
     @Column(name = "send_success")
     private Boolean sendSuccess;
+
+    private RecruitmentNotificationEmailLog(RecruitmentNotificationRequester receiver,
+                                            RecruitmentNotification notification, boolean sendSuccess) {
+        this.receiver = receiver;
+        this.notification = notification;
+        this.sendSuccess = sendSuccess;
+    }
+
+    public static RecruitmentNotificationEmailLog of(RecruitmentNotificationRequester receiver,
+                                                     RecruitmentNotification notification, boolean sendSuccess) {
+        return new RecruitmentNotificationEmailLog(receiver, notification, sendSuccess);
+    }
 }

src/main/java/org/cotato/csquiz/domain/recruitment/entity/RecruitmentNotificationRequester.java

@@ -45,6 +45,10 @@ private RecruitmentNotificationRequester(String email, Boolean policyChecked, Lo
         this.sendStatus = sendStatus;
     }
 
+    public void updateSendStatus(SendStatus sendStatus) {
+        this.sendStatus = sendStatus;
+    }
+
     public static RecruitmentNotificationRequester of(String email, Boolean policyChecked) {
         return new RecruitmentNotificationRequester(email, policyChecked, LocalDateTime.now(), SendStatus.NOT_SENT);
     }

src/main/java/org/cotato/csquiz/domain/recruitment/repository/RecruitmentNotificationEmailLogJdbcRepository.java

@@ -0,0 +1,47 @@
+package org.cotato.csquiz.domain.recruitment.repository;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.cotato.csquiz.domain.recruitment.entity.RecruitmentNotificationEmailLog;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class RecruitmentNotificationEmailLogJdbcRepository {
+
+    private static final int BATCH_SIZE = 1000;
+
+    private final JdbcTemplate jdbcTemplate;
+
+    public void saveAllWithBatch(List<RecruitmentNotificationEmailLog> logs) {
+
+        // language=MySQL
+        final String SQL = "INSERT INTO recruitment_notification_email_log "
+                + "(receiver_id, notification_id, send_success, created_at, modified_at) "
+                + "VALUES (?, ?, ?, now(), now())";
+
+        for (int start = 0; start < logs.size(); start += BATCH_SIZE) {
+            int end = Math.min(start + BATCH_SIZE, logs.size());
+            List<RecruitmentNotificationEmailLog> chunk = logs.subList(start, end);
+
+            jdbcTemplate.batchUpdate(SQL, new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    var log = chunk.get(i);
+                    ps.setLong(1, log.getReceiver().getId());
+                    ps.setLong(2, log.getNotification().getId());
+                    ps.setBoolean(3, log.getSendSuccess());
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return chunk.size();
+                }
+            });
+        }
+    }
+}

src/main/java/org/cotato/csquiz/domain/recruitment/repository/RecruitmentNotificationRepository.java

@@ -0,0 +1,7 @@
+package org.cotato.csquiz.domain.recruitment.repository;
+
+import org.cotato.csquiz.domain.recruitment.entity.RecruitmentNotification;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface RecruitmentNotificationRepository extends JpaRepository<RecruitmentNotification, Long> {
+}

src/main/java/org/cotato/csquiz/domain/recruitment/repository/RecruitmentNotificationRequesterRepository.java

@@ -1,10 +1,20 @@
 package org.cotato.csquiz.domain.recruitment.repository;
 
+import java.util.List;
 import org.cotato.csquiz.domain.recruitment.entity.RecruitmentNotificationRequester;
 import org.cotato.csquiz.domain.recruitment.enums.SendStatus;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 public interface RecruitmentNotificationRequesterRepository extends
         JpaRepository<RecruitmentNotificationRequester, Long> {
     boolean existsByEmailAndSendStatus(String recruitEmail, SendStatus sendStatus);
+
+    List<RecruitmentNotificationRequester> findAllBySendStatusIn(List<SendStatus> status);
+
+    @Modifying
+    @Query("update RecruitmentNotificationRequester r set r.sendStatus = :status where r.id in :ids")
+    void updateSendStatusByIds(@Param("status") SendStatus sendStatus, @Param("ids") List<Long> ids);
 }