diff --git a/src/main/kotlin/io/github/qingshu/ayaka/example/plugin/RandomVideo.kt b/src/main/kotlin/io/github/qingshu/ayaka/example/plugin/RandomVideo.kt index cee10b5..43d9aa5 100644 --- a/src/main/kotlin/io/github/qingshu/ayaka/example/plugin/RandomVideo.kt +++ b/src/main/kotlin/io/github/qingshu/ayaka/example/plugin/RandomVideo.kt @@ -74,6 +74,7 @@ class RandomVideo( @Scheduled(cron = "0 0/15 * * * ?") fun updateVideoInfo() { + if (service.allUnUpdatedCount() == 0) return log.info("开始更新视频信息") val baseConfig = EAConfig.base val botSession = sessionFactory.createSession("localhost") diff --git a/src/main/kotlin/io/github/qingshu/ayaka/example/repository/DouYinVideoRepository.kt b/src/main/kotlin/io/github/qingshu/ayaka/example/repository/DouYinVideoRepository.kt index e465887..efb14d9 100644 --- a/src/main/kotlin/io/github/qingshu/ayaka/example/repository/DouYinVideoRepository.kt +++ b/src/main/kotlin/io/github/qingshu/ayaka/example/repository/DouYinVideoRepository.kt @@ -37,6 +37,10 @@ interface DouYinVideoRepository : JpaRepository { fun findByUsedTodayIsTrue(): List + @Query( + value = "select v from DouYinVideoEntity v " + + "where v.updateStatus = :status order by function('random') " + ) fun findByUpdateStatus(status: String, pageable: Pageable): List fun countByUpdateStatus(status: String = "pending"): Int