service-dataimport/app/schedule/schedule.js

'use strict';

const Subscription = require('egg').Subscription;
let i = 0;
class Schedule extends Subscription {

  // 通过 schedule 属性来设置定时任务的执行间隔等配置
  static get schedule() {
    return {
      interval: '1m', // 1 分钟间隔
      type: 'all', // 指定所有的 worker 都需要执行
    };
  }

  // subscribe 是真正定时任务执行时被运行的函数
  async subscribe() {
    console.log(i++);
    // 从上传表中取得待读取的文件
    const data = { status: '0' };
    const result = await this.ctx.service.dataimp.query(data);
    console.log(result);
    // 调用导入方法
    await this.ctx.service.excelimport.getImportXLSXData(result);
  }
}

module.exports = Schedule;