liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

回滚

Browse Source
This commit is contained in:
邹宗楠
2022-03-15 17:47:06 +08:00
parent 88783fa086
commit 7a7fe1b3da
1 changed files with 23 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
business/partner/purchase/mtwm/callback.go
View File

@@ -7,36 +7,35 @@ import (
) )
func OnCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) { func OnCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
if CurPurchaseHandler == nil { if CurPurchaseHandler != nil {
return &mtwmapi.CallbackResponse{Data: "CurPurchaseHandler init fail"} if msg.Cmd == mtwmapi.MsgTypeStoreStatusChanged || msg.Cmd == mtwmapi.MsgTypeStoreAuditStatusChanged {
}
// 获取orderId
orderID := GetOrderIDFromMsg(msg)
switch {
case msg.Cmd == mtwmapi.MsgTypeStoreStatusChanged || msg.Cmd == mtwmapi.MsgTypeStoreAuditStatusChanged:
response = CurPurchaseHandler.onStoreStatusChanged(msg) response = CurPurchaseHandler.onStoreStatusChanged(msg)
case msg.Cmd == mtwmapi.MsgTypePrivateNumberDowngrade: } else if msg.Cmd == mtwmapi.MsgTypePrivateNumberDowngrade {
response = CurPurchaseHandler.onNumberDowngrade(msg) response = CurPurchaseHandler.onNumberDowngrade(msg)
case msg.Cmd == mtwmapi.MsgTypeStoreBind: } else if msg.Cmd == mtwmapi.MsgTypeStoreBind {
break }
case orderID != "" && msg.Cmd == mtwmapi.MsgTypeWaybillStatus:
jxutils.CallMsgHandler(func() {
if msg.Cmd == mtwmapi.MsgTypeWaybillStatus {
response = CurPurchaseHandler.onWaybillMsg(msg)
} else { } else {
if orderID := GetOrderIDFromMsg(msg); orderID != "" {
jxutils.CallMsgHandler(func() {
switch msg.Cmd {
case mtwmapi.MsgTypeWaybillStatus:
response = CurPurchaseHandler.onWaybillMsg(msg)
default:
response = CurPurchaseHandler.onOrderMsg(msg) response = CurPurchaseHandler.onOrderMsg(msg)
} }
}, jxutils.ComposeUniversalOrderID(orderID, model.VendorIDMTWM)) }, jxutils.ComposeUniversalOrderID(orderID, model.VendorIDMTWM))
} }
/*if msg.Cmd == mtwmapi.MsgTypeOrderRefund || msg.Cmd == mtwmapi.MsgTypeOrderPartialRefund {
utils.CallFuncAsync(func() {
OnFinancialMsg(msg)
})
} */
}
return response return response
} }
func GetOrderIDFromMsg(msg *mtwmapi.CallbackMsg) string { func GetOrderIDFromMsg(msg *mtwmapi.CallbackMsg) string {
return msg.FormData.Get(mtwmapi.KeyOrderID) return msg.FormData.Get(mtwmapi.KeyOrderID)
} }
func GetVendorStoreIDFromMsg(msg *mtwmapi.CallbackMsg) string { func GetVendorStoreIDFromMsg(msg *mtwmapi.CallbackMsg) string {
return msg.FormData.Get(mtwmapi.KeyAppPoiCode) return msg.FormData.Get(mtwmapi.KeyAppPoiCode)
} }