hh

app/service/rabbitmq.js

@@ -1,6 +1,5 @@
 'use strict';
 const msgvalue = require('../util/constants');
-const sd = require('silly-datetime');
 const Service = require('egg').Service;
 
 class RabbitmqService extends Service {
@@ -13,8 +12,7 @@ class RabbitmqService extends Service {
 
   // 发送消息
   async sendQueueMsg(ex, routeKey, msg, parm) {
-    const self = this;
-    const { mq } = self.ctx;
+    const { mq } = this.ctx;
     if (mq) {
       await mq.topic(ex, routeKey, msg, parm);
     } else {
@@ -37,14 +35,10 @@ class RabbitmqService extends Service {
         ch.consume(q.queue, msg => {
           console.log('收到消息: ', msg);
           const result = msg.content.toString();
-          // const fields = msg.fields;
-          // const properties = msg.properties;
           const headers = msg.properties.headers;
           // 插入待办事项到数据库中。
           if (result != null) {
-            // const routingKey = msg.fields.routingKey;
-            const updatetimes = sd.format(new Date(), 'YYYY-MM-DD HH:mm:ss');
-            this.service.message.create({ userid: headers.userId, name: headers.name, createtime: updatetimes, type: headers.type, content: result, remark: '别忘记了' });
+            this.service.message.create({ userid: headers.userId, name: headers.name, createtime: headers.createtime, type: headers.type, content: result, remark: headers.remark });
           }
         }, { noAck: true });
       } catch (e) {