diff --git a/business/partner/purchase/jdshop/callback.go b/business/partner/purchase/jdshop/callback.go index e43544522..0ff5b9daa 100644 --- a/business/partner/purchase/jdshop/callback.go +++ b/business/partner/purchase/jdshop/callback.go @@ -29,13 +29,13 @@ func OnCallbackMsg(msg *jdshopapi.CallBackResult) (err error) { msgType := msg.MsgType switch msgType { case jcqapi.TopicOrderPay: - jxutils.CallMsgHandler(func() { + utils.CallFuncAsync(func() { SaveJdsOrders(msg) - }, jxutils.ComposeUniversalOrderID(msg.OrderID, model.VendorIDJDShop)) + }) case jcqapi.TopicOrderCancel: - jxutils.CallMsgHandler(func() { + utils.CallFuncAsync(func() { CurPurchaseHandler.CancelOrder(jxcontext.AdminCtx, getRealOrderID(msg.OrderID), "系统取消") - }, jxutils.ComposeUniversalOrderID(msg.OrderID, model.VendorIDJDShop)) + }) default: return fmt.Errorf("暂不支持的topic类型!topic: %v", msgType) }