From 5a3e88fd252a1bea1ca956f495b67e34b94b1c02 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 19:06:27 +0800
Subject: [PATCH] heihei

---
 business/jxstore/tempop/tempop.go | 140 ++++++++++++++++--------------
 1 file changed, 75 insertions(+), 65 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index db1f5b5ba..0fbbd333d 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1710,61 +1710,63 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 	cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true)
 	// }
 	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",
-		// }
+		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",
+		}
 		jdStoreIDxipu = "11890095"
+		skuMap        = make(map[string]*partner.StoreSkuInfo)
+		priceList     []*pa
 	)
 	StoreSkuFullList2BareFilter := func(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {
 		for _, v := range storeSkuFull {
@@ -1781,18 +1783,26 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	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 {
+	for _, v := range outStoreSkuList {
+		skuMap[v.VendorSkuID] = v
+	}
+	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 outStoreSkuList2 {
+				if skuMap[v.VendorSkuID] != nil {
+					continue
+				}
+				if skuMap[v.VendorSkuID].VendorPrice != v.VendorPrice {
+					v.VendorPrice = skuMap[v.VendorSkuID].VendorPrice
 
-	// 		}
-	// 		return retVal, err
-	// 	}, jdStoreIDs)
-	// tasksch.HandleTask(task, nil, true).Run()
-	// task.GetID()
+				}
+			}
+			return retVal, err
+		}, jdStoreIDs)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetID()
 	return err
 }