This commit is contained in:
richboo111
2022-11-02 09:50:34 +08:00
14 changed files with 176 additions and 46 deletions

View File

@@ -57,13 +57,15 @@ var (
const (
DeliveryServiceCodeSuperRapid = 4002 // 飞速达
DeliveryServiceCodeRapid = 100004 // 快速达
DeliveryServiceCodeIntime = 100006 // 及时
DeliveryServiceCodeRapid = 100029 // 快速达,时效型
DeliveryServiceLocalDa = 100009 // 同城
DeliveryServiceCodeIntime = 100006 // 及时达(这个暂时没用)
DeliveryServiceCodeTogether = 4013 // 集中送
//DeliveryServiceCodeSuperRapid = 4002 // 飞速达
//DeliveryServiceCodeRapid = 4011 // 快速达
//DeliveryServiceCodeIntime = 100006 // 及时达
//DeliveryServiceCodeTogether = 4013 // 集中送
)
const (

View File

@@ -64,17 +64,17 @@ func TestCreateOrderByShop(t *testing.T) {
DeliveryID: 123456789,
OrderID: "order_123456789",
// 设置测试门店 id测试门店的坐标地址为 97235456,31065079高德坐标配送范围3km
ShopID: "test_0001",
DeliveryServiceCode: DeliveryServiceCodeIntime,
ReceiverName: "xjh",
ReceiverAddress: "九里堤",
ReceiverPhone: "18112345678",
ReceiverLng: 97235456,
ReceiverLat: 31065079,
CoordinateType: CoordinateTypeMars,
GoodsValue: 12.34,
GoodsWeight: 3.4,
OrderType: OrderTypeASAP,
ShopID: "test_0001",
//DeliveryServiceCode: DeliveryServiceCodeIntime,
ReceiverName: "xjh",
ReceiverAddress: "九里堤",
ReceiverPhone: "18112345678",
ReceiverLng: 97235456,
ReceiverLat: 31065079,
CoordinateType: CoordinateTypeMars,
GoodsValue: 12.34,
GoodsWeight: 3.4,
OrderType: OrderTypeASAP,
}
order, err := api.CreateOrderByShop2(basicParams)

View File

@@ -696,6 +696,8 @@ func (a *API) OrderUpdateTip(orderID int64, tipAmount float64) (err error) {
// 美团外卖自配送商家同步发货状态和配送信息(推荐)
// https://waimaiopen.meituan.com/api/v1/ecommerce/order/logistics/sync
func (a *API) OrderStatusAndPsInfo(params map[string]interface{}) (err error) {
delete(params, "opcode") // 美团不需要此参数
delete(params, "logistics_context") // 美团不需要此参数
_, err = a.AccessAPI("ecommerce/order/logistics/sync", false, params)
return err
}

View File

@@ -53,7 +53,7 @@ type LogisticsIndTrackPushParam struct {
// 轨迹信息
TraceMsgs []TraceMsgList `json:"trace_msgs"`
// 未知
AuthorityId string `json:"authority_id"`
//AuthorityId string `json:"authority_id"`
}
type TraceMsgList struct {

View File

@@ -7,8 +7,8 @@ import (
"testing"
)
var token = `{"access_token":"47690a84-3cc2-4958-abf9-41cc7fca5f82","expires_in":1666862533,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"66ea2395-07c7-409d-84ae-93ac1e600b74","authority_id":""}`
var a = New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", token)
var token = `{"access_token":"c4afc5bc-7ddf-4244-b35a-0c393f3dca32","expires_in":1667203717,"scope":"SCOPE","shop_id":57939570,"shop_name":"京西菜市速食","refresh_token":"5a4f9dfe-306b-4bca-8b35-2ae9afc0245e","authority_id":""}`
var a = New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", "")
// 查询售后单详情
func TestAfsOrder(t *testing.T) {

View File

@@ -110,10 +110,6 @@ func (a *API) RefreshToken() (*doudian_sdk.CreateTokenData, error) {
func (a *API) SetToken(token string) {
a.locker.Lock()
defer a.locker.Unlock()
var access *doudian_sdk.AccessToken
if err := json.Unmarshal([]byte(token), &access); err != nil {
return
}
a.accessToken = token
}
@@ -123,6 +119,18 @@ func (a *API) SetRefreshToken(token string) {
a.refreshToken = token
}
func (a *API) SetExpiresIn(expiresIn int64) {
a.locker.Lock()
defer a.locker.Unlock()
a.expiresIn = expiresIn
}
func (a *API) SetAcctokenObj(acctokenObj *doudian_sdk.AccessToken) {
a.locker.Lock()
defer a.locker.Unlock()
a.accessTokenObj = acctokenObj
}
// GetAppId 获取appid
func (a *API) GetAppId() string {
a.locker.Lock()

View File

@@ -103,9 +103,17 @@ func TestOrderStatusAndPsInfo(t *testing.T) {
a := NewExpress("7153997323561879075", "3517d3ea-b96b-4379-a7a4-2d9389e8ffeb", "")
a.CreateToken()
param := make(map[string]interface{}, 0)
param["third_carrier_order_id"] = "1412986874296139776"
param["logistics_context"] = "骑手送达2"
param["courier_name"] = "刘磊"
param["courier_phone"] = "18981810340"
param["third_carrier_order_id"] = "4995851215059621284"
param["logistics_context"] = "呼叫骑手"
param["opcode"] = "CALL_RIDER"
param["courier_name"] = "徐业圩"
param["courier_phone"] = "19817862055"
a.OrderStatusAndPsInfo(param)
}
func TestMap(t *testing.T) {
data := map[string]string{"1": "1", "2": "2"}
fmt.Println(data)
delete(data, "1")
fmt.Println(data)
}

View File

@@ -116,10 +116,10 @@ func (a *APIExpress) OrderStatusAndPsInfo(param map[string]interface{}) error {
// 组合参数
request := logistics_indTrackPush_reqeust.New()
psInfo := &logistics_indTrackPush_reqeust.LogisticsIndTrackPushParam{
CurTime: utils.Time2Str(time.Now()),
Company: TiktokExpressCode,
TraceMsgs: nil,
AuthorityId: "",
CurTime: utils.Time2Str(time.Now()),
Company: TiktokExpressCode,
TraceMsgs: nil,
//AuthorityId: "",
}
traceMsgs := make([]logistics_indTrackPush_reqeust.TraceMsgList, 0, 1)
traceMsg := logistics_indTrackPush_reqeust.TraceMsgList{
@@ -129,7 +129,7 @@ func (a *APIExpress) OrderStatusAndPsInfo(param map[string]interface{}) error {
Opcode: param["opcode"].(string),
OpTime: utils.Time2Str(time.Now()),
Content: param["logistics_context"].(string),
ThirdPartyCompany: TiktokExpressCode,
ThirdPartyCompany: "dada",
ExceptionCode: "",
ExceptionDesc: "",
CancelCode: "",
@@ -149,6 +149,7 @@ func (a *APIExpress) OrderStatusAndPsInfo(param map[string]interface{}) error {
psInfo.TraceMsgs = traceMsgs
request.Param = psInfo
globals.SugarLogger.Debugf("OrderStatusAndPsInfo=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("OrderStatusAndPsInfo=========:%s", utils.Format4Output(request.Param, false))
if a.accessTokenObj == nil || a.accessTokenObj.CreateTokenData.AccessToken == "" {
a.CreateToken()

View File

@@ -32,6 +32,8 @@ func (a *API) GetTiktokOrderDetail(orderId string) (*order_orderDetail_response.
IsSearchable: false,
}
orderDetail, err := reqParam.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取订单详情%s", reqParam.GetUrlPath())
globals.SugarLogger.Debugf("获取订单详情:=%s", utils.Format4Output(orderDetail, false))
if err != nil {
return nil, err
}
@@ -51,6 +53,8 @@ func (a *API) QueryAfsOrderDetail(afterSaleId string, needOperationRecord bool)
param.AfterSaleId = afterSaleId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("查询售后订单详情%s", request.GetUrlPath())
globals.SugarLogger.Debugf("查询售后订单详情:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -69,7 +73,7 @@ func (a *API) ApplyMarketAfterSale(skuOrderId, count int64, afterSaleReason int3
param.ItemCount = count // 拒收是必填
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("====request.param = %s", utils.Format4Output(param, false))
globals.SugarLogger.Debugf("====request.result ==========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("====request.result = %s", utils.Format4Output(result, false))
if err != nil {
return "", err
@@ -153,6 +157,8 @@ func (a *API) AfterSaleOperate(refundType int32, refundId, remark string, storeI
param.Items = refundListParam
// 同意退货
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("AfterSaleOperate=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("====AfterSaleOperate:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -173,6 +179,8 @@ func (a *API) GetRefundAddressId(storeID int64) (int64, error) {
param.StoreId = storeID
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取抖店售后地址列表=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取抖店售后地址列表:=%s", utils.Format4Output(result, false))
if err != nil {
return 0, err
}
@@ -194,6 +202,8 @@ func (a *API) QueryAllReason(afterSaleId int64) ([]afterSale_rejectReasonCodeLis
}
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("查询所有的售后审核处理原因详情=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("查询所有的售后审核处理原因详情:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -216,6 +226,8 @@ func (a *API) GetStoreOrderList(queryData time.Time, storeId int64) ([]string, e
param.Size = 100
orderDetailList, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取门店订单列表=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取门店订单列表:=%s", utils.Format4Output(orderDetailList, false))
if err != nil {
return nil, err
}
@@ -276,6 +288,8 @@ func (a *API) ReturnGoodsToWareHouseSuccess(afsOrderId string) error {
param.OpTime = time.Now().Unix()
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("商家确认售后单对应的用户退货入仓成功=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("商家确认售后单对应的用户退货入仓成功:=%s", utils.Format4Output(result, false))
if err != nil {
return err // 202210141114300102101071350D6F3847
}
@@ -316,6 +330,8 @@ func (a *API) LogisticsAdd(orderId string, companyCode string, isRefundReject bo
AddressId: addressId,
}
data, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("订单发货接口=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("订单发货接口:=%s", utils.Format4Output(data, false))
if err != nil {
return err
}
@@ -591,8 +607,6 @@ func (a *API) GetCallbackOrderId(msgId string, data interface{}) (string, *Callb
default:
return "", CallbackResponseErr(false)
}
return "", &CallbackResponse{Code: CallbackSuccessCode, Msg: CallbackSuccess}
}
// OrderDelivering 订单发货
@@ -601,6 +615,7 @@ func (a *API) OrderDelivering(param *order_logisticsAdd_request.OrderLogisticsAd
request.Param = param
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("OrderDelivering=========%s", request.GetUrlPath())
globals.SugarLogger.Debugf("OrderDelivering=========%s", utils.Format4Output(result, false))
if err != nil {
return err

View File

@@ -37,6 +37,8 @@ func (a *API) UpdateSkuStock(param *sku_syncStock_request.SkuSyncStockParam) err
request := sku_syncStock_request.New()
request.Param = param
resp, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("更新区域库存=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("更新区域库存:=%s", utils.Format4Output(resp, false))
if err != nil {
return err
}
@@ -58,6 +60,8 @@ func (a *API) GetShopCategory(cid int64) ([]*RetailCategoryInfo, error) {
param := request.GetParams()
param.Cid = cid
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取类目id=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取类目id:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -96,6 +100,8 @@ func (a *API) GetCatePropertyV2(categoryLeftId int64) (*product_getCatePropertyV
param.CategoryLeafId = categoryLeftId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("根据类目id获取子节点属性=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("根据类目id获取子节点属性:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -111,6 +117,8 @@ func (a *API) CreateStoreCommodity(skuParam *product_addV2_request.ProductAddV2P
request.Param = skuParam
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("新增商品=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("新增商品:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -126,6 +134,8 @@ func (a *API) SyncStockBatch(param *sku_syncStockBatch_request.SkuSyncStockBatch
request := sku_syncStockBatch_request.New()
request.Param = param
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("库存同步=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("库存同步:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -141,6 +151,8 @@ func (a *API) EditStoreCommodity(sku *product_editV2_request.ProductEditV2Param)
request.Param = sku
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("编辑门店=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("编辑门店============%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -156,6 +168,8 @@ func (a *API) EditStoreCommodityCommit(sku *product_editV2_commit_request.Produc
request.Param = sku
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("商品上架=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("商品上架:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -173,6 +187,8 @@ func (a *API) DeleteStoreCommodity(productId int64) error {
param.DeleteForever = true
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("删除商品=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("删除商品:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -190,6 +206,8 @@ func (a *API) ProductSetOffline(productId int64) error {
param.ProductId = productId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("商品下架=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("商品下架:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -211,7 +229,8 @@ func (a *API) GetSkuDetail(productId, outProductId string) (*product_detail_resp
}
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("%s", utils.Format4Output(result, false))
globals.SugarLogger.Debugf("获取商品详情=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取商品详情:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -231,6 +250,8 @@ func (a *API) GetSkuDetailLocalID(productId, outProductId string) (*product_deta
}
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取商品详情=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取商品详情:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -246,6 +267,8 @@ func (a *API) GetSkuDetailList(param *product_listV2_request.ProductListV2Param)
request.Param = param
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("批量获取商品=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("批量获取商品:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -262,6 +285,8 @@ func (a *API) EditPrice(skuPrice *sku_editPrice_request.SkuEditPriceParam) error
request.Param = skuPrice
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("修改商品价格=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("修改商品价格:=%s", utils.Format4Output(result, false))
if err != nil {
return err
}
@@ -276,6 +301,8 @@ func (a *API) GetSkuBrand(categoryId int64) (int64, error) {
request := brand_list_request.New()
request.Param.CategoryId = categoryId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取商品所属品牌=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取商品所属品牌:=%s", utils.Format4Output(result, false))
if err != nil {
return 0, err
}
@@ -313,6 +340,8 @@ func (a *API) OrderUserInfoDecrypt(orderId, name, tel, address string) (string,
request.Param.CipherInfos = cipherInfos
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("用户信息解密=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("用户信息解密:=%s", utils.Format4Output(result, false))
if err != nil {
return "", "", "", err
}
@@ -361,6 +390,7 @@ func (a *API) OrderUserInfoSensitive(orderId, name, tel, address string) {
request.Param.CipherInfos = paramItems
result, err := request.Execute(a.accessTokenObj)
fmt.Println(result)
globals.SugarLogger.Debugf("用户信息脱敏=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("用户信息脱敏:=%s", utils.Format4Output(result, false))
fmt.Println(err)
}

View File

@@ -218,7 +218,7 @@ func TestInt16(t *testing.T) {
// 查询商品详情(抖音平台id)
func TestGetSkuDetail(t *testing.T) {
data, err := a.GetSkuDetail("3579136668340475469", "")
data, err := a.GetSkuDetail("3580251132888538614", "")
fmt.Println(err)
globals.SugarLogger.Debugf("====%s", utils.Format4Output(data, false))
}
@@ -263,18 +263,21 @@ func TestEiduPrice(t *testing.T) {
// s上架1
func TestEditStoreCommodity(t *testing.T) {
accesstoken := `{"access_token":"60f530b2-9ab6-4723-b487-c094918f0d21","expires_in":1666257163,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"1220666a-5e88-458c-a8c0-06d949fbbd3f","authority_id":""}`
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", accesstoken)
data, _ := a.GetSkuDetail("3580251132888538614", "")
globals.SugarLogger.Debugf("=============%s", data.ProductFormatNew)
specPrice, _ := json.Marshal(data.SpecPrices)
specs, _ := json.Marshal(data.Specs)
a.EditStoreCommodity(&product_editV2_request.ProductEditV2Param{
ProductId: 3576377564144516403,
Commit: true,
ProductId: 1748169491056643,
ProductFormatNew: data.ProductFormatNew,
SpecPrices: string(specPrice),
Specs: string(specs),
Commit: true,
})
}
// 上架2
func TestEditStoreCommodity2(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.EditStoreCommodityCommit(&product_editV2_commit_request.ProductEditV2Param2{
ProductId: 3576377564144516403,
Commit: true,

View File

@@ -6,6 +6,8 @@ import (
material_batchUploadImageSync_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/material_batchUploadImageSync/response"
material_createFolder_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/material_createFolder/request"
material_createFolder_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/material_createFolder/response"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/globals"
)
// CreateFolder 创建商品库文件夹(存放商品图片素材)
@@ -24,6 +26,8 @@ func (a *API) CreateFolder(fileName string) (*material_createFolder_response.Mat
param.ParentFolderId = "0" // 根目录创建文件夹
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("创建商品库文件夹=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("创建商品库文件夹:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -57,6 +61,8 @@ func (a *API) BatchUploadImages(imgs []Imgs) (*material_batchUploadImageSync_res
imgParam.NeedDistinct = true
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("批量上传文件到目录=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("批量上传文件到目录:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}

View File

@@ -51,6 +51,7 @@ import (
warehouse_list_response "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/warehouse_list/response"
warehouse_setFence_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/warehouse_setFence/request"
warehouse_unbindStore_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/warehouse_unbindStore/request"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/globals"
)
@@ -59,6 +60,8 @@ func (a *API) GetStoreDetail(param *shop_getStoreDetail_request.ShopGetStoreDeta
request := shop_getStoreDetail_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("单个获取门店信息=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("单个获取门店信息:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -73,6 +76,8 @@ func (a *API) BatchCreateStore(param *shop_batchCreateStore_request.ShopBatchCre
request := shop_batchCreateStore_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("批量创建门店=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("批量创建门店:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -91,6 +96,8 @@ func (a *API) EditStore(param *shop_editStore_request.ShopEditStoreParam) error
request := shop_editStore_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("编辑门店=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("编辑门店:=%s", utils.Format4Output(response, false))
if err != nil {
return err
}
@@ -105,6 +112,8 @@ func (a *API) StoreSuspend(param *shop_storeSuspend_request.ShopStoreSuspendPara
request := shop_storeSuspend_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("暂停营业=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("暂停营业:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -119,6 +128,8 @@ func (a *API) UnsuspendStore(param *shop_unsuspendStore_request.ShopUnsuspendSto
request := shop_unsuspendStore_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店恢复营业=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店恢复营业:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -133,6 +144,8 @@ func (a *API) GetStoreList(param *shop_getStoreList_request.ShopGetStoreListPara
request := shop_getStoreList_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店列表分页查询=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店列表分页查询:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -147,6 +160,8 @@ func (a *API) CreateTradeLimitTemplate(param *trade_createTradeLimitTemplate_req
request := trade_createTradeLimitTemplate_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("创建限售规则模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("创建限售规则模板:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -161,6 +176,8 @@ func (a *API) BindStoreSaleLimit(param *shop_bindStoreSaleLimit_request.ShopBind
request := shop_bindStoreSaleLimit_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店绑定限售模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店绑定限售模板:=%s", utils.Format4Output(response, false))
if err != nil {
return err
}
@@ -175,6 +192,8 @@ func (a *API) StoreQuerySaleLimitTemp(storeId int64) (int64, error) {
request := shop_getStoreSaleLimit_request.New()
request.Param.StoreId = storeId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店查询限售模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店查询限售模板:=%s", utils.Format4Output(result, false))
if err != nil {
return 0, err
}
@@ -192,6 +211,8 @@ func (a *API) FreightTemplateCreate(param *freightTemplate_create_request.Freigh
request := freightTemplate_create_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("创建运费模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("创建运费模板:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -206,6 +227,8 @@ func (a *API) FreightTemplateUpdate(param *freightTemplate_update_request.Freigh
request := freightTemplate_update_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("更新运费模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("更新运费模板:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -220,6 +243,8 @@ func (a *API) BindFreightTemplate(param *shop_bindStoreFreight_request.ShopBindS
request := shop_bindStoreFreight_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店绑定运费模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店绑定运费模板:=%s", utils.Format4Output(response, false))
if err != nil {
return err
}
@@ -234,6 +259,8 @@ func (a *API) GetStoreFreight(storeId int64) ([]int64, error) {
request := shop_getStoreFreight_request.New()
request.Param.StoreId = storeId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取门店所有的运费模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取门店所有的运费模板:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -257,6 +284,8 @@ func (a *API) GetStoreBindTemp(storeId int64) (freightId int64, err error) {
request := shop_getStoreFreight_request.New()
request.Param.StoreId = storeId
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("获取门店绑定的运费模板=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("获取门店绑定的运费模板:=%s", utils.Format4Output(result, false))
if err != nil {
return 0, err
}
@@ -276,6 +305,8 @@ func (a *API) BatchCreateWarehouse(param *warehouse_createBatch_request.Warehous
request := warehouse_createBatch_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("批量创建区域仓=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("批量创建区域仓:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -290,6 +321,8 @@ func (a *API) CreateWarehouse(param *warehouse_create_request.WarehouseCreatePar
request := warehouse_create_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("创建单个区域仓=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("创建单个区域仓:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -304,6 +337,8 @@ func (a *API) StoreBindWarehouse(param *warehouse_bindStore_request.WarehouseBin
request := warehouse_bindStore_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("仓库绑定门店=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("仓库绑定门店:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -337,6 +372,8 @@ func (a *API) CreateFence(param *warehouse_createFence_request.WarehouseCreateFe
request := warehouse_createFence_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("创建电子围栏=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("创建电子围栏:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -351,6 +388,8 @@ func (a *API) SetFence(param *warehouse_setFence_request.WarehouseSetFenceParam)
request := warehouse_setFence_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("更新电子围栏=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("更新电子围栏:=%s", utils.Format4Output(response, false))
if err != nil {
return err
}
@@ -365,6 +404,8 @@ func (a *API) BindFenceByStore(param *warehouse_bindFencesByStore_request.Wareho
request := warehouse_bindFencesByStore_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("门店绑定电子围栏=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("门店绑定电子围栏:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -379,6 +420,8 @@ func (a *API) WarehouseBindFence(param *warehouse_bindFences_request.WarehouseBi
request := warehouse_bindFences_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf("仓库绑定电子围栏=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf("仓库绑定电子围栏:=%s", utils.Format4Output(response, false))
if err != nil {
return err
}
@@ -393,6 +436,8 @@ func (a *API) GetFence(outFenceID string) (*warehouse_getFences_response.Warehou
request := warehouse_getFences_request.New()
request.Param.OutFenceIdList = []string{outFenceID}
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 获取仓库(即门店)绑定 电子围栏信息列表=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 获取仓库(即门店)绑定 电子围栏信息列表:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -408,6 +453,8 @@ func (a *API) AddressCreate(param *address_create_request.AddressCreateParam) (*
request := address_create_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 门店新增查询发货地址=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 门店新增查询发货地址:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -422,6 +469,8 @@ func (a *API) GetAddressList(param *address_list_request.AddressListParam) (*add
request := address_list_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 分页获取商家地址列表=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 分页获取商家地址列表:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -436,6 +485,8 @@ func (a *API) GetAreasByProvince(param *address_getAreasByProvince_request.Addre
request := address_getAreasByProvince_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 根据省份ID获取全量四级地址=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 根据省份ID获取全量四级地址:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -450,6 +501,8 @@ func (a *API) GetProvince(param *address_getProvince_request.AddressGetProvinceP
request := address_getProvince_request.New()
request.Param = param
response, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 获取四级地址全量省份信息=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 获取四级地址全量省份信息:=%s", utils.Format4Output(response, false))
if err != nil {
return nil, err
}
@@ -464,6 +517,8 @@ func (a *API) QueryAllWarehouse(param *warehouse_list_request.WarehouseListParam
request := warehouse_list_request.New()
request.Param = param
result, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 查询所有的仓库=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 查询所有的仓库:=%s", utils.Format4Output(result, false))
if err != nil {
return nil, err
}
@@ -483,6 +538,8 @@ func (a *API) WarehouseUnbindStore(storeId []int64, outWarehouseId string) error
request.Param.OutWarehouseId = outWarehouseId
data, err := request.Execute(a.accessTokenObj)
globals.SugarLogger.Debugf(" 仓库解绑门店接口=========:%s", request.GetUrlPath())
globals.SugarLogger.Debugf(" 仓库解绑门店接口:=%s", utils.Format4Output(data, false))
if err != nil {
return err
}

View File

@@ -236,12 +236,10 @@ func TestUnsuspendStore(t *testing.T) {
}
func TestUpdateStore(t *testing.T) {
accesstoken := `{"access_token":"60f530b2-9ab6-4723-b487-c094918f0d21","expires_in":1666257163,"scope":"SCOPE","shop_id":"","shop_name":"小时达开放平台对接专用店","refresh_token":"1220666a-5e88-458c-a8c0-06d949fbbd3f","authority_id":""}`
a := New("7136048270014416392", "c397aa9f-3927-47c4-8cfe-4d84e02602e0", accesstoken)
param := &shop_editStore_request.ShopEditStoreParam{
StoreId: 65312663,
StoreId: 65402632,
StoreCode: "",
Name: "测试门店修改1019",
Name: "",
Province: "",
City: "",
District: "",
@@ -250,7 +248,7 @@ func TestUpdateStore(t *testing.T) {
Longitude: "",
Latitude: "",
OpenTime: &shop_editStore_request.OpenTime{DayMap: map[int64]string{
1: "07:00-12:00 14:00-18:00",
1: "07:00-20:00", 2: "07:00-20:00", 3: "07:00-20:00", 4: "07:00-20:00", 5: "07:00-20:00", 6: "07:00-20:00", 7: "07:00-20:00",
}},
}
err := a.EditStore(param)