diff --git a/src/modules/task/event/comm.ts b/src/modules/task/event/comm.ts new file mode 100644 index 0000000..073505d --- /dev/null +++ b/src/modules/task/event/comm.ts @@ -0,0 +1,26 @@ +import { Inject } from '@midwayjs/core'; +import { CoolEvent, Event } from '@cool-midway/core'; +import { TaskInfoService } from '../service/info'; +import { TaskLocalService } from '../service/local'; + +/** + * 应用事件 + */ +@CoolEvent() +export class TaskCommEvent { + @Inject() + taskInfoService: TaskInfoService; + + @Inject() + taskLocalService: TaskLocalService; + + @Event('onServerReadyOnce') + async onServerReady() { + this.taskInfoService.initTask(); + } + + @Event() + async onLocalTaskStop(jobId) { + this.taskLocalService.stopByJobId(jobId); + } +}