diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index ccddd92a0..a816103eb 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -86,7 +86,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo storeCatMap := &model.StoreSkuCategoryMap{} storeCatMap.ID = catInfo.MapID var failedList []*partner.StoreSkuInfoWithErr - fmt.Println("4444444444444444444444444444444444444444444444") if catInfo.IsExdSpec == model.YES { if vendorID != model.VendorIDEBAI { return nil, err @@ -98,7 +97,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo catInfo.Seq = catInfo.StoreCatSeq } } - fmt.Println("3333333333333333333333333333333333333333333333") if model.IsSyncStatusDelete(catInfo.CatSyncStatus) { // 删除 if model.IsSyncStatusDelete(catInfo.CatSyncStatus) && !dao.IsVendorThingIDEmpty(catInfo.VendorCatID) { err = handler.DeleteStoreCategory(ctx, storeID, vendorStoreID, catInfo.VendorCatID, level) @@ -139,14 +137,12 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo } task.AddFailedList(failedList) } - fmt.Println("2222222222222222222222222222222222222222222222") if err == nil { if vendorID == model.VendorIDMTWM { refutil.SetObjFieldByName(storeCatMap, idFieldName, catInfo.VendorCatID) } else { refutil.SetObjFieldByName(storeCatMap, idFieldName, utils.Str2Int64WithDefault(catInfo.VendorCatID, 0)) } - fmt.Println("11111111111111111111111111111111111111111111111111111111111") _, err = dao.UpdateEntity(db, storeCatMap, updateFields...) } return nil, err @@ -418,6 +414,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag globals.SugarLogger.Debugf("syncStoreSkuNew causeFlag:%d", causeFlag) db := dao.GetDB() storeDetail, err := dao.GetStoreDetail(db, storeID, vendorID) + fmt.Println("1111111111111111111111111111111111111111111111111111111111111111111111111111111") if err != nil { return err } @@ -428,9 +425,13 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag } else { skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) } + fmt.Println("22222222222222222222222222222222222222222222222222222222222222222222222222") + if err != nil || len(skus) == 0 { return err } + fmt.Println("3333333333333333333333333333333333333333333333333333333333333333333333333") + if len(excludeSkuIDs) > 0 { excludeSkuMap := jxutils.IntList2Map(excludeSkuIDs) var skus2 []*dao.StoreSkuSyncInfo