diff --git a/src/main/java/com/eactive/apim/portal/djb/apistatus/incident/repository/DjbApistatusIncidentPrenoticeRepository.java b/src/main/java/com/eactive/apim/portal/djb/apistatus/incident/repository/DjbApistatusIncidentPrenoticeRepository.java index 4306822..60112bb 100644 --- a/src/main/java/com/eactive/apim/portal/djb/apistatus/incident/repository/DjbApistatusIncidentPrenoticeRepository.java +++ b/src/main/java/com/eactive/apim/portal/djb/apistatus/incident/repository/DjbApistatusIncidentPrenoticeRepository.java @@ -1,14 +1,22 @@ package com.eactive.apim.portal.djb.apistatus.incident.repository; import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncidentPrenotice; +import com.eactive.apim.portal.djb.apistatus.incident.entity.PrenoticeResult; import com.eactive.eai.rms.data.EMSDataSource; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.stereotype.Repository; +import java.time.LocalDateTime; +import java.util.List; + @Repository @EMSDataSource public interface DjbApistatusIncidentPrenoticeRepository extends JpaRepository { void deleteByIncidentId(Long incidentId); + + /** 발송 스케줄러의 대기 건 폴링용. {@code (RESULT, PRENOTI_AT)} 인덱스를 탄다. */ + List findByResultAndPrenotiAtLessThanEqualOrderByPrenotiAtAsc( + PrenoticeResult result, LocalDateTime at); }