diff --git a/business/jxstore/cms/system_store_sku.go b/business/jxstore/cms/system_store_sku.go index a806ea8f9..d9048fc29 100644 --- a/business/jxstore/cms/system_store_sku.go +++ b/business/jxstore/cms/system_store_sku.go @@ -152,16 +152,6 @@ func BatchInitSkuEBai2EBai(ctx *jxcontext.Context, fromSku []*ebaiapi.SkuInfo, t // CopyMtToMT 美团商品复制到美团 func CopyMtToMT(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isAsync bool, offSet int) (hint string, err error) { - fromAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) - if fromStore.VendorOrgCode == "5873" { - fromAPI.SetToken(fromStore.MtwmToken) - } - - toAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API) - if toStore.VendorOrgCode == "5873" { - toAPI.SetToken(toStore.MtwmToken) - } - taskName := fmt.Sprintf("将美团平台门店[%s],分类和商品复制到[%s]", fromStore.VendorStoreID, toStore.VendorStoreID) config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false) work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { @@ -175,10 +165,17 @@ func CopyMtToMT(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isA // return nil, errs[0] //} case 2: + fromAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) + if fromStore.VendorOrgCode == "5873" { + fromAPI.SetToken(fromStore.MtwmToken) + } + + toAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API) + if toStore.VendorOrgCode == "5873" { + toAPI.SetToken(toStore.MtwmToken) + } // 同步分类 - globals.SugarLogger.Debugf("==fromCategoryList= : %s", utils.Format4Output(fromAPI, false)) fromCategoryList, _ := fromAPI.RetailCatList(fromStore.VendorStoreID) - globals.SugarLogger.Debugf("==fromCategoryList= : %d", len(fromCategoryList)) for _, v := range fromCategoryList { categoryErr := toAPI.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{ CategoryCode: v.Code, @@ -203,6 +200,15 @@ func CopyMtToMT(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isA case 3: i := offSet + fromAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) + if fromStore.VendorOrgCode == "5873" { + fromAPI.SetToken(fromStore.MtwmToken) + } + + toAPI := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API) + if toStore.VendorOrgCode == "5873" { + toAPI.SetToken(toStore.MtwmToken) + } for { // 同步商品 fromFoodList, err1 := fromAPI.RetailListAll(fromStore.VendorStoreID, i)