Merge pull request #31 from softeerbootcamp4th/chore/arrival-test

[Chore] 동기 지연테스트

src/main/java/com/softeer/podoarrival/event/controller/ArrivalEventSyncController.java

@@ -0,0 +1,27 @@
+package com.softeer.podoarrival.event.controller;
+
+
+import com.softeer.podoarrival.common.response.CommonResponse;
+import com.softeer.podoarrival.event.model.dto.ArrivalApplicationResponseDto;
+import com.softeer.podoarrival.event.service.ArrivalEventSyncService;
+import com.softeer.podoarrival.security.Auth;
+import com.softeer.podoarrival.security.AuthInfo;
+import io.swagger.v3.oas.annotations.Operation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+//@RequestMapping("/v1/arrival")
+@Slf4j
+public class ArrivalEventSyncController {
+
+    private final ArrivalEventSyncService arrivalEventSyncService;
+
+//    @PostMapping("/application")
+    @Operation(summary = "선착순 응모용 Api")
+    public CommonResponse<ArrivalApplicationResponseDto> arrivalEventApplication(@Auth AuthInfo authInfo) {
+        return new CommonResponse<>(arrivalEventSyncService.applyEvent(authInfo));
+    }
+}

src/main/java/com/softeer/podoarrival/event/service/ArrivalEventSyncService.java

@@ -0,0 +1,76 @@
+package com.softeer.podoarrival.event.service;
+
+import com.softeer.podoarrival.event.exception.ExistingUserException;
+import com.softeer.podoarrival.event.model.dto.ArrivalApplicationResponseDto;
+import com.softeer.podoarrival.event.model.entity.ArrivalUser;
+import com.softeer.podoarrival.event.model.entity.Role;
+import com.softeer.podoarrival.event.repository.ArrivalUserRepository;
+import com.softeer.podoarrival.security.AuthInfo;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.redisson.api.BatchResult;
+import org.redisson.api.RBatch;
+import org.redisson.api.RedissonClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ArrivalEventSyncService {
+
+    private static final Logger specialLogger = LoggerFactory.getLogger("arrivalEventLogger");
+
+    private final RedissonClient redissonClient;
+    private final ArrivalUserRepository arrivalUserRepository;
+    private boolean CHECK = false;
+
+    private final String ARRIVAL_SET = "arrivalset";
+    private static int MAX_ARRIVAL = 30000; // default
+
+    public ArrivalApplicationResponseDto applyEvent(AuthInfo authInfo) {
+        String redisKey = LocalDate.now() + ARRIVAL_SET;
+
+        if(CHECK){
+            return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), -1);
+        }
+
+        RBatch batch = redissonClient.createBatch();
+        batch.getSet(redisKey).addAsync(authInfo.getPhoneNum());
+        batch.getSet(redisKey).sizeAsync();
+        BatchResult<?> res = batch.execute();
+
+        //첫번째 응답
+        if(!(boolean) res.getResponses().get(0)){
+            log.info("이미 응모한 전화번호 = {}", authInfo.getPhoneNum());
+            throw new ExistingUserException("이미 응모한 전화번호입니다.");
+        }
+
+        int grade = (int) res.getResponses().get(1);
+        // 선착순 순위에 들었다면
+        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(), grade);
+            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);
+        }
+    }
+
+}