- more mtwm callback

This commit is contained in:
gazebo
2018-11-29 16:34:25 +08:00
parent 8b7962f19e
commit 29874f3774
2 changed files with 27 additions and 15 deletions

View File

@@ -8,15 +8,10 @@ import (
"git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/partner" "git.rosy.net.cn/jx-callback/business/partner"
"git.rosy.net.cn/jx-callback/globals"
"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,
@@ -27,7 +22,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, mtwmapi.MsgTypeOrderModified: model.OrderStatusAdjust,
} }
) )
@@ -135,17 +130,22 @@ 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 := "" vendorStatus := ""
remark := ""
statusTime := time.Now().Unix() statusTime := time.Now().Unix()
switch msg.Cmd { switch msg.Cmd {
case mtwmapi.MsgTypeUserUrgeOrder: case mtwmapi.MsgTypeUserUrgeOrder, mtwmapi.MsgTypeOrderModified, mtwmapi.MsgTypeOrderFinancial:
vendorStatus = FakeOrderStatusUserUrgeOrder vendorStatus = msg.Cmd
case mtwmapi.MsgTypeOrderModified: case mtwmapi.MsgTypeOrderCanceled:
vendorStatus = FakeOrderStatusModified vendorStatus = mtwmapi.OrderStatusCanceled
case mtwmapi.MsgTypeOrderFinancial: remark = msg.Data.Get("reason")
vendorStatus = FakeOrderStatusFinancial case mtwmapi.MsgTypeNewOrder, mtwmapi.MsgTypeOrderAccepted, mtwmapi.MsgTypeOrderFinished:
default:
vendorStatus = msg.Data.Get("status") vendorStatus = msg.Data.Get("status")
statusTime = utils.Str2Int64(msg.Data.Get("utime")) statusTime = utils.Str2Int64(msg.Data.Get("utime"))
case mtwmapi.MsgTypeOrderRefund, mtwmapi.MsgTypeOrderPartialRefund:
vendorStatus = msg.Cmd
remark = msg.Data.Get("reason")
default:
globals.SugarLogger.Errorf("mtwm unkonw msg:%s", utils.Format4Output(msg, false))
} }
orderStatus := &model.OrderStatus{ orderStatus := &model.OrderStatus{
VendorOrderID: orderID, VendorOrderID: orderID,
@@ -156,7 +156,7 @@ func (c *PurchaseHandler) callbackMsg2Status(msg *mtwmapi.CallbackMsg) *model.Or
VendorStatus: vendorStatus, VendorStatus: vendorStatus,
Status: c.GetStatusFromVendorStatus(vendorStatus), Status: c.GetStatusFromVendorStatus(vendorStatus),
StatusTime: getTimeFromTimestamp(statusTime), StatusTime: getTimeFromTimestamp(statusTime),
Remark: "", Remark: remark,
} }
return orderStatus return orderStatus
} }

View File

@@ -52,3 +52,15 @@ func (c *MtwmController) NumberDowngrade() {
func (c *MtwmController) OrderModified() { func (c *MtwmController) OrderModified() {
c.onCallbackMsg(mtwmapi.MsgTypeOrderModified) c.onCallbackMsg(mtwmapi.MsgTypeOrderModified)
} }
func (c *MtwmController) OrderCanceled() {
c.onCallbackMsg(mtwmapi.MsgTypeOrderCanceled)
}
func (c *MtwmController) OrderRefund() {
c.onCallbackMsg(mtwmapi.MsgTypeOrderCanceled)
}
func (c *MtwmController) OrderPartialRefund() {
c.onCallbackMsg(mtwmapi.MsgTypeOrderCanceled)
}