liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

商品部分关注

Browse Source
This commit is contained in:
苏尹岚
2020-01-08 10:39:16 +08:00
parent d7ae6eb9a2
commit 82eb16ba66
1 changed files with 14 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
business/jxstore/cms/store_sku.go
View File

@@ -2836,7 +2836,6 @@ func FocusStoreSkusByExcelBin(ctx *jxcontext.Context, reader io.Reader, isAsync,
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
store := batchItemList[0].(*model.Store) store := batchItemList[0].(*model.Store)
var ( var (
skuBindInfos []*StoreSkuBindInfo
skuNameMap = make(map[int]int) skuNameMap = make(map[int]int)
skuInfoMap = make(map[int][]*StoreSkuBindSkuInfo) skuInfoMap = make(map[int][]*StoreSkuBindSkuInfo)
) )
@@ -2879,23 +2878,19 @@ func FocusStoreSkusByExcelBin(ctx *jxcontext.Context, reader io.Reader, isAsync,
IsSale: 1, IsSale: 1,
Skus: skuInfoMap[k], Skus: skuInfoMap[k],
} }
skuBindInfos = append(skuBindInfos, skuBindInfo) retVal = []*StoreSkuBindInfo{skuBindInfo}
} }
tUpdate := &tUpdateStoresSkus{
StoreID: store.ID,
SkuBindInfos: skuBindInfos,
}
retVal = []*tUpdateStoresSkus{tUpdate}
return retVal, err return retVal, err
} }
taskParallel := tasksch.NewParallelTask("根据skuID关注商品", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, storeList) taskParallel := tasksch.NewParallelTask("根据skuID关注商品", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, storeList)
tasksch.HandleTask(taskParallel, task, true).Run() tasksch.HandleTask(taskParallel, task, true).Run()
result1, _ = taskParallel.GetResult(0) result1, _ = taskParallel.GetResult(0)
case 2: case 2:
var skuBindInfos []*StoreSkuBindInfo
for _, v := range result1 { for _, v := range result1 {
tUpdate := v.(*tUpdateStoresSkus) skuBindInfos = append(skuBindInfos, v.(*StoreSkuBindInfo))
UpdateStoresSkusByBind(ctx, tUpdate.SkuBindInfos, true, true)
} }
UpdateStoresSkusByBind(ctx, skuBindInfos, true, true)
} }
return result, err return result, err
} }
@@ -2950,7 +2945,6 @@ func FocusStoreSkusBySku(ctx *jxcontext.Context, skuIDs []int, isAsync, isContin
case 1: case 1:
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
store := batchItemList[0].(*model.Store) store := batchItemList[0].(*model.Store)
var skuBindInfos []*StoreSkuBindInfo
for k, v := range skuNameMap { for k, v := range skuNameMap {
var price int var price int
focusList, _ := dao.GetStoreSkuBindByNameID(db, store.ID, k, model.StoreSkuBindStatusNormal) focusList, _ := dao.GetStoreSkuBindByNameID(db, store.ID, k, model.StoreSkuBindStatusNormal)
@@ -2976,23 +2970,19 @@ func FocusStoreSkusBySku(ctx *jxcontext.Context, skuIDs []int, isAsync, isContin
IsFocus: 1, IsFocus: 1,
Skus: v, Skus: v,
} }
skuBindInfos = append(skuBindInfos, skuBindInfo) retVal = []*StoreSkuBindInfo{skuBindInfo}
} }
tUpdate := &tUpdateStoresSkus{
StoreID: store.ID,
SkuBindInfos: skuBindInfos,
}
retVal = []*tUpdateStoresSkus{tUpdate}
return retVal, err return retVal, err
} }
taskParallel := tasksch.NewParallelTask("根据skuID部分关注商品", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, storeList) taskParallel := tasksch.NewParallelTask("根据skuID部分关注商品", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, storeList)
tasksch.HandleTask(taskParallel, task, true).Run() tasksch.HandleTask(taskParallel, task, true).Run()
result1, _ = taskParallel.GetResult(0) result1, _ = taskParallel.GetResult(0)
case 2: case 2:
var skuBindInfos []*StoreSkuBindInfo
for _, v := range result1 { for _, v := range result1 {
tUpdate := v.(*tUpdateStoresSkus) skuBindInfos = append(skuBindInfos, v.(*StoreSkuBindInfo))
UpdateStoresSkusByBind(ctx, tUpdate.SkuBindInfos, isAsync, isContinueWhenError)
} }
UpdateStoresSkusByBind(ctx, skuBindInfos, isAsync, isContinueWhenError)
} }
return result, err return result, err
} }
@@ -3009,12 +2999,12 @@ func FocusStoreSkusBySku(ctx *jxcontext.Context, skuIDs []int, isAsync, isContin
func AutoFocusStoreSkusWithoutFocusForTopSkus(ctx *jxcontext.Context) (err error) { func AutoFocusStoreSkusWithoutFocusForTopSkus(ctx *jxcontext.Context) (err error) {
db := dao.GetDB() db := dao.GetDB()
var skuBindInfoList []*StoreSkuBindInfo
storeList, err := dao.GetStoreList(db, nil, nil, "") storeList, err := dao.GetStoreList(db, nil, nil, "")
for _, v := range storeList { for _, v := range storeList {
var ( var (
skuName []*model.SkuName skuName []*model.SkuName
skuNameMap = make(map[int]int) skuNameMap = make(map[int]int)
skuBindInfoList []*StoreSkuBindInfo
) )
sql := ` sql := `
SELECT DISTINCT a.name_id id SELECT DISTINCT a.name_id id
@@ -3065,8 +3055,8 @@ func AutoFocusStoreSkusWithoutFocusForTopSkus(ctx *jxcontext.Context) (err error
} }
} }
} }
UpdateStoresSkusByBind(ctx, skuBindInfoList, true, true)
} }
UpdateStoresSkusByBind(ctx, skuBindInfoList, true, true)
return err return err
} }