银豹同步到京西over
This commit is contained in:
@@ -950,9 +950,9 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt
|
|||||||
deleteList = append(deleteList, v)
|
deleteList = append(deleteList, v)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Println("addList", len(addList))
|
// fmt.Println("addList", len(addList))
|
||||||
fmt.Println("updateList", len(updateList))
|
// fmt.Println("updateList", len(updateList))
|
||||||
fmt.Println("deleteList", len(deleteList))
|
// fmt.Println("deleteList", len(deleteList))
|
||||||
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
||||||
store, _ := dao.GetStoreDetail(db, storeID, vendorID)
|
store, _ := dao.GetStoreDetail(db, storeID, vendorID)
|
||||||
switch step {
|
switch step {
|
||||||
|
|||||||
@@ -403,21 +403,21 @@ func loopPages(parameterType, parameterValue string, skuNameList *[]*partner.Sku
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
for _, v := range resultPages.Result {
|
for _, v := range resultPages.Result {
|
||||||
// resultp, err := api.YinBaoAPI.QueryProductImagesByBarcode(v.Barcode)
|
resultp, err := api.YinBaoAPI.QueryProductImagesByBarcode(v.Barcode)
|
||||||
// resultp, err := getProductImages(vendorStoreID, v.Barcode)
|
// resultp, err := getProductImages(vendorStoreID, v.Barcode)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
var resultp []*yinbaoapi.QueryProductImagesByBarcodeResult
|
// var resultp []*yinbaoapi.QueryProductImagesByBarcodeResult
|
||||||
vv := &yinbaoapi.QueryProductByBarcodeResult{}
|
vv := &yinbaoapi.QueryProductByBarcodeResult{}
|
||||||
err = utils.Map2StructByJson(utils.Struct2MapByJson(v), vv, false)
|
err = utils.Map2StructByJson(utils.Struct2MapByJson(v), vv, false)
|
||||||
if skuName := vendorSku2Jx(vv, resultp); skuName != nil {
|
if skuName := vendorSku2Jx(vv, resultp); skuName != nil {
|
||||||
*skuNameList = append(*skuNameList, skuName)
|
*skuNameList = append(*skuNameList, skuName)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
// if len(resultPages.Result) >= resultPages.PageSize {
|
if len(resultPages.Result) >= resultPages.PageSize {
|
||||||
// err = loopPages(resultPages.PostBackParameter.ParameterType, resultPages.PostBackParameter.ParameterValue, skuNameList, vendorStoreID)
|
err = loopPages(resultPages.PostBackParameter.ParameterType, resultPages.PostBackParameter.ParameterValue, skuNameList, vendorStoreID)
|
||||||
// }
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user