NodeMailer 批量发送邮件
#NodeMailer 


GitHub link: https://github.com/luolinjia/batchMail

我们自己在测试nodemailer的时候,只需要如下简单的配置即可:

var nodemailer = require('nodemailer');
var smtpConfig = {
    host: 'mail.xxx.com',
    port: 25,
    secure: false,
    ignoreTLS: true,
    auth: {
        user: '',
        pass: ''
    },
    pool: true,
    maxConnections: 15000
};

// setup e-mail data with unicode symbols
var mailOptions = {
    from: '[email protected]', // sender address
    to: '[email protected]'
    // bcc: '[email protected]',
    subject: '', // Subject line
    text: 'This is a demo email', // plaintext body
    html: '<div></div>' // html body
};
var transporter = nodemailer.createTransport(smtpConfig);

transporter.sendMail(mailOptions, function(err, info){
    console.log('Message sent: ' + info.response);
    if(err){
        console.log('one email send failed with address: ' + mailAddr);
    }else{
        console.log('successfully!');
    }
    callback(null);
});

但是很多实际的场景却跟简单的有很大的差别,这里我们需要达到如下需求:

  • 批量发送,控制批量的具体数量
  • 发送的地址通过excel来获取
  • 发送成功后,记录发送成功邮件的地址
var nodemailer = require('nodemailer');
var Excel = require("exceljs");
var async = require("async");
var _ = require("underscore");
var fs = require("fs");
var smtpConfig = {
    host: 'mail.xxx.com',
    port: 25,
    secure: false,
    ignoreTLS: true,
    auth: {
        user: '',
        pass: ''
    },
    pool: true,
    maxConnections: 15000
};

// setup e-mail data with unicode symbols
var mailOptions = {
    from: '[email protected]', // sender address
    to: '[email protected]'
    // bcc: '[email protected]',
    subject: '', // Subject line
    text: 'This is a demo email', // plaintext body
    html: '<div></div>' // html body
};
var transporter = nodemailer.createTransport(smtpConfig);

async.parallel(
    {
        all: function (callback) {
            var allMembersWorkbook = new Excel.Workbook();
            var emailArr = [];
            allMembersWorkbook.xlsx.readFile('E:\\files\\work\\onenet_members.xlsx')
                .then(function () {
                    var worksheet = allMembersWorkbook.getWorksheet(1);
                    var emailsColumn = worksheet.getColumn(1);
                    emailsColumn.eachCell(function(cell, rowNumber) {
                        cell.value.text ? emailArr.push(cell.value.text) : emailArr.push(cell.value);
                    });
                    emailArr = _.uniq(_.compact(emailArr));
                    callback(null, {arr:emailArr, worksheet: worksheet});
                });
        },
        success:function(callback){
            var successMembersWorkbook = new Excel.Workbook();
            var emailArr = [];
            successMembersWorkbook.xlsx.readFile('E:\\files\\work\\onenet_success.xlsx')
                .then(function () {
                    var worksheet = successMembersWorkbook.getWorksheet(1);
                    var emailsColumn = worksheet.getColumn(1);
                    emailsColumn.eachCell(function(cell, rowNumber) {
                        cell.value.text ? emailArr.push(cell.value.text) : emailArr.push(cell.value);
                    });
                    callback(null, {arr:emailArr, worksheet: worksheet, workbook: successMembersWorkbook});
                });
        }
    },
    function(err1, results){
        if (err1){
            console.log(err1);
            return;
        }
        var resultsArr = _.reject(results.all.arr, function (email) {
            return _.contains(results.success.arr, email);
        });
        // send the maximum 4 at the same time.
        async.eachLimit(resultsArr, 4, function(mailAddr, callback){
            var newMailOptions = _.extend({to: mailAddr}, mailOptions);
            // send mail with defined transport object
            transporter.sendMail(newMailOptions, function(err2, info){
                console.log('Message sent: ' + info.response);
                if(err2){
                    console.log('one email send failed with address: ' + mailAddr);
                }else{
                    // mark the success recording into the excel file!
                    results.success.worksheet.addRow([mailAddr]).commit();
                }
                callback(null);
            });
        }, function(){
            // delete the relevant file
            fs.unlink('E:\\files\\work\\onenet_success.xlsx', function (err3) {
                if(err3){
                    console.log('delete file error:', err3);
                    return;
                }
                // write the relevant file
                results.success.workbook.xlsx.writeFile('E:\\files\\work\\onenet_success.xlsx')
                    .then(function () {
                        console.log('task finished');
                    });
            });
        });
    }
);
Published under (CC) BY-NC-SA