diff --git a/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/NewsRunner.kt b/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/NewsRunner.kt index 9cfc391..9fa9abd 100644 --- a/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/NewsRunner.kt +++ b/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/NewsRunner.kt @@ -5,8 +5,6 @@ import cn.hutool.core.util.NumberUtil import cn.hutool.crypto.SecureUtil import com.lanyuanxiaoyao.digtal.market.Article import com.lanyuanxiaoyao.digtal.market.ArticleRepository -import com.lanyuanxiaoyao.digtal.market.Link -import com.lanyuanxiaoyao.digtal.market.LinkRepository import com.lanyuanxiaoyao.digtal.market.service.DescriptionService import com.lanyuanxiaoyao.digtal.market.sites import com.lanyuanxiaoyao.squirrel.core.common.Management @@ -16,11 +14,13 @@ import dev.failsafe.FailsafeException import dev.failsafe.RetryPolicy import dev.failsafe.function.CheckedSupplier import jakarta.annotation.Resource +import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicLong import kotlin.time.Duration.Companion.seconds import kotlin.time.toJavaDuration import kotlinx.coroutines.runBlocking import org.slf4j.LoggerFactory +import org.springframework.scheduling.annotation.Scheduled import org.springframework.stereotype.Service @Service @@ -42,6 +42,7 @@ class NewsRunner : Runner { @Resource private lateinit var management: Management + @Scheduled(cron = "0 0 * * * ?", initialDelay = 1, timeUnit = TimeUnit.MINUTES) override fun run() { sites.forEach { site -> logger.info("站点: {}", site.name) diff --git a/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/PushRunner.kt b/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/PushRunner.kt index 3a0920e..27cb40e 100644 --- a/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/PushRunner.kt +++ b/src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/PushRunner.kt @@ -3,7 +3,9 @@ package com.lanyuanxiaoyao.digtal.market.runner import com.lanyuanxiaoyao.digtal.market.ArticleRepository import com.lanyuanxiaoyao.digtal.market.sender.DingtalkSender import jakarta.annotation.Resource +import java.util.concurrent.TimeUnit import org.slf4j.LoggerFactory +import org.springframework.scheduling.annotation.Scheduled import org.springframework.stereotype.Service @Service @@ -13,6 +15,7 @@ class PushRunner : Runner { @Resource private lateinit var articleRepository: ArticleRepository + @Scheduled(cron = "0 0 0,6,12,18 * * ?", initialDelay = 1, timeUnit = TimeUnit.MINUTES) override fun run() { val articles = articleRepository.findAll { root, _, builder -> builder.or(