2024-07-21 02:26:03 +08:00
|
|
|
import { Autoload, Config, Init, Inject, Scope, ScopeEnum } from '@midwayjs/core';
|
2024-08-05 12:49:44 +08:00
|
|
|
import { PipelineService } from '../pipeline/service/pipeline-service.js';
|
|
|
|
|
import { logger } from '../../utils/logger.js';
|
2024-09-20 15:15:24 +08:00
|
|
|
import { SysSettingsService } from '../system/service/sys-settings-service.js';
|
2023-01-29 13:44:19 +08:00
|
|
|
|
|
|
|
|
@Autoload()
|
|
|
|
|
@Scope(ScopeEnum.Singleton)
|
|
|
|
|
export class AutoRegisterCron {
|
|
|
|
|
@Inject()
|
|
|
|
|
pipelineService: PipelineService;
|
|
|
|
|
|
2024-08-13 20:30:42 +08:00
|
|
|
@Config('cron.onlyAdminUser')
|
|
|
|
|
private onlyAdminUser: boolean;
|
2024-08-05 12:49:44 +08:00
|
|
|
|
2023-01-29 13:44:19 +08:00
|
|
|
// @Inject()
|
|
|
|
|
// echoPlugin: EchoPlugin;
|
2024-07-21 02:26:03 +08:00
|
|
|
@Config('cron.immediateTriggerOnce')
|
|
|
|
|
private immediateTriggerOnce = false;
|
2023-01-29 13:44:19 +08:00
|
|
|
|
2024-09-20 15:15:24 +08:00
|
|
|
@Inject()
|
|
|
|
|
sysSettingsService: SysSettingsService;
|
|
|
|
|
|
2023-01-29 13:44:19 +08:00
|
|
|
@Init()
|
|
|
|
|
async init() {
|
|
|
|
|
logger.info('加载定时trigger开始');
|
2024-09-20 15:15:24 +08:00
|
|
|
|
2024-08-13 20:30:42 +08:00
|
|
|
await this.pipelineService.onStartup(this.immediateTriggerOnce, this.onlyAdminUser);
|
2024-09-19 17:38:51 +08:00
|
|
|
logger.info('加载定时trigger完成');
|
2023-01-29 13:44:19 +08:00
|
|
|
//
|
|
|
|
|
// const meta = getClassMetadata(CLASS_KEY, this.echoPlugin);
|
|
|
|
|
// console.log('meta', meta);
|
|
|
|
|
// const metas = listPropertyDataFromClass(CLASS_KEY, this.echoPlugin);
|
|
|
|
|
// console.log('metas', metas);
|
|
|
|
|
}
|
|
|
|
|
}
|