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

beta

Browse Source
This commit is contained in:
苏尹岚
2020-11-12 12:02:48 +08:00
parent 02fb1a9873
commit 59c66f71fc
1 changed files with 93 additions and 92 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
business/jxstore/tempop/tempop.go
View File

@@ -1710,8 +1710,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true)
// }
var (
// jdStoreIDs = []string{
// "11053494",
jdStoreIDs = []string{
"11053494",
// "11734848",
// "11734850",
// "11734854",
@@ -1764,7 +1764,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// "11734851",
// "12030632",
// "12050456",
// }
}
jdStoreIDxipu = "11053496"
skuMap = make(map[string]*partner.StoreSkuInfo)
priceList = make(map[string][]*partner.StoreSkuInfo)
@@ -1773,50 +1773,40 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
stockList = make(map[string][]*partner.StoreSkuInfo)
vendorOrgCode = "82029"
)
StoreSkuFullList2BareFilter := func(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {
for _, v := range storeSkuFull {
for _, v2 := range v.SkuList {
if v2.Status > model.SkuStatusDontSale {
bareStoreSkuList = append(bareStoreSkuList, &v2.StoreSkuInfo)
}
}
}
return bareStoreSkuList
}
handler := partner.GetPurchasePlatformFromVendorID(model.VendorIDJD).(partner.IPurchasePlatformStoreSkuHandler)
multiHandler := partner.GetPurchasePlatformFromVendorID(model.VendorIDJD).(partner.IMultipleStoresHandler)
allSkuNameInfoList, err := multiHandler.GetSkus(ctx, vendorOrgCode, 0, "")
skuInfos := StoreSkuFullList2BareFilter(allSkuNameInfoList)
skuInfos := storeSkuFullList2BareFilter(allSkuNameInfoList)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, vendorOrgCode, nil, 0, jdStoreIDxipu, skuInfos)
for _, vv := range outStoreSkuList {
skuMap[vv.VendorSkuID] = vv
}
fmt.Println("ssssssssssssssssssssss", utils.Format4Output(skuMap, false))
// for _, jdStoreID := range jdStoreIDs {
// skuInfos2 := StoreSkuFullList2BareFilter(allSkuNameInfoList)
// outStoreSkuList2, _ := handler.GetStoreSkusBareInfo(ctx, vendorOrgCode, nil, 0, jdStoreID, skuInfos2)
// for _, v := range outStoreSkuList2 {
// if skuMap[v.VendorSkuID] == nil {
// continue
// }
// if skuMap[v.VendorSkuID].VendorPrice != v.VendorPrice {
// v.VendorPrice = skuMap[v.VendorSkuID].VendorPrice
// priceList[jdStoreID] = append(priceList[jdStoreID], v)
// }
// if skuMap[v.VendorSkuID].Status != v.Status {
// v.Status = skuMap[v.VendorSkuID].Status
// if v.Status == model.SkuStatusNormal {
// statusList1[jdStoreID] = append(statusList1[jdStoreID], v)
// } else {
// statusList2[jdStoreID] = append(statusList2[jdStoreID], v)
// }
// }
// if skuMap[v.VendorSkuID].Stock != v.Stock {
// v.Stock = skuMap[v.VendorSkuID].Stock
// stockList[jdStoreID] = append(stockList[jdStoreID], v)
// }
// }
// }
for _, jdStoreID := range jdStoreIDs {
skuInfos2 := storeSkuFullList2BareFilter(allSkuNameInfoList)
outStoreSkuList2, _ := handler.GetStoreSkusBareInfo(ctx, vendorOrgCode, nil, 0, jdStoreID, skuInfos2)
for _, v := range outStoreSkuList2 {
if skuMap[v.VendorSkuID] == nil {
continue
}
if skuMap[v.VendorSkuID].VendorPrice != v.VendorPrice {
v.VendorPrice = skuMap[v.VendorSkuID].VendorPrice
priceList[jdStoreID] = append(priceList[jdStoreID], v)
}
if skuMap[v.VendorSkuID].Status != v.Status {
v.Status = skuMap[v.VendorSkuID].Status
if v.Status == model.SkuStatusNormal {
statusList1[jdStoreID] = append(statusList1[jdStoreID], v)
} else {
statusList2[jdStoreID] = append(statusList2[jdStoreID], v)
}
}
if skuMap[v.VendorSkuID].Stock != v.Stock {
v.Stock = skuMap[v.VendorSkuID].Stock
stockList[jdStoreID] = append(stockList[jdStoreID], v)
}
}
}
if len(priceList) > 0 {
fmt.Println("priceList", utils.Format4Output(priceList, false))
// for k, v := range priceList {
@@ -1841,6 +1831,17 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
return err
}
func storeSkuFullList2BareFilter(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {
for _, v := range storeSkuFull {
for _, v2 := range v.SkuList {
if v2.Status > model.SkuStatusDontSale {
bareStoreSkuList = append(bareStoreSkuList, &v2.StoreSkuInfo)
}
}
}
return bareStoreSkuList
}
func RefreshJXPriceChange(ctx *jxcontext.Context, storeID int) (hint string, err error) {
db := dao.GetDB()
var (