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

heihei

Browse Source
This commit is contained in:
苏尹岚
2020-11-11 18:39:35 +08:00
parent 19c58e4b4a
commit 788c73a734
2 changed files with 79 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1766,9 +1766,33 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }
jdStoreIDxipu = "11890095"
)
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)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreIDxipu, nil)
multiHandler := partner.GetPurchasePlatformFromVendorID(model.VendorIDJD).(partner.IMultipleStoresHandler)
allSkuNameInfoList, err := multiHandler.GetSkus(ctx, "320406", 0, "")
skuInfos := StoreSkuFullList2BareFilter(allSkuNameInfoList)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreIDxipu, skuInfos)
fmt.Println(utils.Format4Output(outStoreSkuList, false))
// task := tasksch.NewParallelTask("初始化京东", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// jdStoreID := batchItemList[0].(string)
// outStoreSkuList2, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreID, skuInfos)
// for _, v := range outStoreSkuList {
// }
// return retVal, err
// }, jdStoreIDs)
// tasksch.HandleTask(task, nil, true).Run()
// task.GetID()
return err
}

4
business/partner/purchase/jd/store_sku2.go
View File

@@ -55,9 +55,9 @@ func (p *PurchaseHandler) getStoreSkusBareInfoLimitSize(ctx *jxcontext.Context,
sku := storeSkuMap[utils.Int64ToStr(v.SkuID)]
sku.Status = jdStoreSkuStatus2Jx(v.Vendibility)
sku.Stock = v.UsableQty
if sku.Stock > 0 {
// if sku.Stock > 0 {
outStoreSkuList = append(outStoreSkuList, sku)
}
// }
}
for _, v := range priceInfo {
sku := storeSkuMap[utils.Int64ToStr(v.SkuID)]