[feat]: card & board 데이터 삭제

Author: westzeroright

server/Recruit-Api/src/main/java/com/econovation/recruit/api/applicant/controller/ApplicantController.java

@@ -13,7 +13,6 @@
 import com.econovation.recruit.api.applicant.usecase.TimeTableLoadUseCase;
 import com.econovation.recruit.api.applicant.usecase.TimeTableRegisterUseCase;
 import com.econovation.recruit.api.applicant.validate.ApplicantValidator;
-import com.econovation.recruit.api.recruitment.usecase.RecruitmentUseCase;
 import com.econovation.recruit.api.recruitment.util.LatestRecruitmentVo;
 import com.econovation.recruitcommon.annotation.ApiErrorExceptionsExample;
 import com.econovation.recruitcommon.annotation.TimeTrace;
@@ -22,21 +21,17 @@
 import com.econovation.recruitdomain.domains.dto.EmailSendDto;
 import com.econovation.recruitdomain.domains.timetable.domain.TimeTable;
 import com.econovation.recruitinfrastructure.apache.CommonsEmailSender;
-import feign.Response;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
-import javax.annotation.PostConstruct;
-import javax.persistence.criteria.CriteriaBuilder.In;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.axonframework.commandhandling.gateway.CommandGateway;
 import org.springdoc.api.annotations.ParameterObject;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
@@ -182,9 +177,7 @@ public ResponseEntity<List<GetApplicantsStatusResponse>> getApplicantsStatus(
 
     @Operation(summary = "year에 해당하는 모든 지원서를 삭제합니다.")
     @DeleteMapping("/applicants/all/{year}")
-    public ResponseEntity<String> deleteApplicants(
-            @PathVariable("year") Integer year
-    ) {
+    public ResponseEntity<String> deleteApplicants(@PathVariable("year") Integer year) {
         applicantCommandUseCase.deleteByYear(year);
         return new ResponseEntity<>(APPLICANTS_BY_YEAR_SUCCESS_DELETE_MESSAGE, HttpStatus.OK);
     }

server/Recruit-Api/src/main/java/com/econovation/recruit/api/applicant/service/AnswerCommandService.java

@@ -10,6 +10,8 @@
 import com.econovation.recruitdomain.domains.applicant.domain.state.ApplicantState;
 import com.econovation.recruitdomain.domains.applicant.event.domainevent.ApplicantRegisterEvent;
 import com.econovation.recruitdomain.domains.applicant.event.domainevent.ApplicantStateModifyEvent;
+import com.econovation.recruitdomain.domains.board.adaptor.BoardAdaptor;
+import com.econovation.recruitdomain.domains.card.adaptor.CardAdaptor;
 import com.econovation.recruitdomain.domains.label.adaptor.LabelAdaptor;
 import com.econovation.recruitdomain.domains.score.adaptor.ScoreAdaptor;
 import com.econovation.recruitdomain.domains.timetable.adaptor.TimeTableAdapter;
@@ -30,6 +32,8 @@ public class AnswerCommandService implements ApplicantCommandUseCase {
     private final TimeTableAdapter timeTableAdapter;
     private final ScoreAdaptor scoreAdaptor;
     private final LabelAdaptor labelAdaptor;
+    private final CardAdaptor cardAdaptor;
+    private final BoardAdaptor boardAdaptor;
 
     @Override
     @Transactional
@@ -75,24 +79,15 @@ public UUID execute(Map<String, Object> qna, UUID id) {
     @Override
     @Transactional
     public void deleteByYear(Integer year) {
-        // TODO: year에 해당하는 지원자 id 리스트로 뽑기
         List<String> applicantIds = answerAdaptor.findApplicantIdsByYear(year);
-        System.out.println(applicantIds);
         mongoAnswerAdaptor.delete(year);
-        // TODO: 지원자 id 리스트를 가지고 time_table 데이터 삭제하기 delete(List<String> applicantIds, Integer year)
-        timeTableAdapter.deleteAllByApplicantIds(applicantIds);
 
-        // TODO: 지원자 id 리스트를 가지고 score 데이터 삭제하기
+        timeTableAdapter.deleteAllByApplicantIds(applicantIds);
         scoreAdaptor.deleteAllByApplicantIds(applicantIds);
-
-        // TODO: 지원자 id 리스트를 가지고 label 데이터 삭제하기
         labelAdaptor.deleteAllByApplicantIds(applicantIds);
 
-        // TODO: card 테이블에서 지원자 id 리스트에 대응하는 board_id 조회하기
-
-        // TODO: 이전에서 조회한 board_id 리스트에 대응하는 board 데이터 삭제하기
-
-        // TODO: card 테이블에서 지원자 id 리스트에 대응하는 데이터 삭제하기
-
+        List<Long> cardIds = cardAdaptor.findAllByApplicantIds(applicantIds);
+        boardAdaptor.deleteAllByCardIds(cardIds);
+        cardAdaptor.deleteAllByApplicantIds(applicantIds);
     }
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/applicant/adaptor/AnswerAdaptor.java

@@ -200,8 +200,6 @@ public List<String> findApplicantIdsByYear(Integer year) {
         query.fields().include("id");
 
         List<MongoAnswer> answers = mongoTemplate.find(query, MongoAnswer.class);
-        return answers.stream()
-                .map(MongoAnswer::getId)
-                .toList();
+        return answers.stream().map(MongoAnswer::getId).toList();
     }
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/board/adaptor/BoardAdaptor.java

@@ -86,4 +86,10 @@ public void delete(Board board) {
     public void saveAll(List<Board> board) {
         boardRepository.saveAll(board);
     }
+
+    @Override
+    public void deleteAllByCardIds(List<Long> cardIds) {
+        boardRepository.deleteAllByCardIdIn(cardIds);
+    }
+    ;
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/board/domain/BoardRepository.java

@@ -17,4 +17,6 @@ public interface BoardRepository extends JpaRepository<Board, Integer> {
     List<Board> findByColumnIdIn(List<Integer> columnsIds);
 
     Optional<Board> findByCardId(Long cardId);
+
+    void deleteAllByCardIdIn(List<Long> cardIds);
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/card/adaptor/CardAdaptor.java

@@ -51,4 +51,14 @@ public Card findByApplicantId(String applicantId) {
     public List<Card> findByIdIn(List<Long> cardIds) {
         return cardRepository.findAllById(cardIds);
     }
+
+    @Override
+    public List<Long> findAllByApplicantIds(List<String> applicantIds) {
+        return cardRepository.findAllCardIdByApplicantIdIn(applicantIds);
+    }
+
+    @Override
+    public void deleteAllByApplicantIds(List<String> applicantIds) {
+        cardRepository.deleteAllByApplicantIdIn(applicantIds);
+    }
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/card/domain/CardRepository.java

@@ -1,10 +1,18 @@
 package com.econovation.recruitdomain.domains.card.domain;
 
+import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
 @Repository
 public interface CardRepository extends JpaRepository<Card, Long> {
     Optional<Card> findByApplicantId(String applicantId);
+
+    @Query("SELECT c.id FROM Card c WHERE c.applicantId IN :applicantIds")
+    List<Long> findAllCardIdByApplicantIdIn(@Param("applicantIds") List<String> applicantIds);
+
+    void deleteAllByApplicantIdIn(List<String> applicantIds);
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/label/adaptor/LabelAdaptor.java

@@ -86,6 +86,6 @@ public List<Label> loadLabelByCardId(Long cardId) {
 
     @Override
     public void deleteAllByApplicantIds(List<String> applicantIds) {
-            labelRepository.deleteAllByApplicantIdIn(applicantIds);
+        labelRepository.deleteAllByApplicantIdIn(applicantIds);
     }
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/domains/timetable/domain/TimeTableRepository.java

@@ -7,5 +7,6 @@
 @Repository
 public interface TimeTableRepository extends JpaRepository<TimeTable, Integer> {
     List<TimeTable> findByApplicantId(String applicantId);
+
     void deleteByApplicantIdIn(List<String> applicantIds);
 }

server/Recruit-Domain/src/main/java/com/econovation/recruitdomain/out/BoardRecordPort.java

@@ -9,4 +9,6 @@ public interface BoardRecordPort {
     void delete(Board board);
 
     void saveAll(List<Board> board);
+
+    void deleteAllByCardIds(List<Long> cardIds);
 }