- mtwm callback

This commit is contained in:
gazebo
2018-11-29 09:59:08 +08:00
parent de110daf0b
commit 9e276a01c9
3 changed files with 35 additions and 12 deletions

View File

@@ -7,6 +7,9 @@ import (
) )
func OnOrderCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) { func OnOrderCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
if msg.Cmd == mtwmapi.MsgTypePrivateNumberDowngrade {
response = mtwmapi.SuccessResponse
} else {
orderID := GetOrderIDFromMsg(msg) orderID := GetOrderIDFromMsg(msg)
jxutils.CallMsgHandler(func() { jxutils.CallMsgHandler(func() {
switch msg.Cmd { switch msg.Cmd {
@@ -16,6 +19,7 @@ func OnOrderCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackRes
response = curPurchaseHandler.onOrderMsg(msg) response = curPurchaseHandler.onOrderMsg(msg)
} }
}, jxutils.ComposeUniversalOrderID(orderID, model.VendorIDMTWM)) }, jxutils.ComposeUniversalOrderID(orderID, model.VendorIDMTWM))
}
return response return response
} }

View File

@@ -11,6 +11,12 @@ import (
"git.rosy.net.cn/jx-callback/globals/api" "git.rosy.net.cn/jx-callback/globals/api"
) )
const (
FakeOrderStatusModified = "10001"
FakeOrderStatusUserUrgeOrder = "10002"
FakeOrderStatusFinancial = "10003"
)
var ( var (
VendorStatus2StatusMap = map[string]int{ VendorStatus2StatusMap = map[string]int{
mtwmapi.OrderStatusUserCommitted: model.OrderStatusUnknown, mtwmapi.OrderStatusUserCommitted: model.OrderStatusUnknown,
@@ -21,6 +27,7 @@ var (
mtwmapi.OrderStatusDelivered: model.OrderStatusDelivered, mtwmapi.OrderStatusDelivered: model.OrderStatusDelivered,
mtwmapi.OrderStatusFinished: model.OrderStatusFinished, mtwmapi.OrderStatusFinished: model.OrderStatusFinished,
mtwmapi.OrderStatusCanceled: model.OrderStatusCanceled, mtwmapi.OrderStatusCanceled: model.OrderStatusCanceled,
FakeOrderStatusModified: model.OrderStatusAdjust,
} }
) )
@@ -127,7 +134,19 @@ func (c *PurchaseHandler) onOrderMsg(msg *mtwmapi.CallbackMsg) (response *mtwmap
func (c *PurchaseHandler) callbackMsg2Status(msg *mtwmapi.CallbackMsg) *model.OrderStatus { func (c *PurchaseHandler) callbackMsg2Status(msg *mtwmapi.CallbackMsg) *model.OrderStatus {
orderID := GetOrderIDFromMsg(msg) orderID := GetOrderIDFromMsg(msg)
vendorStatus := msg.Data.Get("status") vendorStatus := ""
statusTime := time.Now().Unix()
switch msg.Cmd {
case mtwmapi.MsgTypeUserUrgeOrder:
vendorStatus = FakeOrderStatusUserUrgeOrder
case mtwmapi.MsgTypeOrderModified:
vendorStatus = FakeOrderStatusModified
case mtwmapi.MsgTypeOrderFinancial:
vendorStatus = FakeOrderStatusFinancial
default:
vendorStatus = msg.Data.Get("status")
statusTime = utils.Str2Int64(msg.Data.Get("utime"))
}
orderStatus := &model.OrderStatus{ orderStatus := &model.OrderStatus{
VendorOrderID: orderID, VendorOrderID: orderID,
VendorID: model.VendorIDMTWM, VendorID: model.VendorIDMTWM,
@@ -136,7 +155,7 @@ func (c *PurchaseHandler) callbackMsg2Status(msg *mtwmapi.CallbackMsg) *model.Or
RefVendorID: model.VendorIDMTWM, RefVendorID: model.VendorIDMTWM,
VendorStatus: vendorStatus, VendorStatus: vendorStatus,
Status: c.GetStatusFromVendorStatus(vendorStatus), Status: c.GetStatusFromVendorStatus(vendorStatus),
StatusTime: getTimeFromTimestamp(utils.Str2Int64(msg.Data.Get("utime"))), StatusTime: getTimeFromTimestamp(statusTime),
Remark: "", Remark: "",
} }
return orderStatus return orderStatus

View File

@@ -29,7 +29,7 @@ func (c *MtwmController) NewOrder() {
c.onCallbackMsg(mtwmapi.MsgTypeNewOrder) c.onCallbackMsg(mtwmapi.MsgTypeNewOrder)
} }
func (c *MtwmController) OrderAccpted() { func (c *MtwmController) OrderAccepted() {
c.onCallbackMsg(mtwmapi.MsgTypeOrderAccepted) c.onCallbackMsg(mtwmapi.MsgTypeOrderAccepted)
} }