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

获取平台门店商品价格

Browse Source
This commit is contained in:
苏尹岚
2019-12-20 11:56:53 +08:00
parent b8f7ffea18
commit fc588aec60
1 changed files with 19 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxstore/cms/store_sku.go
View File

@@ -2550,7 +2550,8 @@ func GetVendorStoreSkuPrice(ctx *jxcontext.Context, vendorIDs []int, skuID int,
} }
inStoreSkuList = append(inStoreSkuList, inStoreSku) inStoreSkuList = append(inStoreSkuList, inStoreSku)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, v, task, 0, vendorStoreID, inStoreSkuList) outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, v, task, 0, vendorStoreID, inStoreSkuList)
if err != nil { if storeDetail != nil {
if len(outStoreSkuList) == 0 {
data := DataVendorStoreSkuPrice{ data := DataVendorStoreSkuPrice{
StoreID: vendorStoreID, StoreID: vendorStoreID,
StoreName: storeDetail.Name, StoreName: storeDetail.Name,
@@ -2569,6 +2570,7 @@ func GetVendorStoreSkuPrice(ctx *jxcontext.Context, vendorIDs []int, skuID int,
} }
retVal = []DataVendorStoreSkuPrice{data} retVal = []DataVendorStoreSkuPrice{data}
} }
}
return retVal, err return retVal, err
} }
taskParallel := tasksch.NewParallelTask("获取各平台所有门店某商品价格", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, vendorStoreIDs) taskParallel := tasksch.NewParallelTask("获取各平台所有门店某商品价格", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskFunc, vendorStoreIDs)