diff --git a/business/jxstore/cms/sync2.go b/business/jxstore/cms/sync2.go index 3d50111cf..a2fc57cee 100644 --- a/business/jxstore/cms/sync2.go +++ b/business/jxstore/cms/sync2.go @@ -154,7 +154,7 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true) globals.SugarLogger.Debugf("skuList============= skuList:%v", len(skuList)) if err == nil && len(skuList) > 0 { - // todo 按vendorID orgCode合并操作 + // todo 按vendorID orgCode合并操作SyncSkus============= 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) { skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo) @@ -517,6 +517,7 @@ func amendAndPruneVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, task := tasksch.NewParallelTask(fmt.Sprintf("平台:%s,账号:%s上的商品与商家分类", model.VendorChineseNames[vendorID], vendorOrgCode), tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + globals.SugarLogger.Debugf("batchItemList==========%v", batchItemList) step := batchItemList[0].(int) switch step { case 0: @@ -694,13 +695,10 @@ func FullSyncVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, store step := batchItemList[0].(int) switch step { case 0: - // 有点儿像创建本地商品分类(需要第三方同步商店) _, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false) case 1: - // 同步类别 _, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false) case 2: - // 同步商品 _, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false) } return retVal, err