From 788c73a7343d0d63672301911ffc61e6b71d7cdf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 11 Nov 2020 18:39:35 +0800
Subject: [PATCH] heihei

---
 business/jxstore/tempop/tempop.go          | 128 ++++++++++++---------
 business/partner/purchase/jd/store_sku2.go |   6 +-
 2 files changed, 79 insertions(+), 55 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index ac7a3db70..db1f5b5ba 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1712,63 +1712,87 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	var (
 		// jdStoreIDs = []string{
 		// 	"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",
+		// "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 = "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
 }
 
diff --git a/business/partner/purchase/jd/store_sku2.go b/business/partner/purchase/jd/store_sku2.go
index 0cd83d594..00c9ac4c9 100644
--- a/business/partner/purchase/jd/store_sku2.go
+++ b/business/partner/purchase/jd/store_sku2.go
@@ -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 {
-					outStoreSkuList = append(outStoreSkuList, sku)
-				}
+				// if sku.Stock > 0 {
+				outStoreSkuList = append(outStoreSkuList, sku)
+				// }
 			}
 			for _, v := range priceInfo {
 				sku := storeSkuMap[utils.Int64ToStr(v.SkuID)]