[DDING-108] 동아리 지원 결과 email 전송 API 구현

build.gradle

@@ -55,6 +55,7 @@ dependencies {
     implementation 'io.sentry:sentry-logback:7.6.0'
     implementation 'com.fasterxml.jackson.core:jackson-core'
     implementation 'com.github.f4b6a3:uuid-creator:6.0.0'
+    implementation 'software.amazon.awssdk:ses:2.24.0'
 
     //security
     implementation 'org.springframework.boot:spring-boot-starter-security'

src/main/java/ddingdong/ddingdongBE/common/config/AmazonS3Config.java

@@ -7,6 +7,10 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
+import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.ses.SesClient;
 
 @Configuration
 public class AmazonS3Config {
@@ -30,4 +34,14 @@ public AmazonS3Client amazonS3Client() {
                 .build();
     }
 
+    @Bean
+    public SesClient sesClient() {
+        return SesClient.builder()
+                .region(Region.AP_NORTHEAST_2)
+                .credentialsProvider(StaticCredentialsProvider.create(
+                        AwsBasicCredentials.create(accessKey, secretKey)
+                ))
+                .build();
+    }
+
 }

src/main/java/ddingdong/ddingdongBE/common/config/AsyncConfig.java

@@ -0,0 +1,32 @@
+package ddingdong.ddingdongBE.common.config;
+
+import java.util.concurrent.Executor;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+import org.springframework.aop.interceptor.SimpleAsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig implements AsyncConfigurer {
+
+    @Override
+    public Executor getAsyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(5);
+        executor.setMaxPoolSize(10);
+        executor.setQueueCapacity(500);
+        executor.setThreadNamePrefix("EmailAsync-");
+        executor.initialize();
+        return executor;
+    }
+
+    @Override
+    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+        return new SimpleAsyncUncaughtExceptionHandler();
+    }
+
+
+}

src/main/java/ddingdong/ddingdongBE/domain/form/api/CentralFormApi.java

@@ -2,6 +2,7 @@
 
 import ddingdong.ddingdongBE.auth.PrincipalDetails;
 import ddingdong.ddingdongBE.domain.form.controller.dto.request.CreateFormRequest;
+import ddingdong.ddingdongBE.domain.form.controller.dto.request.SendApplicationResultEmailRequest;
 import ddingdong.ddingdongBE.domain.form.controller.dto.request.UpdateFormRequest;
 import ddingdong.ddingdongBE.domain.form.controller.dto.response.FormListResponse;
 import ddingdong.ddingdongBE.domain.form.controller.dto.response.FormResponse;
@@ -115,4 +116,12 @@ FormStatisticsResponse getFormStatistics(
     @SecurityRequirement(name = "AccessToken")
     @PostMapping("/my/forms/{formId}/members/register-applicants")
     void registerMembers(@PathVariable("formId") Long formId);
+
+    @Operation(summary = "동아리 지원 결과 이메일 전송 API")
+    @ApiResponse(responseCode = "201", description = "동아리 지원 결과 이메일 전송 성공")
+    @ResponseStatus(HttpStatus.OK)
+    @SecurityRequirement(name = "AccessToken")
+    @PostMapping("/my/forms/{formId}/results/email")
+    void sendApplicationResultEmail(@PathVariable("formId") Long formId,
+                                    @RequestBody SendApplicationResultEmailRequest request);
 }

src/main/java/ddingdong/ddingdongBE/domain/form/controller/CentralFormController.java

@@ -3,6 +3,7 @@
 import ddingdong.ddingdongBE.auth.PrincipalDetails;
 import ddingdong.ddingdongBE.domain.form.api.CentralFormApi;
 import ddingdong.ddingdongBE.domain.form.controller.dto.request.CreateFormRequest;
+import ddingdong.ddingdongBE.domain.form.controller.dto.request.SendApplicationResultEmailRequest;
 import ddingdong.ddingdongBE.domain.form.controller.dto.request.UpdateFormRequest;
 import ddingdong.ddingdongBE.domain.form.controller.dto.response.FormListResponse;
 import ddingdong.ddingdongBE.domain.form.controller.dto.response.FormResponse;
@@ -93,4 +94,9 @@ public TextFieldStatisticsResponse getTextFieldStatistics(Long fieldId) {
     public void registerMembers(Long formId) {
         facadeCentralFormService.registerApplicantAsMember(formId);
     }
+
+    @Override
+    public void sendApplicationResultEmail(Long formId, SendApplicationResultEmailRequest request) {
+        facadeCentralFormService.sendApplicationResultEmail(request.toCommand(formId));
+    }
 }

src/main/java/ddingdong/ddingdongBE/domain/form/controller/dto/request/SendApplicationResultEmailRequest.java

@@ -0,0 +1,30 @@
+package ddingdong.ddingdongBE.domain.form.controller.dto.request;
+
+import ddingdong.ddingdongBE.domain.form.service.dto.command.SendApplicationResultEmailCommand;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+
+public record SendApplicationResultEmailRequest(
+
+        @Schema(description = "메일 제목", example = "제목")
+        @NotNull(message = "메일 제목은 필수입니다.")
+        String title,
+
+        @Schema(description = "전송 대상",
+                example = "FIRST_PASS",
+                allowableValues = {"FIRST_PASS", "FIRST_FAIL", "FINAL_PASS", "FINAL_FAIL"}
+        )
+        @NotNull(message = "전송 대상은 필수입니다.")
+        String target,
+
+        @Schema(description = "내용", example = "내용")
+        @NotNull(message = "메일 내용은 필수입니다.")
+        String message
+) {
+
+    public SendApplicationResultEmailCommand toCommand(Long formId) {
+        return new SendApplicationResultEmailCommand(formId, title, target, message);
+    }
+
+
+}

src/main/java/ddingdong/ddingdongBE/domain/form/service/FacadeCentralFormService.java

@@ -1,6 +1,7 @@
 package ddingdong.ddingdongBE.domain.form.service;
 
 import ddingdong.ddingdongBE.domain.form.service.dto.command.CreateFormCommand;
+import ddingdong.ddingdongBE.domain.form.service.dto.command.SendApplicationResultEmailCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.command.UpdateFormCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormListQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormQuery;
@@ -29,4 +30,6 @@ public interface FacadeCentralFormService {
     void registerApplicantAsMember(Long formId);
 
     TextFieldStatisticsQuery getTextFieldStatistics(Long fieldId);
+
+    void sendApplicationResultEmail(SendApplicationResultEmailCommand command);
 }

src/main/java/ddingdong/ddingdongBE/domain/form/service/FacadeCentralFormServiceImpl.java

@@ -13,6 +13,7 @@
 import ddingdong.ddingdongBE.domain.form.entity.FormField;
 import ddingdong.ddingdongBE.domain.form.service.dto.command.CreateFormCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.command.CreateFormCommand.CreateFormFieldCommand;
+import ddingdong.ddingdongBE.domain.form.service.dto.command.SendApplicationResultEmailCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.command.UpdateFormCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.command.UpdateFormCommand.UpdateFormFieldCommand;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormListQuery;
@@ -21,30 +22,38 @@
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormStatisticsQuery.ApplicantStatisticQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormStatisticsQuery.DepartmentStatisticQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.FormStatisticsQuery.FieldStatisticsQuery;
+import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplication;
+import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplicationStatus;
+import ddingdong.ddingdongBE.domain.formapplication.service.FormApplicationService;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.MultipleFieldStatisticsQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.MultipleFieldStatisticsQuery.OptionStatisticQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.TextFieldStatisticsQuery;
 import ddingdong.ddingdongBE.domain.form.service.dto.query.TextFieldStatisticsQuery.TextStatisticsQuery;
-import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplication;
-import ddingdong.ddingdongBE.domain.formapplication.service.FormApplicationService;
 import ddingdong.ddingdongBE.domain.user.entity.User;
+import ddingdong.ddingdongBE.email.SesEmailService;
+import ddingdong.ddingdongBE.email.dto.EmailContent;
 import java.time.LocalDate;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
 @Transactional(readOnly = true)
+@Slf4j
 public class FacadeCentralFormServiceImpl implements FacadeCentralFormService {
 
     private final FormService formService;
     private final FormFieldService formFieldService;
     private final ClubService clubService;
     private final FormStatisticService formStatisticService;
     private final FormApplicationService formApplicationService;
+    private final SesEmailService sesEmailService;
 
     @Transactional
     @Override
@@ -132,14 +141,16 @@ public MultipleFieldStatisticsQuery getMultipleFieldStatistics(Long fieldId) {
     @Override
     @Transactional
     public void registerApplicantAsMember(Long formId) {
-        List<FormApplication> finalPassedFormApplications = formApplicationService.getAllFinalPassedByFormId(
-                formId);
+        List<FormApplication> finalPassedFormApplications = formApplicationService.getAllFinalPassedByFormId(formId);
         finalPassedFormApplications.forEach(formApplication -> {
             Club club = formApplication.getForm().getClub();
-            ClubMember clubMember = ClubMember.builder().name(formApplication.getName())
+            ClubMember clubMember = ClubMember.builder()
+                    .name(formApplication.getName())
                     .studentNumber(formApplication.getStudentNumber())
                     .department(formApplication.getDepartment())
-                    .phoneNumber(formApplication.getPhoneNumber()).position(MEMBER).build();
+                    .phoneNumber(formApplication.getPhoneNumber())
+                    .position(MEMBER)
+                    .build();
             club.addClubMember(clubMember);
         });
     }
@@ -155,6 +166,23 @@ public TextFieldStatisticsQuery getTextFieldStatistics(Long fieldId) {
         return new TextFieldStatisticsQuery(type, textStatisticsQueries);
     }
 
+    @Override
+    public void sendApplicationResultEmail(SendApplicationResultEmailCommand command) {
+        List<FormApplication> formApplications = formApplicationService.getAllByFormIdAndFormApplicationStatus(
+                command.formId(),
+                FormApplicationStatus.findStatus(command.target())
+        );
+        EmailContent emailContent = EmailContent.of(command.title(), command.message());
+        CompletableFuture<Void> future = sesEmailService.sendBulkResultEmails(formApplications, emailContent);
+
+        try {
+            future.get(5, TimeUnit.MINUTES);  // 최대 5분 대기
+        } catch (Exception e) {
+            log.error("Failed to send bulk emails", e);
+            throw new RuntimeException("이메일 전송 중 오류가 발생했습니다.", e);
+        }
+    }
+
     private FormListQuery buildFormListQuery(Form form) {
         boolean isActive = TimeUtils.isDateInRange(LocalDate.now(), form.getStartDate(),
                 form.getEndDate());
@@ -177,13 +205,13 @@ public void validateDuplicationDate(Club club, LocalDate startDate, LocalDate en
     }
 
     private List<FormField> toUpdateFormFields(Form originform,
-            List<UpdateFormFieldCommand> updateFormFieldCommands) {
+                                               List<UpdateFormFieldCommand> updateFormFieldCommands) {
         return updateFormFieldCommands.stream()
                 .map(formFieldCommand -> formFieldCommand.toEntity(originform)).toList();
     }
 
     private List<FormField> toCreateFormFields(Form savedForm,
-            List<CreateFormFieldCommand> createFormFieldCommands) {
+                                               List<CreateFormFieldCommand> createFormFieldCommands) {
         return createFormFieldCommands.stream()
                 .map(formFieldCommand -> formFieldCommand.toEntity(savedForm)).toList();
     }

src/main/java/ddingdong/ddingdongBE/domain/form/service/dto/command/SendApplicationResultEmailCommand.java

@@ -0,0 +1,10 @@
+package ddingdong.ddingdongBE.domain.form.service.dto.command;
+
+public record SendApplicationResultEmailCommand(
+        Long formId,
+        String title,
+        String target,
+        String message
+) {
+
+}

src/main/java/ddingdong/ddingdongBE/domain/formapplication/repository/FormApplicationRepository.java

@@ -2,6 +2,7 @@
 
 import ddingdong.ddingdongBE.domain.form.entity.Form;
 import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplication;
+import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplicationStatus;
 import ddingdong.ddingdongBE.domain.formapplication.repository.dto.DepartmentInfo;
 import ddingdong.ddingdongBE.domain.formapplication.repository.dto.RecentFormInfo;
 import java.time.LocalDate;
@@ -15,19 +16,19 @@
 @Repository
 public interface FormApplicationRepository extends JpaRepository<FormApplication, Long> {
 
-  @Query(value = """
-      select *
-        from form_application f
-        where (:currentCursorId = -1 or id < :currentCursorId)
-        and f.form_id = :formId
-        order by f.id DESC
-        limit :size
-      """, nativeQuery = true)
-  Slice<FormApplication> findPageByFormIdOrderById(
-      @Param("formId") Long formId,
-      @Param("size") int size,
-      @Param("currentCursorId") Long currentCursorId
-  );
+    @Query(value = """
+            select *
+              from form_application f
+              where (:currentCursorId = -1 or id < :currentCursorId)
+              and f.form_id = :formId
+              order by f.id DESC
+              limit :size
+            """, nativeQuery = true)
+    Slice<FormApplication> findPageByFormIdOrderById(
+            @Param("formId") Long formId,
+            @Param("size") int size,
+            @Param("currentCursorId") Long currentCursorId
+    );
 
     Long countByForm(Form form);
 
@@ -63,11 +64,14 @@ List<RecentFormInfo> findRecentFormByDateWithApplicationCount(
             @Param("date") LocalDate date,
             @Param("size") int size
     );
+
     @Query(value = """
             select fa
             from FormApplication fa
             where fa.form.id = :formId and (fa.status = 'FINAL_PASS' or (fa.status = 'FIRST_PASS' and fa.form.hasInterview = false))
             """)
     List<FormApplication> findAllFinalPassedByFormId(@Param("formId") Long formId);
 
+    List<FormApplication> getAllByFormIdAndStatus(Long formId, FormApplicationStatus status);
+
 }

src/main/java/ddingdong/ddingdongBE/domain/formapplication/service/FormApplicationService.java

@@ -1,6 +1,7 @@
 package ddingdong.ddingdongBE.domain.formapplication.service;
 
 import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplication;
+import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplicationStatus;
 import org.springframework.data.domain.Slice;
 
 import java.util.List;
@@ -16,4 +17,6 @@ public interface FormApplicationService {
     List<FormApplication> getAllById(List<Long> applicationIds);
 
     List<FormApplication> getAllFinalPassedByFormId(Long formId);
+
+    List<FormApplication> getAllByFormIdAndFormApplicationStatus(Long formId, FormApplicationStatus status);
 }

src/main/java/ddingdong/ddingdongBE/domain/formapplication/service/GeneralFormApplicationService.java

@@ -2,6 +2,7 @@
 
 import ddingdong.ddingdongBE.common.exception.PersistenceException.ResourceNotFound;
 import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplication;
+import ddingdong.ddingdongBE.domain.formapplication.entity.FormApplicationStatus;
 import ddingdong.ddingdongBE.domain.formapplication.repository.FormApplicationRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.PageRequest;
@@ -44,6 +45,11 @@ public List<FormApplication> getAllFinalPassedByFormId(Long formId) {
         return formApplicationRepository.findAllFinalPassedByFormId(formId);
     }
 
+    @Override
+    public List<FormApplication> getAllByFormIdAndFormApplicationStatus(Long formId, FormApplicationStatus status) {
+        return formApplicationRepository.getAllByFormIdAndStatus(formId, status);
+    }
+
     @Override
     public FormApplication getById(Long applicationId) {
         return formApplicationRepository.findById(applicationId)