123456789101112131415161718192021222324252627282930313233343536 |
- 'use strict';
- const Subscription = require('egg').Subscription;
- class UpdateData extends Subscription {
- // 通过 schedule 属性来设置定时任务的执行间隔等配置
- static get schedule() {
- return {
- // interval: '24h', // 1 分钟间隔
- cron: '0 0 5 * * ? ', // 每天凌晨6点
- type: 'worker', // all 指定所有的都需要执行 worker 其中一个
- // immediate: true,
- cronOptions: {
- tz: 'Asia/Shanghai',
- },
- };
- }
- // subscribe 是真正定时任务执行时被运行的函数
- async subscribe() {
- await this.beforeTask();
- await this.service.statisticsService.task();
- await this.endTask();
- }
- async beforeTask() {
- this.app.logger.info('条件任务开始');
- }
- async endTask() {
- this.app.logger.info('条件任务结束');
- }
- }
- module.exports = UpdateData;
|