liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-05-21 18:13:08 +08:00
parent 654ae03bf1
commit eaddb49b26
1 changed files with 39 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
business/jxstore/cms/sku.go
View File

@@ -2952,56 +2952,53 @@ func RefreshNoImgSku(ctx *jxcontext.Context, skuNameID int) (err error) {
} }
dao.GetRows(db, &skuNames, sql, sqlParams) dao.GetRows(db, &skuNames, sql, sqlParams)
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx, //task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { // func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*model.SkuName) for _, v := range skuNames {
data, _, _ := jxutils.DownloadFileByURL(v.Img) data, _, _ := jxutils.DownloadFileByURL(v.Img)
if string(data) == "" { if string(data) == "" {
if v.Upc != nil { if v.Upc != nil {
productInfos, _ := api.JdAPI.GetJdUpcCodeByName("", *v.Upc, 1, 30) productInfos, _ := api.JdAPI.GetJdUpcCodeByName("", *v.Upc, 1, 30)
if len(productInfos) > 0 { if len(productInfos) > 0 {
productInfo := productInfos[0] productInfo := productInfos[0]
if len(productInfo.ImgList) >= 5 { if len(productInfo.ImgList) >= 5 {
v.Img = productInfo.ImgList[0] v.Img = productInfo.ImgList[0]
v.Img2 = productInfo.ImgList[1] v.Img2 = productInfo.ImgList[1]
v.Img3 = productInfo.ImgList[2] v.Img3 = productInfo.ImgList[2]
v.Img4 = productInfo.ImgList[3] v.Img4 = productInfo.ImgList[3]
v.Img5 = productInfo.ImgList[4] v.Img5 = productInfo.ImgList[4]
} else {
result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc)
if result != nil {
imgs := strings.Split(result.Pic, ",")
if len(imgs) >= 5 {
v.Img = imgs[0]
v.Img2 = imgs[1]
v.Img3 = imgs[2]
v.Img4 = imgs[3]
v.Img5 = imgs[4]
} else {
if len(imgs) > len(productInfo.ImgList) {
setImgs2(v, imgs)
} else {
setImgs2(v, productInfo.ImgList)
}
}
} else {
setImgs2(v, productInfo.ImgList)
}
}
} else { } else {
result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc) result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc)
if result != nil { if result != nil {
imgs := strings.Split(result.Pic, ",") imgs := strings.Split(result.Pic, ",")
setImgs2(v, imgs) if len(imgs) >= 5 {
v.Img = imgs[0]
v.Img2 = imgs[1]
v.Img3 = imgs[2]
v.Img4 = imgs[3]
v.Img5 = imgs[4]
} else {
if len(imgs) > len(productInfo.ImgList) {
setImgs2(v, imgs)
} else {
setImgs2(v, productInfo.ImgList)
}
}
} else {
setImgs2(v, productInfo.ImgList)
} }
} }
dao.UpdateEntity(db, v, "Img", "Img2", "Img3", "Img4", "Img5") } else {
result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc)
if result != nil {
imgs := strings.Split(result.Pic, ",")
setImgs2(v, imgs)
}
} }
dao.UpdateEntity(db, v, "Img", "Img2", "Img3", "Img4", "Img5")
} }
return retVal, err }
}, skuNames) }
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
return err return err
} }