测试上传图片后创建

This commit is contained in:
苏尹岚
2020-05-14 11:38:01 +08:00
parent b5a8976fce
commit a2813ab3db

View File

@@ -1515,35 +1515,41 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
err = dao.GetRows(dao.GetDB(), &skuNames, sql, sqlParams)
for _, v := range skuNames {
for _, vv := range []string{v.Img, v.Img2, v.DescImg} {
datar := &model.DataResource{
MainURL: vv,
if vv == "" {
continue
}
err = dao.GetEntity(db, datar, "MainURL")
resBinary, hashCode, _ := jxutils.DownloadFileByURL(vv)
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 v.ID == 9619 {
datar := &model.DataResource{
MainURL: vv,
}
if vv == v.DescImg {
dataRes.UseType = model.ImgTypeDesc
err = dao.GetEntity(db, datar, "MainURL")
resBinary, hashCode, _ := jxutils.DownloadFileByURL(vv)
handler := partner.GetPurchasePlatformFromVendorID(model.VendorIDJDShop)
img, err := handler.UploadImg(ctx, "", "", resBinary, v.Name, 1)
if dao.IsNoRowsError(err) {
dataRes := &model.DataResource{
HashCode: hashCode,
ResourceType: http.DetectContentType(resBinary),
MainURL: vv,
JdsURL: img,
}
if vv == v.DescImg {
dataRes.Name = v.Name + "_desc"
dataRes.UseType = model.ImgTypeDesc
} else {
dataRes.UseType = model.ImgTypeMain
dataRes.Name = v.Name
}
dao.CreateEntity(db, dataRes)
} else {
dataRes.UseType = model.ImgTypeMain
}
dao.CreateEntity(db, dataRes)
} else {
if err == nil {
datar.JdsURL = img
dao.UpdateEntity(db, datar, "JdsURL")
if err == nil {
datar.JdsURL = img
dao.UpdateEntity(db, datar, "JdsURL")
}
}
}
}
break
}
return err
}