From 9307114a7a6b816461fed823ee7abd36acdd4650 Mon Sep 17 00:00:00 2001 From: gazebo Date: Mon, 2 Sep 2019 09:31:26 +0800 Subject: [PATCH] + sync2.go --- business/jxstore/cms/sync2.go | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 business/jxstore/cms/sync2.go diff --git a/business/jxstore/cms/sync2.go b/business/jxstore/cms/sync2.go new file mode 100644 index 000000000..6c9e9db9a --- /dev/null +++ b/business/jxstore/cms/sync2.go @@ -0,0 +1,30 @@ +package cms + +import ( + "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" + "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" +) + +func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, appOrgCodes []string, catIDs []int, isAsync bool) (hint string, err error) { + // if len(vendorIDs) == 0 { + // vendorIDs = partner.GetMultiStoreVendorIDs() + // } + // vendorOrgCodeList := apimanager.CurAPIManager.GetVendorOrgCodeList(vendorIDs, appOrgCodes) + // task := tasksch.NewParallelTask("同步商家分类", nil, ctx, + // func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + // vendorOrgCodePair := batchItemList[0].(*apimanager.VendorOrgCodePair) + // if handler := partner.GetPurchasePlatformFromVendorID(vendorOrgCodePair.VendorID); handler != nil { + // } + // return retVal, err + // }, vendorOrgCodeList) + // tasksch.HandleTask(task, parentTask, len(catIDs) > 0).Run() + // if isAsync { + // hint = task.GetID() + // } else { + // resultList, err2 := task.GetResult(0) + // if err = err2; err == nil { + // hint = utils.Int2Str(len(resultList)) + // } + // } + return hint, err +}