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:22:41 +08:00
parent d1d49d464e
commit f72257d07c
1 changed files with 36 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2527,42 +2527,51 @@ func GetVendorStoreSkuPrice(ctx *jxcontext.Context, vendorIDs []int, skuID int,
err = err2 err = err2
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
vendorStoreID := batchItemList[0].(string) vendorStoreID := batchItemList[0].(string)
var inStoreSkuList []*partner.StoreSkuInfo var (
var storeDetail *dao.StoreDetail inStoreSkuList []*partner.StoreSkuInfo
inStoreSku := &partner.StoreSkuInfo{ storeDetail *dao.StoreDetail
SkuID: skuID, inStoreSku = &partner.StoreSkuInfo{}
)
skuNameList, err := dao.GetSkus(dao.GetDB(), []int{skuID}, nil, nil, nil)
if err != nil {
return retVal, err
} }
inStoreSkuList = append(inStoreSkuList, inStoreSku)
if partner.IsMultiStore(vendorID) { if partner.IsMultiStore(vendorID) {
multiHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IMultipleStoresHandler) multiHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IMultipleStoresHandler)
storeDetail, err = multiHandler.ReadStore(ctx, "", vendorStoreID) storeDetail, err = multiHandler.ReadStore(ctx, v, vendorStoreID)
if len(skuNameList) > 0 {
inStoreSku.VendorSkuID = utils.Int64ToStr(skuNameList[0].JdID)
}
} else { } else {
singleHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreHandler) singleHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreHandler)
storeDetail, err = singleHandler.ReadStore(ctx, "", vendorStoreID) storeDetail, err = singleHandler.ReadStore(ctx, v, vendorStoreID)
inStoreSku.SkuID = skuID
} }
inStoreSkuList = append(inStoreSkuList, inStoreSku)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, v, task, 0, vendorStoreID, inStoreSkuList) outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, v, task, 0, vendorStoreID, inStoreSkuList)
skuNameList, err := dao.GetSkus(dao.GetDB(), []int{skuID}, nil, nil, nil) if err != nil {
return retVal, err
}
if storeDetail != nil { if storeDetail != nil {
if len(skuNameList) > 0 { if len(outStoreSkuList) > 0 {
if len(outStoreSkuList) > 0 { data := DataVendorStoreSkuPrice{
data := DataVendorStoreSkuPrice{ StoreID: vendorStoreID,
StoreID: vendorStoreID, StoreName: storeDetail.Name,
StoreName: storeDetail.Name, SkuID: skuID,
SkuID: skuID, SkuName: skuNameList[0].Name,
SkuName: skuNameList[0].Name, VendorPrice: utils.Float64ToStr(utils.Str2Float64(utils.Int64ToStr(outStoreSkuList[0].VendorPrice)) / 100),
VendorPrice: utils.Float64ToStr(utils.Str2Float64(utils.Int64ToStr(outStoreSkuList[0].VendorPrice)) / 100),
}
retVal = []DataVendorStoreSkuPrice{data}
} else {
data := DataVendorStoreSkuPrice{
StoreID: vendorStoreID,
StoreName: storeDetail.Name,
SkuID: skuID,
SkuName: skuNameList[0].Name,
VendorPrice: "",
}
retVal = []DataVendorStoreSkuPrice{data}
} }
retVal = []DataVendorStoreSkuPrice{data}
} else {
data := DataVendorStoreSkuPrice{
StoreID: vendorStoreID,
StoreName: storeDetail.Name,
SkuID: skuID,
SkuName: skuNameList[0].Name,
VendorPrice: "",
}
retVal = []DataVendorStoreSkuPrice{data}
} }
} }
return retVal, err return retVal, err