Merge pull request #302 from 6QuizOnTheBlock/be/feat/#153-receiveRelay

feat #153: 이어달리기 타임아웃 시 종료 스케줄링 추가
6QuizOnTheBlock · May 13, 2024 · eb6adae · eb6adae
2 parents 07dcb15 + 1459b50
commit eb6adae
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 1 deletion.
diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/relay/repository/RelayRepository.java b/backEnd/src/main/java/com/quiz/ourclass/domain/relay/repository/RelayRepository.java
@@ -2,6 +2,7 @@
 
 import com.quiz.ourclass.domain.organization.entity.Organization;
 import com.quiz.ourclass.domain.relay.entity.Relay;
+import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
 
@@ -10,4 +11,6 @@ public interface RelayRepository extends JpaRepository<Relay, Long>, RelayReposi
     Boolean existsByOrganizationAndEndStatusIsFalse(Organization organization);
 
     Optional<Relay> findByOrganizationIdAndEndStatusIsFalse(long organizationId);
+
+    List<Relay> findAllByEndStatusIsFalse();
 }
diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/relay/service/RelayServiceImpl.java b/backEnd/src/main/java/com/quiz/ourclass/domain/relay/service/RelayServiceImpl.java
@@ -21,8 +21,12 @@
 import com.quiz.ourclass.global.exception.GlobalException;
 import com.quiz.ourclass.global.util.ConstantUtil;
 import com.quiz.ourclass.global.util.UserAccessUtil;
+import com.quiz.ourclass.global.util.scheduler.SchedulingService;
 import java.time.LocalDateTime;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -36,6 +40,7 @@ public class RelayServiceImpl implements RelayService {
     private final OrganizationRepository organizationRepository;
     private final MemberOrganizationRepository memberOrganizationRepository;
     private final UserAccessUtil accessUtil;
+    private final SchedulingService schedulingService;
 
 
     @Transactional
@@ -136,7 +141,9 @@ public ReceiveRelayResponse receiveRelay(long id, ReceiveRelayRequest receiveRel
             .orElseThrow(() -> new GlobalException(ErrorCode.MEMBER_ORGANIZATION_NOT_FOUND));
         memberOrganization.updateRelayCount();
         memberOrganizationRepository.save(memberOrganization);
-        //TODO: 타임아웃 스케줄러 체크
+
+        schedulingService.scheduleTask(relayMember, this::relayClosing,
+            relayMember.getReceiveTime().plusDays(ConstantUtil.RELAY_TIMEOUT_DAY));
         return ReceiveRelayResponse.builder()
             .senderName(currentRunner.getCurMember().getName())
             .question(currentRunner.getQuestion())
@@ -160,4 +167,31 @@ public SendRelayResponse sendRelay(long id) {
             .prevMemberName(prevRelayMember.getCurMember().getName())
             .prevQuestion(prevRelayMember.getQuestion()).build();
     }
+
+    protected void relayClosing(RelayMember relayMember) {
+        Relay relay = relayMember.getRelay();
+        relay.setEndStatus(true);
+        relayRepository.save(relay);
+        relayMember.setEndStatus(true);
+        Member curMember = relayMember.getCurMember();
+        MemberOrganization memberOrganization = memberOrganizationRepository.findByOrganizationAndMember(
+            relay.getOrganization(), curMember).orElseThrow();
+        memberOrganization.updateExp(ConstantUtil.RELAY_DEMERIT);
+        relayMemberRepository.save(relayMember);
+    }
+
+    @EventListener(ApplicationReadyEvent.class)
+    protected void challengeClosingReload() {
+        List<Relay> relays = relayRepository.findAllByEndStatusIsFalse();
+        relays.forEach(relay -> {
+            RelayMember lastRunner = relay.getLastRunner();
+            if (lastRunner.getReceiveTime().plusDays(ConstantUtil.RELAY_TIMEOUT_DAY)
+                .isBefore(LocalDateTime.now())) {
+                relayClosing(lastRunner);
+            } else {
+                schedulingService.scheduleTask(lastRunner, this::relayClosing,
+                    lastRunner.getReceiveTime().plusDays(ConstantUtil.RELAY_TIMEOUT_DAY));
+            }
+        });
+    }
 }