如何将链式 Promise 与数组的 for 循环一起使用？

Question

所以，我有这个代码。我正在尝试永远调试它。我不知道为什么它返回错误。我可能忘记了一些承诺，或者我的 array.push 有问题，因为当我查看日志时，它会在我将一些对象推入数组的地方抛出错误。

到目前为止，这是我的代码：

router.post('/inventory/product/stocks/add/(:id)', authenticationMiddleware(), function(req, res, next) {
const db = require('../db.js')

var product_no = req.params.id
var cog = req.body.cog
var size_slug = req.body.size_slug
var size_name = req.body.size_name
var rowinserted = 0
var initial_stock = req.body.initial_stock
var stock_id = new Array
var batch_id = new Array
var stock = new Array
var batch = new Array

new Promise(function(resolve, reject) {
    console.log('one');
    // Getting product product_slug for product_sku

    let sql = `SELECT product_slug
               FROM inventory_tbl
               WHERE product_no = ?`

    db.query(sql, [req.params.id], (error, results, fields) => {
        if (error) {
            throw error;
        } else {
            var product_slug = results[0].product_slug
            resolve(product_slug)
        }
    })
})
.then(function(value) {
    console.log('two');
    // Insert product sizes together with its initial stock

    for (var x = 0; x < size_slug.length; x++) {
        var product_sku = value + size_slug[x]
        var slug = size_slug[x]
        var name = size_name[x]
        var initial_stock = initial_stock[x]
        console.log(product_sku);
        if (size_slug[x] != '') {
            stock.push({
                product_sku: product_sku,
                product_no: product_no,
                size_slug: slug,
                size_name: name,
                total_stock: initial_stock,
                available_stock: initial_stock
            })
        }
        console.log(stock);
    }

    for (var x = 0; x < size_slug.length; x++) {
        var product_sku = value + size_slug[x]
        var initial_stock = initial_stock[x]
        if (size_slug[x] != '') {
            batch.push({
                product_no: product_no,
                product_sku: product_sku,
                production_date: mysql.raw('CURRENT_TIMESTAMP'),
                batch_cog: cog,
                initial_stock: initial_stock,
                stock_left: initial_stock
            })
        }
        console.log(batch);
    }

    return value
})
.then(function(value) {
    console.log('three');
    // Insert rows to product_tbl and stock_tbl

    for (var i = 0; i < stock.length; i++) {
        let sql = `INSERT INTO product_tbl(product_sku, product_no, size_slug, size_name, total_stock, available_stock) VALUES (?, ?, ?, ?, ?, ?)`

        db.query(sql, [stock[i].product_sku, req.params.id, stock[i].size_slug, stock[i].size_name, stock[i].total_stock, stock[i].available_stock], (error, results, fields) => {
            if (error) throw error
            db.query(`SELECT LAST_INSERT_ID() AS id;`, (error, results, fields) => {
                stock_id[i] = results[0].id
            })
        })

        sql = `INSERT INTO stocks_tbl(product_no, product_sku, production_date, batch_cog, initial_stock, stock_left) VALUES (?, ?, CURRENT_DATE, ?, ?, ?)`

        db.query(sql, [req.params.id, batch[i].product_sku, batch[i].batch_cog, batch[i].initial_stock, batch[i].stock_left], (error, results, fields) => {
            if (error) throw error
            db.query(`SELECT LAST_INSERT_ID() AS id;`, (error, results, fields) => {
                batch_id[i] = results[0].id
            })
        })
        rowsupdated++
    }

    return value
})
.then(function(value) {
    console.log('four');
    // Render the web page
    if (rowinserted != sizeslug.length) {
        req.flash('error', error)

        res.redirect('/admin/inventory/product/stock/add/' + req.params.id)
    } else {
        req.flash('success', 'Data added successfully!')
        res.redirect('/admin/inventory/product/stock/add/' + req.params.id)
    }
})
.catch(function(error) {
    console.log('error');
    // Error handler

    for (var i = 0; i < rowinserted; i++) {
        let sql = `DELETE FROM product_tbl WHERE product_sku = ?`

        db.query(sql, [stock_id[i]], (error, results, fields) => {
            if (error) throw error
        })

        sql = `DELETE FROM stocks_tbl WHERE product_sku = ?`

        db.query(sql, [batch_id[i]], (error, results, fields) => {
            if (error) throw error
        })
    }

    res.redirect('/admin/inventory/product/stock/add/' + req.params.id)
})
})

我的日志返回：

一个

两个

错误

编辑：进程在 console.log('two') 之后停止（我不确定具体的行，但根据日志输出），因为我尝试在for 循环，但它们不会在那里继续。它只是转到 .catch/error。

Answer 1

而不是在console.log('error'); 中输出字符串，而是转储您在catch 处理程序中收到的实际error 对象。它将提供有关失败原因和位置的更多详细信息。我怀疑console.log('two');之后的代码会抛出异常，然后你不小心把它吞到下面了。

考虑将您的代码拆分为单独的主题函数。这样您就可以更轻松地维护和发现错误（或拼写错误）。

Answer 2

查看输出，我可以看到 console.log(product_sku); 这没有被打印出来。所以，实际上问题是var initial_stock = initial_stock[x]。您已经声明了与全局变量（到您的 route.post 回调函数）同名的局部变量（到您的 then 回调函数），现在您的全局 initial_stock 变量被本地变量掩盖，这不是一个数组（实际上是不明确的）。因此，尝试将变量名称更改为 then 块中的其他名称，看看问题是否消失。

希望这会有所帮助。