diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go index 6f77e355e..944164de7 100644 --- a/business/jxcallback/scheduler/defsch/defsch.go +++ b/business/jxcallback/scheduler/defsch/defsch.go @@ -229,6 +229,13 @@ func (s *DefScheduler) OnOrderNew(order *model.GoodsOrder, isPending bool) (err } if order.Status >= model.OrderStatusNew { s.resetTimer(savedOrderInfo, nil, isPending) + if !isPending && order.Status >= model.OrderStatusAccepted { // 有订单消息错序,先收到接单消息,再收到新订单消息,导致接单TIMER不动作,这里补一下 + netprinter.PrintOrderByOrder(jxcontext.AdminCtx, order) + utils.CallFuncAsync(func() { + weixinmsg.NotifyNewOrder(order) + }) + msghub.OnNewOrder(order) + } } return err }