[feat] 관리자: 회원 탈퇴 기능 추가

build.gradle

@@ -66,6 +66,10 @@ dependencies {
     // Thymeleaf
     implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
     implementation 'nz.net.ultraq.thymeleaf:thymeleaf-layout-dialect'
+
+    // Batch
+    implementation 'org.springframework.boot:spring-boot-starter-batch'
+    testImplementation 'org.springframework.batch:spring-batch-test'
 }
 
 tasks.named('test') {

src/main/java/org/programmers/signalbuddy/SignalBuddyApplication.java

@@ -2,6 +2,7 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 public class SignalBuddyApplication {

src/main/java/org/programmers/signalbuddy/domain/bookmark/entity/Bookmark.java

@@ -1,5 +1,6 @@
 package org.programmers.signalbuddy.domain.bookmark.entity;
 
+import jakarta.persistence.CascadeType;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.FetchType;
@@ -14,6 +15,8 @@
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.ToString;
+import org.hibernate.annotations.OnDelete;
+import org.hibernate.annotations.OnDeleteAction;
 import org.locationtech.jts.geom.Point;
 import org.programmers.signalbuddy.domain.basetime.BaseTimeEntity;
 import org.programmers.signalbuddy.domain.member.entity.Member;
@@ -35,7 +38,7 @@ public class Bookmark extends BaseTimeEntity {
     @Column(nullable = false)
     private String address;
 
-    @ManyToOne(fetch = FetchType.LAZY)
+    @ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.REMOVE)
     @JoinColumn(name = "member_id", nullable = false)
     private Member member;
 

src/main/java/org/programmers/signalbuddy/domain/member/batch/CustomReader.java

@@ -0,0 +1,69 @@
+package org.programmers.signalbuddy.domain.member.batch;
+
+import com.querydsl.core.BooleanBuilder;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.EntityManagerFactory;
+import java.time.LocalDateTime;
+import lombok.extern.slf4j.Slf4j;
+import org.programmers.signalbuddy.domain.member.entity.Member;
+import org.programmers.signalbuddy.domain.member.entity.QMember;
+import org.programmers.signalbuddy.domain.member.entity.enums.MemberStatus;
+import org.springframework.batch.item.ItemReader;
+
+import java.util.List;
+
+@Slf4j
+public class CustomReader implements ItemReader<Member> {
+
+    private final JPAQueryFactory queryFactory;
+    private final int pageSize;
+    private Long lastSeenId;
+    private List<Member> currentPage;
+    private int currentIndex;
+
+    public CustomReader(EntityManagerFactory entityManagerFactory, int pageSize) {
+        EntityManager entityManager = entityManagerFactory.createEntityManager();
+        this.queryFactory = new JPAQueryFactory(entityManager);
+        this.pageSize = pageSize;
+        this.lastSeenId = null;
+        this.currentIndex = 0;
+    }
+
+    @Override
+    public Member read() {
+        if (currentPage == null || currentIndex >= currentPage.size()) {
+            fetchNextPage();
+        }
+
+        if (currentPage == null || currentPage.isEmpty()) {
+            return null;
+        }
+
+        Member member = currentPage.get(currentIndex);
+        currentIndex++;
+        return member;
+    }
+
+    private void fetchNextPage() {
+        QMember qMember = QMember.member;
+
+        currentPage = queryFactory
+            .selectFrom(qMember)
+            .where(
+                lastSeenId != null ? qMember.memberId.gt(lastSeenId) : null,
+                qMember.memberStatus.eq(MemberStatus.WITHDRAWAL).and(qMember.updatedAt.loe(
+                    LocalDateTime.now().minusMonths(6)))
+            ).orderBy(qMember.memberId.asc())
+            .offset(0)
+            .limit(pageSize)
+            .fetch();
+        // log.info("마지막으로 읽은 id: " + lastSeenId);
+
+        if (!currentPage.isEmpty()) {
+            lastSeenId = currentPage.get(currentPage.size() - 1).getMemberId();
+        }
+        currentIndex = 0;
+    }
+
+}

src/main/java/org/programmers/signalbuddy/domain/member/batch/JobConfig.java

@@ -0,0 +1,64 @@
+package org.programmers.signalbuddy.domain.member.batch;
+
+
+import jakarta.persistence.EntityManagerFactory;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.programmers.signalbuddy.domain.member.entity.Member;
+
+import org.programmers.signalbuddy.domain.member.repository.MemberRepository;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.Step;
+import org.springframework.batch.core.configuration.annotation.JobScope;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.core.job.builder.JobBuilder;
+import org.springframework.batch.core.launch.support.RunIdIncrementer;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.item.ItemWriter;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.transaction.PlatformTransactionManager;
+
+@Configuration
+@RequiredArgsConstructor
+@Slf4j
+public class JobConfig {
+
+    private static final int chunkSize = 10;
+    private final MemberRepository memberRepository;
+    private final EntityManagerFactory entityManagerFactory;
+
+    @Bean
+    public Job deleteMemberJob(JobRepository jobRepository,
+        PlatformTransactionManager transactionManager) {
+        return new JobBuilder("deleteMemberJob", jobRepository).incrementer(new RunIdIncrementer())
+            .start(deleteMemberStep(jobRepository, transactionManager)).build();
+    }
+
+    @Bean
+    @JobScope
+    public Step deleteMemberStep(JobRepository jobRepository,
+        PlatformTransactionManager transactionManager) {
+        return new StepBuilder("deleteMemberStep", jobRepository).<Member, Member>chunk(chunkSize,
+            transactionManager).reader(customReader()).writer(deleteMemberWriter()).build();
+    }
+
+
+    @Bean
+    @StepScope
+    public CustomReader customReader() {
+        return new CustomReader(entityManagerFactory, chunkSize);
+    }
+
+    @Bean
+    @StepScope
+    public ItemWriter<Member> deleteMemberWriter() {
+        return items -> {
+            if (items != null && !items.isEmpty()) {
+                items.forEach(member -> memberRepository.deleteById(member.getMemberId()));
+            }
+        };
+    }
+}

src/main/java/org/programmers/signalbuddy/domain/member/batch/Scheduler.java

@@ -0,0 +1,27 @@
+package org.programmers.signalbuddy.domain.member.batch;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.JobParameters;
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.batch.core.launch.JobLauncher;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+@Configuration
+@EnableScheduling
+@RequiredArgsConstructor
+public class Scheduler {
+
+    private final JobLauncher jobLauncher;
+    private final Job deleteMemberJob;
+
+    @Scheduled(cron = "0 59 23 * * ?")
+    public void runJob() throws Exception {
+
+        JobParameters params = new JobParametersBuilder()
+            .toJobParameters();
+        jobLauncher.run(deleteMemberJob, params);
+    }
+}

src/test/java/org/programmers/signalbuddy/global/config/DataInitializer.java

@@ -41,6 +41,9 @@ private void findDatabaseTableNames() {
     private void truncate() {
         setForeignKeyCheck(OFF);
         for (String tableName : tableNames) {
+            if (tableName.startsWith("BATCH")) {
+                continue;
+            }
             entityManager.createNativeQuery(String.format("TRUNCATE TABLE %s", tableName)).executeUpdate();
         }
         setForeignKeyCheck(ON);

src/test/resources/application-test.yml

@@ -17,6 +17,13 @@ spring:
         show_sql: true
         format_sql: true # 이쁘게 보기
         dialect: org.hibernate.dialect.MariaDBDialect
+    open-in-view: false
+
+  batch:
+    jdbc:
+      initialize-schema: always
+    job:
+      enabled: false
 
 logging:
   level: