aa
This commit is contained in:
@@ -501,7 +501,7 @@ func (s *DefScheduler) OnOrderStatusChanged(order *model.GoodsOrder, status *mod
|
|||||||
// 以下是运单
|
// 以下是运单
|
||||||
func (s *DefScheduler) OnWaybillStatusChanged(bill *model.Waybill, isPending bool) (err error) {
|
func (s *DefScheduler) OnWaybillStatusChanged(bill *model.Waybill, isPending bool) (err error) {
|
||||||
if bill.Status > model.WaybillStatusUnknown {
|
if bill.Status > model.WaybillStatusUnknown {
|
||||||
globals.SugarLogger.Debugf("OnWaybillStatusChanged orderID:%s %s, bill:%v", bill.VendorOrderID, model.WaybillStatusName[bill.Status], bill)
|
globals.SugarLogger.Debugf("OnWaybillStatusChanged orderID:%s %s, bill:%v", bill.VendorOrderID, model.WaybillStatusName[bill.Status], utils.Format4Output(bill, true))
|
||||||
savedOrderInfo := s.loadSavedOrderFromMap(model.Waybill2Status(bill), true)
|
savedOrderInfo := s.loadSavedOrderFromMap(model.Waybill2Status(bill), true)
|
||||||
order := savedOrderInfo.order
|
order := savedOrderInfo.order
|
||||||
// todo 当前收到的事件顺序有时是乱的,不能严格限制,暂时放开
|
// todo 当前收到的事件顺序有时是乱的,不能严格限制,暂时放开
|
||||||
@@ -1039,6 +1039,7 @@ func (s *DefScheduler) resetTimer(savedOrderInfo *WatchOrderInfo, bill *model.Wa
|
|||||||
}
|
}
|
||||||
|
|
||||||
if config != nil && config.TimeoutAction != nil && config.TimerType != partner.TimerTypeByPass {
|
if config != nil && config.TimeoutAction != nil && config.TimerType != partner.TimerTypeByPass {
|
||||||
|
globals.SugarLogger.Debugf("CallShouldSetTimer : order : %v, waybill: %v", utils.Format4Output(savedOrderInfo, true), utils.Format4Output(bill, true))
|
||||||
if config.CallShouldSetTimer(savedOrderInfo, bill) {
|
if config.CallShouldSetTimer(savedOrderInfo, bill) {
|
||||||
timeout := config.GetRefTimeout(statusTime, order.OrderCreatedAt)
|
timeout := config.GetRefTimeout(statusTime, order.OrderCreatedAt)
|
||||||
if config.TimeoutGap != 0 {
|
if config.TimeoutGap != 0 {
|
||||||
|
|||||||
Reference in New Issue
Block a user