测试上传图片后创建

business/jxstore/tempop/tempop.go

@@ -9,8 +9,6 @@ import (
 	"strings"
 	"time"
 
-	"git.rosy.net.cn/jx-callback/business/jxutils/datares"
-
 	"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
 	"git.rosy.net.cn/jx-callback/business/partner/delivery"
 	"github.com/360EntSecGroup-Skylar/excelize"
@@ -1501,7 +1499,10 @@ func addSku(outSkuId string, cagtegoryId int, shopCategories []int64, brandId in
 }
 
 func UploadJdsImage(ctx *jxcontext.Context) (err error) {
-	var skuNames []*model.SkuName
+	var (
+		skuNames []*model.SkuName
+		db       = dao.GetDB()
+	)
 	sql := `
 	 	SELECT DISTINCT a.* 
 	 	FROM sku_name a, store_sku_bind b, sku c
@@ -1513,13 +1514,35 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue, utils.DefaultTimeValue, 102919}
 	err = dao.GetRows(dao.GetDB(), &skuNames, sql, sqlParams)
 	for _, v := range skuNames {
-		fmt.Println("test1", *v)
+		for _, vv := range []string{v.Img, v.Img2, v.DescImg} {
-		resBinary1, hashCode1, _ := jxutils.DownloadFileByURL(v.Img)
+			datar := &model.DataResource{
-		resBinary2, hashCode2, _ := jxutils.DownloadFileByURL(v.Img2)
+				MainURL: vv,
-		resBinary3, hashCode3, _ := jxutils.DownloadFileByURL(v.DescImg)
+			}
-		datares.RegisterDataResource(ctx, v.Name, v.Img, http.DetectContentType(resBinary1), hashCode1, resBinary1, model.ImgTypeMain, false)
+			err = dao.GetEntity(db, datar, "MainURL")
-		datares.RegisterDataResource(ctx, v.Name, v.Img2, http.DetectContentType(resBinary2), hashCode2, resBinary2, model.ImgTypeMain, false)
+			resBinary, hashCode, _ := jxutils.DownloadFileByURL(vv)
-		datares.RegisterDataResource(ctx, v.Name, v.DescImg, http.DetectContentType(resBinary3), hashCode3, resBinary3, model.ImgTypeMain, false)
+			handler := partner.GetPurchasePlatformFromVendorID(model.VendorIDJDShop)
+			img, err := handler.UploadImg(ctx, "", "", resBinary, v.Name, 1)
+			if dao.IsNoRowsError(err) {
+				dataRes := &model.DataResource{
+					Name:         v.Name,
+					HashCode:     hashCode,
+					ResourceType: http.DetectContentType(resBinary),
+					MainURL:      vv,
+					JdsURL:       img,
+				}
+				if vv == v.DescImg {
+					dataRes.UseType = model.ImgTypeDesc
+				} else {
+					dataRes.UseType = model.ImgTypeMain
+				}
+				dao.CreateEntity(db, dataRes)
+			} else {
+				if err == nil {
+					datar.JdsURL = img
+					dao.UpdateEntity(db, datar, "JdsURL")
+				}
+			}
+		}
 		break
 	}
 	return err