feat: 설문조사 구현

close: #27 

# 변경점 👍
1. 설문조사를 위한 api를 구현했습니다.
2. SMTP를 활용해서 설문조사를 작성하면 비동기로 이메일이 전송됩니다.

# 사진
<img width="1169" height="365" alt="스크린샷 2025-12-01 오후 5 49 04"
src="https://github.com/user-attachments/assets/d77c6fa8-a9bc-4c31-9fa4-69feaa8456b4"
/>

# 고민되는 부분
설문조사를 내용을 일단 DB에 저장하기는 하는데, 이걸 계속 남겨둬야할지 스케줄링으로 삭제해야할지 고민입니다. (개인적인
생각으로는 그래도 남겨두는게 좋지 않을지..)

Author: jinwon1234

build.gradle

@@ -62,6 +62,13 @@ dependencies {
 
 	// aws
 	implementation 'software.amazon.awssdk:s3:2.20.0'
+
+	// smtp
+	implementation 'org.springframework.boot:spring-boot-starter-mail'
+
+	// template engine for mail
+	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
+
 }
 
 tasks.named('test') {

src/main/java/apptive/team5/config/AsyncConfig.java

@@ -0,0 +1,34 @@
+package apptive.team5.config;
+
+import apptive.team5.global.AsyncExceptionHandler;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+@EnableAsync
+@Configuration
+public class AsyncConfig implements AsyncConfigurer {
+
+    @Bean("surveyMailSend")
+    public Executor surveyMailExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(50);
+        executor.setQueueCapacity(1000);
+        executor.setThreadNamePrefix("SurveyMail-");
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
+        executor.initialize();
+        return executor;
+    }
+
+    @Override
+    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+        return new AsyncExceptionHandler();
+    }
+}

src/main/java/apptive/team5/global/AsyncExceptionHandler.java

@@ -0,0 +1,18 @@
+package apptive.team5.global;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Configuration;
+
+import java.lang.reflect.Method;
+
+@Configuration
+@Slf4j
+public class AsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
+
+    @Override
+    public void handleUncaughtException(Throwable ex, Method method, Object... params) {
+        log.info("예외 메서드 = {},  예외 메세지 {}", method.getName(), ex.getMessage());
+
+    }
+}

src/main/java/apptive/team5/mail/service/MailService.java

@@ -0,0 +1,53 @@
+package apptive.team5.mail.service;
+
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.thymeleaf.context.Context;
+import org.thymeleaf.spring6.SpringTemplateEngine;
+
+@Service
+@RequiredArgsConstructor
+public class MailService {
+
+    private final JavaMailSender javaMailSender;
+    private final SpringTemplateEngine templateEngine;
+    @Value("${spring.mail.survey.email}")
+    private String surveySubscribeEmail;
+    @Value("${spring.mail.username}")
+    private String senderEmail;
+
+    @Async("surveyMailSend")
+    public void sendSurveyMailMessage(String content) {
+
+        try {
+
+            MimeMessage message = javaMailSender.createMimeMessage();
+            MimeMessageHelper helper = new MimeMessageHelper(message, true, "UTF-8");
+            helper.setTo(surveySubscribeEmail);
+            helper.setSubject("KillingPart 설문조사가 도착했습니다.");
+            helper.setFrom(senderEmail, "KillingPart");
+            helper.setText(setContext(content), true);
+
+            javaMailSender.send(message);
+
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+
+    public String setContext(String content) {
+
+        Context context = new Context();
+        context.setVariable("content", content);
+        return templateEngine.process("survey", context);
+
+    }
+}
+
+

src/main/java/apptive/team5/survey/controller/SurveyController.java

@@ -0,0 +1,35 @@
+package apptive.team5.survey.controller;
+
+import apptive.team5.mail.service.MailService;
+import apptive.team5.survey.domain.SurveyEntity;
+import apptive.team5.survey.dto.SurveyCreateRequestDto;
+import apptive.team5.survey.service.SurveyService;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/surveys")
+@RequiredArgsConstructor
+public class SurveyController {
+
+    private final SurveyService surveyService;
+    private final MailService mailService;
+
+    @PostMapping
+    public ResponseEntity<Void> createSurvey(@AuthenticationPrincipal Long userId,
+                                             @Valid @RequestBody SurveyCreateRequestDto surveyCreateRequestDto) {
+
+        SurveyEntity survey = surveyService.save(surveyCreateRequestDto, userId);
+        mailService.sendSurveyMailMessage(survey.getContent());
+
+        return ResponseEntity.status(HttpStatus.CREATED).build();
+
+    }
+}

src/main/java/apptive/team5/survey/domain/SurveyEntity.java

@@ -0,0 +1,28 @@
+package apptive.team5.survey.domain;
+
+import apptive.team5.user.domain.UserEntity;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class SurveyEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(columnDefinition = "TEXT", nullable = false)
+    private String content;
+
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    private UserEntity user;
+
+    public SurveyEntity(String content, UserEntity user) {
+        this.content = content;
+        this.user = user;
+    }
+}

src/main/java/apptive/team5/survey/dto/SurveyCreateRequestDto.java

@@ -0,0 +1,12 @@
+package apptive.team5.survey.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+
+public record SurveyCreateRequestDto(
+
+        @NotBlank(message = "빈 값은 입력이 불가능합니다.")
+        @Size(min = 1, max = 1000, message = "1자 이상 1000자 이하로 작성 가능합니다.")
+        String content
+) {
+}

src/main/java/apptive/team5/survey/repository/SurveyRepository.java

@@ -0,0 +1,13 @@
+package apptive.team5.survey.repository;
+
+import apptive.team5.survey.domain.SurveyEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+
+public interface SurveyRepository extends JpaRepository<SurveyEntity, Long> {
+
+    @Modifying(clearAutomatically = true)
+    @Query("delete from SurveyEntity s where s.user.id = :userId")
+    void deleteByUserId(Long userId);
+}

src/main/java/apptive/team5/survey/service/SurveyLowService.java

@@ -0,0 +1,23 @@
+package apptive.team5.survey.service;
+
+import apptive.team5.survey.domain.SurveyEntity;
+import apptive.team5.survey.repository.SurveyRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class SurveyLowService {
+
+    private final SurveyRepository surveyRepository;
+
+    public SurveyEntity save(SurveyEntity surveyEntity) {
+        return surveyRepository.save(surveyEntity);
+    }
+
+    public void deleteByUserId(Long userId) {
+        surveyRepository.deleteByUserId(userId);
+    }
+}

src/main/java/apptive/team5/survey/service/SurveyService.java

@@ -0,0 +1,26 @@
+package apptive.team5.survey.service;
+
+import apptive.team5.survey.domain.SurveyEntity;
+import apptive.team5.survey.dto.SurveyCreateRequestDto;
+import apptive.team5.user.domain.UserEntity;
+import apptive.team5.user.service.UserLowService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class SurveyService {
+
+    private final SurveyLowService surveyLowService;
+    private final UserLowService userLowService;
+
+    public SurveyEntity save(SurveyCreateRequestDto surveyCreateRequestDto, Long userId) {
+
+        UserEntity userEntity = userLowService.getReferenceById(userId);
+
+        return surveyLowService.save(new SurveyEntity(surveyCreateRequestDto.content(), userEntity));
+    }
+
+}