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

京东商城一堆

Browse Source
This commit is contained in:
苏尹岚
2020-05-12 15:37:04 +08:00
parent 9e8b8dbf13
commit 35cd9ffa79
7 changed files with 577 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
platformapi/jdshopapi/jdshopapi.go
View File

@@ -19,6 +19,10 @@ const (
CreateCatType = "3"
UpdateCatType = "1"
TransportID = 2158480
JxBrandId = 559853
JdShopMaxStock = 9999
)
type API struct {
@@ -109,3 +113,43 @@ func (a *API) AccessAPI(action string, url string, bizParams map[string]interfac
})
return retVal, err
}
func (a *API) AccessAPI2(action string, url string, bizParams map[string]interface{}) (retVal map[string]interface{}, err error) {
params := make(map[string]interface{})
params["access_token"] = a.accessToken
params["app_key"] = a.appKey
params["timestamp"] = utils.Time2Str(time.Now())
params["method"] = action
params["v"] = "2.0"
params = utils.MergeMaps(params, bizParams)
signStr := a.signParam(params)
params["sign"] = signStr
fullURL := utils.GenerateGetURL(url, "", nil)
// delete(params, "ware")
// delete(params, "skus")
// ware := bizParams["ware"].(string)
// skus := bizParams["skus"].(string)
err = platformapi.AccessPlatformAPIWithRetry(a.client,
func() *http.Request {
request, _ := http.NewRequest(http.MethodPost, fullURL, strings.NewReader(utils.URLQueryEscape(utils.Map2URLValues(params).Encode())))
request.Header.Set("charset", "UTF-8")
request.Header.Set("Content-Type", "application/x-www-form-urlencoded")
return request
},
a.config,
func(response *http.Response, bodyStr string, jsonResult1 map[string]interface{}) (errLevel string, err error) {
if jsonResult1 == nil {
return platformapi.ErrLevelRecoverableErr, fmt.Errorf("mapData is nil")
}
if err == nil {
if jsonResult1["error_response"] != nil {
errLevel = platformapi.ErrLevelGeneralFail
err = utils.NewErrorCode(jsonResult1["error_response"].(map[string]interface{})["zh_desc"].(string), jsonResult1["error_response"].(map[string]interface{})["code"].(string))
baseapi.SugarLogger.Debugf("jdeclp AccessAPI failed, jsonResult1:%s", utils.Format4Output(jsonResult1, true))
}
retVal = jsonResult1
}
return errLevel, err
})
return retVal, err
}

4
platformapi/jdshopapi/jxshopapi_test.go
View File

@@ -14,6 +14,6 @@ func init() {
logger, _ := zap.NewDevelopment()
sugarLogger = logger.Sugar()
baseapi.Init(sugarLogger)
api = New("da8db492e20149e494afaf5607e1d6654zgi", "E1D746D42474D5F1F1A10CECE75D99F6", "efa7e1d1a22640fa990e6cf164b28608")
api.SetCookie("thor", "80FAF09E9A09B6E618A68057BDFCFCB81C821714A15F3E8682FBAD9605C6284CE3D573A97D5021559891D214CDCCFA4A90F8254643B0A60E168F976FF8C3D2E5ACB0F3DB2ABFBC0A2E4EE6297EC49919CAE5CBBD6A686F1F7370B6ABD7AE8BE70DD216650EC9AAD79928DAC85CFA2D9BC581BA085F0D45C613A99F13F25AA3B24372930D5BB7CEBF685AF34698EBFD92")
api = New("de8157b447584885910f429011e49cb93yjq", "E1D746D42474D5F1F1A10CECE75D99F6", "efa7e1d1a22640fa990e6cf164b28608")
api.SetCookie("thor", "80FAF09E9A09B6E618A68057BDFCFCB8B87C1706FE86F2E8F20251DD598C89ABC8F03DCAB3F5BE7A0CDD0F812D17258CA4603C28541A12C7183F098906F2EBD451175D5A5E341996FDBE3D23CA1D8B847A98C67F3533705D0757AFF57A4B0B4D1D6AD40D1E4AD9AF90E6BE6F807C2802DF5072847E20C96602C459A17166562FF47B9F01900825FF8EFE50C0FA08092F")
}

268
platformapi/jdshopapi/sku.go
View File

@@ -1,6 +1,8 @@
package jdshopapi
import (
"encoding/base64"
"encoding/json"
"fmt"
"git.rosy.net.cn/baseapi/utils"
@@ -20,6 +22,122 @@ type FindShopCategoriesResult struct {
ModifyTime int64 `json:"modify_time"` // 修改时间。每修改一次此值都会发生变化。
}
type FindVendorCategoriesResult struct {
ID int `json:"id"`
Fid int `json:"fid"`
AliasName string `json:"aliasName"`
Lev int `json:"lev"`
IndexID int `json:"indexId"`
Status int `json:"status"`
Created int64 `json:"created"`
Name string `json:"name"`
Modified int64 `json:"modified"`
}
type CreateSkuParamWare struct {
Title string `json:"title"` //是 无 商品名称（限制50个字符以内）
CategoryID int `json:"categoryId"` //是 无 已经授权过的京东“三级”类目(通过商家授权类目接口获取)
// MultiCategoryID int `json:"multiCategoryId"` // 否 无 末级类目ID
BrandID int `json:"brandId"` // 否 无 不同类目是否必填情况不同，若发布时提示[此类目要求品牌必填]，则表示品牌需要必填。品牌ID获取方式通过商家授权类目接口获取。
// TemplateID int `json:"templateId"` // 否 无 发布时不可设置
TransportID int `json:"transportId"` //是 无 运费模板ID
WareStatus int `json:"wareStatus"` // 否 新增仅可以使用 1:从未上架 8:在售(上架) 商品状态1:从未上架 2:自主下架 4:系统下架 8:在售 513:从未上架 待审核 514:自主下架 待审核 516:系统下架 待审核 520:在售 待审核 1025:从未上架 审核不通过 暂时没用 1026:自主下架 审核不通过 暂时没用 1028:系统下架 审核不通过 1032:在售 审核不通过
OuterID string `json:"outerId"` // 否 无 商品外部ID,商家自行设置的ID（便于关联京东商品）
VenderID int `json:"venderId"`
Is7ToReturn int `json:"is7ToReturn"` // 0 不支持，1 支持7天， 2支持90天
// ItemNum string `json:"itemNum"` // 否 无 商品货号
// BarCode string `json:"barCode"` // 否 无 商品的条形码.UPC码,SN码,PLU码统称为条形码
// WareLocation int `json:"wareLocation"` // 否 无 商品产出地区
// Delivery int `json:"delivery"` // 否 无 商品发货地
// PromiseID int `json:"promiseId"` // 否 无 配送时效
// adWords // 否 无 商品广告词对象 （单品页显示的优先级低于促销广告词）
// Wrap string `json:"wrap"` //否 无 包装规格（已废弃）
// PackListing string `json:"packListing"` // 否 无 商品包装清单
Length int `json:"length"` // 否 无 商品长度,单位mm。根据类目区分 是 否必填
Width int `json:"width"` // 否 无 商品宽度,单位mm。根据类目区分 是 否必填
Height int `json:"height"` // 否 无 商品高度,单位mm。根据类目区分 是 否必填
Weight int `json:"weight"` // 否 无 商品重量,单位kg。根据类目区分 是 否必填
// Props []struct {
// AttrID string `json:"attrID"` // 否 无 属性ID
// AttrValues string `json:"attrValues"` //否 无 属性值ID数组
// } `json:"props"` // 否 无 属性列表(已废弃 请使用multiCateProps,已经按照类目限制使用3级类目修改，请及时迁移到多级类目)
// Features []struct {
// Key string `json:"key"` //是 无 特殊属性key
// Value string `json:"value"` //否 无 特殊属性value
// } `json:"features"` // 否 无 商品维度的特殊属性 目前两个特殊属性 IBS、FBP、FCS、SCF 4种商家类型【规格型号】 model和【销售单位】 unit 字段且为必填（如 个、盒、袋等）请勿填写公司名称。
Images []*CreateSkuParamImages `json:"images"` // 是 无 商品图片列表，发布时必须有主图(颜色为十个0，index为1的图片)
ShopCategorys []int `json:"shopCategorys"` // 否 无 商品店内分类（商家接口获取到的最末级的分类）
MobileDesc string `json:"mobileDesc"` // 是 无 移动版的商品介绍 长度限制10W个字符
Introduction string `json:"introduction"` // 是 无 PC版的商品介绍 长度限制10W个字符
// AfterSales string `json:"afterSales"` // 否 无 售后服务
JdPrice int `json:"jdPrice"` // 否 无 商品的京东价,人民币单元 是元
MarketPrice int `json:"marketPrice"` // 否 无 商品的市场价,人民币单元 是元
// ZhuangBaID string `json:"zhuangBaId"` // 否 无 商品描述装吧实例ID
// IntroductionUseFlag string `json:"introductionUseFlag"` // 否 无 商品描述使用标识 ,0：使用默认的商品描述,1：使用装吧商详
// MobileZhuangBaID string `json:"mobileZhuangBaId"` // 否 无 移动版商品描述装吧实例ID
// MobileDescUseFlag string `json:"mobileDescUseFlag"` // 否 无 移动版商品描述使用标识,0：使用默认的移动商详；1：使用装吧移动版商详
// DesignConcept string `json:"designConcept"` // 否 无 商品设计理念,适用范围 是toplife类目
// FitCaseHTMLApp string `json:"fitCaseHtmlApp"` // 否 无 装修案例移动版描述,装修类目才可填写
// FitCaseHTMLPc string `json:"fitCaseHtmlPc"` // 否 无 装修案例PC版描述,装修类目才可填写
// SpecialServices []string `json:"specialServices"` // 否 无 特色服务,装修类目才可填写,装修类必填,最大为5,每个值最长为8个字符
MultiCateProps []*CreateSkuParamAttrs `json:"multiCateProps"` // 否 无 类目属性列表，类目属性中有必填项时，此字段必填；若未设置或设置错误，会有“通用属性必填”等错误提示！
}
type CreateSkuParamImages struct {
ColorID string `json:"colorId"` //是 无 颜色id，颜色id和您设置的销售属性值id对应，使用接口jingdong.category.read.findValuesByAttrIdUnlimit 获取 ，如果没销售属性，则默认为10个0（主图，并且主图必填）
ImgIndex int `json:"imgIndex"` //是 无 图片顺序。index值：1N，如果index存在，则直接覆盖相应index图片
ImgURL string `json:"imgUrl"` //是 无 京东图片服务器地址，不包括前缀。例如：jfs/t2116/102/1731643157/81969/c3df941a/5670f868Nc441d4c3.jpg
ImgZoneID string `json:"imgZoneId"` //否 无 图片空间中的图片Id
}
type CreateSkuParamSkus struct {
// SkuID int `json:"skuId"` //否 无 skuID（新建商品不需要填写）
// SaleAttrs []struct {
// AttrValueAlias []string `json:"attrValueAlias"` //否 无 值别名，发布商品时不可设置
// AttrID string `json:"attrId "` // 是 无 属性ID 通过接口 jingdong.category.read.findAttrsByCategoryIdUnlimitCate 传3级分类 type=4获取
// AttrValues []string `json:"attrValues "` //是 无 销售属性值 使用接口jingdong.category.read.findValuesByAttrIdUnlimit获取
// } `json:"saleAttrs"` //是 无 SKU销售属性
// Features []struct {
// JdPrice int `json:"jdPrice"` //是 无 京东价必填 单位：元
// OuterID string `json:"outerId"` //否 无 外部ID,系统不保证唯一性,如需唯一性自行保证
// StockNum string `json:"stockNum"` //是 无 总库存数
// BarCode string `json:"barCode"` //否 无 SKU的条形码
// } `json:"features"` //否 无 特殊属性
JdPrice int `json:"jdPrice"` //是 无 京东价必填 单位：元
OuterID string `json:"outerId"` //否 无 外部ID,系统不保证唯一性,如需唯一性自行保证
StockNum int `json:"stockNum"` //是 无 总库存数
// BarCode string `json:"barCode"` //否 无 SKU的条形码
// Props []struct{} `json:"props"` //否 无 SKU属性(已废弃 请使用multiCateProps，已经按照类目限制使用3级类目修改，请及时迁移到多级类目)
SaleAttrs []*CreateSkuParamAttrs `json:"saleAttrs"` //否 无 多级SKU属性，仅当属性可以下沉时才能设置，不验证必填！sku维度设置后，以sku上的属性为准！
// Capacity string `json:"capacity"` // 否 20L 20T 容量，在有特殊要求的类目下必填！最多支持6位小数。
Type string `json:"type"` //"com.jd.pop.ware.ic.api.domain.sku"
Type2 string `json:"@type"`
}
type CreateSkuParamAttrs struct {
// AttrValueAlias []string `json:"attrValueAlias"` //否 无 值别名，发布商品时不可设置
AttrID string `json:"attrId"` //是 无 下沉到sku的属性ID 通过接口 jingdong.category.read.findAttrsByCategoryIdUnlimitCate 获取 features字段中attrLevel=1
AttrValues []string `json:"attrValues"` //是 无 下沉到sku属性值 单选或者多选 通过接口jingdong.category.read.findValuesByAttrIdUnlimit获取 输入类型请手动输入
}
type CreateSkuResult struct {
WareID int `json:"wareId"`
skus []struct {
SkuID int `json:"skuId"`
saleAttrs []struct {
AttrValueAlias []string `json:"attrValueAlias"`
AttrID string `json:"attrId"`
AttrValues []string `json:"attrValues"`
}
}
}
type UpdateWareParam struct {
WareID int `json:"wareId"`
Title string `json:"title"` //否 标题 商品名称 限制45个字符内
Weight int `json:"weight"` //否 无 商品重量,单位kg
}
//查询商家所有的店内分类
//https://open.jd.com/home/home#/doc/api?apiCateId=88&apiId=2801&apiName=jingdong.vender.shopcategory.findShopCategoriesByVenderId
func (a *API) FindShopCategories() (findShopCategoriesResult []*FindShopCategoriesResult, err error) {
@@ -45,18 +163,6 @@ func (a *API) DeleteShopCategory(cid int64) (uniteResp *UniteResp, err error) {
return uniteResp, err
}
type FindVendorCategoriesResult struct {
ID int `json:"id"`
Fid int `json:"fid"`
AliasName string `json:"aliasName"`
Lev int `json:"lev"`
IndexID int `json:"indexId"`
Status int `json:"status"`
Created int64 `json:"created"`
Name string `json:"name"`
Modified int64 `json:"modified"`
}
//查询商家所有的类目
//https://open.jd.com/home/home#/doc/api?apiCateId=88&apiId=2727&apiName=jingdong.vender.category.getValidCategoryResultByVenderId
func (a *API) FindVendorCategories() (findVendorCategoriesResult []*FindVendorCategoriesResult, err error) {
@@ -67,8 +173,142 @@ func (a *API) FindVendorCategories() (findVendorCategoriesResult []*FindVendorCa
return findVendorCategoriesResult, err
}
//京东商城发布商品（创建商品？）
//京东商城发布商品（创建商品）
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=1379&apiName=jingdong.ware.write.add
func (a *API) CreateSku() (err error) {
func (a *API) CreateWare(createSkuParamWare *CreateSkuParamWare, createSkuParamSkus []*CreateSkuParamSkus) (createSkuResult *CreateSkuResult, err error) {
wares, _ := json.Marshal(createSkuParamWare)
skus, _ := json.Marshal(createSkuParamSkus)
result, err := a.AccessAPI2("jingdong.ware.write.add", prodURL, map[string]interface{}{
"ware": string(wares),
"skus": string(skus),
})
if err == nil {
utils.Map2StructByJson(result["jingdong_ware_write_add_responce"].(map[string]interface{})["ware"], &createSkuResult, false)
}
return createSkuResult, err
}
type UploadPictureResult struct {
ReturnCode int `json:"returnCode"` //返回码：1，操作成功；0，操作失败
Desc string `json:"desc"` //返回码为1时为操作成功，返回码为0时为操作失败原
PictureID string `json:"pictureId "` //上传成功的图片i
PictureURL string `json:"pictureUrl"` //上传成功的图片url
}
//京东商城上传图片
//https://open.jd.com/home/home#/doc/api?apiCateId=61&apiId=164&apiName=jingdong.imgzone.picture.upload
func (a *API) UploadPicture(imageData []byte, pictureCateID int, pictureName string) (uploadPictureResult *UploadPictureResult, err error) {
result, err := a.AccessAPI("jingdong.imgzone.picture.upload", prodURL, map[string]interface{}{
"image_data": base64.StdEncoding.EncodeToString(imageData),
"picture_name": pictureName,
})
if err == nil {
utils.Map2StructByJson(result["jingdong_imgzone_picture_upload_responce"], &uploadPictureResult, false)
}
return uploadPictureResult, err
}
//查询运费模板
//https://open.jd.com/home/home#/doc/api?apiCateId=137&apiId=906&apiName=jingdong.ept.feight.outapi.query
func (a *API) GetFeightMb() (err error) {
_, err = a.AccessAPI("jingdong.SkuFareTemplateService.getTemplates", prodURL, nil)
return err
}
//类目属性
//https://open.jd.com/home/home#/doc/api?apiCateId=62&apiId=1264&apiName=jingdong.category.read.findAttrsByCategoryId
func (a *API) GetAttrsByCategoryId(currPage, pageSize int) (err error) {
_, err = a.AccessAPI("jingdong.category.read.findAttrsByCategoryId", prodURL, map[string]interface{}{
"currPage": currPage,
"pageSize": pageSize,
})
return err
}
//修改商品基础信息
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=1380&apiName=jingdong.ware.write.updateWare
func (a *API) UpdateWare(updateWareParam *UpdateWareParam) (err error) {
result2, _ := json.Marshal(utils.Struct2FlatMap(updateWareParam))
result, err := a.AccessAPI("jingdong.ware.write.updateWare", prodURL, map[string]interface{}{
"ware": string(result2),
})
if err == nil {
if result["jingdong_ware_write_updateWare_responce"].(map[string]interface{})["success"] != "success" {
return err
}
}
return err
}
//删除商品
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=1250&apiName=jingdong.ware.write.delete
func (a *API) DeleteWare(wareId int) (err error) {
_, err = a.AccessAPI("jingdong.ware.write.delete", prodURL, map[string]interface{}{
"wareId": wareId,
})
return err
}
//获取类目属性ID
//https://open.jd.com/home/home#/doc/api?apiCateId=62&apiId=2809&apiName=jingdong.category.read.findAttrsByCategoryIdUnlimitCate
func (a *API) FindAttrs(cid int) (err error) {
_, err = a.AccessAPI("jingdong.category.read.findAttrsByCategoryIdUnlimitCate", prodURL, map[string]interface{}{
"cid": cid,
})
return err
}
//获取类目属性值
//https://open.jd.com/home/home#/doc/api?apiCateId=62&apiId=2821&apiName=jingdong.category.read.findValuesByAttrIdUnlimit
func (a *API) FindValuesByAttrId(categoryAttrId int) (err error) {
_, err = a.AccessAPI("jingdong.category.read.findValuesByAttrIdUnlimit", prodURL, map[string]interface{}{
"categoryAttrId": categoryAttrId,
})
return err
}
//新增类目属性值
//https://open.jd.com/home/home#/doc/api?apiCateId=62&apiId=1262&apiName=jingdong.category.write.saveVenderAttrValue
func (a *API) SaveVenderAttrValue(attValue string, attributeId, categoryId, indexId int) (err error) {
_, err = a.AccessAPI("jingdong.category.write.saveVenderAttrValue", prodURL, map[string]interface{}{
"attValue": attValue,
"attributeId": attributeId,
"categoryId": categoryId,
"indexId": indexId,
})
return err
}
//设置sku库存
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=1224&apiName=jingdong.stock.write.updateSkuStock
func (a *API) UpdateSkuStock(skuId, stockNum int) (err error) {
_, err = a.AccessAPI("jingdong.stock.write.updateSkuStock", prodURL, map[string]interface{}{
"skuId": skuId,
"stockNum": stockNum,
})
return err
}
//设置门店sku库存
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=2980&apiName=jingdong.stock.write.updateSkuSiteStock
//siteId 门店ID，venderSource 固定传4
func (a *API) UpdateSkuSiteStock(skuId, stockNum, siteId int) (err error) {
_, err = a.AccessAPI("jingdong.stock.write.updateSkuSiteStock", prodURL, map[string]interface{}{
"skuId": skuId,
"stockNum": stockNum,
"siteId": siteId,
"venderSource": 4,
})
return err
}
//修改sku京东价
//https://open.jd.com/home/home#/doc/api?apiCateId=48&apiId=1253&apiName=jingdong.price.write.updateSkuJdPrice
//单位为元
func (a *API) UpdateSkuJdPrice(skuId, jdPrice int) (err error) {
_, err = a.AccessAPI("jingdong.price.write.updateSkuJdPrice", prodURL, map[string]interface{}{
"skuId": skuId,
"jdPrice": jdPrice,
})
return err
}

215
platformapi/jdshopapi/sku_test.go
View File

@@ -1,9 +1,21 @@
package jdshopapi
import (
"bytes"
"crypto/md5"
"encoding/json"
"fmt"
"image"
"image/gif"
"image/jpeg"
"image/png"
"io/ioutil"
"net/http"
"testing"
"git.rosy.net.cn/baseapi/platformapi"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/model"
)
func TestFindShopCategories(t *testing.T) {
@@ -29,3 +41,206 @@ func TestFindVendorCategories(t *testing.T) {
}
t.Log(utils.Format4Output(result, false))
}
func TestUploadPicture(t *testing.T) {
data, _, err := DownloadFileByURL("https://image.jxc4.com/noGoodsImg.jpg")
// img, outMimeType, _ := Binary2Image(data, "")
// result2, _ := Image2Binary(img, outMimeType)
result, err := api.UploadPicture(data, 0, "noGoodsImg")
if err != nil {
t.Fatal(err)
}
t.Log(utils.Format4Output(result, false))
}
func DownloadFileByURL(fileURL string) (bodyData []byte, fileMD5 string, err error) {
response, err := http.Get(fileURL)
if err == nil {
defer response.Body.Close()
if response.StatusCode == http.StatusOK {
if bodyData, err = ioutil.ReadAll(response.Body); err == nil {
fileMD5 = fmt.Sprintf("%X", md5.Sum(bodyData))
}
} else {
err = platformapi.ErrHTTPCodeIsNot200
}
}
return bodyData, fileMD5, err
}
func Binary2Image(binaryData []byte, mimeType string) (img image.Image, outMimeType string, err error) {
if mimeType == "" {
mimeType = http.DetectContentType(binaryData)
}
switch mimeType {
case model.MimeTypeJpeg:
img, err = jpeg.Decode(bytes.NewReader(binaryData))
case model.MimeTypePng:
img, err = png.Decode(bytes.NewReader(binaryData))
case model.MimeTypeGif:
img, err = gif.Decode(bytes.NewReader(binaryData))
}
return img, mimeType, err
}
func Image2Binary(img image.Image, mimeType string) (binaryData []byte, err error) {
buf := new(bytes.Buffer)
switch mimeType {
case model.MimeTypeJpeg:
jpeg.Encode(buf, img, nil)
case model.MimeTypePng:
png.Encode(buf, img)
case model.MimeTypeGif:
gif.Encode(buf, img, nil)
}
binaryData = buf.Bytes()
return binaryData, err
}
func TestGetFeightMb(t *testing.T) {
err := api.GetFeightMb()
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}
func TestAA(t *testing.T) {
ware := &CreateSkuParamWare{
Title: "测试商品1",
CategoryID: 13577,
TransportID: TransportID,
MobileDesc: "测试",
Introduction: "测试",
WareStatus: 8,
OuterID: "1",
Weight: 2300,
Height: 100,
Length: 100,
Width: 100,
JdPrice: 20,
MarketPrice: 10,
VenderID: 0,
BrandID: JxBrandId,
}
result, _ := json.Marshal(ware)
fmt.Println(string(result))
}
func TestCreateSku(t *testing.T) {
var images []*CreateSkuParamImages
var skus []*CreateSkuParamSkus
var attrs []*CreateSkuParamAttrs
var attrs2 []*CreateSkuParamAttrs
var attrs3 []*CreateSkuParamAttrs
ware := &CreateSkuParamWare{
Title: "测试商品1",
ShopCategorys: []int{11},
CategoryID: 13577,
TransportID: TransportID,
MobileDesc: "测试",
Introduction: "测试",
WareStatus: 8,
OuterID: "1",
Weight: 2300,
Height: 100,
Length: 100,
Width: 100,
JdPrice: 20,
MarketPrice: 10,
VenderID: 0,
BrandID: JxBrandId,
Is7ToReturn: 0,
}
image := &CreateSkuParamImages{
ColorID: "0000000000",
ImgIndex: 1,
ImgURL: "jfs/t1/124185/34/1067/20460/5eb90d1aE2a81b6e4/ab451433f5e963b0.jpg",
}
images = append(images, image)
ware.Images = images
sku := &CreateSkuParamSkus{
JdPrice: 10,
StockNum: 1,
Type: "com.jd.pop.ware.ic.api.domain.sku",
Type2: "com.jd.pop.ware.ic.api.domain.Sku",
}
sku2 := &CreateSkuParamSkus{
JdPrice: 10,
StockNum: 1,
Type: "com.jd.pop.ware.ic.api.domain.sku",
Type2: "com.jd.pop.ware.ic.api.domain.Sku",
}
attr1 := &CreateSkuParamAttrs{
AttrID: "109692",
AttrValues: []string{"613613"},
}
// attr2 := &CreateSkuParamAttrs{
// AttrID: "109897",
// AttrValues: []string{"613771"},
// }
attr3 := &CreateSkuParamAttrs{
AttrID: "160508",
AttrValues: []string{"0.5"},
}
attr4 := &CreateSkuParamAttrs{
AttrID: "160781",
AttrValues: []string{"5"},
}
attr5 := &CreateSkuParamAttrs{
AttrID: "1001027606",
AttrValues: []string{"2440273517"},
}
attr6 := &CreateSkuParamAttrs{
AttrID: "1001027606",
AttrValues: []string{"2440272539"},
}
attrs = append(attrs, attr1)
// attrs = append(attrs, attr2)
attrs = append(attrs, attr3)
attrs = append(attrs, attr4)
attrs2 = append(attrs2, attr5)
attrs3 = append(attrs3, attr6)
ware.MultiCateProps = attrs
sku2.SaleAttrs = attrs3
sku.SaleAttrs = attrs2
skus = append(skus, sku)
skus = append(skus, sku2)
result, err := api.CreateWare(ware, skus)
if err != nil {
t.Fatal(err)
}
t.Log(utils.Format4Output(result, false))
}
func TestFindAttrs(t *testing.T) {
err := api.FindAttrs(13577)
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}
func TestFindValuesByAttrId(t *testing.T) {
err := api.FindValuesByAttrId(109692)
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}
func TestSaveVenderAttrValue(t *testing.T) {
err := api.SaveVenderAttrValue("0.5", 160806, 13571, 1)
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}
func TestDeleteWare(t *testing.T) {
err := api.DeleteWare(14509148757)
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}

26
platformapi/jdshopapi/store.go Normal file
View File

@@ -0,0 +1,26 @@
package jdshopapi
import (
"git.rosy.net.cn/baseapi/utils"
)
type CreateEntityStoreParam struct {
Name string `json:"name"` //是 门店名称
AddCode int `json:"addCode"` //是 门店三级标准地址编码(京东)
AddCodeName string `json:"addCodeName"` //否 门店三级标准地址名称(京东)
AddName string `json:"addName"` //是 标准地址加扩展地址以@！分隔 必填 例：北京大兴区亦庄经济开发区@!京东大厦
Coordinate string `json:"coordinate"` //是 门店坐标 纬度在前，经度在后 例：39.786683,116.563075
Phone string `json:"phone"` //是 门店电话
Item []int `json:"item"` //否 门店组ID
CustomerId string `json:"customerId"` //否 商家门店Id，商家维度不可重复
CategoryName string `json:"categoryName"` //否 门店扩展属性类目名称固定填为：popmendianSelfdelivery
ExtendJson string `json:"extendJson"` //是 扩展属性JSON如：{name1：'value1',name2:'value2'},营业时间必传固定json格式：{\'businessBeginTime\':\'09:00\',\'businessEndTime\':\'22:00\'}' ，可将中间的时间变更
ImageFile []byte `json:"imageFile"` //否 门店图片,图片二进制文件流，允许png、jpg、gif、jpeg、bmp图片格式，1M以内。
}
//创建门店
//https://open.jd.com/home/home#/doc/api?apiCateId=351&apiId=2224&apiName=jingdong.createEntityStore
func (a *API) CreateEntityStore(createEntityStoreParam *CreateEntityStoreParam) (err error) {
_, err = a.AccessAPI("jingdong.createEntityStore", prodURL, utils.Struct2FlatMap(createEntityStoreParam))
return err
}

11
platformapi/jdshopapi/store_test.go Normal file
View File

@@ -0,0 +1,11 @@
package jdshopapi
import "testing"
func TestCreateEntityStore(t *testing.T) {
err := api.CreateEntityStore(&CreateEntityStoreParam{})
if err != nil {
t.Fatal(err)
}
// t.Log(utils.Format4Output(result, false))
}

25
utils/typeconv.go
View File

@@ -392,6 +392,18 @@ func Map2URLValues(mapData map[string]interface{}) (retVal url.Values) {
return retVal
}
func Map2URLValues2(mapData map[string]interface{}) (retVal url.Values) {
retVal = make(url.Values)
for k, v := range mapData {
if data, ok := v.(string); ok {
retVal.Set(k, data)
} else {
retVal.Set(k, fmt.Sprint(v))
}
}
return retVal
}
func MapKV2List(mapData map[string]interface{}) []map[string]interface{} {
retVal := make([]map[string]interface{}, len(mapData))
index := 0
@@ -542,3 +554,16 @@ func Int2Float64(i int) (f float64) {
func Float32ToInt(f float32) (i int) {
return int(Str2Int64(Float64ToStr(math.Round(float64(f)))))
}
func Str2Int(s string) (i int) {
return int(Str2Int64(s))
}
func Float64TwoInt(f float64) (i int) {
return int(Float64TwoInt64(f))
}
func URLQueryEscape(s string) (str string) {
str, _ = url.QueryUnescape(s)
return str
}