wangchuanjin 2 éve
szülő
commit
cdf75a851b
1 módosított fájl, 5 hozzáadás és 1 törlés
  1. 5 1
      jyBXSubscribe/rpc/model/push.go

+ 5 - 1
jyBXSubscribe/rpc/model/push.go

@@ -165,12 +165,14 @@ func (s *subscribePush) PutTodayCache(userId, userType string, pc_a *SubPush) {
 
 // 获取redis key
 func (s *subscribePush) todayKey(userId, userType string) string {
-	if userType == EntnicheFlag {
+	if s.ModuleFlag == EntnicheFlag {
 		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)
+		case SubFreeFlag:
+			return fmt.Sprintf("%s_%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, "free", userId)
 		}
 	}
 	return fmt.Sprintf("%s_%s", aboutDbMsg[s.ModuleFlag].RedisKeyFlag, userId)
@@ -182,6 +184,8 @@ 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)