From 6dc8f9d451cbf2206bc52c0754b190b083e4e6bf 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, 7 Apr 2021 15:11:13 +0800
Subject: [PATCH] aa

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

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 5556ceccd..2481f31d9 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1840,78 +1840,58 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// tasksch.HandleTask(task, nil, true).Run()
 	// task.GetID()
 	//删京东会员价
-	// 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 != "" {
-	// 		vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
-	// 		thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
-	// 	}
-	// }
-
-	// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().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) {
-	// 			api := jd.GetAPI("320406")
-	// 			priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
-	// 			var list []*jdapi.SkuIdEntity
-	// 			for _, vv := range priceInfo {
-	// 				if vv.VipPrice != 0 {
-	// 					list = append(list, &jdapi.SkuIdEntity{
-	// 						OutSkuId: thingIDmap[vv.SkuID],
-	// 					})
-	// 				}
-	// 			}
-	// 			if len(list) > 0 {
-	// 				err = api.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()
+		db             = dao.GetDB()
+		vendorThingIDs []int64
 	)
-	if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil {
-		api.JdAPI.SetCookieWithStr(configs[0].Value)
-		result, _ := api.JdAPI.GetJdAppInfo()
-		if result != nil {
-			if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 {
-				vocs[0].AppKey = result.AppKey
-				vocs[0].AppSecret = result.AppSecret
-				dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret")
-			}
+	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 != "" {
+			vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
+			thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
 		}
 	}
+
+	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().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) {
+				api := jd.GetAPI("320406")
+				priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
+				var list []*jdapi.SkuIdEntity
+				for _, vv := range priceInfo {
+					if vv.VipPrice != 0 {
+						list = append(list, &jdapi.SkuIdEntity{
+							OutSkuId: thingIDmap[vv.SkuID],
+						})
+					}
+				}
+				if len(list) > 0 {
+					err = api.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()
-	// 	users []*model.User
+	// 	db = dao.GetDB()
 	// )
-	// 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)
+	// if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil {
+	// 	api.JdAPI.SetCookieWithStr(configs[0].Value)
+	// 	result, _ := api.JdAPI.GetJdAppInfo()
+	// 	if result != nil {
+	// 		if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 {
+	// 			vocs[0].AppKey = result.AppKey
+	// 			vocs[0].AppSecret = result.AppSecret
+	// 			dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret")
+	// 		}
 	// 	}
-	// 	dao.DeleteEntity(db, v)
 	// }
 	return err
 }