diff --git a/pkg/common/storage/cache/redis/conversation.go b/pkg/common/storage/cache/redis/conversation.go index 7c025d50a..40df1e57a 100644 --- a/pkg/common/storage/cache/redis/conversation.go +++ b/pkg/common/storage/cache/redis/conversation.go @@ -104,13 +104,13 @@ func (c *ConversationRedisCache) getConversationUserMaxVersionKey(ownerUserID st } func (c *ConversationRedisCache) GetUserConversationIDs(ctx context.Context, ownerUserID string) ([]string, error) { - return getCache(ctx, c.rcClient, c.getNotNotifyConversationIDsKey(ownerUserID), c.expireTime, func(ctx context.Context) ([]string, error) { + return getCache(ctx, c.rcClient, c.getConversationIDsKey(ownerUserID), c.expireTime, func(ctx context.Context) ([]string, error) { return c.conversationDB.FindUserIDAllConversationID(ctx, ownerUserID) }) } func (c *ConversationRedisCache) GetUserNotNotifyConversationIDs(ctx context.Context, userID string) ([]string, error) { - return getCache(ctx, c.rcClient, c.getConversationIDsKey(userID), c.expireTime, func(ctx context.Context) ([]string, error) { + return getCache(ctx, c.rcClient, c.getNotNotifyConversationIDsKey(userID), c.expireTime, func(ctx context.Context) ([]string, error) { return c.conversationDB.FindUserIDAllNotNotifyConversationID(ctx, userID) }) }