获取各平台未营业门店
This commit is contained in:
@@ -2306,14 +2306,12 @@ func GetVendorStoreInfo(ctx *jxcontext.Context, vendorIDList []int, isAsync, isC
|
||||
if partner.IsMultiStore(vendorID) {
|
||||
multiHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IMultipleStoresHandler)
|
||||
storeDetail, err = multiHandler.ReadStore(ctx, storeID)
|
||||
time.Sleep(time.Second / 2)
|
||||
if err != nil {
|
||||
return retVal, err
|
||||
}
|
||||
} else {
|
||||
singleHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreHandler)
|
||||
storeDetail, err = singleHandler.ReadStore(ctx, storeID)
|
||||
time.Sleep(time.Second / 4)
|
||||
if err != nil {
|
||||
return retVal, err
|
||||
}
|
||||
@@ -2330,7 +2328,7 @@ func GetVendorStoreInfo(ctx *jxcontext.Context, vendorIDList []int, isAsync, isC
|
||||
}
|
||||
return retVal, err
|
||||
}
|
||||
taskParallel := tasksch.NewParallelTask("获取各平台未营业门店", tasksch.NewParallelConfig(), ctx, taskFunc, storeIDs)
|
||||
taskParallel := tasksch.NewParallelTask("获取各平台未营业门店", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, storeIDs)
|
||||
tasksch.HandleTask(taskParallel, task, true).Run()
|
||||
storeList, err := taskParallel.GetResult(0)
|
||||
for _, v := range storeList {
|
||||
|
||||
Reference in New Issue
Block a user