- GetStoreOrderAfterTime修改条件为小于OrderStatusEndBegin
This commit is contained in:
@@ -131,7 +131,7 @@ func (c *OrderManager) OnOrderAdjust(order *model.GoodsOrder, msgVendorStatus st
|
||||
msghub.OnNewOrder(order)
|
||||
// 因为订单调度器需要的是真实状态,所以用order的状态
|
||||
_ = scheduler.CurrentScheduler.OnOrderNew(order, false)
|
||||
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(model.Order2Status(order), false)
|
||||
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(order, model.Order2Status(order), false)
|
||||
}
|
||||
} else {
|
||||
dao.Rollback(db)
|
||||
@@ -148,11 +148,11 @@ func (c *OrderManager) OnOrderStatusChanged(orderStatus *model.OrderStatus) (err
|
||||
panic(r)
|
||||
}
|
||||
}()
|
||||
isDuplicated, _, err := c.addOrderStatus(orderStatus, db)
|
||||
isDuplicated, order, err := c.addOrderStatus(orderStatus, db)
|
||||
if err == nil {
|
||||
dao.Commit(db)
|
||||
if !isDuplicated {
|
||||
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(orderStatus, false)
|
||||
_ = scheduler.CurrentScheduler.OnOrderStatusChanged(order, orderStatus, false)
|
||||
}
|
||||
} else {
|
||||
dao.Rollback(db)
|
||||
|
||||
Reference in New Issue
Block a user