cron.schedule()重复执行问题求助：定时邮件触发多次发送

你现在的问题核心是两个逻辑错误叠加导致的：

• 用setInterval每秒调用send函数，每次循环都会给同一个邮件任务重复注册cron定时器。比如1分钟就会生成60个相同的定时任务，到时间后所有定时器同时触发，自然会重复执行几十次。
• cron表达式后面多拼了一个*，导致格式错误，进一步打乱了定时触发逻辑。

核心思路 #

彻底抛弃setInterval，用cron本身做定时调度，给每个邮件任务只注册一次定时器，执行完成后销毁定时器并标记任务已处理。

修改后的代码 #

// 记录已注册的邮件ID，防止重复添加定时器
const registeredEmails = new Set();

function registerEmailTasks() {
  for (let i = 0; i < emails.length; i++) {
    const [emailTime, recipient, subject, message, emailId] = emails[i];
    
    // 跳过已注册的任务，避免重复创建定时器
    if (registeredEmails.has(emailId)) continue;
    
    let correctedTime = emailTime;
    // 修正cron小时范围：cron支持0-23，24点实际是次日0点，不是1点
    const timeParts = correctedTime.split(' ');
    if (timeParts[1] === '24') {
      timeParts[1] = '00';
    }
    correctedTime = timeParts.join(' ');
    
    // 注册cron任务，获取定时器对象用于后续销毁
    const task = cron.schedule(correctedTime, async () => {
      try {
        // 等待邮件发送完成（如果sendEmail返回Promise，必须加await）
        await sendEmail(recipient, subject, message);
        
        // 用参数化查询避免SQL注入风险，不要直接拼接变量
        const sql = 'DELETE FROM emails WHERE email_id = ?';
        con.query(sql, [emailId], (err, result) => {
          if (err) throw err;
          console.log(`邮件ID ${emailId} 已从数据库删除`);
        });
        
        // 销毁定时器，防止重复触发
        task.stop();
        // 更新注册记录和邮件数组
        registeredEmails.delete(emailId);
        emails.splice(i, 1);
        i--; // 数组长度变化，索引回退避免跳过下一个元素
      } catch (err) {
        console.error(`处理邮件ID ${emailId} 出错:`, err);
      }
    });
    
    // 标记该邮件已注册定时器
    registeredEmails.add(emailId);
  }
}

// 只需要调用一次，完成所有邮件任务的注册
registerEmailTasks();

// 如果后续会从数据库新增邮件，可以定时刷新任务（比如每5分钟一次）
// setInterval(registerEmailTasks, 5 * 60 * 1000);

关键注意事项 #

1. SQL注入防护：绝对不要直接拼接SQL语句，用?占位符的参数化查询是必须的，避免被恶意攻击。
2. 异步逻辑处理：如果sendEmail是异步函数（返回Promise），一定要加await，确保邮件发送完成后再执行删除操作，避免数据不一致。
3. cron时间格式：标准cron表达式是分 时 日 月 周，不要额外拼接*，否则会导致解析错误。

内容的提问来源于stack exchange，提问作者CodingRookie