From 59c66f71fc36ba1cf57d03e2c25d26cb37c55c2c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Thu, 12 Nov 2020 12:02:48 +0800 Subject: [PATCH] beta --- business/jxstore/tempop/tempop.go | 185 +++++++++++++++--------------- 1 file changed, 93 insertions(+), 92 deletions(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 9281605a7..8ca8895c5 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1710,61 +1710,61 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true) // } var ( - // jdStoreIDs = []string{ - // "11053494", - // "11734848", - // "11734850", - // "11734854", - // "11734862", - // "11734868", - // "11734873", - // "11734874", - // "11734886", - // "11748353", - // "11890095", - // "11800399", - // "11738114", - // "11857499", - // "11873440", - // "11883071", - // "11734852", - // "11886763", - // "11874614", - // "11734884", - // "11926674", - // "11929173", - // "11894144", - // "11734861", - // "11951611", - // "11800403", - // "11913597", - // "11980746", - // "11981675", - // "12011812", - // "12007545", - // "11734846", - // "12005417", - // "12005640", - // "12005682", - // "12006134", - // "11982352", - // "12007250", - // "12007560", - // "11982427", - // "12008087", - // "12035806", - // "12008160", - // "12008395", - // "12009345", - // "11940019", - // "12010237", - // "12010654", - // "12011111", - // "12006857", - // "11734851", - // "12030632", - // "12050456", - // } + jdStoreIDs = []string{ + "11053494", + // "11734848", + // "11734850", + // "11734854", + // "11734862", + // "11734868", + // "11734873", + // "11734874", + // "11734886", + // "11748353", + // "11890095", + // "11800399", + // "11738114", + // "11857499", + // "11873440", + // "11883071", + // "11734852", + // "11886763", + // "11874614", + // "11734884", + // "11926674", + // "11929173", + // "11894144", + // "11734861", + // "11951611", + // "11800403", + // "11913597", + // "11980746", + // "11981675", + // "12011812", + // "12007545", + // "11734846", + // "12005417", + // "12005640", + // "12005682", + // "12006134", + // "11982352", + // "12007250", + // "12007560", + // "11982427", + // "12008087", + // "12035806", + // "12008160", + // "12008395", + // "12009345", + // "11940019", + // "12010237", + // "12010654", + // "12011111", + // "12006857", + // "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 (