liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2024-01-29 19:00:24 +08:00
parent 818f4f87fa
commit 9207af3445
1 changed files with 18 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
business/jxstore/cms/system_store_sku.go
View File

@@ -152,16 +152,6 @@ func BatchInitSkuEBai2EBai(ctx *jxcontext.Context, fromSku []*ebaiapi.SkuInfo, t
// CopyMtToMT 美团商品复制到美团 // CopyMtToMT 美团商品复制到美团
func CopyMtToMT(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isAsync bool, offSet int) (hint string, err error) { 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) taskName := fmt.Sprintf("将美团平台门店[%s],分类和商品复制到[%s]", fromStore.VendorStoreID, toStore.VendorStoreID)
config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false) config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false)
work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { 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] // return nil, errs[0]
//} //}
case 2: 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) fromCategoryList, _ := fromAPI.RetailCatList(fromStore.VendorStoreID)
globals.SugarLogger.Debugf("==fromCategoryList= : %d", len(fromCategoryList))
for _, v := range fromCategoryList { for _, v := range fromCategoryList {
categoryErr := toAPI.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{ categoryErr := toAPI.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{
CategoryCode: v.Code, CategoryCode: v.Code,
@@ -203,6 +200,15 @@ func CopyMtToMT(ctx *jxcontext.Context, fromStore, toStore *dao.StoreDetail, isA
case 3: case 3:
i := offSet 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 { for {
// 同步商品 // 同步商品
fromFoodList, err1 := fromAPI.RetailListAll(fromStore.VendorStoreID, i) fromFoodList, err1 := fromAPI.RetailListAll(fromStore.VendorStoreID, i)