浏览代码

feat: 清除缓存、用户中台接口封装

zhangxinlei1996 2 年之前
父节点
当前提交
50df9d46d7
共有 2 个文件被更改,包括 22 次插入5 次删除
  1. 14 5
      common/src/qfw/util/jy/bigVipPower.go
  2. 8 0
      common/src/qfw/util/jy/userCenter.go

+ 14 - 5
common/src/qfw/util/jy/bigVipPower.go

@@ -1,6 +1,11 @@
 package jy
 
 import (
+	"fmt"
+	"log"
+	"strings"
+	"time"
+
 	qutil "app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/go-xweb/httpsession"
 	m "app.yhyue.com/moapp/jybase/mongodb"
@@ -8,10 +13,6 @@ import (
 	"app.yhyue.com/moapp/jybase/redis"
 	"app.yhyue.com/moapp/jypkg/middleground"
 	"bp.jydev.jianyu360.cn/BaseService/powerCheckCenter/rpc/pb"
-	"fmt"
-	"log"
-	"strings"
-	"time"
 )
 
 // 大会员状态redis缓存
@@ -86,6 +87,7 @@ const (
 	RedisMenuKeyWX            = "jy_workdesktopmenu_10000_WX_%s"  //剑鱼appid:10000
 	RedisMenuKeyAPP           = "jy_workdesktopmenu_10000_APP_%s" //剑鱼appid:10000
 	UserPowerRedisKey         = "jy_userpowerredis_10000_%d_%s"   //工作桌面 用户功能缓存(类似bigmember_power_3_%s)
+	PowerCheckKey             = "user_power_info_%s"              //权益校验中台缓存
 )
 
 // 初始化大会员权益
@@ -124,7 +126,14 @@ func ClearBigVipUserPower(userId string) bool {
 	redisMenuKeyWX := fmt.Sprintf(RedisMenuKeyWX, userId)
 	redisMenuKeyAPP := fmt.Sprintf(RedisMenuKeyAPP, userId)
 	userPowerRedisKey := fmt.Sprintf(UserPowerRedisKey, time.Now().Day(), userId)
-	return redis.Del(BaseInfoCacheDb, cacheKey) && redis.Del(BaseInfoCacheDb, baseInfoCacheKey) && redis.Del(BaseInfoCacheDb, redisMenuKeyPC) && redis.Del(BaseInfoCacheDb, redisMenuKeyWX) && redis.Del(BaseInfoCacheDb, redisMenuKeyAPP) && redis.Del(BaseInfoCacheDb, userPowerRedisKey)
+	powerCheckKey := fmt.Sprintf(PowerCheckKey, userId)
+	return redis.Del(BaseInfoCacheDb, cacheKey) &&
+		redis.Del(BaseInfoCacheDb, baseInfoCacheKey) &&
+		redis.Del(BaseInfoCacheDb, redisMenuKeyPC) &&
+		redis.Del(BaseInfoCacheDb, redisMenuKeyWX) &&
+		redis.Del(BaseInfoCacheDb, redisMenuKeyAPP) &&
+		redis.Del(BaseInfoCacheDb, userPowerRedisKey) &&
+		redis.Del(BaseInfoCacheDb, powerCheckKey)
 }
 
 // 获取商机管理个人基本信息

+ 8 - 0
common/src/qfw/util/jy/userCenter.go

@@ -23,3 +23,11 @@ func AddUser(mgo mongodb.MongodbSim, userid string, req pb.UserAddReq, middlegro
 	}
 	return false
 }
+
+//获取base-user相关参数
+func UpdateUser(mgo mongodb.MongodbSim, userid string, req pb.UserIdReq, middleground middleground.Middleground) bool {
+	if resp := middleground.UserCenter.UserUpdate(req); resp != nil {
+		return resp.Data.Status == 1
+	}
+	return false
+}