liulei/baseapi
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-11-15 13:38:17 +08:00
parent ab22ffa6d7
commit 74ae3243e1
1 changed files with 48 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
platformapi/tiktok_shop/tiktok_api/order.go
View File

@@ -336,148 +336,170 @@ func (a *API) OrderDelivering(param *order_logisticsAdd_request.OrderLogisticsAd
} }
// CreateOrderCallback 订单创建,抖店创建订单后,回调消息通知本服务器 // CreateOrderCallback 订单创建,抖店创建订单后,回调消息通知本服务器
func (a *API) CreateOrderCallback(orderStatus []byte) (map[string][]interface{}, *CallbackResponse) { func (a *API) CreateOrderCallback(orderStatus []byte) (map[string][]interface{}, map[int64]bool, *CallbackResponse) {
var resp []*OrderCallback var resp []*OrderCallback
if err := json.Unmarshal(orderStatus, &resp); err != nil { if err := json.Unmarshal(orderStatus, &resp); err != nil {
return nil, &CallbackResponse{Code: CallbackFailCode, Msg: CallbackFail} return nil, nil, &CallbackResponse{Code: CallbackFailCode, Msg: CallbackFail}
} }
callbackResult := make(map[string][]interface{}, 0) callbackResult := make(map[string][]interface{}, 0)
storeIdMap := make(map[int64]bool, 0)
for _, data := range resp { for _, data := range resp {
switch data.Tag { switch data.Tag {
case CallbackCreatedOrderMsgTagId: // 创建订单 case CallbackCreatedOrderMsgTagId: // 创建订单
create := CreateOrderData{} create := CreateOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackCreatedOrderMsgTagId] = append(callbackResult[CallbackCreatedOrderMsgTagId], create) callbackResult[CallbackCreatedOrderMsgTagId] = append(callbackResult[CallbackCreatedOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackPayOrderMsgTagId: // 支付订单 case CallbackPayOrderMsgTagId: // 支付订单
create := PayOrderData{} create := PayOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackPayOrderMsgTagId] = append(callbackResult[CallbackPayOrderMsgTagId], create) callbackResult[CallbackPayOrderMsgTagId] = append(callbackResult[CallbackPayOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackWaitOrderMsgTagId: // 支付订单待处理(风控审核) case CallbackWaitOrderMsgTagId: // 支付订单待处理(风控审核)
create := WaitOrderData{} create := WaitOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackWaitOrderMsgTagId] = append(callbackResult[CallbackWaitOrderMsgTagId], create) callbackResult[CallbackWaitOrderMsgTagId] = append(callbackResult[CallbackWaitOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackPartGoodsMsgTagId: // 卖家部分发货 case CallbackPartGoodsMsgTagId: // 卖家部分发货
create := SomeSendOrderData{} create := SomeSendOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackPartGoodsMsgTagId] = append(callbackResult[CallbackPartGoodsMsgTagId], create) callbackResult[CallbackPartGoodsMsgTagId] = append(callbackResult[CallbackPartGoodsMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackPartAllGoodsMsgTagId: // 卖家发货 case CallbackPartAllGoodsMsgTagId: // 卖家发货
create := BusinessDeliveryData{} create := BusinessDeliveryData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackPartAllGoodsMsgTagId] = append(callbackResult[CallbackPartAllGoodsMsgTagId], create) callbackResult[CallbackPartAllGoodsMsgTagId] = append(callbackResult[CallbackPartAllGoodsMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackCancelOrderMsgTagId: // 取消订单 case CallbackCancelOrderMsgTagId: // 取消订单
create := CreateOrderData{} create := CreateOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackCancelOrderMsgTagId] = append(callbackResult[CallbackCancelOrderMsgTagId], create) callbackResult[CallbackCancelOrderMsgTagId] = append(callbackResult[CallbackCancelOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackSuccessOrderMsgTagId: // 卖家确认收货时,会自动完成 case CallbackSuccessOrderMsgTagId: // 卖家确认收货时,会自动完成
create := SuccessOrderData{} create := SuccessOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackSuccessOrderMsgTagId] = append(callbackResult[CallbackSuccessOrderMsgTagId], create) callbackResult[CallbackSuccessOrderMsgTagId] = append(callbackResult[CallbackSuccessOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackWayBillChangeOrderMsgTagId: // 发货物流消息便跟 case CallbackWayBillChangeOrderMsgTagId: // 发货物流消息便跟
create := WayBillChangeData{} create := WayBillChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[CallbackWayBillChangeOrderMsgTagId], create) callbackResult[CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[CallbackWayBillChangeOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackReceivingChangeOrderMsgTagId: // 收货地址消息变更(商家审核通过触发) case CallbackReceivingChangeOrderMsgTagId: // 收货地址消息变更(商家审核通过触发)
create := ReceivingAddressChangeData{} create := ReceivingAddressChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[CallbackReceivingChangeOrderMsgTagId], create) callbackResult[CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[CallbackReceivingChangeOrderMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackChangeMoneyMsgTagId: // 卖家修改订单/运单金额回调 case CallbackChangeMoneyMsgTagId: // 卖家修改订单/运单金额回调
create := UpdateAmountChangeData{} create := UpdateAmountChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackChangeMoneyMsgTagId] = append(callbackResult[CallbackChangeMoneyMsgTagId], create) callbackResult[CallbackChangeMoneyMsgTagId] = append(callbackResult[CallbackChangeMoneyMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackBusinessRemarkMsgTagId: // 买家收货消息变更(手机,地址,姓名),用户C端修改触发(需要上面审核接口) case CallbackBusinessRemarkMsgTagId: // 买家收货消息变更(手机,地址,姓名),用户C端修改触发(需要上面审核接口)
create := BuyerUpdateWayBillData{} create := BuyerUpdateWayBillData{}
if err := json.Unmarshal([]byte(data.Data), create); err != nil { if err := json.Unmarshal([]byte(data.Data), create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackBusinessRemarkMsgTagId] = append(callbackResult[CallbackBusinessRemarkMsgTagId], create) callbackResult[CallbackBusinessRemarkMsgTagId] = append(callbackResult[CallbackBusinessRemarkMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackApplyUpdateAddressMsgTagId: // 商家修改交易备注回调 case CallbackApplyUpdateAddressMsgTagId: // 商家修改交易备注回调
create := BusinessUpdateRemakeData{} create := BusinessUpdateRemakeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[CallbackApplyUpdateAddressMsgTagId], create) callbackResult[CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[CallbackApplyUpdateAddressMsgTagId], create)
storeIdMap[create.ShopId] = true
case CallbackSendOrderTimeChangeMsgTagId: // 订单发货时消息变更回调 case CallbackSendOrderTimeChangeMsgTagId: // 订单发货时消息变更回调
create := AppointmentChangeData{} create := AppointmentChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackSendOrderTimeChangeMsgTagId] = append(callbackResult[CallbackSendOrderTimeChangeMsgTagId], create) callbackResult[CallbackSendOrderTimeChangeMsgTagId] = append(callbackResult[CallbackSendOrderTimeChangeMsgTagId], create)
storeIdMap[create.ShopId] = true
/*********下面属于订单退货消息************/ /*********下面属于订单退货消息************/
case CallbackRefundOrderMsgTagId: // 买家发起售后申请消息 case CallbackRefundOrderMsgTagId: // 买家发起售后申请消息
create := BuyerRefundCreatedData{} create := BuyerRefundCreatedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackRefundOrderMsgTagId] = append(callbackResult[CallbackRefundOrderMsgTagId], create) callbackResult[CallbackRefundOrderMsgTagId] = append(callbackResult[CallbackRefundOrderMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackUpdateRefundOrderMsgTagId: // 买家修改售后申请消息 case CallbackUpdateRefundOrderMsgTagId: // 买家修改售后申请消息
create := BuyerRefundModifiedData{} create := BuyerRefundModifiedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[CallbackUpdateRefundOrderMsgTagId], create) callbackResult[CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[CallbackUpdateRefundOrderMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackRefundOrderSuccessMsgTagId: // 退款成功消息 case CallbackRefundOrderSuccessMsgTagId: // 退款成功消息
create := BusinessRefundSuccessData{} create := BusinessRefundSuccessData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[CallbackRefundOrderSuccessMsgTagId], create) callbackResult[CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[CallbackRefundOrderSuccessMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackRefundOrderRefuseMsgTagId: // 拒绝退款消息 case CallbackRefundOrderRefuseMsgTagId: // 拒绝退款消息
create := BusinessNotRefundRefusedData{} create := BusinessNotRefundRefusedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[CallbackRefundOrderRefuseMsgTagId], create) callbackResult[CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[CallbackRefundOrderRefuseMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackRefundShopMsgTagId: // 拒绝退货申请消息 case CallbackRefundShopMsgTagId: // 拒绝退货申请消息
create := BusinessNotReturnApplyRefusedData{} create := BusinessNotReturnApplyRefusedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackRefundShopMsgTagId] = append(callbackResult[CallbackRefundShopMsgTagId], create) callbackResult[CallbackRefundShopMsgTagId] = append(callbackResult[CallbackRefundShopMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackReturnApplyAgreedMsgTagId: // 卖家同意时，推送此消息 case CallbackReturnApplyAgreedMsgTagId: // 卖家同意时，推送此消息
create := BusinessReturnApplyAgreedData{} create := BusinessReturnApplyAgreedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackReturnApplyAgreedMsgTagId] = append(callbackResult[CallbackReturnApplyAgreedMsgTagId], create) callbackResult[CallbackReturnApplyAgreedMsgTagId] = append(callbackResult[CallbackReturnApplyAgreedMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackReturnRefundAgreedMsgTagId: // 同意退款消息 case CallbackReturnRefundAgreedMsgTagId: // 同意退款消息
create := BusinessRefundAgreedData{} create := BusinessRefundAgreedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[CallbackReturnRefundAgreedMsgTagId], create) callbackResult[CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[CallbackReturnRefundAgreedMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
case CallbackRefundClosedMsgTagId: case CallbackRefundClosedMsgTagId:
create := UserCancelRefundOrderData{} create := UserCancelRefundOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil { if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
callbackResult[CallbackRefundClosedMsgTagId] = append(callbackResult[CallbackRefundClosedMsgTagId], create) callbackResult[CallbackRefundClosedMsgTagId] = append(callbackResult[CallbackRefundClosedMsgTagId], create)
storeIdMap[int64(create.ShopId)] = true
default: default:
return nil, CallbackResponseErr(false) return nil, nil, CallbackResponseErr(false)
} }
} }
return callbackResult, &CallbackResponse{Code: CallbackSuccessCode, Msg: CallbackSuccess} return callbackResult, storeIdMap, &CallbackResponse{Code: CallbackSuccessCode, Msg: CallbackSuccess}
} }
// GetCallbackOrderId 获取回调函数订单id // GetCallbackOrderId 获取回调函数订单id