From eaddb49b2675d1fa47743a0dfd1efc825b01c628 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Fri, 21 May 2021 18:13:08 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/sku.go | 81 ++++++++++++++++++-------------------
 1 file changed, 39 insertions(+), 42 deletions(-)

diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go
index 7e051a2f2..a0f95d5c9 100644
--- a/business/jxstore/cms/sku.go
+++ b/business/jxstore/cms/sku.go
@@ -2952,56 +2952,53 @@ func RefreshNoImgSku(ctx *jxcontext.Context, skuNameID int) (err error) {
 	}
 
 	dao.GetRows(db, &skuNames, sql, sqlParams)
-	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx,
-		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			v := batchItemList[0].(*model.SkuName)
-			data, _, _ := jxutils.DownloadFileByURL(v.Img)
-			if string(data) == "" {
-				if v.Upc != nil {
-					productInfos, _ := api.JdAPI.GetJdUpcCodeByName("", *v.Upc, 1, 30)
-					if len(productInfos) > 0 {
-						productInfo := productInfos[0]
-						if len(productInfo.ImgList) >= 5 {
-							v.Img = productInfo.ImgList[0]
-							v.Img2 = productInfo.ImgList[1]
-							v.Img3 = productInfo.ImgList[2]
-							v.Img4 = productInfo.ImgList[3]
-							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)
-							}
-						}
+	//task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx,
+	//	func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+	for _, v := range skuNames {
+		data, _, _ := jxutils.DownloadFileByURL(v.Img)
+		if string(data) == "" {
+			if v.Upc != nil {
+				productInfos, _ := api.JdAPI.GetJdUpcCodeByName("", *v.Upc, 1, 30)
+				if len(productInfos) > 0 {
+					productInfo := productInfos[0]
+					if len(productInfo.ImgList) >= 5 {
+						v.Img = productInfo.ImgList[0]
+						v.Img2 = productInfo.ImgList[1]
+						v.Img3 = productInfo.ImgList[2]
+						v.Img4 = productInfo.ImgList[3]
+						v.Img5 = productInfo.ImgList[4]
 					} else {
 						result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc)
 						if result != nil {
 							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
 }