diff --git a/business/jxstore/cms/system_store_sku.go b/business/jxstore/cms/system_store_sku.go index fab447d6c..dbacd121c 100644 --- a/business/jxstore/cms/system_store_sku.go +++ b/business/jxstore/cms/system_store_sku.go @@ -45,7 +45,22 @@ func CopyOnStoreSkuToOther(ctx *jxcontext.Context, fromStoreId, toStoreId string // CopyEBaiToEBai 饿了么商品复制到饿了么 func CopyEBaiToEBai(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isAsync bool) (hint string, err error) { - VendorCategoryIDMap := make(map[int64]int64, 0) + VendorCategoryIDMap := map[int64]int64{ + 170606586622696: 170625362622152, + 170606586622697: 170625362622153, + 170606586722698: 170625362622154, + 170606586822844: 170625362622155, + 170606586922845: 170625362722162, + 170606587022847: 170625362722163, + 170606587122869: 170625362722164, + 170606587222899: 170625362722165, + 170606587322900: 170625362822166, + 170606587422901: 170625362822167, + 170606587522928: 170625362822168, + 170606587622931: 170625362822169, + 170606587722932: 170625362922170, + 170606587822933: 170625362922171, + } api := api.EbaiAPI taskName := fmt.Sprintf("将饿了么平台门店[%s],分类和商品复制到[%s]", fromStore.VendorStoreID, toStore.VendorStoreID) config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false) @@ -61,42 +76,43 @@ func CopyEBaiToEBai(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, //} case 2: // 同步分类 - fromCategoryList, err := api.ShopCategoryGet(utils.Int2Str(fromStore.ID)) - if err != nil { - return nil, err - } - for _, v := range fromCategoryList { - parentID, categoryErr := api.ShopCategoryCreate(utils.Int2Str(toStore.ID), 0, v.Name, v.Rank) - if categoryErr != nil { - globals.SugarLogger.Debugf("err := RetailCatUpdate : %v", categoryErr) - continue - } - VendorCategoryIDMap[v.CategoryID] = parentID - if v.Children != nil && len(v.Children) != 0 { - for _, c := range v.Children { - childrenCateId, err := api.ShopCategoryCreate(utils.Int2Str(toStore.ID), parentID, c.Name, c.Rank) - if err != nil { - globals.SugarLogger.Debugf("err := RetailCatUpdate Children : %v", err) - continue - } - VendorCategoryIDMap[c.CategoryID] = childrenCateId - } - } - } - globals.SugarLogger.Debugf("======VendorCategoryIDMap := %s", utils.Format4Output(VendorCategoryIDMap, false)) + //fromCategoryList, err := api.ShopCategoryGet(utils.Int2Str(fromStore.ID)) + //if err != nil { + // return nil, err + //} + //for _, v := range fromCategoryList { + // parentID, categoryErr := api.ShopCategoryCreate(utils.Int2Str(toStore.ID), 0, v.Name, v.Rank) + // if categoryErr != nil { + // globals.SugarLogger.Debugf("err := RetailCatUpdate : %v", categoryErr) + // continue + // } + // VendorCategoryIDMap[v.CategoryID] = parentID + // if v.Children != nil && len(v.Children) != 0 { + // for _, c := range v.Children { + // childrenCateId, err := api.ShopCategoryCreate(utils.Int2Str(toStore.ID), parentID, c.Name, c.Rank) + // if err != nil { + // globals.SugarLogger.Debugf("err := RetailCatUpdate Children : %v", err) + // continue + // } + // VendorCategoryIDMap[c.CategoryID] = childrenCateId + // } + // } + //} case 3: - i := 0 + i := 1 for { // 同步商品 - fromFoodList, err1 := api.SkuList(utils.Int2Str(fromStore.ID), &ebaiapi.SkuListParams{}) + fromFoodList, err1 := api.SkuList(utils.Int2Str(fromStore.ID), &ebaiapi.SkuListParams{ + Page: i, + }) if len(fromFoodList.List) == 0 || fromFoodList == nil { return nil, fmt.Errorf("fromFoodList 为空 %s ,i:= %d", utils.Format4Output(err1, false), i) } - + globals.SugarLogger.Debugf("============len %d", len(fromFoodList.List)) if err = BatchInitSkuEBai2EBai(ctx, fromFoodList.List, api, utils.Int2Str(toStore.ID), VendorCategoryIDMap); err != nil { globals.SugarLogger.Debugf("BatchInitData : %s", utils.Format4Output(err, false)) } - i = fromFoodList.SkuIdOffset + i = i + 1 } } @@ -124,9 +140,10 @@ func BatchInitSkuEBai2EBai(ctx *jxcontext.Context, fromSku []*ebaiapi.SkuInfo, t } params["upc"] = storeSku.Upc params["name"] = storeSku.Name - params["cat3_id"] = VendorCategoryIDMap[int64(storeSku.CateId2)] - params["category_id"] = VendorCategoryIDMap[int64(storeSku.CateId)] + params["cat3_id"] = storeSku.CateId + params["category_id"] = VendorCategoryIDMap[utils.Str2Int64(storeSku.CustomCatList[0].CustomCatID)] params["rtf"] = storeSku.Rtf + params["left_num"] = storeSku.LeftNum params["process_type"] = storeSku.ProcessType params["process_detail"] = storeSku.ProcessDetail params["sale_price"] = storeSku.SalePrice