jdsorder补充
This commit is contained in:
@@ -29,13 +29,13 @@ func OnCallbackMsg(msg *jdshopapi.CallBackResult) (err error) {
|
|||||||
msgType := msg.MsgType
|
msgType := msg.MsgType
|
||||||
switch msgType {
|
switch msgType {
|
||||||
case jcqapi.TopicOrderPay:
|
case jcqapi.TopicOrderPay:
|
||||||
jxutils.CallMsgHandler(func() {
|
utils.CallFuncAsync(func() {
|
||||||
SaveJdsOrders(msg)
|
SaveJdsOrders(msg)
|
||||||
}, jxutils.ComposeUniversalOrderID(msg.OrderID, model.VendorIDJDShop))
|
})
|
||||||
case jcqapi.TopicOrderCancel:
|
case jcqapi.TopicOrderCancel:
|
||||||
jxutils.CallMsgHandler(func() {
|
utils.CallFuncAsync(func() {
|
||||||
CurPurchaseHandler.CancelOrder(jxcontext.AdminCtx, getRealOrderID(msg.OrderID), "系统取消")
|
CurPurchaseHandler.CancelOrder(jxcontext.AdminCtx, getRealOrderID(msg.OrderID), "系统取消")
|
||||||
}, jxutils.ComposeUniversalOrderID(msg.OrderID, model.VendorIDJDShop))
|
})
|
||||||
default:
|
default:
|
||||||
return fmt.Errorf("暂不支持的topic类型!topic: %v", msgType)
|
return fmt.Errorf("暂不支持的topic类型!topic: %v", msgType)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user