饿鲜达获取商品库接口修改

This commit is contained in:
苏尹岚
2020-02-14 09:22:06 +08:00
parent 661c9aba89
commit 76e9091494
2 changed files with 21 additions and 16 deletions

View File

@@ -908,6 +908,7 @@ func (a *API) GetExianDaSkuDepot() (results []*ExianDaSkus, err error) {
pageNum = 1 pageNum = 1
pageSize = 200 pageSize = 200
) )
for {
params := map[string]interface{}{ params := map[string]interface{}{
"metas": map[string]interface{}{}, "metas": map[string]interface{}{},
"params": map[string]interface{}{ "params": map[string]interface{}{
@@ -917,19 +918,20 @@ func (a *API) GetExianDaSkuDepot() (results []*ExianDaSkus, err error) {
}, },
}, },
} }
for {
result, err := a.AccessStorePage("bwm_newretail.scm_ic/GoodsServiceI/findGoodsList", "https://ncp.ele.me", params, true) result, err := a.AccessStorePage("bwm_newretail.scm_ic/GoodsServiceI/findGoodsList", "https://ncp.ele.me", params, true)
if err != nil { if err != nil {
continue return results, err
} }
if len(result) < pageSize { if result["data"] != nil {
break
}
if len(result) > 0 {
var exianDaSkus []*ExianDaSkus var exianDaSkus []*ExianDaSkus
utils.Map2StructByJson(result["data"], &exianDaSkus, false) utils.Map2StructByJson(result["data"], &exianDaSkus, false)
if len(exianDaSkus) < pageSize {
break
}
if len(exianDaSkus) > 0 {
results = append(results, exianDaSkus...) results = append(results, exianDaSkus...)
} }
}
pageNum++ pageNum++
} }
return results, err return results, err

View File

@@ -153,7 +153,10 @@ func TestGetStoresShowWindowSkus(t *testing.T) {
} }
func TestGetExianDaSkuDepot(t *testing.T) { func TestGetExianDaSkuDepot(t *testing.T) {
result, _ := api.GetExianDaSkuDepot() result, err := api.GetExianDaSkuDepot()
if err != nil {
t.Fatal(err)
}
t.Log(utils.Format4Output(result, false)) t.Log(utils.Format4Output(result, false))
} }