From fbe40b226c75ca731575a7540bd0bb9444e48409 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 15 Mar 2021 17:07:29 +0800
Subject: [PATCH] aa

---
 business/jxstore/tempop/tempop.go | 38 ++++++++++++++++++-------------
 1 file changed, 22 insertions(+), 16 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 6d372f0d8..9b45ea4fe 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1889,8 +1889,9 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// tasksch.HandleTask(task, nil, true).Run()
 	// _, err = task.GetResult(0)
 	var (
-		db       = dao.GetDB()
-		skuNames []*model.SkuName
+		db        = dao.GetDB()
+		skuNames  []*model.SkuName
+		failedSku []string
 	)
 	sql := `
 		SELECT * FROM sku_name WHERE deleted_at = ? AND img = ? 
@@ -1902,24 +1903,29 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	for _, v := range skuNames {
 		if v.Upc != nil {
 			result, _ := api.MtwmAPI.GetStandardProductListWithCond(*v.Upc)
-			if v.Img == model.NOSkuNameImg {
-				imgs := strings.Split(result.Pic, ",")
-				if len(imgs) == 1 {
-					v.Img = imgs[0]
+			if result != nil {
+				if v.Img == model.NOSkuNameImg {
+					imgs := strings.Split(result.Pic, ",")
+					if len(imgs) == 1 {
+						v.Img = imgs[0]
+					}
+					if len(imgs) == 2 {
+						v.Img = imgs[0]
+						v.Img2 = imgs[1]
+					}
+					if len(imgs) >= 3 {
+						v.Img = imgs[0]
+						v.Img2 = imgs[1]
+						v.Img3 = imgs[3]
+					}
+					dao.UpdateEntity(db, v, "Img", "Img2", "Img3")
 				}
-				if len(imgs) == 2 {
-					v.Img = imgs[0]
-					v.Img2 = imgs[1]
-				}
-				if len(imgs) >= 3 {
-					v.Img = imgs[0]
-					v.Img2 = imgs[1]
-					v.Img3 = imgs[3]
-				}
-				dao.UpdateEntity(db, v, "Img", "Img2", "Img3")
+			} else {
+				failedSku = append(failedSku, v.Upc)
 			}
 		}
 	}
+	fmt.Println("failedSku11111111111111111111111111111111", failedSku)
 	return err
 }