aa

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
 }