根据skuID关注部分商品

business/jxstore/cms/store_sku.go

@@ -2835,3 +2835,45 @@ func GetCellForFocusStoreSkus(db *dao.DaoDB, rowNum int, row []string, sheetPara
 	}
 	skuMap[skuID] = price
 }
+
+func FocusStoreSkusBySku(ctx *jxcontext.Context, skuIDs []int, isAsync, isContinueWhenError bool) (hint string, err error) {
+	var (
+		skuBindInfos []*StoreSkuBindInfo
+		skuNameMap   = make(map[int][]*StoreSkuBindSkuInfo)
+		storeIDs     []int
+	)
+	db := dao.GetDB()
+	skuList, err := dao.GetSkus(db, skuIDs, nil, nil, nil)
+	storeList, err := dao.GetStoreList(db, nil, nil, "")
+	for _, v := range storeList {
+		storeIDs = append(storeIDs, v.ID)
+	}
+	for _, v := range skuList {
+		skuNameMap[v.NameID] = append(skuNameMap[v.NameID], &StoreSkuBindSkuInfo{
+			SkuID:  v.ID,
+			IsSale: 1,
+		})
+	}
+	task := tasksch.NewParallelTask("根据skuID部分关注商品", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			store := batchItemList[0].(*model.Store)
+			for k, v := range skuNameMap {
+				midPrice, _ := dao.GetMidPriceByNameID(db, store.CityCode, k, utils.Time2Date(time.Now().AddDate(0, 0, -1)))
+				skuBindInfo := &StoreSkuBindInfo{
+					NameID:    k,
+					UnitPrice: midPrice,
+					IsFocus:   1,
+					Skus:      v,
+				}
+				retVal = []*StoreSkuBindInfo{skuBindInfo}
+			}
+			return retVal, err
+		}, storeList)
+	tasksch.HandleTask(task, nil, true).Run()
+	result, err := task.GetResult(0)
+	for _, v := range result {
+		skuBindInfos = append(skuBindInfos, v.(*StoreSkuBindInfo))
+	}
+	hint, err = UpdateStoresSkus(ctx, storeIDs, skuBindInfos, false, isAsync, isContinueWhenError)
+	return hint, err
+}