feat: 동기 테스트 코드 추가 (기록용)

Author: eckrin

Diff for: src/main/java/com/softeer/podoarrival/event/controller/ArrivalEventSyncController.java

@@ -22,6 +22,6 @@ public class ArrivalEventSyncController {
 //    @PostMapping("/application")
     @Operation(summary = "선착순 응모용 Api")
     public CommonResponse<ArrivalApplicationResponseDto> arrivalEventApplication(@Auth AuthInfo authInfo) {
-        return new CommonResponse<>(arrivalEventSyncService.applyEvent(authInfo));
+        return new CommonResponse<>(arrivalEventSyncService.applyEventWithRedis(authInfo));
     }
 }

Diff for: src/main/java/com/softeer/podoarrival/event/repository/ArrivalUserRepository.java

@@ -3,5 +3,8 @@
 import com.softeer.podoarrival.event.model.entity.ArrivalUser;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import java.util.Optional;
+
 public interface ArrivalUserRepository extends JpaRepository<ArrivalUser, Long> {
+    Optional<ArrivalUser> findByPhoneNum(String phoneNum);
 }

Diff for: src/main/java/com/softeer/podoarrival/event/service/ArrivalEventSyncService.java

@@ -1,5 +1,6 @@
 package com.softeer.podoarrival.event.service;
 
+import com.softeer.podoarrival.event.exception.EventClosedException;
 import com.softeer.podoarrival.event.exception.ExistingUserException;
 import com.softeer.podoarrival.event.model.dto.ArrivalApplicationResponseDto;
 import com.softeer.podoarrival.event.model.entity.ArrivalUser;
@@ -14,8 +15,14 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.Optional;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
 
 @Slf4j
 @Service
@@ -29,9 +36,14 @@ public class ArrivalEventSyncService {
     private boolean CHECK = false;
 
     private final String ARRIVAL_SET = "arrivalset";
-    private static int MAX_ARRIVAL = 30000; // default
+    private static int MAX_ARRIVAL = 40000; // default
+    private static int count = 1;
 
-    public ArrivalApplicationResponseDto applyEvent(AuthInfo authInfo) {
+    private static AtomicInteger countAtomic = new AtomicInteger(1);
+    private static ConcurrentHashMap<String, Integer> hashMap = new ConcurrentHashMap<>();
+
+
+    public ArrivalApplicationResponseDto applyEventWithRedis(AuthInfo authInfo) {
         String redisKey = LocalDate.now() + ARRIVAL_SET;
 
         if(CHECK){
@@ -61,11 +73,71 @@ public ArrivalApplicationResponseDto applyEvent(AuthInfo authInfo) {
                             .build()
             );
             log.info("[당첨] 유저 전화번호 = {}, 등수 = {}", authInfo.getPhoneNum(), grade);
-            try {
-                Thread.sleep(15);
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
+//            try {
+//                Thread.sleep(15);
+//            } catch (InterruptedException e) {
+//                throw new RuntimeException(e);
+//            }
+            return new ArrivalApplicationResponseDto(true, authInfo.getName(), authInfo.getPhoneNum(), grade);
+        } else {
+            CHECK = true;
+            return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), grade);
+        }
+    }
+
+    @Transactional
+    public synchronized ArrivalApplicationResponseDto applyEventWithSynchronized(AuthInfo authInfo) {
+
+        if(CHECK){
+            return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), -1);
+        }
+
+        Optional<ArrivalUser> findUser = arrivalUserRepository.findByPhoneNum(authInfo.getPhoneNum());
+
+        int grade = count++;
+        if(grade<=MAX_ARRIVAL) {
+            if(findUser.isEmpty()) {
+                arrivalUserRepository.save(
+                        ArrivalUser.builder()
+                                .name(authInfo.getName())
+                                .phoneNum(authInfo.getPhoneNum())
+                                .role(Role.ROLE_USER)
+                                .arrivalRank(grade)
+                                .build()
+                );
+                return new ArrivalApplicationResponseDto(true, authInfo.getName(), authInfo.getPhoneNum(), grade);
+            } else {
+                throw new ExistingUserException("이미 응모한 전화번호입니다.");
             }
+        } else {
+            CHECK = true;
+            return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), grade);
+        }
+    }
+
+    @Transactional
+    public ArrivalApplicationResponseDto applyEventWithJava(AuthInfo authInfo) {
+        if(CHECK){
+            return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), -1);
+        }
+
+        //첫번째 응답
+        if(hashMap.containsKey(authInfo.getPhoneNum())){
+            throw new ExistingUserException("이미 응모한 전화번호입니다.");
+        }
+
+        int grade = countAtomic.getAndIncrement();
+        // 선착순 순위에 들었다면
+        if(grade <= MAX_ARRIVAL){
+            arrivalUserRepository.save(
+                    ArrivalUser.builder()
+                            .name(authInfo.getName())
+                            .phoneNum(authInfo.getPhoneNum())
+                            .role(Role.ROLE_USER)
+                            .arrivalRank(grade)
+                            .build()
+            );
+            log.info("전화번호 = {}", authInfo.getPhoneNum());
             return new ArrivalApplicationResponseDto(true, authInfo.getName(), authInfo.getPhoneNum(), grade);
         } else {
             CHECK = true;