创建标品测试

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