如何使用循环发送电子邮件并更新每条记录？

Question

我已经实现了用于发送电子邮件的 nodemailer。对于电子邮件详细信息，如电子邮件 ID、主题和文本，我在数据库中有一个 table。在那 table 我有一个标志（新的，已处理的）来获取新记录列表，以便我可以发送新记录的邮件我在记录列表上使用 for 循环来发送电子邮件。我想知道的是，一旦邮件转发成功，我想更新数据库中的记录标志。我在 node.js.

中使用 sequlize


var WEBDialerList=[];
var WEBDialerListCount;

SqlObj.WEBDialer.findAll(
        {
            where: {
                IsDeleted: 0,
                Status: 'New'
            }
        }
    )
        .then(data => {
            WEBDialerList = JSON.parse(JSON.stringify(data));
            console.log("d.length")
            console.log(WEBDialerList.length)
            console.log("d.length")
            if (WEBDialerList.length > 0) {
                for (var i in WEBDialerList){//= 0; i < WEBDialerList.length; i++) {
                    WEBDialerListCount = i;

                    "use strict";
                    const nodemailer = require("nodemailer");
                    let transporter = nodemailer.createTransport({
                        service: "Gmail",
                        auth: {
                            user: 'abc@gmail.com',
                            pass: '******'
                        }
                    });
                    var e = WEBDialerList[i].Email;
                    let mailOptions = {

                        from: '"ib ik" <ib.ik2093@gmail.com>',
                        to: e,

                        subject: "Test Email from Node.js",
                        text: " scheduler Hello, this is a test email.  I have configured my gmail account in node.js to send emails. I am checking, is it configured correctly.",// plain text body
                        html: "<b> " + WEBDialerList[i].WEBDialerId + " scheduler Hello, this is a test email.  I have configured my gmail account in node.js to send emails. I am checking, is it configured correctly.</b>" // html body
                    };
                     transporter.sendMail(mailOptions, function (error, info) {
                        if (error) {
                            return console.log(error);
                        }
                        else {
                            console.log("Message sent1: ", info);
                            console.log(WEBDialerListCount)
                            transporter.close();
                        }
                    })

                }
            }
        })
        .catch(function (err) {
            console.log(err)
        });

在transporter.sendMail中，我只是在循环结束时才得到它，所以我很难得到需要更新的记录。

Answer 1

可能的解决方案是：

[..]

// Move this declarations out is a good idea
const nodemailer = require("nodemailer");
let transporter = nodemailer.createTransport({
    service: "Gmail",
    auth: {
         user: 'foobar@gmail.com',
         pass: 'foobar'
    }
});

[..]

for (var i in WEBDialerList) {
    [..]

    transporter.sendMail(mailOptions, function (error, info) {
        if (error) {
            sql.setFlag('errored') // pseudocode
        } else {
            sql.setFlag('processed') // pseudocode
            transporter.close();
         }
    })
}

[..]

PS：删除您的 Gmail 凭据！

Answer 2

拜托，async await 而不是 promises 代码看起来不错且易于阅读。

这是您问题的答案。

Promis.all(
  WEBDialerList.map(WEBDialer => {
    let mailOptions = {
      from: '"ib ik" <ib.ik2093@gmail.com>',
      to: WEBDialer.email,

      subject: "Test Email from Node.js",
      text: " scheduler Hello, this is a test email.  I have configured my gmail account in node.js to send emails. I am checking, is it configured correctly.",// plain text body
      html: "<b> " + WEBDialer.WEBDialerId + " scheduler Hello, this is a test email.  I have configured my gmail account in node.js to send emails. I am checking, is it configured correctly.</b>" // html body
    };
    return new Promise((resolve, reject) => {
      transporter.sendMail(mailOptions, function (error, info) {
        if (error) {
          reject(error)
        } else {
          console.log("Message sent1: ", info);
          console.log(WEBDialerListCount)
          // Update user here
          transporter.close();
          resolve()
        }
      })  
    })
  })
)

请根据您的要求进行必要的修改。

如果您需要更多帮助或有任何问题，请告诉我。

希望你喜欢:)

如何使用循环发送电子邮件并更新每条记录？

how to send email using loop and update each record?

node.js

sequelize.js

nodemailer