feat: 선착순 종료시 이벤트 시간이 다시 설정되게끔 수정

- ArrivalEventReleaseService interface에 getStartTime method 추가
- 기존에 있던 static method도 이름을 변경하여 유지
- start time을 local date가 아닌 localDatetimed으로 저장하게끔 수정

Author: luna156

Diff for: src/main/java/com/softeer/podoarrival/event/scheduler/ArrivalEventInformationScheduler.java

@@ -78,7 +78,7 @@ public void setArrivalEventInformation() {
         ArrivalEventReleaseServiceRedisImpl.setMaxArrival(rewardCount);
         ArrivalEventReleaseServiceJavaImpl.setMaxArrival(rewardCount);
 
-        ArrivalEventReleaseServiceRedisImpl.setStartTime(repeatTime);
-        ArrivalEventReleaseServiceJavaImpl.setStartTime(repeatTime);
+        ArrivalEventReleaseServiceRedisImpl.setStartTime(LocalDateTime.of(LocalDate.now(), repeatTime));
+        ArrivalEventReleaseServiceJavaImpl.setStartTime(LocalDateTime.of(LocalDate.now(), repeatTime));
     }
 }

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

@@ -3,9 +3,12 @@
 import com.softeer.podoarrival.event.model.dto.ArrivalApplicationResponseDto;
 import com.softeer.podoarrival.security.AuthInfo;
 
+import java.time.LocalDateTime;
 import java.util.concurrent.CompletableFuture;
 
 public interface ArrivalEventReleaseService {
 
     CompletableFuture<ArrivalApplicationResponseDto> applyEvent(AuthInfo authInfo);
+
+    public LocalDateTime getStartTime();
 }

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

@@ -14,6 +14,8 @@
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentHashMap;
@@ -28,7 +30,7 @@ public class ArrivalEventReleaseServiceJavaImpl implements ArrivalEventReleaseSe
 
     private static int MAX_ARRIVAL = 100; // default
     private boolean CHECK = false;
-    private static LocalTime START_TIME = LocalTime.of(0, 0);
+    private static LocalDateTime START_TIME = LocalDateTime.of(LocalDate.now(), LocalTime.of(0, 0));
     private static boolean START_DATE = true;
 
     private static AtomicInteger count = new AtomicInteger(1);
@@ -43,7 +45,7 @@ public class ArrivalEventReleaseServiceJavaImpl implements ArrivalEventReleaseSe
     public CompletableFuture<ArrivalApplicationResponseDto> applyEvent(AuthInfo authInfo) {
         return CompletableFuture.supplyAsync(() -> {
             if(!START_DATE) throw new EventClosedException("이벤트 요일이 아닙니다.");
-            if(LocalTime.now().isBefore(START_TIME)) throw new EventClosedException("이벤트 시간이 아닙니다.");
+            if(LocalDateTime.now().isBefore(START_TIME)) throw new EventClosedException("이벤트 시간이 아닙니다.");
 
             if(CHECK){
                 return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), -1);
@@ -69,6 +71,7 @@ public CompletableFuture<ArrivalApplicationResponseDto> applyEvent(AuthInfo auth
                 return new ArrivalApplicationResponseDto(true, authInfo.getName(), authInfo.getPhoneNum(), grade);
             } else {
                 CHECK = true;
+                START_TIME = LocalDateTime.of(LocalDate.now().plusDays(1), START_TIME.toLocalTime());
                 return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), grade);
             }
         });
@@ -78,7 +81,7 @@ public static void setMaxArrival(int val) {
         MAX_ARRIVAL = val;
     }
 
-    public static void setStartTime(LocalTime val) {
+    public static void setStartTime(LocalDateTime val) {
         START_TIME = val;
     }
 
@@ -91,7 +94,11 @@ public static int getMaxArrival() {
     }
 
 
-    public static LocalTime getStartTime() {
+    public LocalDateTime getStartTime() {
+        return START_TIME;
+    }
+
+    public static LocalDateTime getStartTimeStatic(){
         return START_TIME;
     }
 

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

@@ -18,6 +18,7 @@
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.util.concurrent.CompletableFuture;
 
@@ -34,7 +35,7 @@ public class ArrivalEventReleaseServiceRedisImpl implements ArrivalEventReleaseS
     private final String ARRIVAL_SET = "arrivalset";
     private boolean CHECK = false;
     private static int MAX_ARRIVAL = 100; // default
-    private static LocalTime START_TIME = LocalTime.of(0, 0);
+    private static LocalDateTime START_TIME = LocalDateTime.of(LocalDate.now(), LocalTime.of(0, 0));
     private static boolean START_DATE = true;
 
     /**
@@ -49,7 +50,7 @@ public CompletableFuture<ArrivalApplicationResponseDto> applyEvent(AuthInfo auth
             String redisKey = LocalDate.now() + ARRIVAL_SET;
 
             if(!START_DATE) throw new EventClosedException("이벤트 요일이 아닙니다.");
-            if(LocalTime.now().isBefore(START_TIME)) throw new EventClosedException("이벤트 시간이 아닙니다.");
+            if(LocalDateTime.now().isBefore(START_TIME)) throw new EventClosedException("이벤트 시간이 아닙니다.");
 
             if(CHECK){
                 return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), -1);
@@ -80,6 +81,7 @@ public CompletableFuture<ArrivalApplicationResponseDto> applyEvent(AuthInfo auth
                 return new ArrivalApplicationResponseDto(true, authInfo.getName(), authInfo.getPhoneNum(), grade);
             } else {
                 CHECK = true;
+                START_TIME = LocalDateTime.of(LocalDate.now().plusDays(1), START_TIME.toLocalTime());
                 return new ArrivalApplicationResponseDto(false, authInfo.getName(), authInfo.getPhoneNum(), grade);
             }
         });
@@ -89,7 +91,7 @@ public static void setMaxArrival(int val) {
         MAX_ARRIVAL = val;
     }
 
-    public static void setStartTime(LocalTime val) {
+    public static void setStartTime(LocalDateTime val) {
         START_TIME = val;
     }
 
@@ -101,7 +103,11 @@ public static int getMaxArrival() {
         return MAX_ARRIVAL;
     }
 
-    public static LocalTime getStartTime() {
+    public LocalDateTime getStartTime() {
+        return START_TIME;
+    }
+
+    public static LocalDateTime getStartTimeStatic(){
         return START_TIME;
     }
 

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

@@ -8,7 +8,7 @@
 import reactor.core.publisher.Flux;
 
 import java.time.Duration;
-import java.time.LocalTime;
+import java.time.LocalDateTime;
 import java.util.concurrent.CompletableFuture;
 
 @Slf4j
@@ -37,8 +37,8 @@ public Flux<Long> streamLeftSecondsToEventTime() {
                 Flux.just(0L), // Emit initial value immediately
                 Flux.interval(Duration.ofSeconds(20)))
                 .map(sequence -> {
-                    LocalTime startTime = ArrivalEventReleaseServiceJavaImpl.getStartTime();
-                    long seconds = Duration.between(LocalTime.now(), startTime).getSeconds();
+                    LocalDateTime startTime = arrivalEventReleaseServiceRedisImpl.getStartTime();
+                    long seconds = Duration.between(LocalDateTime.now(), startTime).getSeconds();
                     return Math.max(seconds, 0);
                 });
     }

Diff for: src/test/java/com/softeer/podoarrival/unit/scheduler/ArrivalEventInformationTest.java

@@ -48,9 +48,9 @@ public void setArrivalEventCountSuccess_Data_Exists() {
                 .isEqualTo(60);
         Assertions.assertThat(ArrivalEventReleaseServiceJavaImpl.getMaxArrival())
                 .isEqualTo(60);
-        Assertions.assertThat(ArrivalEventReleaseServiceRedisImpl.getStartTime())
+        Assertions.assertThat(ArrivalEventReleaseServiceRedisImpl.getStartTimeStatic())
                 .isEqualTo(LocalTime.of(15, 0));
-        Assertions.assertThat(ArrivalEventReleaseServiceJavaImpl.getStartTime())
+        Assertions.assertThat(ArrivalEventReleaseServiceJavaImpl.getStartTimeStatic())
                 .isEqualTo(LocalTime.of(15, 0));
     }