diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index c5f173bbd..961960446 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -913,10 +913,10 @@ func (v *VendorSync) SyncStoreSkusFromYb(ctx *jxcontext.Context, storeIDs []int, func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorStoreID string, isAsync, isContinueWhenError bool) (hint string, err error) { var ( - db = dao.GetDB() - localSkuMap = make(map[string]*dao.StoreSkuSyncInfo) - vendorSkuMap = make(map[string]*partner.SkuNameInfo) - // skuBindInfosDel []*StoreSkuBindInfo + db = dao.GetDB() + localSkuMap = make(map[string]*dao.StoreSkuSyncInfo) + vendorSkuMap = make(map[string]*partner.SkuNameInfo) + skuBindInfosDel []*StoreSkuBindInfo // skuBindInfosUpt []*StoreSkuBindInfo addList []*partner.SkuNameInfo updateList []*partner.SkuNameInfo @@ -974,26 +974,26 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt _, err = taskParallel.GetResult(0) } case 1: - // if len(deleteList) > 0 { - // taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - // var ( - // v = batchItemList[0].(*dao.StoreSkuSyncInfo) - // ) - // skuBindInfo := &StoreSkuBindInfo{ - // NameID: v.NameID, - // IsFocus: -1, - // } - // retVal = []*StoreSkuBindInfo{skuBindInfo} - // return retVal, err - // } - // taskParallel := tasksch.NewParallelTask("删除商品", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, taskFunc, deleteList) - // tasksch.HandleTask(taskParallel, task, true).Run() - // resultDel, _ := taskParallel.GetResult(0) - // for _, v := range resultDel { - // skuBindInfosDel = append(skuBindInfosDel, v.(*StoreSkuBindInfo)) - // } - // _, err = updateStoresSkusWithoutSync(ctx, db, []int{storeID}, skuBindInfosDel, false) - // } + if len(deleteList) > 0 { + taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + var ( + v = batchItemList[0].(*dao.StoreSkuSyncInfo) + ) + skuBindInfo := &StoreSkuBindInfo{ + NameID: v.NameID, + IsFocus: -1, + } + retVal = []*StoreSkuBindInfo{skuBindInfo} + return retVal, err + } + taskParallel := tasksch.NewParallelTask("删除商品", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, taskFunc, deleteList) + tasksch.HandleTask(taskParallel, task, true).Run() + resultDel, _ := taskParallel.GetResult(0) + for _, v := range resultDel { + skuBindInfosDel = append(skuBindInfosDel, v.(*StoreSkuBindInfo)) + } + _, err = updateStoresSkusWithoutSync(ctx, db, []int{storeID}, skuBindInfosDel, false) + } // case 2: // if len(updateList) > 0 { // taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {