Node.js使用Sequelize实现MySQL订单30天后自动更新状态

你最初猜测用Hook实现的思路存在偏差：Sequelize的Hook是绑定在模型增删改操作上的回调，只有应用主动调用Sequelize执行数据操作时才会触发，本身不具备定时调度能力，没法独立监控时间阈值自动更新数据。
这个需求的核心逻辑分两部分：

• 精准记录订单状态最后一次更新的时间，避免其他字段更新干扰判断
• 定时扫描符合“状态为processing、距最后一次状态更新满30天”条件的订单，批量更新状态
  其中Hook可以用来自动维护状态更新时间，避免业务代码漏写更新逻辑；定时调度能力需要引入定时任务模块实现。

1. 定义订单模型，用Hook自动维护状态更新时间 #

不要用表默认的updatedAt字段做判断——订单除了状态变更，修改收货地址、备注、物流信息等操作都会更新updatedAt，会导致判断失准，需要单独加status_updated_at字段专门记录状态最后变更时间，通过Sequelize Hook自动维护这个字段的值：

const { DataTypes } = require('sequelize');
const sequelize = require('./db/sequelize'); // 替换为你项目里的Sequelize连接实例

const Order = sequelize.define('Order', {
  id: {
    type: DataTypes.INTEGER,
    primaryKey: true,
    autoIncrement: true
  },
  status: {
    type: DataTypes.ENUM('processing', 'on Hold', 'completed', 'cancelled'),
    defaultValue: 'processing',
    allowNull: false
  },
  status_updated_at: {
    type: DataTypes.DATE,
    allowNull: false,
    defaultValue: DataTypes.NOW
  }
}, {
  tableName: 'orders',
  timestamps: true,
  hooks: {
    // 创建订单时默认写入当前时间为状态更新时间
    beforeCreate: (order) => {
      order.status_updated_at = new Date();
    },
    // 每次更新订单时，检测到status字段变更就自动更新status_updated_at
    beforeUpdate: (order) => {
      if (order.changed('status')) {
        order.status_updated_at = new Date();
      }
    }
  }
});

module.exports = Order;

2. 编写定时任务批量更新超时订单 #

Node.js生态里用node-cron实现定时任务足够轻量，选业务低峰期（比如每天凌晨2点）执行扫描更新即可，先安装依赖：
npm install node-cron

然后在项目启动入口加定时任务逻辑：

const cron = require('node-cron');
const Order = require('./models/order');
const { Op } = require('sequelize');
const sequelize = require('./db/sequelize');

// cron表达式顺序：秒 分 时 日 月 周，示例为每天凌晨2点整执行
cron.schedule('0 0 2 * * *', async () => {
  const t = await sequelize.transaction();
  try {
    // 计算30天前的时间阈值
    const thresholdTime = new Date();
    thresholdTime.setDate(thresholdTime.getDate() - 30);

    // 批量更新符合条件的订单，加事务保证数据一致性
    const [updatedCount] = await Order.update(
      { status: 'on Hold' },
      {
        where: {
          status: 'processing',
          status_updated_at: {
            [Op.lt]: thresholdTime
          }
        },
        transaction: t
      }
    );

    await t.commit();
    console.log(`订单超时状态更新完成，共更新${updatedCount}个30天无状态变动的processing订单`);
  } catch (err) {
    await t.rollback();
    console.error('订单超时状态更新任务执行失败:', err);
  }
}, {
  scheduled: true,
  timezone: 'Asia/Shanghai' // 替换为你服务部署的时区，避免时间计算偏差
});

• 如果你的服务是多实例部署，要避免多个实例同时执行定时任务导致重复逻辑，可以给定时任务加分布式锁，或者把定时任务拆成独立的单实例服务运行。
• 如果对状态变更的实时性要求很高，不想等每天的定时任务，可以在每次查询processing状态的订单时，顺带判断是否满足超时条件做即时更新，但定时批量扫描的方案对数据库压力最小，适合绝大多数业务场景。
• 不要直接在数据库层写MySQL事件调度实现，一是不利于逻辑迭代维护，二是多环境部署时容易出现配置不一致的问题。

内容的提问来源于stack exchange，提问作者Thắng Nguyễn Quyết