package cn.flightfeather.supervision.scheduler
|
|
import cn.flightfeather.supervision.bgtask.TaskJinAnHourlyDustData
|
import cn.flightfeather.supervision.bgtask.maintenance.MTJinAnHourlyDustData
|
import org.slf4j.Logger
|
import org.slf4j.LoggerFactory
|
import org.springframework.beans.factory.annotation.Value
|
import org.springframework.scheduling.annotation.Async
|
import org.springframework.scheduling.annotation.Scheduled
|
import org.springframework.stereotype.Component
|
import java.time.LocalDate
|
import java.time.LocalDateTime
|
|
/**
|
* 定时任务调度
|
* 一个cron表达式有至少6个（也可能7个）有空格分隔的时间元素。按顺序依次为：
|
* 秒（0~59）
|
* 分钟（0~59）
|
* 小时（0~23）
|
* 天（0~31）
|
* 月（0~11）
|
* 星期（1~7 1=SUN 或 SUN，MON，TUE，WED，THU，FRI，SAT）
|
* 年份（1970－2099）
|
*/
|
@Component
|
class ScheduleService(
|
@Value("\${mode}") var mode: String,
|
private val taskJinAnHourlyDustData: TaskJinAnHourlyDustData,
|
private val mTaskJinAnHourlyDustData: MTJinAnHourlyDustData,
|
) {
|
val logger: Logger = LoggerFactory.getLogger(ScheduleService::class.java)
|
|
@Async
|
@Scheduled(cron = "0 0 * * * *")
|
fun eachHour() {
|
logger.info("=====>>>>>每小时任务执行 {}", System.currentTimeMillis())
|
taskJinAnHourlyDustData.doTask(LocalDateTime.now())
|
logger.info("=====>>>>>每小时任务结束 {}", System.currentTimeMillis())
|
}
|
|
// @Async
|
// @Scheduled(cron = "0 0 0 * * *")
|
fun eachDay() {
|
logger.info("=====>>>>>每日任务执行 {}", System.currentTimeMillis())
|
|
logger.info("=====>>>>>每日任务结束 {}", System.currentTimeMillis())
|
}
|
|
@Async
|
@Scheduled(cron = "0 0 0 * * SUN")
|
fun eachSunday() {
|
logger.info("=====>>>>>每周日零点任务执行 {}", System.currentTimeMillis())
|
mTaskJinAnHourlyDustData.handle()
|
logger.info("=====>>>>>每周日零点任务结束 {}", System.currentTimeMillis())
|
}
|
|
@Async
|
@Scheduled(cron = "0 0 3 1 * *")
|
fun eachMonth() {
|
logger.info("=====>>>>>每月初任务执行 {}", System.currentTimeMillis())
|
// 执行上个月的静安工地扬尘数据补全任务
|
val now = LocalDate.now().minusMonths(1)
|
mTaskJinAnHourlyDustData.handle(now.year, now.monthValue)
|
logger.info("=====>>>>>每月初任务结束 {}", System.currentTimeMillis())
|
}
|
}
|
