diff --git a/src/app/modules/demo/queue/demo.ts b/src/app/modules/demo/queue/demo.ts new file mode 100644 index 0000000..1bfeab5 --- /dev/null +++ b/src/app/modules/demo/queue/demo.ts @@ -0,0 +1,19 @@ +import { App, Provide } from '@midwayjs/decorator'; +import { IMidwayWebApplication } from '@midwayjs/web'; +import { ICoolQueue, Queue } from 'midwayjs-cool-queue'; + +/** + * 任务 + */ +@Queue() +@Provide() +export abstract class DemoQueue implements ICoolQueue { + @App() + app: IMidwayWebApplication; + + async data(job: any, done: any): Promise { + // 这边可以执行定时任务具体的业务或队列的业务 + console.log('数据', job); + done(); + } +} diff --git a/src/app/modules/demo/service/task.ts b/src/app/modules/demo/service/task.ts new file mode 100644 index 0000000..3c086a0 --- /dev/null +++ b/src/app/modules/demo/service/task.ts @@ -0,0 +1,15 @@ +import { Provide } from '@midwayjs/decorator'; +import { BaseService } from 'midwayjs-cool-core'; +/** + * 描述 + */ +@Provide() +export class DemoTaskService extends BaseService { + /** + * 测试任务执行 + */ + async test() { + // 需要登录后台任务管理配置任务 + console.log('任务执行了'); + } +}