From b84ff3e0f70553796c096742e56e22a135e632f5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Tue, 6 Apr 2021 16:26:45 +0800
Subject: [PATCH] aa

---
 business/jxstore/tempop/tempop.go | 114 +++++++++++++++---------------
 1 file changed, 57 insertions(+), 57 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 9085c26ee..6d107f103 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1839,45 +1839,45 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 	}, storeMaps)
 	// tasksch.HandleTask(task, nil, true).Run()
 	// task.GetID()
-	// var (
-	// 	db             = dao.GetDB()
-	// 	vendorThingIDs []int64
-	// )
-	// storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, []int{model.StoreStatusOpened, model.StoreStatusHaveRest, model.StoreStatusClosed}, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
-	// things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
-	// thingIDmap := make(map[int64]string)
+	var (
+		db             = dao.GetDB()
+		vendorThingIDs []int64
+	)
+	storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
+	things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
+	thingIDmap := make(map[int64]string)
 
-	// for _, v := range things {
-	// 	if v.VendorThingID != "" {
-	// 		// lists = append(lists, &jdapi.SkuIdEntity{
-	// 		// 	OutSkuId: utils.Int64ToStr(v.ThingID),
-	// 		// })
-	// 		vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
-	// 		thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
-	// 	}
-	// }
+	for _, v := range things {
+		if v.VendorThingID != "" {
+			// lists = append(lists, &jdapi.SkuIdEntity{
+			// 	OutSkuId: utils.Int64ToStr(v.ThingID),
+			// })
+			vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
+			thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
+		}
+	}
 
-	// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
-	// 	func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-	// 		storeMap := batchItemList[0].(*model.StoreMap)
-	// 		FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
-	// 			priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
-	// 			var list []*jdapi.SkuIdEntity
-	// 			for _, vv := range priceInfo {
-	// 				if vv.VipPrice != 0 {
-	// 					fmt.Println("vipPrice uuu", vv.SkuID)
-	// 					list = append(list, &jdapi.SkuIdEntity{
-	// 						OutSkuId: thingIDmap[vv.SkuID],
-	// 					})
-	// 				}
-	// 			}
-	// 			err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
-	// 			return result, 0, err
-	// 		}, ctx, task, vendorThingIDs, 50, true)
-	// 		return retVal, err
-	// 	}, storeMaps)
-	// tasksch.HandleTask(task, nil, true).Run()
-	// _, err = task.GetResult(0)
+	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			storeMap := batchItemList[0].(*model.StoreMap)
+			FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
+				priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
+				var list []*jdapi.SkuIdEntity
+				for _, vv := range priceInfo {
+					if vv.VipPrice != 0 {
+						// fmt.Println("vipPrice uuu", vv.SkuID)
+						list = append(list, &jdapi.SkuIdEntity{
+							OutSkuId: thingIDmap[vv.SkuID],
+						})
+					}
+				}
+				err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
+				return result, 0, err
+			}, ctx, task, vendorThingIDs, 50, true)
+			return retVal, err
+		}, storeMaps)
+	tasksch.HandleTask(task, nil, true).Run()
+	_, err = task.GetResult(0)
 	//京东账号更新
 	// var (
 	// 	db = dao.GetDB()
@@ -1893,26 +1893,26 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 		}
 	// 	}
 	// }
-	var (
-		db    = dao.GetDB()
-		users []*model.User
-	)
-	sql := `
-		SELECT DISTINCT a.* FROM user a 
-		LEFT JOIN auth_bind b ON a.user_id2 = b.auth_id
-		WHERE name IN (
-		SELECT name FROM user WHERE deleted_at = '1970-01-01 00:00:00' GROUP BY name HAVING COUNT(*) > 1 )
-		AND a.mobile is null AND a.user_id <> b.user_id
-		ORDER BY a.name
-	`
-	dao.GetRows(db, &users, sql, nil)
-	for _, v := range users {
-		tokens, _ := api.Cacher.Keys(v.UserID)
-		for _, vv := range tokens {
-			api.Cacher.Del(vv)
-		}
-		dao.DeleteEntity(db, v)
-	}
+	// var (
+	// 	db    = dao.GetDB()
+	// 	users []*model.User
+	// )
+	// sql := `
+	// 	SELECT DISTINCT a.* FROM user a
+	// 	LEFT JOIN auth_bind b ON a.user_id2 = b.auth_id
+	// 	WHERE name IN (
+	// 	SELECT name FROM user WHERE deleted_at = '1970-01-01 00:00:00' GROUP BY name HAVING COUNT(*) > 1 )
+	// 	AND a.mobile is null AND a.user_id <> b.user_id
+	// 	ORDER BY a.name
+	// `
+	// dao.GetRows(db, &users, sql, nil)
+	// for _, v := range users {
+	// 	tokens, _ := api.Cacher.Keys(v.UserID)
+	// 	for _, vv := range tokens {
+	// 		api.Cacher.Del(vv)
+	// 	}
+	// 	dao.DeleteEntity(db, v)
+	// }
 	return err
 }