소스 검색

修改缓存key

wangchuanjin 2 년 전
부모
커밋
83cf823938
1개의 변경된 파일7개의 추가작업 그리고 6개의 파일을 삭제
  1. 7 6
      jyBXSubscribe/rpc/model/push.go

+ 7 - 6
jyBXSubscribe/rpc/model/push.go

@@ -166,11 +166,14 @@ func (s *subscribePush) PutTodayCache(userId, userType string, pc_a *SubPush) {
 // 获取redis key
 func (s *subscribePush) todayKey(userId, userType string) string {
 	if userType == EntnicheFlag {
-		return fmt.Sprintf("%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, userId)
-	} else {
-		return fmt.Sprintf("%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, userId)
+		switch userType {
+		case SubVipFlag:
+			return fmt.Sprintf("%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "vip", userId)
+		case MemberFlag:
+			return fmt.Sprintf("%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "member", userId)
+		}
 	}
-
+	return fmt.Sprintf("%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, userId)
 }
 func (s *subscribePush) allKey(userId, userType string) string {
 	if s.ModuleFlag == EntnicheFlag {
@@ -179,8 +182,6 @@ func (s *subscribePush) allKey(userId, userType string) string {
 			return fmt.Sprintf("all_%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "vip", userId)
 		case MemberFlag:
 			return fmt.Sprintf("all_%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "member", userId)
-		case SubFreeFlag:
-			return fmt.Sprintf("all_%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "free", userId)
 		}
 	}
 	return fmt.Sprintf("all_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, userId)