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

- fix callback response.

Browse Source
This commit is contained in:
gazebo
2018-09-27 18:44:22 +08:00
parent 392b6ad813
commit 919a342665
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/partner/purchase/ebai/order.go
View File

@@ -150,7 +150,7 @@ func (c *PurchaseHandler) onOrderMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiapi.
} else { } else {
status := c.callbackMsg2Status(msg) status := c.callbackMsg2Status(msg)
err := partner.CurOrderManager.OnOrderStatusChanged(status) err := partner.CurOrderManager.OnOrderStatusChanged(status)
retVal = ebaiapi.Err2CallbackResponse(err, status.VendorStatus) retVal = api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, status.VendorStatus)
} }
return retVal return retVal
} }
@@ -160,7 +160,7 @@ func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiap
if err == nil { if err == nil {
err = partner.CurOrderManager.OnOrderNew(order, order.VendorStatus) err = partner.CurOrderManager.OnOrderNew(order, order.VendorStatus)
} }
return ebaiapi.Err2CallbackResponse(err, "ebai onOrderNew") return api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, "ebai onOrderNew")
} }
func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus { func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus {
@@ -173,7 +173,7 @@ func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.Or
RefVendorID: model.VendorIDEBAI, RefVendorID: model.VendorIDEBAI,
VendorStatus: body["status"].(string), VendorStatus: body["status"].(string),
Status: c.GetStatusFromVendorStatus(body["status"].(string)), Status: c.GetStatusFromVendorStatus(body["status"].(string)),
StatusTime: utils.Timestamp2Time(msg.TimeStamp), StatusTime: utils.Timestamp2Time(msg.Timestamp),
Remark: utils.Interface2String(body["reason"]), Remark: utils.Interface2String(body["reason"]),
} }
return orderStatus return orderStatus

6
business/partner/purchase/ebai/waybill.go
View File

@@ -35,12 +35,12 @@ func (c *PurchaseHandler) onWaybillMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiap
order := c.callbackMsg2Waybill(msg) order := c.callbackMsg2Waybill(msg)
if order.Status == model.WaybillStatusAccepted { if order.Status == model.WaybillStatusAccepted {
if result, err := api.EbaiAPI.OrderGet(order.VendorOrderID); err != nil { if result, err := api.EbaiAPI.OrderGet(order.VendorOrderID); err != nil {
return ebaiapi.Err2CallbackResponse(err, order.VendorOrderID) return api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, order.VendorOrderID)
} else { } else {
order.CourierMobile = utils.Interface2String(result["order"].(map[string]interface{})["delivery_phone"]) order.CourierMobile = utils.Interface2String(result["order"].(map[string]interface{})["delivery_phone"])
} }
} }
return ebaiapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus) return api.EbaiAPI.Err2CallbackResponse(msg.Cmd, partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus)
} }
func (c *PurchaseHandler) callbackMsg2Waybill(msg *ebaiapi.CallbackMsg) (retVal *model.Waybill) { func (c *PurchaseHandler) callbackMsg2Waybill(msg *ebaiapi.CallbackMsg) (retVal *model.Waybill) {
@@ -55,7 +55,7 @@ func (c *PurchaseHandler) callbackMsg2Waybill(msg *ebaiapi.CallbackMsg) (retVal
CourierName: "", // 饿百取不到骑手的名字 CourierName: "", // 饿百取不到骑手的名字
// CourierMobile: msg.Phone, // CourierMobile: msg.Phone,
VendorStatus: vendorStatus, VendorStatus: vendorStatus,
StatusTime: utils.Timestamp2Time(msg.TimeStamp), StatusTime: utils.Timestamp2Time(msg.Timestamp),
} }
return retVal return retVal
} }