[feat] 정책 변경 이메일 고지 시스템 구현

.github/workflows/cd.yml

@@ -67,12 +67,14 @@ jobs:
           V_DISCORD_WEBHOOK_5XX_URL: ${{ secrets.DISCORD_WEBHOOK_5XX_URL }}
           V_DISCORD_WEBHOOK_4XX_URL: ${{ secrets.DISCORD_WEBHOOK_4XX_URL }}
           V_DISCORD_WEBHOOK_INQUIRY_URL: ${{ secrets.DISCORD_WEBHOOK_INQUIRY_URL }}
+          V_MAIL_USERNAME: ${{ secrets.MAIL_USERNAME }}
+          V_MAIL_PASSWORD: ${{ secrets.MAIL_PASSWORD }}
         with:
           host: ${{ secrets.SERVER_HOST }}
           username: ${{ secrets.SERVER_USER }}
           key: ${{ secrets.SSH_PRIVATE_KEY }}
           port: 2222
-          envs: V_GHCR_TOKEN,V_GHCR_USER,V_DB_URL,V_DB_USERNAME,V_DB_PASSWORD,V_JWT_SECRET,V_GOOGLE_CLIENT_ID,V_GOOGLE_CLIENT_SECRET,V_KAKAO_CLIENT_ID,V_KAKAO_CLIENT_SECRET,V_CORS_ALLOWED_ORIGINS,V_OAUTH2_REDIRECT_BASE_URI,V_GOOGLE_REDIRECT_URI,V_KAKAO_REDIRECT_URI,V_DATA_PIPELINE_SECRET,V_DATA_PIPELINE_BASE_URL,V_REDIS_PASSWORD,V_DISCORD_WEBHOOK_5XX_URL,V_DISCORD_WEBHOOK_4XX_URL,V_DISCORD_WEBHOOK_INQUIRY_URL
+          envs: V_GHCR_TOKEN,V_GHCR_USER,V_DB_URL,V_DB_USERNAME,V_DB_PASSWORD,V_JWT_SECRET,V_GOOGLE_CLIENT_ID,V_GOOGLE_CLIENT_SECRET,V_KAKAO_CLIENT_ID,V_KAKAO_CLIENT_SECRET,V_CORS_ALLOWED_ORIGINS,V_OAUTH2_REDIRECT_BASE_URI,V_GOOGLE_REDIRECT_URI,V_KAKAO_REDIRECT_URI,V_DATA_PIPELINE_SECRET,V_DATA_PIPELINE_BASE_URL,V_REDIS_PASSWORD,V_DISCORD_WEBHOOK_5XX_URL,V_DISCORD_WEBHOOK_4XX_URL,V_DISCORD_WEBHOOK_INQUIRY_URL,V_MAIL_USERNAME,V_MAIL_PASSWORD
           script: |
             echo "$V_GHCR_TOKEN" | docker login ghcr.io -u "$V_GHCR_USER" --password-stdin
 
@@ -98,6 +100,8 @@ jobs:
             printf 'DISCORD_WEBHOOK_5XX_URL=%s\n' "$V_DISCORD_WEBHOOK_5XX_URL" >> ~/compose/be.env
             printf 'DISCORD_WEBHOOK_4XX_URL=%s\n' "$V_DISCORD_WEBHOOK_4XX_URL" >> ~/compose/be.env
             printf 'DISCORD_WEBHOOK_INQUIRY_URL=%s\n' "$V_DISCORD_WEBHOOK_INQUIRY_URL" >> ~/compose/be.env
+            printf 'MAIL_USERNAME=%s\n' "$V_MAIL_USERNAME" >> ~/compose/be.env
+            printf 'MAIL_PASSWORD=%s\n' "$V_MAIL_PASSWORD" >> ~/compose/be.env
 
             chmod +x ~/scripts/deploy.sh
             bash ~/scripts/deploy.sh

build.gradle

@@ -29,6 +29,9 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-security'
 	implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	implementation 'org.springframework.boot:spring-boot-starter-mail'
+	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
+	implementation 'org.springframework.boot:spring-boot-starter-batch'
 	implementation 'org.flywaydb:flyway-database-postgresql'
 	implementation 'io.jsonwebtoken:jjwt-api:0.12.6'
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.6'

src/main/java/com/Coming/Backend/BackendApplication.java

@@ -3,9 +3,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableJpaAuditing
+@EnableScheduling
 public class BackendApplication {
 
 	public static void main(String[] args) {

src/main/java/com/Coming/Backend/auth/entity/User.java

@@ -9,7 +9,6 @@
 import jakarta.persistence.GenerationType;
 import jakarta.persistence.Id;
 import jakarta.persistence.Table;
-import java.time.LocalDateTime;
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -51,26 +50,13 @@ public class User extends BaseTimeEntity {
     @Column(name = "birth_year")
     private Integer birthYear;
 
-    @Column(name = "agreed_terms")
-    private Boolean agreedTerms;
-
-    @Column(name = "agreed_privacy")
-    private Boolean agreedPrivacy;
-
     @Column(name = "agreed_marketing")
     private Boolean agreedMarketing;
 
-    @Column(name = "agreed_at")
-    private LocalDateTime agreedAt;
-
-    public void completeRegistration(String nickname, int birthYear,
-            boolean agreedTerms, boolean agreedPrivacy, boolean agreedMarketing) {
+    public void completeRegistration(String nickname, int birthYear, boolean agreedMarketing) {
         this.nickname = nickname;
         this.birthYear = birthYear;
-        this.agreedTerms = agreedTerms;
-        this.agreedPrivacy = agreedPrivacy;
         this.agreedMarketing = agreedMarketing;
-        this.agreedAt = LocalDateTime.now();
         this.role = UserRole.USER;
     }
 
@@ -91,14 +77,15 @@ public void updateEmail(String email) {
         this.email = email;
     }
 
+    public boolean hasNoEmail() {
+        return email == null || email.isBlank();
+    }
+
     public void reactivate() {
         this.status = UserStatus.ACTIVE;
         this.role = UserRole.PENDING;
         this.nickname = null;
         this.birthYear = null;
-        this.agreedTerms = null;
-        this.agreedPrivacy = null;
         this.agreedMarketing = null;
-        this.agreedAt = null;
     }
 }

src/main/java/com/Coming/Backend/auth/repository/UserRepository.java

@@ -1,6 +1,7 @@
 package com.Coming.Backend.auth.repository;
 
 import com.Coming.Backend.auth.entity.User;
+import com.Coming.Backend.auth.entity.UserStatus;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.Collection;
@@ -14,4 +15,6 @@ public interface UserRepository extends JpaRepository<User, Long> {
     List<User> findAllByIdIn(Collection<Long> ids);
 
     boolean existsByNickname(String nickname);
+
+    List<User> findByStatus(UserStatus status);
 }

src/main/java/com/Coming/Backend/auth/service/AuthService.java

@@ -25,6 +25,14 @@
 import com.Coming.Backend.auth.repository.UserRepository;
 import com.Coming.Backend.calendar.repository.UserConcertCalendarRepository;
 import com.Coming.Backend.inquiry.repository.InquiryRepository;
+import com.Coming.Backend.policy.entity.PolicyDocument;
+import com.Coming.Backend.policy.entity.PolicyType;
+import com.Coming.Backend.policy.entity.UserPolicyAgreement;
+import com.Coming.Backend.policy.exception.PolicyNotFoundException;
+import com.Coming.Backend.policy.repository.PolicyDocumentRepository;
+import com.Coming.Backend.policy.repository.UserPolicyAgreementRepository;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.dao.DataIntegrityViolationException;
@@ -43,6 +51,8 @@ public class AuthService {
     private final UserFollowArtistRepository userFollowArtistRepository;
     private final UserConcertCalendarRepository userConcertCalendarRepository;
     private final InquiryRepository inquiryRepository;
+    private final PolicyDocumentRepository policyDocumentRepository;
+    private final UserPolicyAgreementRepository userPolicyAgreementRepository;
 
     /**
      * Refresh Token을 검증하고 새 Access Token과 새 Refresh Token을 발급한다.
@@ -128,11 +138,11 @@ public TokenResponse register(Long userId, RegisterRequest request) {
         user.completeRegistration(
                 request.nickname(),
                 request.birthYear(),
-                request.agreedTerms(),
-                request.agreedPrivacy(),
                 Boolean.TRUE.equals(request.agreedMarketing())
         );
         try {
+            recordPolicyAgreement(userId, PolicyType.TERMS);
+            recordPolicyAgreement(userId, PolicyType.PRIVACY);
             userRepository.flush();
         } catch (DataIntegrityViolationException e) {
             throw new NicknameDuplicateException();
@@ -142,6 +152,25 @@ public TokenResponse register(Long userId, RegisterRequest request) {
         return new TokenResponse(accessToken);
     }
 
+    /**
+     * 현재 시행 중인 정책 버전에 대한 사용자 동의 이력을 기록한다. 이미 동의 이력이 있으면 건너뛴다(탈퇴 후 재가입 대비).
+     */
+    private void recordPolicyAgreement(Long userId, PolicyType type) {
+        PolicyDocument currentPolicy = policyDocumentRepository
+                .findFirstByTypeAndEffectiveDateLessThanEqualOrderByEffectiveDateDesc(type, LocalDate.now())
+                .orElseThrow(PolicyNotFoundException::new);
+        if (userPolicyAgreementRepository.existsByUserIdAndPolicyId(userId, currentPolicy.getId())) {
+            return;
+        }
+        userPolicyAgreementRepository.save(
+                UserPolicyAgreement.builder()
+                        .userId(userId)
+                        .policyId(currentPolicy.getId())
+                        .agreedAt(LocalDateTime.now())
+                        .build()
+        );
+    }
+
     private void validateRegisterRequest(RegisterRequest request) {
         if (!Boolean.TRUE.equals(request.agreedTerms()) || !Boolean.TRUE.equals(request.agreedPrivacy())) {
             throw new TermsNotAgreedException();

src/main/java/com/Coming/Backend/common/exception/ErrorCode.java

@@ -67,6 +67,10 @@ public enum ErrorCode {
     PIPELINE_SERVER_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "Data 파이프라인 서버 오류가 발생했습니다."),
     PIPELINE_TIMEOUT(HttpStatus.GATEWAY_TIMEOUT, "Data 파이프라인 응답이 지연되고 있습니다. 잠시 후 다시 확인해주세요."),
 
+    // Policy
+    POLICY_VERSION_DUPLICATE(HttpStatus.CONFLICT, "이미 등록된 정책 버전입니다."),
+    POLICY_NOT_FOUND(HttpStatus.NOT_FOUND, "존재하지 않는 정책입니다."),
+
     // Common
     RATE_LIMIT_EXCEEDED(HttpStatus.TOO_MANY_REQUESTS, "요청이 너무 많습니다. 잠시 후 다시 시도해주세요."),
     INVALID_INPUT(HttpStatus.BAD_REQUEST, "잘못된 입력값입니다."),

src/main/java/com/Coming/Backend/policy/batch/PolicyNotificationBatchConfig.java

@@ -0,0 +1,54 @@
+package com.Coming.Backend.policy.batch;
+
+import com.Coming.Backend.policy.entity.PolicyNotificationTarget;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.job.Job;
+import org.springframework.batch.core.job.builder.JobBuilder;
+import org.springframework.batch.core.job.parameters.RunIdIncrementer;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.Step;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.transaction.PlatformTransactionManager;
+
+@Configuration
+@RequiredArgsConstructor
+public class PolicyNotificationBatchConfig {
+
+    private static final int CHUNK_SIZE = 20;
+
+    private final JobRepository jobRepository;
+    private final PlatformTransactionManager transactionManager;
+    private final PolicyNotificationTargetCreationTasklet policyNotificationTargetCreationTasklet;
+    private final PolicyNotificationPendingTargetReader policyNotificationPendingTargetReader;
+    private final PolicyNotificationMailProcessor policyNotificationMailProcessor;
+    private final PolicyNotificationTargetWriter policyNotificationTargetWriter;
+
+    @Bean
+    public Job policyNotificationJob() {
+        return new JobBuilder("policyNotificationJob", jobRepository)
+                .incrementer(new RunIdIncrementer())
+                .start(targetCreationStep())
+                .next(mailSendStep())
+                .build();
+    }
+
+    @Bean
+    public Step targetCreationStep() {
+        return new StepBuilder("targetCreationStep", jobRepository)
+                .tasklet(policyNotificationTargetCreationTasklet, transactionManager)
+                .build();
+    }
+
+    @Bean
+    public Step mailSendStep() {
+        return new StepBuilder("mailSendStep", jobRepository)
+                .<PolicyNotificationTarget, PolicyNotificationTarget>chunk(CHUNK_SIZE)
+                .reader(policyNotificationPendingTargetReader)
+                .processor(policyNotificationMailProcessor)
+                .writer(policyNotificationTargetWriter)
+                .transactionManager(transactionManager)
+                .build();
+    }
+}

src/main/java/com/Coming/Backend/policy/batch/PolicyNotificationJobTrigger.java

@@ -0,0 +1,51 @@
+package com.Coming.Backend.policy.batch;
+
+import com.Coming.Backend.policy.event.PolicyRegisteredEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.job.Job;
+import org.springframework.batch.core.job.parameters.JobParameters;
+import org.springframework.batch.core.job.parameters.JobParametersBuilder;
+import org.springframework.batch.core.launch.JobOperator;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+/**
+ * 정책 등록 트랜잭션이 커밋된 후, 해당 정책에 대한 알림 대상 생성·메일 발송 배치를 실행한다.
+ * AFTER_COMMIT 콜백과 같은 스레드에서 배치(자체 트랜잭션 포함)를 직접 실행하면 커밋 중이던
+ * 트랜잭션 동기화 상태와 충돌해 JobInterruptedException이 발생하므로, 별도 스레드에서 실행하고
+ * join으로 대기해 호출자 입장에서는 동기로 완료를 기다리게 한다.
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class PolicyNotificationJobTrigger {
+
+    private final JobOperator jobOperator;
+    private final Job policyNotificationJob;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void onPolicyRegistered(PolicyRegisteredEvent event) {
+        Thread jobThread = Thread.ofVirtual().start(() -> runJob(event.policyId()));
+        try {
+            jobThread.join();
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            log.error("정책 알림 배치 대기 중 인터럽트 발생 — policyId: {}", event.policyId(), e);
+        }
+    }
+
+    private void runJob(Long policyId) {
+        try {
+            JobParameters jobParameters = policyNotificationJob.getJobParametersIncrementer().getNext(
+                    new JobParametersBuilder()
+                            .addLong("policyId", policyId)
+                            .toJobParameters()
+            );
+            jobOperator.run(policyNotificationJob, jobParameters);
+        } catch (Exception e) {
+            log.error("정책 알림 배치 실행 실패 — policyId: {}", policyId, e);
+        }
+    }
+}

src/main/java/com/Coming/Backend/policy/batch/PolicyNotificationMailProcessor.java

@@ -0,0 +1,45 @@
+package com.Coming.Backend.policy.batch;
+
+import com.Coming.Backend.auth.entity.User;
+import com.Coming.Backend.auth.repository.UserRepository;
+import com.Coming.Backend.policy.entity.PolicyDocument;
+import com.Coming.Backend.policy.entity.PolicyNotificationTarget;
+import com.Coming.Backend.policy.exception.PolicyNotFoundException;
+import com.Coming.Backend.policy.repository.PolicyDocumentRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.infrastructure.item.ItemProcessor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * PENDING 상태의 PolicyNotificationTarget에 대해 정책 변경 고지 메일을 발송하고 상태(SENT/FAILED)를 갱신한다.
+ */
+@Component
+@StepScope
+@RequiredArgsConstructor
+public class PolicyNotificationMailProcessor implements ItemProcessor<PolicyNotificationTarget, PolicyNotificationTarget> {
+
+    private final UserRepository userRepository;
+    private final PolicyDocumentRepository policyDocumentRepository;
+    private final PolicyNotificationSender policyNotificationSender;
+
+    @Value("#{jobParameters['policyId']}")
+    private Long policyId;
+
+    private PolicyDocument policyDocument;
+
+    @Override
+    public PolicyNotificationTarget process(PolicyNotificationTarget target) {
+        User user = userRepository.findById(target.getUserId()).orElse(null);
+        policyNotificationSender.sendAndMark(target, user, resolvePolicyDocument());
+        return target;
+    }
+
+    private PolicyDocument resolvePolicyDocument() {
+        if (policyDocument == null) {
+            policyDocument = policyDocumentRepository.findById(policyId).orElseThrow(PolicyNotFoundException::new);
+        }
+        return policyDocument;
+    }
+}

src/main/java/com/Coming/Backend/policy/batch/PolicyNotificationPendingTargetReader.java

@@ -0,0 +1,49 @@
+package com.Coming.Backend.policy.batch;
+
+import com.Coming.Backend.policy.entity.NotificationStatus;
+import com.Coming.Backend.policy.entity.PolicyNotificationTarget;
+import com.Coming.Backend.policy.repository.PolicyNotificationTargetRepository;
+import java.util.Iterator;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.infrastructure.item.ItemReader;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.stereotype.Component;
+
+/**
+ * PENDING 상태의 정책 알림 대상을 id 오름차순 커서 기반으로 읽는다.
+ * offset 페이징을 사용하면 처리된 항목이 PENDING에서 벗어나며 결과 집합이 줄어들어
+ * 다음 페이지 조회 시 대상을 건너뛰는 문제가 있어, 마지막으로 읽은 id를 커서로 다음 배치를 조회한다.
+ */
+@Component
+@StepScope
+@RequiredArgsConstructor
+public class PolicyNotificationPendingTargetReader implements ItemReader<PolicyNotificationTarget> {
+
+    private static final int PAGE_SIZE = 20;
+
+    private final PolicyNotificationTargetRepository policyNotificationTargetRepository;
+
+    @Value("#{jobParameters['policyId']}")
+    private Long policyId;
+
+    private Long lastId = 0L;
+    private Iterator<PolicyNotificationTarget> currentBatch = List.<PolicyNotificationTarget>of().iterator();
+
+    @Override
+    public PolicyNotificationTarget read() {
+        if (!currentBatch.hasNext()) {
+            List<PolicyNotificationTarget> batch = policyNotificationTargetRepository
+                    .findByPolicyIdAndStatusAndIdGreaterThanOrderByIdAsc(
+                            policyId, NotificationStatus.PENDING, lastId, PageRequest.of(0, PAGE_SIZE));
+            if (batch.isEmpty()) {
+                return null;
+            }
+            lastId = batch.get(batch.size() - 1).getId();
+            currentBatch = batch.iterator();
+        }
+        return currentBatch.next();
+    }
+}