notice send time & logger

@@ -6,6 +6,7 @@
 const _ = require('lodash');
 const _ = require('lodash');
 const moment = require('moment');
 const moment = require('moment');
 const mysqlCli = global.yoho.utils.mysqlCli;
 const mysqlCli = global.yoho.utils.mysqlCli;
+const logger = global.yoho.logger;
 const MemoryCache = require('../../../utils/memory-cache');
 const MemoryCache = require('../../../utils/memory-cache');
 
 
 const TABLE_ACT_PRIZE_PRODUCT = 'act_prize_product';
 const TABLE_ACT_PRIZE_PRODUCT = 'act_prize_product';
@@ -91,6 +92,33 @@ function handelActivityList(list, nums) {
     return list;
     return list;
 }
 }
 
 
+// 抽奖码创建统计，并生成日志
+const prizeCodeCreateCount = {
+    succedTime: 0,
+    failedTime: 0,
+    logTime: 0,
+    success() {
+        this.succedTime++;
+        this.log();
+    },
+    fail() {
+        this.failedTime++;
+        this.log();
+    },
+    log() {
+        let now = new Date().getTime() / 1000;
+
+        if (now - this.logTime < 60 * 1000) {
+            return;
+        }
+
+        this.logTime = now;
+
+        // 记录抽奖码创建成功失败次数
+        logger.info(`prize_code_create succed: ${this.succedTime}; failed: ${this.failedTime}`);
+    }
+};
+
 module.exports = class extends global.yoho.BaseModel {
 module.exports = class extends global.yoho.BaseModel {
     constructor(ctx) {
     constructor(ctx) {
         super(ctx);
         super(ctx);
@@ -394,11 +422,15 @@ module.exports = class extends global.yoho.BaseModel {
 
 
         if (info && info.length) {
         if (info && info.length) {
             if (isRetry) {
             if (isRetry) {
+                prizeCodeCreateCount.fail(); // 记录生成抽奖码失败
+
                 return '';
                 return '';
             } else {
             } else {
                 return this.createPrizeCode(length, true);
                 return this.createPrizeCode(length, true);
             }
             }
         } else {
         } else {
+            prizeCodeCreateCount.success(); // 记录生成抽奖码成功
+
             return prizeCode;
             return prizeCode;
         }
         }
     }
     }
@@ -538,6 +570,10 @@ module.exports = class extends global.yoho.BaseModel {
                 }),
                 }),
                 uidList: [uid]
                 uidList: [uid]
             }, info)
             }, info)
+        }).then(result => {
+            if (result.code !== 200) {
+                logger.info(`zerobuy_join_notice send fail uid: ${uid}`);
+            }
         });
         });
     }
     }
 };
 };

@@ -5,6 +5,7 @@
  */
  */
 
 
 const mysqlCli = global.yoho.utils.mysqlCli;
 const mysqlCli = global.yoho.utils.mysqlCli;
+const logger = global.yoho.logger;
 const _ = require('lodash');
 const _ = require('lodash');
 const moment = require('moment');
 const moment = require('moment');
 
 
@@ -21,6 +22,10 @@ const TABLE_ACT_PRIZE_PRODUCT = 'act_prize_product';
 const TABLE_ACT_PRIZE_PRODUCT_CONTENT = 'act_prize_product_content';
 const TABLE_ACT_PRIZE_PRODUCT_CONTENT = 'act_prize_product_content';
 const TABLE_ACT_PRIZE_PRODUCT_USER = 'act_prize_product_user';
 const TABLE_ACT_PRIZE_PRODUCT_USER = 'act_prize_product_user';
 
 
+const NOTICE_BATCH_SEND_USER_NUM = 400; // 批量发送模板消息每个请求uid数量
+const NOTICE_BATCH_SEND_API_NUM = 10; // 批量发送模板消息每个批次请求数量
+const NOTICE_BATCH_SEND_INTERVAL = 5000; // 批量发送模板消息批次间隔时间（ms）
+
 const timeFormat = (time) => {
 const timeFormat = (time) => {
     if (_.isNumber(time)) {
     if (_.isNumber(time)) {
         time = moment.unix(time);
         time = moment.unix(time);
@@ -765,9 +770,11 @@ class AdminModel extends global.yoho.BaseModel {
             })
             })
         };
         };
 
 
-        _.forEach(_.chunk(userList, 400), value => {
+        _.forEach(_.chunk(userList, NOTICE_BATCH_SEND_USER_NUM), value => {
             if (value && value.length) {
             if (value && value.length) {
-                msgApi.push(this.get({data: Object.assign({uidList: value}, msgData)}));
+                msgApi.push(this.get({data: Object.assign({uidList: value}, msgData)}).then(result => {
+                    logger.info(`zerobuy_winning_notice send ${result.code === 200 ? 'success' : 'fail'} uids: ${value.join(',')}`);
+                }));
             }
             }
         });
         });
 
 
@@ -785,10 +792,10 @@ class AdminModel extends global.yoho.BaseModel {
         }
         }
 
 
         setTimeout(() => {
         setTimeout(() => {
-            this.batchSend(_.drop(apis, 20));
-        }, 1000);
+            this.batchSend(_.drop(apis, NOTICE_BATCH_SEND_API_NUM));
+        }, NOTICE_BATCH_SEND_INTERVAL);
 
 
-        return Promise.all(_.take(apis, 20));
+        return Promise.all(_.take(apis, NOTICE_BATCH_SEND_API_NUM));
     }
     }
 }
 }