diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index 60ba4f317..99bd78223 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -69,7 +69,6 @@ func (c *OrderManager) OnOrderNew(order *model.GoodsOrder, msgVendorStatus strin isDuplicated, err := addOrderOrWaybillStatus(status, db) if err == nil && !isDuplicated { if isDuplicated, err = c.SaveOrder(order, false, db); err == nil && !isDuplicated { - msghub.OnNewOrder(order) err = scheduler.CurrentScheduler.OnOrderNew(order, false) } } diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go index d7d64b892..6f77e355e 100644 --- a/business/jxcallback/scheduler/defsch/defsch.go +++ b/business/jxcallback/scheduler/defsch/defsch.go @@ -8,6 +8,7 @@ import ( "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/netprinter" + "git.rosy.net.cn/jx-callback/business/msghub" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxcallback/scheduler" @@ -150,12 +151,13 @@ func init() { err = err2 } } - if isAcceptIt { - netprinter.PrintOrderByOrder(jxcontext.AdminCtx, order) - utils.CallFuncAsync(func() { - weixinmsg.NotifyNewOrder(order) - }) - } + } + if isAcceptIt { + netprinter.PrintOrderByOrder(jxcontext.AdminCtx, order) + utils.CallFuncAsync(func() { + weixinmsg.NotifyNewOrder(order) + }) + msghub.OnNewOrder(order) } return err })