easynode/server/app/schedule/index.js

import schedule from 'node-schedule'
import { sendNoticeAsync } from '../utils/notify.js'
import { formatTimestamp } from '../utils/tools.js'
import { HostListDB, SessionDB } from '../utils/db-class.js'
import { LOGIN_LOG_RETENTION_DAYS, pruneLoginLogs } from '../utils/login-log.js'
const hostListDB = new HostListDB().getInstance()
const sessionDB = new SessionDB().getInstance()

const expiredNotifyJob = async () => {
  logger.info('=====开始检测服务器到期时间=====', new Date())
  const hostList = await hostListDB.findAsync({})
  for (const item of hostList) {
    if (!item.expiredNotify) continue
    const { host, name, expired, consoleUrl } = item
    const restDay = Number(((expired - Date.now()) / (1000 * 60 * 60 * 24)).toFixed(1))
    console.log(Date.now(), restDay)
    let title = '服务器到期提醒'
    let content = `别名: ${ name }\nIP: ${ host }\n到期时间：${ formatTimestamp(expired, 'week') }\n控制台: ${ consoleUrl || '未填写' }`
    if (0 <= restDay && restDay <= 1) {
      let temp = '有服务器将在一天后到期，请关注\n'
      sendNoticeAsync('host_expired', title, temp + content)
    } else if (3 <= restDay && restDay < 4) {
      let temp = '有服务器将在三天后到期，请关注\n'
      sendNoticeAsync('host_expired', title, temp + content)
    } else if (7 <= restDay && restDay < 8) {
      let temp = '有服务器将在七天后到期，请关注\n'
      sendNoticeAsync('host_expired', title, temp + content)
    }
  }
}

const loginLogRetentionJob = async () => {
  const removed = await pruneLoginLogs(sessionDB)
  if (removed > 0) logger.info(`已清理 ${ removed } 条超过 ${ LOGIN_LOG_RETENTION_DAYS } 天的登录日志`)
}

export default () => {
  schedule.scheduleJob('0 0 12 1/1 * ?', expiredNotifyJob)
  schedule.scheduleJob('0 0 3 * * *', loginLogRetentionJob)
}