新增demo示例

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 { IQueue } from 'midwayjs-cool-queue';
-import { DemoGoodsService } from '../../../service/goods';
+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,
+    });
+  }
 }

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();
   }
 }

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);
   }
 }