- ebai the format of order_id of some different msgs are different.
This commit is contained in:
@@ -2,12 +2,18 @@ package ebai
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
|
"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
|
||||||
|
"git.rosy.net.cn/baseapi/utils"
|
||||||
"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"
|
||||||
)
|
)
|
||||||
|
|
||||||
func OnCallbackMsg(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) {
|
func OnCallbackMsg(msg *ebaiapi.CallbackMsg) (response *ebaiapi.CallbackResponse) {
|
||||||
orderID := msg.Body["order_id"].(string)
|
orderID := ""
|
||||||
|
if response.Cmd == ebaiapi.CmdOrderCreate {
|
||||||
|
orderID = msg.Body["order_id"].(string)
|
||||||
|
} else {
|
||||||
|
orderID = utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
|
||||||
|
}
|
||||||
jxutils.CallMsgHandler(func() {
|
jxutils.CallMsgHandler(func() {
|
||||||
switch msg.Cmd {
|
switch msg.Cmd {
|
||||||
case ebaiapi.CmdOrderCreate, ebaiapi.CmdOrderStatus:
|
case ebaiapi.CmdOrderCreate, ebaiapi.CmdOrderStatus:
|
||||||
|
|||||||
@@ -169,11 +169,12 @@ func (c *PurchaseHandler) onOrderNew(msg *ebaiapi.CallbackMsg) (response *ebaiap
|
|||||||
func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus {
|
func (c *PurchaseHandler) callbackMsg2Status(msg *ebaiapi.CallbackMsg) *model.OrderStatus {
|
||||||
body := msg.Body
|
body := msg.Body
|
||||||
vendorStatus := utils.Int64ToStr(utils.MustInterface2Int64(body["status"]))
|
vendorStatus := utils.Int64ToStr(utils.MustInterface2Int64(body["status"]))
|
||||||
|
orderID := utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
|
||||||
orderStatus := &model.OrderStatus{
|
orderStatus := &model.OrderStatus{
|
||||||
VendorOrderID: body["order_id"].(string),
|
VendorOrderID: orderID,
|
||||||
VendorID: model.VendorIDEBAI,
|
VendorID: model.VendorIDEBAI,
|
||||||
OrderType: model.OrderTypeOrder,
|
OrderType: model.OrderTypeOrder,
|
||||||
RefVendorOrderID: body["order_id"].(string),
|
RefVendorOrderID: orderID,
|
||||||
RefVendorID: model.VendorIDEBAI,
|
RefVendorID: model.VendorIDEBAI,
|
||||||
VendorStatus: vendorStatus,
|
VendorStatus: vendorStatus,
|
||||||
Status: c.GetStatusFromVendorStatus(vendorStatus),
|
Status: c.GetStatusFromVendorStatus(vendorStatus),
|
||||||
|
|||||||
@@ -46,10 +46,11 @@ func (c *PurchaseHandler) onWaybillMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiap
|
|||||||
func (c *PurchaseHandler) callbackMsg2Waybill(msg *ebaiapi.CallbackMsg) (retVal *model.Waybill) {
|
func (c *PurchaseHandler) callbackMsg2Waybill(msg *ebaiapi.CallbackMsg) (retVal *model.Waybill) {
|
||||||
body := msg.Body
|
body := msg.Body
|
||||||
vendorStatus := utils.Int64ToStr(utils.MustInterface2Int64(body["status"]))
|
vendorStatus := utils.Int64ToStr(utils.MustInterface2Int64(body["status"]))
|
||||||
|
orderID := utils.Int64ToStr(utils.MustInterface2Int64(msg.Body["order_id"]))
|
||||||
retVal = &model.Waybill{
|
retVal = &model.Waybill{
|
||||||
VendorOrderID: body["order_id"].(string),
|
VendorOrderID: orderID,
|
||||||
OrderVendorID: model.VendorIDEBAI,
|
OrderVendorID: model.VendorIDEBAI,
|
||||||
VendorWaybillID: body["order_id"].(string),
|
VendorWaybillID: orderID,
|
||||||
WaybillVendorID: model.VendorIDEBAI,
|
WaybillVendorID: model.VendorIDEBAI,
|
||||||
Status: c.GetWaybillStatusFromVendorStatus(vendorStatus),
|
Status: c.GetWaybillStatusFromVendorStatus(vendorStatus),
|
||||||
CourierName: "", // 饿百取不到骑手的名字
|
CourierName: "", // 饿百取不到骑手的名字
|
||||||
|
|||||||
Reference in New Issue
Block a user