aa

business/jxstore/cms/sku.go

@@ -3241,7 +3241,9 @@ func GetSkuNamesNew(ctx *jxcontext.Context, keyword string, skuIDs, skuNameIDs [
 	if err = dao.GetRowsTx(txDB, &skuNamesInfo.SkuNames, sql, sqlParams...); err == nil {
 		skuNamesInfo.TotalCount = dao.GetLastTotalRowCount2(db, txDB)
 		dao.Commit(db, txDB)
-		for _, skuName := range skuNamesInfo.SkuNames {
+		task := tasksch.NewParallelTask("GetSkuNamesNew", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				skuName := batchItemList[0].(*model.SkuNameExt)
 				skuName.FullName = jxutils.ComposeSkuName(skuName.Prefix, skuName.Name, "", "", 0, "", 0, skuName.ExPrefix, skuName.ExPrefixBegin, skuName.ExPrefixEnd)
 				var (
 					skus      []*model.Sku
@@ -3283,9 +3285,10 @@ func GetSkuNamesNew(ctx *jxcontext.Context, keyword string, skuIDs, skuNameIDs [
 					}
 					skuName.Places = placeCodes
 				}
-		}
-	} else {
-		dao.Rollback(db, txDB)
+				return retVal, err
+			}, skuNamesInfo.SkuNames)
+		tasksch.HandleTask(task, nil, true).Run()
+		task.GetResult(0)
 	}
 	return skuNamesInfo, err
 }