From f2b4d62f11dffef82569edbcd63a7a17985900b7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=95=8A=E5=B9=B3?= <951984189@qq.com>
Date: Tue, 23 Mar 2021 20:36:44 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=88=86=E5=B8=83=E5=BC=8F?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E8=B0=83=E5=BA=A6=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/app/modules/demo/queue/demo.ts   | 19 +++++++++++++++++++
 src/app/modules/demo/service/task.ts | 15 +++++++++++++++
 2 files changed, 34 insertions(+)
 create mode 100644 src/app/modules/demo/queue/demo.ts
 create mode 100644 src/app/modules/demo/service/task.ts

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<void> {
+    // 这边可以执行定时任务具体的业务或队列的业务
+    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('任务执行了');
+  }
+}