feat: 합격자 관리시 비관락 적용

Author: Gothax

src/main/java/ceos/backend/domain/application/helper/ApplicationHelper.java

@@ -11,12 +11,13 @@
 import ceos.backend.global.common.dto.AwsSESMail;
 import ceos.backend.global.common.dto.SlackUnavailableReason;
 import ceos.backend.global.common.event.Event;
-import java.util.List;
-import java.util.UUID;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+import java.util.UUID;
+
 @Slf4j
 @Component
 @RequiredArgsConstructor
@@ -74,4 +75,14 @@ public Application getApplicationByUuidAndEmail(String uuid, String email) {
                             throw ApplicantNotFound.EXCEPTION;
                         });
     }
+
+    public Application getApplicationByUuidAndEmailForUpdate(String uuid, String email) {
+        return applicationRepository
+                .findByUuidAndEmailWithPessimisticLock(uuid, email)
+                .orElseThrow(
+                        () -> {
+                            throw ApplicantNotFound.EXCEPTION;
+                        });
+    }
+
 }

src/main/java/ceos/backend/domain/application/repository/ApplicationRepository.java

@@ -4,8 +4,6 @@
 import ceos.backend.domain.application.domain.Application;
 import ceos.backend.domain.application.domain.Pass;
 import ceos.backend.global.common.entity.Part;
-import java.util.Optional;
-
 import jakarta.persistence.LockModeType;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
@@ -14,6 +12,8 @@
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
+import java.util.Optional;
+
 public interface ApplicationRepository
         extends JpaRepository<Application, Long>, ApplicationRepositoryCustom {
     @Query("select distinct a from Application a" + " where a.applicantInfo.email = :email")
@@ -22,13 +22,23 @@ public interface ApplicationRepository
     @Query("select distinct a from Application a" + " where a.applicantInfo.uuid = :uuid")
     Optional<Application> findByUuid(@Param("uuid") String uuid);
 
+
     @Query(
             "select a from Application a"
                     + " where a.applicantInfo.uuid = :uuid"
                     + " and a.applicantInfo.email = :email")
     Optional<Application> findByUuidAndEmail(
             @Param("uuid") String uuid, @Param("email") String email);
 
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    @Query(
+            "select a from Application a"
+                    + " where a.applicantInfo.uuid = :uuid"
+                    + " and a.applicantInfo.email = :email")
+    Optional<Application> findByUuidAndEmailWithPessimisticLock(
+            @Param("uuid") String uuid, @Param("email") String email);
+
+
     @Query("select count(a) > 0 from Application a" + " where a.applicantInfo.email = :email")
     boolean existsByEmail(@Param("email") String email);
 

src/main/java/ceos/backend/domain/application/service/ApplicationService.java

@@ -158,12 +158,12 @@ public void updateInterviewAttendance(
             String uuid, String email, UpdateAttendanceRequest request) {
         recruitmentValidator.validateBetweenResultDateDocAndResultDateFinal(); // 서류 합격 기간 검증
         applicationValidator.validateApplicantAccessible(uuid, email); // 유저 검증
-        final Application application = applicationHelper.getApplicationByUuidAndEmail(uuid, email);
+        final Application application =
+                applicationHelper.getApplicationByUuidAndEmailForUpdate(uuid, email);
         applicationValidator.validateApplicantInterviewCheckStatus(application); // 서류합격, 인터뷰 체크 검증
 
         if (request.isAvailable()) {
             application.updateInterviewCheck(true);
-            applicationRepository.save(application);
         } else {
             application.updateUnableReason(request.getReason());
             applicationHelper.sendSlackUnableReasonMessage(application, request, false);
@@ -187,12 +187,12 @@ public void updateParticipationAvailability(
             String uuid, String email, UpdateAttendanceRequest request) {
         recruitmentValidator.validateFinalResultAbleDuration(); // 최종 합격 기간 검증
         applicationValidator.validateApplicantAccessible(uuid, email); // 유저 검증
-        final Application application = applicationHelper.getApplicationByUuidAndEmail(uuid, email);
+        final Application application =
+                applicationHelper.getApplicationByUuidAndEmailForUpdate(uuid, email);
         applicationValidator.validateApplicantActivityCheckStatus(application); // 유저 확인 여부 검증
 
         if (request.isAvailable()) {
             application.updateFinalCheck(true);
-            applicationRepository.save(application);
         } else {
             application.updateUnableReason(request.getReason());
             applicationHelper.sendSlackUnableReasonMessage(application, request, true);