diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index ce864e3a9..94015dbc1 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -1853,15 +1853,18 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader, categoryID } case 1: taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - v := batchItemList[0].(*model.SkuName) - skuName := &model.SkuNameExt{ - SkuName: model.SkuName{}, - Skus: []*model.SkuWithVendor{ - &model.SkuWithVendor{ - Sku: &model.Sku{}, + var ( + v = batchItemList[0].(*model.SkuName) + skuNames []model.SkuName + skuName = &model.SkuNameExt{ + SkuName: model.SkuName{}, + Skus: []*model.SkuWithVendor{ + &model.SkuWithVendor{ + Sku: &model.Sku{}, + }, }, - }, - } + } + ) if v.Upc != nil { upc := upcRegexp.FindString(*v.Upc) if upc == "" { @@ -1873,10 +1876,11 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader, categoryID retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "商品的条码不能为空!")} return retVal, err } - skuNames, err := dao.GetSkuNames(db, nil, []string{*v.Upc}, "", false) - fmt.Println(utils.Format4Output(v, false)) - fmt.Println(err) - fmt.Println("test1111111111111111111111111111", utils.Format4Output(skuNames, false)) + sql := ` + SELECT * FROM sku_name WHERE upc = ? AND deleted_at = ? + ` + sqlParams := []interface{}{*v.Upc, utils.DefaultTimeValue} + err = dao.GetRows(db, &skuNames, sql, sqlParams) if len(skuNames) > 0 { retVal = []*CreateUpcSkuByExcelErr{buildCreateUpcSkuByExcelErr(v, "商品在京西库中已存在!")} return retVal, err