新增邮件补发功能

cloud.js

@@ -28,6 +28,27 @@ AV.Cloud.afterSave('Comment', function (request) {
     });
 });
 
+AV.Cloud.define('resend_mails', function(req) {
+    let query = new AV.Query(Comment);
+    query.greaterThanOrEqualTo('createdAt', new Date(new Date().getTime() - 24*60*60*1000));
+    query.notEqualTo('isNotified', true);
+    // 如果你的评论量很大，可以适当调高数量限制，最高1000
+    query.limit(200);
+    return query.find().then(function(results) {
+        new Promise((resolve, reject)=>{
+            count = results.length;
+            for (var i = 0; i < results.length; i++ ) {
+                sendNotification(results[i], req.meta.remoteAddress);
+            }
+            resolve(count);
+        }).then((count)=>{
+            console.log(`昨日${count}条未成功发送的通知邮件处理完毕！`);
+        }).catch(()=>{
+
+        });
+    });
+});
+
 AV.Cloud.define('self_wake', function(req) {
     request(process.env.ADMIN_URL, function (error, response, body) {
         console.log('自唤醒任务执行成功，响应状态码为:', response && response.statusCode);

utilities/send-mail.js

@@ -54,6 +54,8 @@ exports.notice = (comment) => {
         if (error) {
             return console.log(error);
         }
+        comment.set('isNotified', true);
+        comment.save();
         console.log("收到一条评论, 已提醒站长");
     });
 }
@@ -89,6 +91,8 @@ exports.send = (currentComment, parentComment)=> {
         if (error) {
             return console.log(error);
         }
+        currentComment.set('isNotified', true);
+        currentComment.save();
         console.log(currentComment.get('nick') + " @了" + parentComment.get('nick') + ", 已通知.");
     });
 };