1
This commit is contained in:
@@ -2,6 +2,8 @@ package order_batchDecrypt_request
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
order_batchDecrypt_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/order_batchDecrypt/response"
|
||||||
|
doudian_sdk "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/core"
|
||||||
)
|
)
|
||||||
|
|
||||||
type OrderBatchDecryptRequest struct {
|
type OrderBatchDecryptRequest struct {
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
package order_batchDecrypt_response
|
package order_batchDecrypt_response
|
||||||
|
|
||||||
|
import doudian_sdk "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/core"
|
||||||
|
|
||||||
type OrderBatchDecryptResponse struct {
|
type OrderBatchDecryptResponse struct {
|
||||||
doudian_sdk.BaseDoudianOpApiResponse
|
doudian_sdk.BaseDoudianOpApiResponse
|
||||||
Data *OrderBatchDecryptData `json:"data"`
|
Data *OrderBatchDecryptData `json:"data"`
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
package order_batchSensitive_response
|
package order_batchSensitive_response
|
||||||
|
|
||||||
|
import doudian_sdk "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/core"
|
||||||
|
|
||||||
type OrderBatchSensitiveResponse struct {
|
type OrderBatchSensitiveResponse struct {
|
||||||
doudian_sdk.BaseDoudianOpApiResponse
|
doudian_sdk.BaseDoudianOpApiResponse
|
||||||
Data *OrderBatchSensitiveData `json:"data"`
|
Data *OrderBatchSensitiveData `json:"data"`
|
||||||
|
|||||||
@@ -16,3 +16,17 @@ func TestApi(t *testing.T) {
|
|||||||
globals.SugarLogger.Debugf("%v", utils.Format4Output(a.appKey, false))
|
globals.SugarLogger.Debugf("%v", utils.Format4Output(a.appKey, false))
|
||||||
globals.SugarLogger.Debugf("%v", utils.Format4Output(a.appSecret, false))
|
globals.SugarLogger.Debugf("%v", utils.Format4Output(a.appSecret, false))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestQueryOrderDetail(t *testing.T) {
|
||||||
|
token := `{"access_token":"a1746210-a8a3-4497-a87b-09d1f10dbb95","expires_in":1665652230,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"c1cf8d88-0983-4f2a-b969-3746fae6b0cd","authority_id":""}`
|
||||||
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
|
data, err := a.GetTiktokOrderDetail("4988354190732430566")
|
||||||
|
globals.SugarLogger.Debugf("=====%s", utils.Format4Output(data, false))
|
||||||
|
globals.SugarLogger.Debugf("=====%s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRefaseToken(t *testing.T) {
|
||||||
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", "")
|
||||||
|
a.CreateToken("41155cd5-d30f-4075-9c44-b75ffa1a84ee")
|
||||||
|
//{"access_token":"37f41ac7-49ac-4848-a0ee-ea86bb0dfd9f","expires_in":519389,"scope":"SCOPE","shop_id":"","shop_name":"抖店开放平台测试专用店","refresh_token":"3dd8f638-fdf1-46e7-b974-88df382f03c6","authority_id" :""}
|
||||||
|
}
|
||||||
|
|||||||
@@ -335,204 +335,166 @@ func (a *API) CreateOrderCallback(orderStatus []byte) (map[string][]interface{},
|
|||||||
for _, data := range resp {
|
for _, data := range resp {
|
||||||
switch data.Tag {
|
switch data.Tag {
|
||||||
case CallbackCreatedOrderMsgTagId: // 创建订单
|
case CallbackCreatedOrderMsgTagId: // 创建订单
|
||||||
if utils.IsNil(data.Data) {
|
create := []CreateOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackCreatedOrderMsgTagId] = append(callbackResult[CallbackCreatedOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := CreateOrderData{}
|
|
||||||
//if err := json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackCreatedOrderMsgTagId] = append(callbackResult[CallbackCreatedOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackCreatedOrderMsgTagId] = append(callbackResult[CallbackCreatedOrderMsgTagId], data.Data)
|
|
||||||
case CallbackPayOrderMsgTagId: // 支付订单
|
case CallbackPayOrderMsgTagId: // 支付订单
|
||||||
if utils.IsNil(data.Data) {
|
create := []PayOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackPayOrderMsgTagId] = append(callbackResult[CallbackPayOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := PayOrderData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackPayOrderMsgTagId] = append(callbackResult[CallbackPayOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackPayOrderMsgTagId] = append(callbackResult[CallbackPayOrderMsgTagId], data.Data)
|
|
||||||
case CallbackWaitOrderMsgTagId: // 支付订单待处理(风控审核)
|
case CallbackWaitOrderMsgTagId: // 支付订单待处理(风控审核)
|
||||||
if utils.IsNil(data.Data) {
|
create := []WaitOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackWaitOrderMsgTagId] = append(callbackResult[CallbackWaitOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := WaitOrderData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackWaitOrderMsgTagId] = append(callbackResult[CallbackWaitOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackWaitOrderMsgTagId] = append(callbackResult[CallbackWaitOrderMsgTagId], data.Data)
|
|
||||||
case CallbackPartGoodsMsgTagId: // 卖家部分发货
|
case CallbackPartGoodsMsgTagId: // 卖家部分发货
|
||||||
if utils.IsNil(data.Data) {
|
create := []SomeSendOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackPartGoodsMsgTagId] = append(callbackResult[CallbackPartGoodsMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := SomeSendOrderData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackPartGoodsMsgTagId] = append(callbackResult[CallbackPartGoodsMsgTagId], create)
|
|
||||||
callbackResult[CallbackPartGoodsMsgTagId] = append(callbackResult[CallbackPartGoodsMsgTagId], data.Data)
|
|
||||||
case CallbackPartAllGoodsMsgTagId: // 卖家发货
|
case CallbackPartAllGoodsMsgTagId: // 卖家发货
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessDeliveryCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackPartAllGoodsMsgTagId] = append(callbackResult[CallbackPartAllGoodsMsgTagId], v.data)
|
||||||
}
|
}
|
||||||
//create := BusinessDeliveryData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackPartAllGoodsMsgTagId] = append(callbackResult[CallbackPartAllGoodsMsgTagId], create)
|
|
||||||
callbackResult[CallbackPartAllGoodsMsgTagId] = append(callbackResult[CallbackPartAllGoodsMsgTagId], data.Data)
|
|
||||||
case CallbackCancelOrderMsgTagId: // 取消订单
|
case CallbackCancelOrderMsgTagId: // 取消订单
|
||||||
if utils.IsNil(data.Data) {
|
create := []CancelOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackCancelOrderMsgTagId] = append(callbackResult[CallbackCancelOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := CancelOrderData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackCancelOrderMsgTagId] = append(callbackResult[CallbackCancelOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackCancelOrderMsgTagId] = append(callbackResult[CallbackCancelOrderMsgTagId], data.Data)
|
|
||||||
case CallbackSuccessOrderMsgTagId: // 卖家确认收货时,会自动完成
|
case CallbackSuccessOrderMsgTagId: // 卖家确认收货时,会自动完成
|
||||||
if utils.IsNil(data.Data) {
|
create := []SuccessOrderCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackSuccessOrderMsgTagId] = append(callbackResult[CallbackSuccessOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := SuccessOrderData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackSuccessOrderMsgTagId] = append(callbackResult[CallbackSuccessOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackSuccessOrderMsgTagId] = append(callbackResult[CallbackSuccessOrderMsgTagId], data.Data)
|
|
||||||
case CallbackWayBillChangeOrderMsgTagId: // 发货物流消息便跟
|
case CallbackWayBillChangeOrderMsgTagId: // 发货物流消息便跟
|
||||||
if utils.IsNil(data.Data) {
|
create := []WayBillChangeCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[CallbackWayBillChangeOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := WayBillChangeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[CallbackWayBillChangeOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[CallbackWayBillChangeOrderMsgTagId], data.Data)
|
|
||||||
case CallbackReceivingChangeOrderMsgTagId: // 收货地址消息变更(商家审核通过触发)
|
case CallbackReceivingChangeOrderMsgTagId: // 收货地址消息变更(商家审核通过触发)
|
||||||
if utils.IsNil(data.Data) {
|
create := []ReceivingAddressChangeCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[CallbackReceivingChangeOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := ReceivingAddressChangeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[CallbackReceivingChangeOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[CallbackReceivingChangeOrderMsgTagId], data.Data)
|
|
||||||
case CallbackChangeMoneyMsgTagId: // 卖家修改订单/运单金额回调
|
case CallbackChangeMoneyMsgTagId: // 卖家修改订单/运单金额回调
|
||||||
if utils.IsNil(data.Data) {
|
create := []UpdateAmountChangeCallback{}
|
||||||
continue
|
if err := json.Unmarshal([]byte(orderStatus), &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackChangeMoneyMsgTagId] = append(callbackResult[CallbackChangeMoneyMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := UpdateAmountChangeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackChangeMoneyMsgTagId] = append(callbackResult[CallbackChangeMoneyMsgTagId], create)
|
|
||||||
callbackResult[CallbackChangeMoneyMsgTagId] = append(callbackResult[CallbackChangeMoneyMsgTagId], data.Data)
|
|
||||||
case CallbackBusinessRemarkMsgTagId: // 买家收货消息变更(手机,地址,姓名),用户C端修改触发(需要上面审核接口)
|
case CallbackBusinessRemarkMsgTagId: // 买家收货消息变更(手机,地址,姓名),用户C端修改触发(需要上面审核接口)
|
||||||
if utils.IsNil(data.Data) {
|
create := []BuyerUpdateWayBillCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackBusinessRemarkMsgTagId] = append(callbackResult[CallbackBusinessRemarkMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BuyerUpdateWayBillData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackBusinessRemarkMsgTagId] = append(callbackResult[CallbackBusinessRemarkMsgTagId], create)
|
|
||||||
callbackResult[CallbackBusinessRemarkMsgTagId] = append(callbackResult[CallbackBusinessRemarkMsgTagId], data.Data)
|
|
||||||
case CallbackApplyUpdateAddressMsgTagId: // 商家修改交易备注回调
|
case CallbackApplyUpdateAddressMsgTagId: // 商家修改交易备注回调
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessUpdateRemakeCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[CallbackApplyUpdateAddressMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BusinessUpdateRemakeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[CallbackApplyUpdateAddressMsgTagId], create)
|
|
||||||
callbackResult[CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[CallbackApplyUpdateAddressMsgTagId], data.Data)
|
|
||||||
case CallbackSendOrderTimeChangeMsgTagId: // 订单发货时消息变更回调
|
case CallbackSendOrderTimeChangeMsgTagId: // 订单发货时消息变更回调
|
||||||
if utils.IsNil(data.Data) {
|
create := []AppointmentChangeCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackSendOrderTimeChangeMsgTagId] = append(callbackResult[CallbackSendOrderTimeChangeMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := AppointmentChangeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
callbackResult[CallbackSendOrderTimeChangeMsgTagId] = append(callbackResult[CallbackSendOrderTimeChangeMsgTagId], data.Data)
|
|
||||||
/*********下面属于订单退货消息************/
|
/*********下面属于订单退货消息************/
|
||||||
case CallbackRefundOrderMsgTagId: // 买家发起售后申请消息
|
case CallbackRefundOrderMsgTagId: // 买家发起售后申请消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BuyerRefundCreatedCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackRefundOrderMsgTagId] = append(callbackResult[CallbackRefundOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BuyerRefundCreatedData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackRefundOrderMsgTagId] = append(callbackResult[CallbackRefundOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackRefundOrderMsgTagId] = append(callbackResult[CallbackRefundOrderMsgTagId], data.Data)
|
|
||||||
case CallbackUpdateRefundOrderMsgTagId: // 买家修改售后申请消息
|
case CallbackUpdateRefundOrderMsgTagId: // 买家修改售后申请消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BuyerRefundModifiedCallBack{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[CallbackUpdateRefundOrderMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BuyerRefundModifiedData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[CallbackUpdateRefundOrderMsgTagId], create)
|
|
||||||
callbackResult[CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[CallbackUpdateRefundOrderMsgTagId], data.Data)
|
|
||||||
case CallbackRefundOrderSuccessMsgTagId: // 退款成功消息
|
case CallbackRefundOrderSuccessMsgTagId: // 退款成功消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessRefundSuccessCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[CallbackRefundOrderSuccessMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BusinessRefundSuccessData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[CallbackRefundOrderSuccessMsgTagId], create)
|
|
||||||
callbackResult[CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[CallbackRefundOrderSuccessMsgTagId], data.Data)
|
|
||||||
case CallbackRefundOrderRefuseMsgTagId: // 拒绝退款消息
|
case CallbackRefundOrderRefuseMsgTagId: // 拒绝退款消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessNotRefundRefusedCallBack{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[CallbackRefundOrderRefuseMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BusinessNotRefundRefusedData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[CallbackRefundOrderRefuseMsgTagId], create)
|
|
||||||
callbackResult[CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[CallbackRefundOrderRefuseMsgTagId], data.Data)
|
|
||||||
case CallbackRefundShopMsgTagId: // 拒绝退货申请消息
|
case CallbackRefundShopMsgTagId: // 拒绝退货申请消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessNotReturnApplyRefusedCallBack{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackRefundShopMsgTagId] = append(callbackResult[CallbackRefundShopMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BusinessNotReturnApplyRefusedData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackRefundShopMsgTagId] = append(callbackResult[CallbackRefundShopMsgTagId], create)
|
|
||||||
callbackResult[CallbackRefundShopMsgTagId] = append(callbackResult[CallbackRefundShopMsgTagId], data.Data)
|
|
||||||
case CallbackReturnApplyAgreedMsgTagId: // 卖家同意时,推送此消息
|
case CallbackReturnApplyAgreedMsgTagId: // 卖家同意时,推送此消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessReturnApplyAgreedCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackReturnApplyAgreedMsgTagId] = append(callbackResult[CallbackReturnApplyAgreedMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := BusinessReturnApplyAgreedData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
callbackResult[CallbackReturnApplyAgreedMsgTagId] = append(callbackResult[CallbackReturnApplyAgreedMsgTagId], data.Data)
|
|
||||||
case CallbackReturnRefundAgreedMsgTagId: // 同意退款消息
|
case CallbackReturnRefundAgreedMsgTagId: // 同意退款消息
|
||||||
if utils.IsNil(data.Data) {
|
create := []BusinessRefundAgreedCallback{}
|
||||||
continue
|
if err := json.Unmarshal(orderStatus, &create); err != nil {
|
||||||
|
return nil, CallbackResponseErr(false)
|
||||||
|
}
|
||||||
|
for _, v := range create {
|
||||||
|
callbackResult[CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[CallbackReturnRefundAgreedMsgTagId], v.Data)
|
||||||
}
|
}
|
||||||
//create := AppointmentChangeData{}
|
|
||||||
//if err = json.Unmarshal([]byte(utils.Interface2String(data.Data)), create); err != nil {
|
|
||||||
// return nil, CallbackResponseErr(false)
|
|
||||||
//}
|
|
||||||
//callbackResult[CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[CallbackReturnRefundAgreedMsgTagId], create)
|
|
||||||
callbackResult[CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[CallbackReturnRefundAgreedMsgTagId], data.Data)
|
|
||||||
default:
|
default:
|
||||||
return nil, CallbackResponseErr(false)
|
return nil, CallbackResponseErr(false)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -475,7 +475,7 @@ type BusinessReturnApplyAgreedData struct {
|
|||||||
|
|
||||||
type BusinessRefundAgreedCallback struct {
|
type BusinessRefundAgreedCallback struct {
|
||||||
PublicOrderCallback
|
PublicOrderCallback
|
||||||
Data *AppointmentChangeData `json:"data"`
|
Data *BusinessRefundAgreedData `json:"data"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type BusinessRefundAgreedData struct {
|
type BusinessRefundAgreedData struct {
|
||||||
|
|||||||
@@ -2,7 +2,10 @@ package tiktok_api
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
brand_list_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/brand_list/request"
|
brand_list_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/brand_list/request"
|
||||||
|
order_batchDecrypt_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/order_batchDecrypt/request"
|
||||||
|
order_batchSensitive_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/order_batchSensitive/request"
|
||||||
product_addV2_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_addV2/request"
|
product_addV2_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_addV2/request"
|
||||||
product_addV2_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_addV2/response"
|
product_addV2_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_addV2/response"
|
||||||
product_del_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_del/request"
|
product_del_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_del/request"
|
||||||
@@ -287,3 +290,58 @@ func (a *API) GetSkuBrand(categoryId int64) (int64, error) {
|
|||||||
|
|
||||||
return result.Data.AuthBrandList[0].BrandId, nil
|
return result.Data.AuthBrandList[0].BrandId, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// OrderUserInfoDecrypt 用户信息解密
|
||||||
|
func (a *API) OrderUserInfoDecrypt(orderId string) {
|
||||||
|
request := order_batchDecrypt_request.New()
|
||||||
|
|
||||||
|
cipherInfos := make([]order_batchDecrypt_request.CipherInfosItem, 0, 0)
|
||||||
|
for i := 0; i < 3; i++ {
|
||||||
|
cipher := order_batchDecrypt_request.CipherInfosItem{}
|
||||||
|
cipher.AuthId = orderId
|
||||||
|
switch i {
|
||||||
|
case 1: // 姓名
|
||||||
|
cipher.CipherText = `#4/6R5x2e#yNZ5R4x+4YGk4yVVUVj5wDFNcIO8SPEjbXC7v55AV0oJKDafFKn9onnavg==&CgwIARDmDhjXESAEKAESPgo8UJvXDogRQo6o/CTNf5vPfN8ncAvwDTZrf4nw4v5BDusLnWFb0kH6vvl6qtlZ6MwEph9vT9DIHobUFoQxGgA=#1##`
|
||||||
|
cipherInfos = append(cipherInfos, cipher)
|
||||||
|
case 2: // 手机号
|
||||||
|
cipher.CipherText = `$L2ixwE3gFa/PhQeeN1Hxc0+TIImkbdVAcjdvVK1+BKE=$CT/fyQwDSEZskk3rWaxj5Je4w871eh1YBvge+aAv1chQ8pZsVBvJsQhRj+Rs&CgwIARDmDhjXESAEKAESPgo8Hs17yiBRdtnvUSwCjYO5fFyy/b8/ihLznxEgZeFaSO0LpVZrlIqHcNmBMrh3g0WNi3fLMAwFfi0v8qpoGgA=$1$$`
|
||||||
|
cipherInfos = append(cipherInfos, cipher)
|
||||||
|
case 3: // 地址
|
||||||
|
cipher.CipherText = `#UK1DDyGyV7AafNwBv0jMYdu1SxWkQlvD8/jN1W36QM/2y1hzIUVLCYMDhJWgAbEWCYMDUnbMaB6m0Rx7#ztuYzQyi68RWDzQGHNQwgNW4/aC19tCAyTJKZFTA5vd5YdBbzllK6lXCA58ulHB9FyvxzpUDAtWUVgywqCPsaDYsaDTjCo0g4RbUyyuRGoYz/BY=&CgwIARDmDhjXESAEKAESPgo8lmOxB5Al56WzV1wV3mupjuiJEnavXuyPyFoMJ0WexY9pCI56tSyZN78zvqrnqSSLrdt3V4Q0OugOv8seGgA=#1##`
|
||||||
|
cipherInfos = append(cipherInfos, cipher)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
request.Param.CipherInfos = cipherInfos
|
||||||
|
|
||||||
|
result, err := request.Execute(a.accessTokenObj)
|
||||||
|
fmt.Println(result)
|
||||||
|
fmt.Println(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// OrderUserInfoSensitive 用户信息脱敏
|
||||||
|
func (a *API) OrderUserInfoSensitive(orderId string) {
|
||||||
|
request := order_batchSensitive_request.New()
|
||||||
|
|
||||||
|
paramItems := make([]order_batchSensitive_request.CipherInfosItem, 0, 0)
|
||||||
|
for i := 0; i < 3; i++ {
|
||||||
|
cipher := order_batchSensitive_request.CipherInfosItem{}
|
||||||
|
cipher.AuthId = orderId
|
||||||
|
switch i {
|
||||||
|
case 1: // 姓名
|
||||||
|
cipher.CipherText = `#4/6R5x2e#yNZ5R4x+4YGk4yVVUVj5wDFNcIO8SPEjbXC7v55AV0oJKDafFKn9onnavg==&CgwIARDmDhjXESAEKAESPgo8UJvXDogRQo6o/CTNf5vPfN8ncAvwDTZrf4nw4v5BDusLnWFb0kH6vvl6qtlZ6MwEph9vT9DIHobUFoQxGgA=#1##`
|
||||||
|
paramItems = append(paramItems, cipher)
|
||||||
|
case 2: // 手机号
|
||||||
|
cipher.CipherText = `$L2ixwE3gFa/PhQeeN1Hxc0+TIImkbdVAcjdvVK1+BKE=$CT/fyQwDSEZskk3rWaxj5Je4w871eh1YBvge+aAv1chQ8pZsVBvJsQhRj+Rs&CgwIARDmDhjXESAEKAESPgo8Hs17yiBRdtnvUSwCjYO5fFyy/b8/ihLznxEgZeFaSO0LpVZrlIqHcNmBMrh3g0WNi3fLMAwFfi0v8qpoGgA=$1$$`
|
||||||
|
paramItems = append(paramItems, cipher)
|
||||||
|
case 3: // 地址
|
||||||
|
cipher.CipherText = `#UK1DDyGyV7AafNwBv0jMYdu1SxWkQlvD8/jN1W36QM/2y1hzIUVLCYMDhJWgAbEWCYMDUnbMaB6m0Rx7#ztuYzQyi68RWDzQGHNQwgNW4/aC19tCAyTJKZFTA5vd5YdBbzllK6lXCA58ulHB9FyvxzpUDAtWUVgywqCPsaDYsaDTjCo0g4RbUyyuRGoYz/BY=&CgwIARDmDhjXESAEKAESPgo8lmOxB5Al56WzV1wV3mupjuiJEnavXuyPyFoMJ0WexY9pCI56tSyZN78zvqrnqSSLrdt3V4Q0OugOv8seGgA=#1##`
|
||||||
|
paramItems = append(paramItems, cipher)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
request.Param.CipherInfos = paramItems
|
||||||
|
|
||||||
|
result, err := request.Execute(a.accessTokenObj)
|
||||||
|
fmt.Println(result)
|
||||||
|
fmt.Println(err)
|
||||||
|
}
|
||||||
|
|||||||
@@ -35,9 +35,8 @@ func TestCategory(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestGetCatePropertyV2(t *testing.T) {
|
func TestGetCatePropertyV2(t *testing.T) {
|
||||||
accesstoken := `{"access_token":"6c4d71b3-831c-4a96-8d2e-977e37afba5a","expires_in":604800,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"65aae144-4cc0-44d2-89ba-5d3062caca41","authority_id":""}
|
token := `{"access_token":"a1746210-a8a3-4497-a87b-09d1f10dbb95","expires_in":1665652230,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"c1cf8d88-0983-4f2a-b969-3746fae6b0cd","authority_id":""}`
|
||||||
`
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", accesstoken)
|
|
||||||
data, err := a.GetCatePropertyV2(23065)
|
data, err := a.GetCatePropertyV2(23065)
|
||||||
fmt.Println("err=====", err)
|
fmt.Println("err=====", err)
|
||||||
fmt.Println("data====", data) // 202209281558450102081001701D7B32C5
|
fmt.Println("data====", data) // 202209281558450102081001701D7B32C5
|
||||||
@@ -295,3 +294,19 @@ func TestProductSetOffline(t *testing.T) {
|
|||||||
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
a.ProductSetOffline(3576377564144516403)
|
a.ProductSetOffline(3576377564144516403)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 解密购买用户电话,名字,地址
|
||||||
|
func TestBatchDecrypt(t *testing.T) {
|
||||||
|
token := `{"access_token":"a1746210-a8a3-4497-a87b-09d1f10dbb95","expires_in":1665652230,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"c1cf8d88-0983-4f2a-b969-3746fae6b0cd","authority_id":""}`
|
||||||
|
|
||||||
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
|
a.OrderUserInfoDecrypt("4988354190732430566")
|
||||||
|
}
|
||||||
|
|
||||||
|
// 脱敏购买用户电话,名字,地址
|
||||||
|
func TestOrderUserInfoSensitive(t *testing.T) {
|
||||||
|
token := `{"access_token":"a1746210-a8a3-4497-a87b-09d1f10dbb95","expires_in":1665652230,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"c1cf8d88-0983-4f2a-b969-3746fae6b0cd","authority_id":""}`
|
||||||
|
|
||||||
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
|
a.OrderUserInfoSensitive("4988354190732430566")
|
||||||
|
}
|
||||||
|
|||||||
@@ -109,3 +109,7 @@ func TestUnBindd(t *testing.T) {
|
|||||||
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
|
||||||
a.WarehouseUnbindStore([]int64{63114504}, "666667")
|
a.WarehouseUnbindStore([]int64{63114504}, "666667")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestJNTM(t *testing.T) {
|
||||||
|
fmt.Println(2 | 8)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user