mysql - 使用 sequelize 多次更新同一行的正确方法

Question

我有一个 order 表，我想“再次购买”，order 表包含一列 productDetails 。在此列中，我有一个带有 products 的数组。

要执行此“再次购买”操作，我需要将相同的数组放入购物车。及时更新重要信息(检查是否有库存，产品是否在目录中处于事件状态等)，对于数组中的每个产品，我都会在我的购物车表上进行更新，基本上，我将尝试以下操作:

我正在使用 node.js 和 sequelize.js 来做到这一点:

// Get the older order
const order = await Order.findOne({
    include: [
        {
            model: OrderProduct,
        },
    ],
    where: {
        orderId,
    },
});

// If the cart have something inside, clean the cartDetails column
await CartService.clean(order.userId);

// The addProduct do the checks and insert the product inside the cart
await Promise.all(
    order.OrderProducts.map(async data => {
        await CartService.addProduct(order.userId, data.productMarketId, data.quantity);
    })
);

也许， addProduct 只插入了一种产品。如果我们有更多， map 会正确执行，但只会在列表中添加一个产品。

当我在调试时运行，首先代码在 addProduct() 上调用两次(当我的订单上有两个产品时)，因此获取购物车数据的选择总是为空，并且只有最后一个产品被正确插入。

2 种产品的预期行为:

1. clean cart
2. enter on iterator (map or something else) (product 0):

  2.1. Select cart details (which is empty on first time)
  2.2. Insert product on cart

3. next item on iterator (product 1)

  3.1. Select cart details (which have one element)
  3.2. Insert product on cart

3. end of iterator with 2 products registered on my database.

发生了什么:

1. clean cart
2. enter on iterator (map or something else):
  2.1.a. get the empty cart
  2.1.b. get the empty cart again
  2.2.a. update the product 0 on empty cart selected in 2.1.a. (following the stack of (a)
  2.2.b. update the product 1 on empty cart selected in 2.1.b. (following the stack of (b)

3. Return the cart with only one product inside (the last product).

编辑: 我做了一个关于行为的视频: video here

还有原始的 addProduct 函数(使用 async )并在第一个 await 上并行化(我将 /* ... */ 放在某些地方以使问题更小):

  async addProduct(userId, productMarketId, quantity) {
        const productMarketData = await productMarket.findByPk(productMarketId, { /* ... */ });

        const productKey = Buffer.from(PHPSerialize.serialize(`SP_${productMarketId}`)).toString('base64');

        /* ... */

        const cart = await Cart.findOne({ /* ... */ });

        if (!cart) {
            cart = await this.clean(userId);
        }

        /* ... */

        const newCart = await Cart.upsert({ /* ... */ }).then(result => {
            return result.cartUserId;
        });
        return newCart;
    }

这种行为与 promise 有关？还是异步/等待行为？谢谢。

Answer 1

Array.map 不适用于异步函数，因此您应该将 Promise.all 调用修改为如下所示:

await Promise.all(
    order.OrderProducts.map(data => {
        return CartService.addProduct(order.userId, data.productMarketId, data.quantity);
    })
);

或

顺序版本

for (const orderProduct of order.OrderProducts) {
  await CartService.addProduct(order.userId, orderProduct.productMarketId, orderProduct.quantity)
}