根据excel中skuid关注商品

business/jxstore/cms/store_sku.go

@@ -2766,9 +2766,12 @@ func FocusStoreSkusByExcelBin(ctx *jxcontext.Context, reader io.Reader, isAsync,
 		SkuRow:      1,
 	}
 	// xlsx, err := excelize.OpenFile("111.xlsx")
+	taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
+		switch step {
+		case 0:
 			xlsx, err := excelize.OpenReader(reader)
 			if err != nil {
-		return "", err
+				return result, err
 			}
 			rows, _ := xlsx.GetRows(xlsx.GetSheetName(1))
 			for rowNum, row := range rows {
@@ -2777,12 +2780,13 @@ func FocusStoreSkusByExcelBin(ctx *jxcontext.Context, reader io.Reader, isAsync,
 				}
 				GetCellForFocusStoreSkus(db, rowNum, row, sheetParam, skuMap)
 			}
+		case 1:
 			for k, _ := range skuMap {
 				skuIDs = append(skuIDs, k)
 			}
 			skuList, err := dao.GetSkus(db, skuIDs, nil, nil, nil)
 			if err != nil && len(skuList) == 0 {
-		return
+				return result, err
 			}
 			for _, v := range skuList {
 				var (
@@ -2816,7 +2820,19 @@ func FocusStoreSkusByExcelBin(ctx *jxcontext.Context, reader io.Reader, isAsync,
 			for _, v := range storeList {
 				storeIDs = append(storeIDs, v.ID)
 			}
-	hint, err = UpdateStoresSkus(ctx, storeIDs, skuBindInfos, false, isAsync, isContinueWhenError)
+		case 2:
+			UpdateStoresSkus(ctx, storeIDs, skuBindInfos, false, isAsync, isContinueWhenError)
+		}
+		return result, err
+	}
+	taskSeq := tasksch.NewSeqTask2("根据Excel中skuID批量关注商品", ctx, isContinueWhenError, taskSeqFunc, 3)
+	tasksch.HandleTask(taskSeq, nil, true).Run()
+	if !isAsync {
+		_, err = taskSeq.GetResult(0)
+		hint = "1"
+	} else {
+		hint = taskSeq.GetID()
+	}
 	return hint, err
 }