From 0753b2ca3c534e71f8ce5c0cf7ff8b83e7c97249 Mon Sep 17 00:00:00 2001
From: ap <951984189@qq.com>
Date: Wed, 24 Mar 2021 00:35:59 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Edemo=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../demo/controller/app/{hh => }/goods.ts     | 22 ++++++++++++++++---
 src/app/modules/demo/queue/demo.ts            |  2 +-
 src/app/modules/demo/service/task.ts          |  7 +++---
 3 files changed, 24 insertions(+), 7 deletions(-)
 rename src/app/modules/demo/controller/app/{hh => }/goods.ts (53%)

diff --git a/src/app/modules/demo/controller/app/hh/goods.ts b/src/app/modules/demo/controller/app/goods.ts
similarity index 53%
rename from src/app/modules/demo/controller/app/hh/goods.ts
rename to src/app/modules/demo/controller/app/goods.ts
index 2b70cb4..3014f27 100644
--- a/src/app/modules/demo/controller/app/hh/goods.ts
+++ b/src/app/modules/demo/controller/app/goods.ts
@@ -1,7 +1,8 @@
-import { Get, Inject, Provide } from '@midwayjs/decorator';
+import { Get, Inject, Post, Provide } from '@midwayjs/decorator';
 import { CoolController, BaseController } from 'midwayjs-cool-core';
-import { DemoAppGoodsEntity } from '../../../entity/goods';
-import { DemoGoodsService } from '../../../service/goods';
+import { IQueue } from 'midwayjs-cool-queue';
+import { DemoAppGoodsEntity } from '../../entity/goods';
+import { DemoGoodsService } from '../../service/goods';
 
 /**
  * 商品
@@ -18,6 +19,10 @@ export class DemoAppGoodsController extends BaseController {
   @Inject()
   demoGoodsService: DemoGoodsService;
 
+  // 队列
+  @Inject()
+  demoQueue: IQueue;
+
   /**
    * 请求所有数据
    * @returns
@@ -26,4 +31,15 @@ export class DemoAppGoodsController extends BaseController {
   async all() {
     return this.ok(await this.demoGoodsService.all());
   }
+
+  /**
+   * 发送数据到队列
+   */
+  @Post('/queue')
+  async queue(){
+    this.demoQueue.queue.add({a: 1}, {
+      removeOnComplete: true,
+      removeOnFail: true,
+    });
+  }
 }
diff --git a/src/app/modules/demo/queue/demo.ts b/src/app/modules/demo/queue/demo.ts
index 1bfeab5..199ded0 100644
--- a/src/app/modules/demo/queue/demo.ts
+++ b/src/app/modules/demo/queue/demo.ts
@@ -13,7 +13,7 @@ export abstract class DemoQueue implements ICoolQueue {
 
   async data(job: any, done: any): Promise<void> {
     // 这边可以执行定时任务具体的业务或队列的业务
-    console.log('数据', job);
+    console.log('数据', job.data);
     done();
   }
 }
diff --git a/src/app/modules/demo/service/task.ts b/src/app/modules/demo/service/task.ts
index 3c086a0..ec64cc4 100644
--- a/src/app/modules/demo/service/task.ts
+++ b/src/app/modules/demo/service/task.ts
@@ -1,15 +1,16 @@
 import { Provide } from '@midwayjs/decorator';
 import { BaseService } from 'midwayjs-cool-core';
 /**
- * 描述
+ * 任务执行的demo示例
  */
 @Provide()
 export class DemoTaskService extends BaseService {
   /**
    * 测试任务执行
+   * @param params 接收的参数 数组 [] 可不传
    */
-  async test() {
+  async test(params?: []) {
     // 需要登录后台任务管理配置任务
-    console.log('任务执行了');
+    console.log('任务执行了', params);
   }
 }