This commit is contained in:
gazebo
2019-09-18 14:16:30 +08:00
parent 135089e12b
commit f438b005a2

View File

@@ -161,8 +161,10 @@ func (c *OrderManager) OnOrderStatusChanged(orderStatus *model.OrderStatus) (err
if err == nil {
dao.Commit(db)
if !isDuplicated {
// order.Skus = c.loadOrderSku(db, order.VendorOrderID, order.VendorID)
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(order, orderStatus, false)
if order != nil {
order.Skus = c.loadOrderSku(db, order.VendorOrderID, order.VendorID)
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(order, orderStatus, false)
}
}
} else {
dao.Rollback(db)
@@ -471,6 +473,7 @@ func (c *OrderManager) addOrderStatus(orderStatus *model.OrderStatus, db *dao.Da
isDuplicated = true
}
} else {
order = nil
if dao.IsNoRowsError(err) { // todo 消息错序
err = nil
} else {