Node.js定时脚本月末退款任务未执行问题排查求助

问题背景 #

要开发部署在网页服务器的Node.js脚本，需求是：

• 每月1号统计数据库用户数，按公式0.8 * 用户数 * 100生成待退款代币数
• 每月最后一天再次统计用户数，将月初生成的代币平均退还给所有用户
• 服务器启动后自动运行，无需手动执行

测试时设置每分钟执行统计逻辑，每两分钟执行退款逻辑，但退款逻辑始终未触发，refundTokens内的日志无输出。

核心错误点 #

1. Node.js环境不支持localStorage #

localStorage是浏览器专属的Web API，Node.js运行环境中不存在这个对象。第一个定时任务执行时会直接抛出错误，导致后续代码（包括第二个定时任务）无法正常运行，只是因为没有错误捕获，你没看到报错信息。

2. 异步函数调用未处理await与错误捕获 #

• 调用refundTokens时没有加await，异步操作的错误会静默丢失
• 定时任务内的异步函数未做错误捕获，一旦出现异常会直接终止任务，且无日志提示

3. 潜在的类型转换问题 #

即使存储方式正常，localStorage.getItem返回的是字符串类型，直接传入refundTokens会导致!isNaN(tokensToRefund)判断失效（字符串形式的数字会被isNaN判定为false，但如果是null/undefined则会是true）。

修复方案 #

替换存储方式 #

用Node.js环境支持的方式存储待退款代币数，比如：

• 模块内的内存变量（简单测试用）
• 数据库专门的配置表（生产环境推荐，避免服务器重启丢失数据）
• 本地文件（适合轻量场景）

这里先用内存变量示例。

完善异步错误处理 #

所有异步函数调用添加await，并通过try/catch捕获错误，确保任务异常时能输出日志，避免静默失败。

处理类型转换 #

确保存储和读取的代币数是数值类型，避免类型错误。

修复后的完整代码 #

const { Pool } = require('pg');
const cron = require('node-cron');

// Connection configuration
const config = {
  user: '',
  password: '',
  host: '',
  database: ''
};

// Create a new connection pool
const pool = new Pool(config);

// 内存变量存储待退款代币数，替换localStorage
let tokensToRefund = 0;

async function countUsers() {
  try {
    const query = `SELECT COUNT(*) as count FROM users`;
    const res = await pool.query(query);
    const numUsers = +res.rows[0].count;
    console.log(`当前用户数: ${numUsers}`);
    return numUsers;
  } catch (err) {
    console.error('统计用户数失败:', err);
    return 0;
  }
}

async function refundTokens(tokensToRefund, numUsers) {
  console.log("进入退款逻辑");
  console.log(`待退款总数: ${tokensToRefund}, 当前用户数: ${numUsers}`);
  if (numUsers !== 0 && !isNaN(tokensToRefund)) {
    const tokensPerUser = Math.round(tokensToRefund / numUsers);
    try {
      const query = `UPDATE users SET tokens = tokens + $1`;
      await pool.query(query, [tokensPerUser]);
      console.log(`退款完成，每人发放${tokensPerUser}代币`);
    } catch (err) {
      console.error('退款执行失败:', err);
    }
  } else {
    console.log('退款条件不满足：用户数为0或代币数无效');
  }
}

// 每分钟执行统计逻辑
cron.schedule('* * * * *', async () => {
  try {
    const numUsers = await countUsers();
    tokensToRefund = 0.8 * numUsers * 100;
    console.log(`生成待退款代币数: ${tokensToRefund}`);
  } catch (err) {
    console.error('统计任务执行失败:', err);
  }
});

// 每两分钟执行退款逻辑
cron.schedule('*/2 * * * *', async () => {
  try {
    const numUsers = await countUsers();
    await refundTokens(tokensToRefund, numUsers);
  } catch (err) {
    console.error('退款任务执行失败:', err);
  }
});

生产环境优化建议 #

• 不要用内存变量存储待退款代币数，服务器重启会丢失数据，建议在数据库中创建一个配置表（比如system_config），存储monthly_refund_tokens字段
• 定时任务的时间表达式改成每月1号和每月最后一天：
  • 每月1号0点：0 0 1 * *
  • 每月最后一天0点：0 0 L * *（node-cron支持L表示当月最后一天）
• 添加日志持久化，比如用winston或pino库将日志写入文件，方便排查问题

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