lanyuanxiaoyao/digtal-market
1
0
Fork 0
Code Activity

feat: 增加定时任务

Browse Source
This commit is contained in:
兰缘小妖
2024-11-03 16:08:50 +08:00
parent a1ca88b829
commit 79a1e94f6b
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/NewsRunner.kt
View File

@@ -5,8 +5,6 @@ import cn.hutool.core.util.NumberUtil
import cn.hutool.crypto.SecureUtil import cn.hutool.crypto.SecureUtil
import com.lanyuanxiaoyao.digtal.market.Article import com.lanyuanxiaoyao.digtal.market.Article
import com.lanyuanxiaoyao.digtal.market.ArticleRepository 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.service.DescriptionService
import com.lanyuanxiaoyao.digtal.market.sites import com.lanyuanxiaoyao.digtal.market.sites
import com.lanyuanxiaoyao.squirrel.core.common.Management import com.lanyuanxiaoyao.squirrel.core.common.Management
@@ -16,11 +14,13 @@ import dev.failsafe.FailsafeException
import dev.failsafe.RetryPolicy import dev.failsafe.RetryPolicy
import dev.failsafe.function.CheckedSupplier import dev.failsafe.function.CheckedSupplier
import jakarta.annotation.Resource import jakarta.annotation.Resource
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicLong import java.util.concurrent.atomic.AtomicLong
import kotlin.time.Duration.Companion.seconds import kotlin.time.Duration.Companion.seconds
import kotlin.time.toJavaDuration import kotlin.time.toJavaDuration
import kotlinx.coroutines.runBlocking import kotlinx.coroutines.runBlocking
import org.slf4j.LoggerFactory import org.slf4j.LoggerFactory
import org.springframework.scheduling.annotation.Scheduled
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@Service @Service
@@ -42,6 +42,7 @@ class NewsRunner : Runner {
@Resource @Resource
private lateinit var management: Management private lateinit var management: Management
@Scheduled(cron = "0 0 * * * ?", initialDelay = 1, timeUnit = TimeUnit.MINUTES)
override fun run() { override fun run() {
sites.forEach { site -> sites.forEach { site ->
logger.info("站点: {}", site.name) logger.info("站点: {}", site.name)

3
src/main/kotlin/com/lanyuanxiaoyao/digtal/market/runner/PushRunner.kt
View File

@@ -3,7 +3,9 @@ package com.lanyuanxiaoyao.digtal.market.runner
import com.lanyuanxiaoyao.digtal.market.ArticleRepository import com.lanyuanxiaoyao.digtal.market.ArticleRepository
import com.lanyuanxiaoyao.digtal.market.sender.DingtalkSender import com.lanyuanxiaoyao.digtal.market.sender.DingtalkSender
import jakarta.annotation.Resource import jakarta.annotation.Resource
import java.util.concurrent.TimeUnit
import org.slf4j.LoggerFactory import org.slf4j.LoggerFactory
import org.springframework.scheduling.annotation.Scheduled
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@Service @Service
@@ -13,6 +15,7 @@ class PushRunner : Runner {
@Resource @Resource
private lateinit var articleRepository: ArticleRepository private lateinit var articleRepository: ArticleRepository
@Scheduled(cron = "0 0 0,6,12,18 * * ?", initialDelay = 1, timeUnit = TimeUnit.MINUTES)
override fun run() { override fun run() {
val articles = articleRepository.findAll { root, _, builder -> val articles = articleRepository.findAll { root, _, builder ->
builder.or( builder.or(