liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

根据excel创建标品终极优化

Browse Source
This commit is contained in:
苏尹岚
2020-04-14 17:11:34 +08:00
parent 72486feb83
commit 999be05e68
1 changed files with 58 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

93
business/jxstore/cms/sku.go
View File

@@ -1792,6 +1792,7 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
db = dao.GetDB() db = dao.GetDB()
skuParams []*model.SkuName skuParams []*model.SkuName
createUpcSkuByExcelErrList []*CreateUpcSkuByExcelErr createUpcSkuByExcelErrList []*CreateUpcSkuByExcelErr
createUpcSkuByExcelErrListInterface []interface{}
excelTitle = []string{ excelTitle = []string{
"商品条码", "商品条码",
"商品名称", "商品名称",
@@ -1849,7 +1850,8 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
skuParams = append(skuParams, skuParam) skuParams = append(skuParams, skuParam)
} }
case 1: case 1:
for _, v := range skuParams { taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*model.SkuName)
skuName := &model.SkuNameExt{ skuName := &model.SkuNameExt{
SkuName: model.SkuName{}, SkuName: model.SkuName{},
Skus: []*model.SkuWithVendor{ Skus: []*model.SkuWithVendor{
@@ -1861,29 +1863,29 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
if v.Upc != nil { if v.Upc != nil {
upc := upcRegexp.FindString(*v.Upc) upc := upcRegexp.FindString(*v.Upc)
if upc == "" { if upc == "" {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "请输入正确的商品条码！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "请输入正确的商品条码！")}
continue return retVal, err
} }
skuName.Upc = v.Upc skuName.Upc = v.Upc
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "商品的条码不能为空！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "商品的条码不能为空！")}
continue return retVal, err
} }
skuNames, _ := dao.GetSkuNames(db, nil, []string{*v.Upc}, "") skuNames, _ := dao.GetSkuNames(db, nil, []string{*v.Upc}, "")
if len(skuNames) > 0 { if len(skuNames) > 0 {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "商品在京西库中已存在！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "商品在京西库中已存在！")}
continue return retVal, err
} }
productInfos, err := GetJdUpcCodeByCode(ctx, *v.Upc) productInfos, err := GetJdUpcCodeByCode(ctx, *v.Upc)
if err != nil { if err != nil {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
if len(productInfos) == 0 { if len(productInfos) == 0 {
result, _ := api.AliUpcAPI.GetAliUpcInfo(*v.Upc) result, _ := api.AliUpcAPI.GetAliUpcInfo(*v.Upc)
if result == nil { if result == nil {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未在标品库查到此商品，请手动创建！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未在标品库查到此商品，请手动创建！")}
continue return retVal, err
} }
if result.Img != "" { if result.Img != "" {
if resBinary, _, err := jxutils.DownloadFileByURL(result.Img); err == nil { if resBinary, _, err := jxutils.DownloadFileByURL(result.Img); err == nil {
@@ -1893,16 +1895,16 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
if err == nil { if err == nil {
skuName.Img = downloadURL2 skuName.Img = downloadURL2
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
} else { } else {
skuName.Img = model.NOSkuNameImg skuName.Img = model.NOSkuNameImg
@@ -1914,8 +1916,8 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
} }
if v.Price == 0 { if v.Price == 0 {
if result.Price == "" { if result.Price == "" {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未查询到商品售价，请补充商品的售价！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未查询到商品售价，请补充商品的售价！")}
continue return retVal, err
} else { } else {
skuName.Price = int(utils.Str2Int64(result.Price) * 100) skuName.Price = int(utils.Str2Int64(result.Price) * 100)
} }
@@ -1924,13 +1926,13 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
} }
if v.Unit != "" { if v.Unit != "" {
if v.Unit == model.UnitNames[0] { if v.Unit == model.UnitNames[0] {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "标品的单位不能为份！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "标品的单位不能为份！")}
continue return retVal, err
} }
skuName.Unit = v.Unit skuName.Unit = v.Unit
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未查询到商品单位，请补充商品单位！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未查询到商品单位，请补充商品单位！")}
continue return retVal, err
} }
if v.SpecQuality != 0 { if v.SpecQuality != 0 {
skuName.Skus[0].SpecQuality = v.SpecQuality skuName.Skus[0].SpecQuality = v.SpecQuality
@@ -1941,8 +1943,8 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
skuName.Skus[0].SpecQuality = specQuality skuName.Skus[0].SpecQuality = specQuality
skuName.Skus[0].Weight = int(utils.Str2Int64(utils.Float64ToStr(float64(specQuality)))) skuName.Skus[0].Weight = int(utils.Str2Int64(utils.Float64ToStr(float64(specQuality))))
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未查询到商品重量，请补充商品重量！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未查询到商品重量，请补充商品重量！")}
continue return retVal, err
} }
} }
skuName.Skus[0].SpecUnit = model.SpecialSpecUnit skuName.Skus[0].SpecUnit = model.SpecialSpecUnit
@@ -1952,30 +1954,30 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
if v.Name != "" { if v.Name != "" {
productInfo.Name = v.Name productInfo.Name = v.Name
} else { } else {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "需要填上一个合适的商品名！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "需要填上一个合适的商品名！")}
continue return retVal, err
} }
} }
skuNames2, _ := dao.GetSkuNames(db, nil, nil, productInfo.Name) skuNames2, _ := dao.GetSkuNames(db, nil, nil, productInfo.Name)
if len(skuNames2) > 1 { if len(skuNames2) > 1 {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "此商品名在京西库中查询出了大于1个商品！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "此商品名在京西库中查询出了大于1个商品！")}
continue return retVal, err
} }
//表示查到了，需要把upc更新上去，没查到就要新建 //表示查到了，需要把upc更新上去，没查到就要新建
if len(skuNames2) == 1 && (productInfo.SpecQuality == skuNames2[0].SpecQuality && productInfo.SpecUnit == skuNames2[0].SpecUnit) { if len(skuNames2) == 1 && (productInfo.SpecQuality == skuNames2[0].SpecQuality && productInfo.SpecUnit == skuNames2[0].SpecUnit) {
skuNames2[0].Upc = v.Upc skuNames2[0].Upc = v.Upc
dao.UpdateEntity(db, skuNames2[0], "Upc") dao.UpdateEntity(db, skuNames2[0], "Upc")
continue return retVal, err
} else { } else {
if v.Price == 0 { if v.Price == 0 {
result, err := api.AliUpcAPI.GetAliUpcInfo(*v.Upc) result, err := api.AliUpcAPI.GetAliUpcInfo(*v.Upc)
if err != nil { if err != nil {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
if result.Price == "" { if result.Price == "" {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未查询到商品售价，请补充商品售价！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未查询到商品售价，请补充商品售价！")}
continue return retVal, err
} else { } else {
skuName.Price = int(utils.Str2Int64(result.Price) * 100) skuName.Price = int(utils.Str2Int64(result.Price) * 100)
} }
@@ -1995,17 +1997,18 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
} }
} }
if skuName.Img == "" { if skuName.Img == "" {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, "未查询到商品图片，请联系开发！")) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "未查询到商品图片，请联系开发！")}
continue return retVal, err
} }
suffix := skuName.Img[strings.LastIndex(skuName.Img, "."):] suffix := skuName.Img[strings.LastIndex(skuName.Img, "."):]
if suffix != ".jpg" && suffix != ".png" && suffix != ".jpeg" && suffix != ".gif" { if suffix != ".jpg" && suffix != ".png" && suffix != ".jpeg" && suffix != ".gif" {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, fmt.Sprintf("暂不支持的图片格式：[%v]", skuName.Img))) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, fmt.Sprintf("暂不支持的图片格式：[%v]", skuName.Img))}
continue return retVal, err
} }
//需要把图片传到七牛云上 //需要把图片传到七牛云上
if !strings.Contains(skuName.Img, "image.jxc4.com") { if !strings.Contains(skuName.Img, "image.jxc4.com") {
if resBinary, _, err := jxutils.DownloadFileByURL(skuName.Img); err == nil { if resBinary, _, err := jxutils.DownloadFileByURL(skuName.Img); err == nil {
time.Sleep(time.Second / 4)
if downloadURL, err := jxutils.UploadExportContent(resBinary, skuName.Img[strings.LastIndex(skuName.Img, "/")+1:len(skuName.Img)]); err == nil { if downloadURL, err := jxutils.UploadExportContent(resBinary, skuName.Img[strings.LastIndex(skuName.Img, "/")+1:len(skuName.Img)]); err == nil {
if img, _, err := datares.Binary2Image(resBinary, http.DetectContentType(resBinary)); err == nil { if img, _, err := datares.Binary2Image(resBinary, http.DetectContentType(resBinary)); err == nil {
if img.Bounds().Dx() != datares.MainImgWidth || img.Bounds().Dy() != datares.MainImgHeight { if img.Bounds().Dx() != datares.MainImgWidth || img.Bounds().Dy() != datares.MainImgHeight {
@@ -2025,18 +2028,26 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint stri
skuName.IsGlobal = model.YES skuName.IsGlobal = model.YES
skuName.CategoryID = model.NoCatCatgoryID skuName.CategoryID = model.NoCatCatgoryID
skuName.Skus[0].Status = model.SkuStatusNormal skuName.Skus[0].Status = model.SkuStatusNormal
time.Sleep(time.Second / 2) //addskuname里下载图片有点问题，所以设置一个时间。。
_, err = AddSkuName(ctx, skuName, ctx.GetUserName()) _, err = AddSkuName(ctx, skuName, ctx.GetUserName())
if err != nil { if err != nil {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, buildCreateUpcSkuByExcelErr(v, err.Error())) retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, err.Error())}
continue return retVal, err
} }
return retVal, err
} }
taskParallel := tasksch.NewParallelTask("创建标品中", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, taskFunc, skuParams)
tasksch.HandleTask(taskParallel, task, true).Run()
createUpcSkuByExcelErrListInterface, err = taskParallel.GetResult(0)
case 2: case 2:
if len(createUpcSkuByExcelErrListInterface) > 0 {
for _, v := range createUpcSkuByExcelErrListInterface {
createUpcSkuByExcelErrList = append(createUpcSkuByExcelErrList, v.(*CreateUpcSkuByExcelErr))
}
if len(createUpcSkuByExcelErrList) > 0 { if len(createUpcSkuByExcelErrList) > 0 {
err = writeToExcel(excelTitle, createUpcSkuByExcelErrList, task) err = writeToExcel(excelTitle, createUpcSkuByExcelErrList, task)
} }
} }
}
return result2, err return result2, err
} }
taskSeq := tasksch.NewSeqTask2("根据excel创建标品-序列任务", ctx, true, taskSeqFunc, 3) taskSeq := tasksch.NewSeqTask2("根据excel创建标品-序列任务", ctx, true, taskSeqFunc, 3)