订单库存加上事务

This commit is contained in:
苏尹岚
2020-09-25 17:18:59 +08:00
parent 9dfab431b8
commit 1e019f8767

View File

@@ -372,6 +372,13 @@ func ModifyOrderSkusStock(db *dao.DaoDB, order *model.GoodsOrder, isAdd bool) (e
}
continue
}
dao.Begin(db)
defer func() {
if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
}()
if isAdd {
stock = storeSku.Stock + sku.Count
} else {
@@ -395,6 +402,7 @@ func ModifyOrderSkusStock(db *dao.DaoDB, order *model.GoodsOrder, isAdd bool) (e
if order.VendorID != model.VendorIDJX {
dao.SetStoreSkuSyncStatus(db, order.VendorID, []int{jxutils.GetSaleStoreIDFromOrder(order)}, []int{sku.SkuID}, model.SyncFlagStockMask)
}
dao.Commit(db)
}
return err
}