Node.js+Express中创建Sale后SaleService未生成的问题排查

使用Node.js + Express + Sequelize开发，Sale与Service通过SaleService中间表实现多对多关联。创建Sale记录成功，但循环创建SaleService时无数据生成，控制台也未输出任何报错信息。

相关代码如下：

控制器代码（createSale方法） #

const Sale = require('../models/Sale.model');
const Service = require('../models/Service.model');
const SaleService = require('../models/SaleService.model');
const ErrorResponse = require('../utils/errorResponse');
const asyncHandler = require('../middleware/async');

//@route   POST /api/v1/sales
//@desc    Create Sale
//@access  Private

exports.createSale = asyncHandler(async (req, res, next) => {
    const { services, customer_id, employee_id } = req.body;

    const sale = await Sale.create({ employee_id, customer_id });

    const saleServices = await Promise.all(services.map(async (serviceData) => {
        const { id } = serviceData;
        const service = await Service.findByPk(id, { attributes: ['id'] });
        if (!service) {
            return next(new ErrorResponse(`Service with id: ${id} not found`, 404));
        }

        return await SaleService.create({ 
            sale_id: sale.id, 
            service_id: id, 
        });
    }));

    res.status(201).json({ sale, saleServices });
});

关联配置（associations.js） #

const User = require('./User.model');
const Employee = require('./Employee.model');
const Sale = require('./Sale.model');
const Service = require('./Service.model');

Sale.belongsToMany(Service, { through: 'Sale_Service', onDelete: 'CASCADE' });
Service.belongsToMany(Sale, { through: 'Sale_Service', onDelete: 'CASCADE' });
User.hasOne(Employee, { foreignKey: 'user_id', as: 'Employee', onDelete: 'CASCADE' });
Employee.belongsTo(User, { foreignKey: 'user_id', as: 'User', onDelete: 'CASCADE' });


module.exports = { User, Employee, Sale, Service };

Service.model.js #

const { Sequelize, DataTypes } = require('sequelize');
const sequelize = require('../config/db');

const Service = sequelize.define('Service', {
    id: {
        type: DataTypes.INTEGER,
        primaryKey: true,
        autoIncrement: true
    },
    service_code: {
        type: DataTypes.STRING,
        allowNull: false,
        unique: true    
    },
    name: {
        type: DataTypes.STRING,
        allowNull: false,
        unique: true    
    },
    description: {
        type: DataTypes.STRING,
        allowNull: false,
 
    },
    service_date: {
        type: Sequelize.DATE,
        allowNull: false,
    },
    price: {
        type: Sequelize.DECIMAL(20,2),
        allowNull: false,
    },

});

module.exports = Service;

Sale.model.js #

const { Sequelize, DataTypes } = require('sequelize');
const sequelize = require('../config/db');

const Sale = sequelize.define('Sale', {
    id: {
        type: DataTypes.INTEGER,
        primaryKey: true,
        autoIncrement: true
    },
    employee_id: {
        type: DataTypes.INTEGER,
        references: {
            model: 'employees',
            key: 'id'
        },
        required: true,
        allowNull: false,
    },
    customer_id: {
        type: DataTypes.INTEGER,
        references: {
            model: 'customers',
            key: 'id'
        },
        required: true,
        allowNull: false,
    },
    
});

module.exports = Sale;

SaleService.model.js #

const { Sequelize, DataTypes } = require('sequelize');
const sequelize = require('../config/db');

const SaleService = sequelize.define('SaleService', {
    id: {
        type: DataTypes.INTEGER,
        primaryKey: true,
        autoIncrement: true
    },
    sale_id: {
        type: DataTypes.INTEGER,
        allowNull: false,
        primaryKey: true,
        references: {
            model: 'sales', 
            key: 'id'
        },
    },
    service_id: {
        type: DataTypes.INTEGER,
        allowNull: false,
        primaryKey: true,
        references: {
            model: 'services',
            key: 'id'
        },
    }
}, {
    tableName: 'SaleService', 
    timestamps: false, 
});

module.exports = SaleService;

可能的原因及修复方案 #

1. 中间表名称不匹配 #

关联配置中belongsToMany指定的中间表是'Sale_Service'，但自定义的SaleService模型设置的表名是'SaleService'（tableName属性）。Sequelize会优先使用关联定义的through值操作中间表，导致实际操作的表与你定义的模型表不一致，插入数据自然无法在目标表中显示。

修复：
将关联配置中的through改为与模型tableName一致的值：

Sale.belongsToMany(Service, { through: 'SaleService', onDelete: 'CASCADE' });
Service.belongsToMany(Sale, { through: 'SaleService', onDelete: 'CASCADE' });

2. SaleService模型主键定义冲突 #

在SaleService.model.js中，同时将自增id和sale_id、service_id标记为primaryKey: true。Sequelize中一个模型只能有一组主键，这种重复定义会触发主键约束异常，但可能因为异步操作的特性静默失败。

修复：
选择以下两种方案之一：

• 方案1：保留自增id作为唯一主键，去掉sale_id和service_id的primaryKey: true配置
• 方案2：删除自增id，将sale_id和service_id设为联合主键（更符合多对多中间表的设计规范）

示例方案2代码：

const SaleService = sequelize.define('SaleService', {
    sale_id: {
        type: DataTypes.INTEGER,
        allowNull: false,
        primaryKey: true,
        references: {
            model: 'sales', 
            key: 'id'
        },
    },
    service_id: {
        type: DataTypes.INTEGER,
        allowNull: false,
        primaryKey: true,
        references: {
            model: 'services',
            key: 'id'
        },
    }
}, {
    tableName: 'SaleService', 
    timestamps: false, 
});

3. 请求体services格式异常 #

检查前端传入的req.body.services是否为包含有效id字段的数组（比如[{id:1}, {id:2}]）。如果services是空数组、或者每个serviceData没有id属性，都会导致循环逻辑不执行或插入无效数据。

验证方式：
在控制器开头添加日志打印：

console.log('Received services:', req.body.services);

4. 改用Sequelize关联方法替代手动插入 #

其实无需手动创建SaleService，利用Sequelize多对多关联提供的addServices方法更简单可靠，还能避免手动插入的各类错误：

优化后的控制器代码：

exports.createSale = asyncHandler(async (req, res, next) => {
    const { services, customer_id, employee_id } = req.body;

    const sale = await Sale.create({ employee_id, customer_id });

    // 提取所有服务ID
    const serviceIds = services.map(s => s.id);
    // 校验所有服务是否存在
    const existingServices = await Service.findAll({
        where: { id: serviceIds },
        attributes: ['id']
    });
    if (existingServices.length !== serviceIds.length) {
        const missingIds = serviceIds.filter(id => !existingServices.some(s => s.id === id));
        return next(new ErrorResponse(`Services with ids: ${missingIds.join(',')} not found`, 404));
    }

    // 使用关联方法批量添加服务
    await sale.addServices(serviceIds);

    // 查询包含关联服务的Sale数据返回
    const saleWithServices = await Sale.findByPk(sale.id, {
        include: [{ model: Service }]
    });

    res.status(201).json({ sale: saleWithServices });
});

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