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

打桩

Browse Source
This commit is contained in:
邹宗楠
2022-03-18 11:16:57 +08:00
parent 0b4e7af7bd
commit 62eda9a72f
1 changed files with 76 additions and 70 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
business/jxstore/cms/sync2.go
View File

@@ -154,12 +154,12 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
db := dao.GetDB() db := dao.GetDB()
skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true) skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true)
globals.SugarLogger.Debugf("skuList============= skuList:%v", len(skuList)) globals.SugarLogger.Debugf("skuList============= skuList:%v", len(skuList))
if err == nil && len(skuList) > 0 {
// todo 按vendorID orgCode合并操作SyncSkus============= cc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
task := tasksch.NewParallelTask(fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs), tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
globals.SugarLogger.Debugf("batchItemList============DeleteSku2:%v", batchItemList) globals.SugarLogger.Debugf("batchItemList============DeleteSku2:%v", batchItemList)
skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo) skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo)
globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", skuVendorInfo)
globals.SugarLogger.Debugf("skuVendorInfo============skuVendorInfo:%v", &skuVendorInfo)
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
// if skuVendorInfo.VendorCatID == "" { // if skuVendorInfo.VendorCatID == "" {
// return nil, fmt.Errorf("商品:%d的商家分类没有同步", skuVendorInfo.SkuID) // return nil, fmt.Errorf("商品:%d的商家分类没有同步", skuVendorInfo.SkuID)
@@ -225,7 +225,13 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
retVal = []int{1} retVal = []int{1}
} }
return retVal, err return retVal, err
}, skuList) }
if err == nil && len(skuList) > 0 {
// todo 按vendorID orgCode合并操作SyncSkus=============
task := tasksch.NewParallelTask(
fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs),
tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, cc, skuList)
if isAsync { if isAsync {
buildSetFinishHook(task, ctx) buildSetFinishHook(task, ctx)
} }