diff --git a/business/scheduler/defsch/defsch.go b/business/scheduler/defsch/defsch.go index b8474d016..3a836ce79 100644 --- a/business/scheduler/defsch/defsch.go +++ b/business/scheduler/defsch/defsch.go @@ -94,7 +94,7 @@ func (s *DefScheduler) OnOrderStatusChanged(status *model.OrderStatus) (err erro globals.SugarLogger.Debugf("OnOrderStatusChanged, status:%v", status) savedOrderInfo := s.loadSavedOrderFromMap(status) s.updateOrderByStatus(savedOrderInfo.order, status) - if status.Status > model.OrderStatusUnknown && status.Status < model.OrderStatusEndBegin { + if (status.Status > model.OrderStatusUnknown && status.Status < model.OrderStatusEndBegin) && status.Status != model.OrderStatusFinishedPickup { if !(status.Status == model.OrderStatusFinishedPickup && len(savedOrderInfo.waybills) > 0) { //饿了么还观察到运单消息早于拣货完成消息 gap := 0 * time.Second beginTime := status.StatusTime