using MediaBrowser.Common.Extensions; using MediaBrowser.Controller.Dto; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities.Movies; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Persistence; using MediaBrowser.Model.Dto; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Querying; using ServiceStack; using System; using System.Collections.Generic; using System.Linq; namespace MediaBrowser.Api.Movies { /// /// Class GetSimilarMovies /// [Route("/Movies/{Id}/Similar", "GET", Summary = "Finds movies and trailers similar to a given movie.")] public class GetSimilarMovies : BaseGetSimilarItemsFromItem { [ApiMember(Name = "IncludeTrailers", Description = "Whether or not to include trailers within the results. Defaults to true.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")] public bool IncludeTrailers { get; set; } public GetSimilarMovies() { IncludeTrailers = true; } } [Route("/Movies/Recommendations", "GET", Summary = "Gets movie recommendations")] public class GetMovieRecommendations : IReturn, IHasItemFields { [ApiMember(Name = "CategoryLimit", Description = "The max number of categories to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")] public int CategoryLimit { get; set; } [ApiMember(Name = "ItemLimit", Description = "The max number of items to return per category", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")] public int ItemLimit { get; set; } /// /// Gets or sets the user id. /// /// The user id. [ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] public Guid? UserId { get; set; } /// /// Specify this to localize the search to a specific item or folder. Omit to use the root. /// /// The parent id. [ApiMember(Name = "ParentId", Description = "Specify this to localize the search to a specific item or folder. Omit to use the root", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] public string ParentId { get; set; } public GetMovieRecommendations() { CategoryLimit = 5; ItemLimit = 8; } public string Fields { get; set; } } /// /// Class MoviesService /// public class MoviesService : BaseApiService { /// /// The _user manager /// private readonly IUserManager _userManager; /// /// The _user data repository /// private readonly IUserDataManager _userDataRepository; /// /// The _library manager /// private readonly ILibraryManager _libraryManager; private readonly IItemRepository _itemRepo; private readonly IDtoService _dtoService; /// /// Initializes a new instance of the class. /// /// The user manager. /// The user data repository. /// The library manager. public MoviesService(IUserManager userManager, IUserDataManager userDataRepository, ILibraryManager libraryManager, IItemRepository itemRepo, IDtoService dtoService) { _userManager = userManager; _userDataRepository = userDataRepository; _libraryManager = libraryManager; _itemRepo = itemRepo; _dtoService = dtoService; } /// /// Gets the specified request. /// /// The request. /// System.Object. public object Get(GetSimilarMovies request) { var result = SimilarItemsHelper.GetSimilarItemsResult(_userManager, _itemRepo, _libraryManager, _userDataRepository, _dtoService, Logger, // Strip out secondary versions request, item => (item is Movie || (item is Trailer && request.IncludeTrailers)) && !((Video)item).PrimaryVersionId.HasValue, SimilarItemsHelper.GetSimiliarityScore); return ToOptimizedSerializedResultUsingCache(result); } public object Get(GetMovieRecommendations request) { var user = _userManager.GetUserById(request.UserId.Value); var movies = GetAllLibraryItems(request.UserId, _userManager, _libraryManager, request.ParentId) .OfType(); movies = _libraryManager.ReplaceVideosWithPrimaryVersions(movies).Cast(); var result = GetRecommendationCategories(user, movies.ToList(), request.CategoryLimit, request.ItemLimit, request.GetItemFields().ToList()); return ToOptimizedResult(result); } private IEnumerable GetRecommendationCategories(User user, List allMovies, int categoryLimit, int itemLimit, List fields) { var categories = new List(); var recentlyPlayedMovies = allMovies .Select(i => { var userdata = _userDataRepository.GetUserData(user.Id, i.GetUserDataKey()); return new Tuple(i, userdata.Played, userdata.LastPlayedDate ?? DateTime.MinValue); }) .Where(i => i.Item2) .OrderByDescending(i => i.Item3) .Select(i => i.Item1) .ToList(); var excludeFromLiked = recentlyPlayedMovies.Take(10); var likedMovies = allMovies .Select(i => { var score = 0; var userData = _userDataRepository.GetUserData(user.Id, i.GetUserDataKey()); if (userData.IsFavorite) { score = 2; } else { score = userData.Likes.HasValue ? userData.Likes.Value ? 1 : -1 : 0; } return new Tuple(i, score); }) .OrderByDescending(i => i.Item2) .ThenBy(i => Guid.NewGuid()) .Where(i => i.Item2 > 0) .Select(i => i.Item1) .Where(i => !excludeFromLiked.Contains(i)); var mostRecentMovies = recentlyPlayedMovies.Take(6).ToList(); // Get recently played directors var recentDirectors = GetDirectors(mostRecentMovies) .OrderBy(i => Guid.NewGuid()) .ToList(); // Get recently played actors var recentActors = GetActors(mostRecentMovies) .OrderBy(i => Guid.NewGuid()) .ToList(); var similarToRecentlyPlayed = GetSimilarTo(user, allMovies, recentlyPlayedMovies.Take(7).OrderBy(i => Guid.NewGuid()), itemLimit, fields, RecommendationType.SimilarToRecentlyPlayed).GetEnumerator(); var similarToLiked = GetSimilarTo(user, allMovies, likedMovies, itemLimit, fields, RecommendationType.SimilarToLikedItem).GetEnumerator(); var hasDirectorFromRecentlyPlayed = GetWithDirector(user, allMovies, recentDirectors, itemLimit, fields, RecommendationType.HasDirectorFromRecentlyPlayed).GetEnumerator(); var hasActorFromRecentlyPlayed = GetWithActor(user, allMovies, recentActors, itemLimit, fields, RecommendationType.HasActorFromRecentlyPlayed).GetEnumerator(); var categoryTypes = new List> { // Give this extra weight similarToRecentlyPlayed, similarToRecentlyPlayed, // Give this extra weight similarToLiked, similarToLiked, hasDirectorFromRecentlyPlayed, hasActorFromRecentlyPlayed }; while (categories.Count < categoryLimit) { var allEmpty = true; foreach (var category in categoryTypes) { if (category.MoveNext()) { categories.Add(category.Current); allEmpty = false; if (categories.Count >= categoryLimit) { break; } } } if (allEmpty) { break; } } return categories.OrderBy(i => i.RecommendationType).ThenBy(i => Guid.NewGuid()); } private IEnumerable GetWithDirector(User user, List allMovies, IEnumerable directors, int itemLimit, List fields, RecommendationType type) { var userId = user.Id; foreach (var director in directors) { var items = allMovies .Where(i => i.People.Any(p => string.Equals(p.Type, PersonType.Director, StringComparison.OrdinalIgnoreCase) && string.Equals(p.Name, director, StringComparison.OrdinalIgnoreCase))) .Take(itemLimit) .ToList(); if (items.Count > 0) { yield return new RecommendationDto { BaselineItemName = director, CategoryId = director.GetMD5().ToString("N"), RecommendationType = type, Items = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user)).ToArray() }; } } } private IEnumerable GetWithActor(User user, List allMovies, IEnumerable names, int itemLimit, List fields, RecommendationType type) { var userId = user.Id; foreach (var name in names) { var items = allMovies .Where(i => i.People.Any(p => string.Equals(p.Name, name, StringComparison.OrdinalIgnoreCase))) .Take(itemLimit) .ToList(); if (items.Count > 0) { yield return new RecommendationDto { BaselineItemName = name, CategoryId = name.GetMD5().ToString("N"), RecommendationType = type, Items = items.Select(i => _dtoService.GetBaseItemDto(i, fields, user)).ToArray() }; } } } private IEnumerable GetSimilarTo(User user, List allMovies, IEnumerable baselineItems, int itemLimit, List fields, RecommendationType type) { var userId = user.Id; foreach (var item in baselineItems) { var similar = SimilarItemsHelper .GetSimilaritems(item, allMovies, SimilarItemsHelper.GetSimiliarityScore) .Take(itemLimit) .ToList(); if (similar.Count > 0) { yield return new RecommendationDto { BaselineItemName = item.Name, CategoryId = item.Id.ToString("N"), RecommendationType = type, Items = similar.Select(i => _dtoService.GetBaseItemDto(i, fields, user)).ToArray() }; } } } private IEnumerable GetActors(IEnumerable items) { // Get the two leading actors for all movies return items .SelectMany(i => i.People.Where(p => !string.Equals(PersonType.Director, p.Type, StringComparison.OrdinalIgnoreCase)).Take(2)) .Select(i => i.Name) .Distinct(StringComparer.OrdinalIgnoreCase); } private IEnumerable GetDirectors(IEnumerable items) { return items .Select(i => i.People.FirstOrDefault(p => string.Equals(PersonType.Director, p.Type, StringComparison.OrdinalIgnoreCase))) .Where(i => i != null) .Select(i => i.Name) .Distinct(StringComparer.OrdinalIgnoreCase); } } }