diff --git a/business/jxstore/cms/sync2.go b/business/jxstore/cms/sync2.go index 333e33058..3d50111cf 100644 --- a/business/jxstore/cms/sync2.go +++ b/business/jxstore/cms/sync2.go @@ -104,6 +104,7 @@ func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs globals.SugarLogger.Debugf("SyncCategories vendorIDs:%v, appOrgCodes:%v, catIDs:%v", vendorIDs, appOrgCodes, catIDs) db := dao.GetDB() catList, err := dao.GetSkuCategoryWithVendor(db, vendorIDs, appOrgCodes, -1, catIDs, true) + globals.SugarLogger.Debugf("SyncCategories catListLenght:%v", len(catList)) if err == nil && len(catList) > 0 { //TODO 同一平台不同账号会有影响needSyncParentIDs,暂不处理 var needSyncParentIDs []int @@ -112,6 +113,8 @@ func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs needSyncParentIDs = append(needSyncParentIDs, cat.ParentID) } } + globals.SugarLogger.Debugf("needSyncParentIDs needSyncParentIDsLen:%v", needSyncParentIDs) + if len(needSyncParentIDs) > 0 { task := tasksch.NewSeqTask(fmt.Sprintf("同步分类1:%v", catIDs), ctx, func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { @@ -146,9 +149,10 @@ func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs } func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, appOrgCodes []string, nameIDs, skuIDs []int, isAsync bool) (hint string, err error) { - globals.SugarLogger.Debugf("SyncSkus vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs) + globals.SugarLogger.Debugf("SyncSkus============= vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs) db := dao.GetDB() 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合并操作 task := tasksch.NewParallelTask(fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs), tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, @@ -187,6 +191,7 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, } } } else if model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) { // 新增 + globals.SugarLogger.Debugf("CreateSku2============= CreateSku2:%v", model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus)) err = multiStoresHandler.CreateSku2(ctx, skuVendorInfo) if err != nil { failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, model.VendorChineseNames[skuVendorInfo.VendorID], "新增商品")