ReportsService.cs 29 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162
  1. using MediaBrowser.Controller.Dto;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Controller.Library;
  4. using MediaBrowser.Model.Querying;
  5. using System.Collections.Generic;
  6. using System.Threading.Tasks;
  7. using System.Globalization;
  8. using System.Linq;
  9. using MediaBrowser.Model.Dto;
  10. using MediaBrowser.Controller.Localization;
  11. using MediaBrowser.Controller.Entities.Movies;
  12. using MediaBrowser.Controller.Persistence;
  13. using MediaBrowser.Api.UserLibrary;
  14. using MediaBrowser.Controller.Collections;
  15. using MediaBrowser.Controller.Entities.TV;
  16. using System;
  17. using MediaBrowser.Controller.Entities.Audio;
  18. using MediaBrowser.Model.Entities;
  19. using MediaBrowser.Controller.Net;
  20. using MediaBrowser.Model.Activity;
  21. using MediaBrowser.Controller.Activity;
  22. using System.IO;
  23. using System.Text;
  24. namespace MediaBrowser.Api.Reports
  25. {
  26. /// <summary> The reports service. </summary>
  27. /// <seealso cref="T:MediaBrowser.Api.BaseApiService"/>
  28. public class ReportsService : BaseApiService
  29. {
  30. /// <summary> Manager for user. </summary>
  31. private readonly IUserManager _userManager;
  32. /// <summary> Manager for library. </summary>
  33. private readonly ILibraryManager _libraryManager;
  34. /// <summary> The localization. </summary>
  35. private readonly ILocalizationManager _localization;
  36. /// <summary>
  37. /// Initializes a new instance of the MediaBrowser.Api.Reports.ReportsService class. </summary>
  38. /// <param name="userManager"> Manager for user. </param>
  39. /// <param name="libraryManager"> Manager for library. </param>
  40. /// <param name="localization"> The localization. </param>
  41. public ReportsService(IUserManager userManager, ILibraryManager libraryManager, ILocalizationManager localization)
  42. {
  43. _userManager = userManager;
  44. _libraryManager = libraryManager;
  45. _localization = localization;
  46. }
  47. /// <summary> Gets the given request. </summary>
  48. /// <param name="request"> The request. </param>
  49. /// <returns> A Task&lt;object&gt; </returns>
  50. public async Task<object> Get(GetReportHeaders request)
  51. {
  52. if (string.IsNullOrEmpty(request.IncludeItemTypes))
  53. return null;
  54. ReportViewType reportRowType = ReportHelper.GetRowType(request.IncludeItemTypes);
  55. ReportBuilder reportBuilder = new ReportBuilder(_libraryManager);
  56. var reportResult = reportBuilder.GetReportHeaders(reportRowType, request);
  57. return ToOptimizedResult(reportResult);
  58. }
  59. /// <summary> Gets the given request. </summary>
  60. /// <param name="request"> The request. </param>
  61. /// <returns> A Task&lt;object&gt; </returns>
  62. public async Task<object> Get(GetItemReport request)
  63. {
  64. if (string.IsNullOrEmpty(request.IncludeItemTypes))
  65. return null;
  66. var reportResult = await GetReportResult(request);
  67. return ToOptimizedResult(reportResult);
  68. }
  69. /// <summary> Gets the given request. </summary>
  70. /// <param name="request"> The request. </param>
  71. /// <returns> A Task&lt;object&gt; </returns>
  72. public async Task<object> Get(GetReportDownload request)
  73. {
  74. if (string.IsNullOrEmpty(request.IncludeItemTypes))
  75. return null;
  76. var headers = new Dictionary<string, string>();
  77. string fileExtension = "csv";
  78. string contentType = "text/plain;charset='utf-8'";
  79. switch (request.ExportType)
  80. {
  81. case ReportExportType.CSV:
  82. break;
  83. case ReportExportType.Excel:
  84. contentType = "application/vnd.ms-excel";
  85. fileExtension = "xls";
  86. break;
  87. }
  88. var filename = "ReportExport." + fileExtension;
  89. headers["Content-Disposition"] = string.Format("attachment; filename=\"{0}\"", filename);
  90. headers["Content-Encoding"] = "UTF-8";
  91. ReportViewType reportRowType = ReportHelper.GetRowType(request.IncludeItemTypes);
  92. ReportBuilder reportBuilder = new ReportBuilder(_libraryManager);
  93. QueryResult<BaseItem> queryResult = await GetQueryResult(request).ConfigureAwait(false);
  94. ReportResult reportResult = reportBuilder.GetReportResult(queryResult.Items, reportRowType, request);
  95. reportResult.TotalRecordCount = queryResult.TotalRecordCount;
  96. string result = string.Empty;
  97. switch (request.ExportType)
  98. {
  99. case ReportExportType.CSV:
  100. result = new ReportExport().ExportToCsv(reportResult);
  101. break;
  102. case ReportExportType.Excel:
  103. result = new ReportExport().ExportToExcel(reportResult);
  104. break;
  105. }
  106. object ro = ResultFactory.GetResult(result, contentType, headers);
  107. return ro;
  108. }
  109. /// <summary> Gets the given request. </summary>
  110. /// <param name="request"> The request. </param>
  111. /// <returns> A Task&lt;object&gt; </returns>
  112. public async Task<object> Get(GetReportStatistics request)
  113. {
  114. if (string.IsNullOrEmpty(request.IncludeItemTypes))
  115. return null;
  116. var reportResult = await GetReportStatistic(request);
  117. return ToOptimizedResult(reportResult);
  118. }
  119. /// <summary> Gets report statistic. </summary>
  120. /// <param name="request"> The request. </param>
  121. /// <returns> The report statistic. </returns>
  122. private async Task<ReportStatResult> GetReportStatistic(GetReportStatistics request)
  123. {
  124. ReportViewType reportRowType = ReportHelper.GetRowType(request.IncludeItemTypes);
  125. QueryResult<BaseItem> queryResult = await GetQueryResult(request).ConfigureAwait(false);
  126. ReportStatBuilder reportBuilder = new ReportStatBuilder(_libraryManager);
  127. ReportStatResult reportResult = reportBuilder.GetReportStatResult(queryResult.Items, ReportHelper.GetRowType(request.IncludeItemTypes), request.TopItems ?? 5);
  128. reportResult.TotalRecordCount = reportResult.Groups.Count();
  129. return reportResult;
  130. }
  131. /// <summary> Gets report result. </summary>
  132. /// <param name="request"> The request. </param>
  133. /// <returns> The report result. </returns>
  134. private async Task<ReportResult> GetReportResult(GetItemReport request)
  135. {
  136. ReportViewType reportRowType = ReportHelper.GetRowType(request.IncludeItemTypes);
  137. ReportBuilder reportBuilder = new ReportBuilder(_libraryManager);
  138. QueryResult<BaseItem> queryResult = await GetQueryResult(request).ConfigureAwait(false);
  139. ReportResult reportResult = reportBuilder.GetReportResult(queryResult.Items, reportRowType, request);
  140. reportResult.TotalRecordCount = queryResult.TotalRecordCount;
  141. return reportResult;
  142. }
  143. /// <summary> Gets query result. </summary>
  144. /// <param name="request"> The request. </param>
  145. /// <returns> The query result. </returns>
  146. private async Task<QueryResult<BaseItem>> GetQueryResult(BaseReportRequest request)
  147. {
  148. // Placeholder in case needed later
  149. request.Recursive = true;
  150. var user = !string.IsNullOrWhiteSpace(request.UserId) ? _userManager.GetUserById(request.UserId) : null;
  151. request.Fields = "MediaSources,DateCreated,Settings,Studios,SyncInfo,ItemCounts";
  152. var parentItem = string.IsNullOrEmpty(request.ParentId) ?
  153. (user == null ? _libraryManager.RootFolder : user.RootFolder) :
  154. _libraryManager.GetItemById(request.ParentId);
  155. var item = string.IsNullOrEmpty(request.ParentId) ?
  156. user == null ? _libraryManager.RootFolder : user.RootFolder :
  157. parentItem;
  158. IEnumerable<BaseItem> items;
  159. if (request.Recursive)
  160. {
  161. var result = await ((Folder)item).GetItems(GetItemsQuery(request, user)).ConfigureAwait(false);
  162. return result;
  163. }
  164. else
  165. {
  166. if (user == null)
  167. {
  168. var result = await ((Folder)item).GetItems(GetItemsQuery(request, null)).ConfigureAwait(false);
  169. return result;
  170. }
  171. var userRoot = item as UserRootFolder;
  172. if (userRoot == null)
  173. {
  174. var result = await ((Folder)item).GetItems(GetItemsQuery(request, user)).ConfigureAwait(false);
  175. return result;
  176. }
  177. items = ((Folder)item).GetChildren(user, true);
  178. }
  179. return new QueryResult<BaseItem> { Items = items.ToArray() };
  180. }
  181. /// <summary> Gets items query. </summary>
  182. /// <param name="request"> The request. </param>
  183. /// <param name="user"> The user. </param>
  184. /// <returns> The items query. </returns>
  185. private InternalItemsQuery GetItemsQuery(BaseReportRequest request, User user)
  186. {
  187. var query = new InternalItemsQuery
  188. {
  189. User = user,
  190. IsPlayed = request.IsPlayed,
  191. MediaTypes = request.GetMediaTypes(),
  192. IncludeItemTypes = request.GetIncludeItemTypes(),
  193. ExcludeItemTypes = request.GetExcludeItemTypes(),
  194. Recursive = true,
  195. SortBy = request.GetOrderBy(),
  196. SortOrder = request.SortOrder ?? SortOrder.Ascending,
  197. Filter = i => ApplyAdditionalFilters(request, i, user, true, _libraryManager),
  198. StartIndex = request.StartIndex,
  199. IsMissing = request.IsMissing,
  200. IsVirtualUnaired = request.IsVirtualUnaired,
  201. IsUnaired = request.IsUnaired,
  202. CollapseBoxSetItems = request.CollapseBoxSetItems,
  203. NameLessThan = request.NameLessThan,
  204. NameStartsWith = request.NameStartsWith,
  205. NameStartsWithOrGreater = request.NameStartsWithOrGreater,
  206. HasImdbId = request.HasImdbId,
  207. IsYearMismatched = request.IsYearMismatched,
  208. IsUnidentified = request.IsUnidentified,
  209. IsPlaceHolder = request.IsPlaceHolder,
  210. IsLocked = request.IsLocked,
  211. IsInBoxSet = request.IsInBoxSet,
  212. IsHD = request.IsHD,
  213. Is3D = request.Is3D,
  214. HasTvdbId = request.HasTvdbId,
  215. HasTmdbId = request.HasTmdbId,
  216. HasOverview = request.HasOverview,
  217. HasOfficialRating = request.HasOfficialRating,
  218. HasParentalRating = request.HasParentalRating,
  219. HasSpecialFeature = request.HasSpecialFeature,
  220. HasSubtitles = request.HasSubtitles,
  221. HasThemeSong = request.HasThemeSong,
  222. HasThemeVideo = request.HasThemeVideo,
  223. HasTrailer = request.HasTrailer,
  224. Tags = request.GetTags(),
  225. OfficialRatings = request.GetOfficialRatings(),
  226. Genres = request.GetGenres(),
  227. Studios = request.GetStudios(),
  228. StudioIds = request.GetStudioIds(),
  229. Person = request.Person,
  230. PersonIds = request.GetPersonIds(),
  231. PersonTypes = request.GetPersonTypes(),
  232. Years = request.GetYears(),
  233. ImageTypes = request.GetImageTypes().ToArray(),
  234. VideoTypes = request.GetVideoTypes().ToArray(),
  235. AdjacentTo = request.AdjacentTo
  236. };
  237. if (!string.IsNullOrWhiteSpace(request.Ids))
  238. {
  239. query.CollapseBoxSetItems = false;
  240. }
  241. foreach (var filter in request.GetFilters())
  242. {
  243. switch (filter)
  244. {
  245. case ItemFilter.Dislikes:
  246. query.IsLiked = false;
  247. break;
  248. case ItemFilter.IsFavorite:
  249. query.IsFavorite = true;
  250. break;
  251. case ItemFilter.IsFavoriteOrLikes:
  252. query.IsFavoriteOrLiked = true;
  253. break;
  254. case ItemFilter.IsFolder:
  255. query.IsFolder = true;
  256. break;
  257. case ItemFilter.IsNotFolder:
  258. query.IsFolder = false;
  259. break;
  260. case ItemFilter.IsPlayed:
  261. query.IsPlayed = true;
  262. break;
  263. case ItemFilter.IsRecentlyAdded:
  264. break;
  265. case ItemFilter.IsResumable:
  266. query.IsResumable = true;
  267. break;
  268. case ItemFilter.IsUnplayed:
  269. query.IsPlayed = false;
  270. break;
  271. case ItemFilter.Likes:
  272. query.IsLiked = true;
  273. break;
  274. }
  275. }
  276. if (request.HasQueryLimit)
  277. query.Limit = request.Limit;
  278. return query;
  279. }
  280. /// <summary> Applies filtering. </summary>
  281. /// <param name="items"> The items. </param>
  282. /// <param name="filter"> The filter. </param>
  283. /// <param name="user"> The user. </param>
  284. /// <param name="repository"> The repository. </param>
  285. /// <returns> IEnumerable{BaseItem}. </returns>
  286. internal static IEnumerable<BaseItem> ApplyFilter(IEnumerable<BaseItem> items, ItemFilter filter, User user, IUserDataManager repository)
  287. {
  288. // Avoid implicitly captured closure
  289. var currentUser = user;
  290. switch (filter)
  291. {
  292. case ItemFilter.IsFavoriteOrLikes:
  293. return items.Where(item =>
  294. {
  295. var userdata = repository.GetUserData(user.Id, item.GetUserDataKey());
  296. if (userdata == null)
  297. {
  298. return false;
  299. }
  300. var likes = userdata.Likes ?? false;
  301. var favorite = userdata.IsFavorite;
  302. return likes || favorite;
  303. });
  304. case ItemFilter.Likes:
  305. return items.Where(item =>
  306. {
  307. var userdata = repository.GetUserData(user.Id, item.GetUserDataKey());
  308. return userdata != null && userdata.Likes.HasValue && userdata.Likes.Value;
  309. });
  310. case ItemFilter.Dislikes:
  311. return items.Where(item =>
  312. {
  313. var userdata = repository.GetUserData(user.Id, item.GetUserDataKey());
  314. return userdata != null && userdata.Likes.HasValue && !userdata.Likes.Value;
  315. });
  316. case ItemFilter.IsFavorite:
  317. return items.Where(item =>
  318. {
  319. var userdata = repository.GetUserData(user.Id, item.GetUserDataKey());
  320. return userdata != null && userdata.IsFavorite;
  321. });
  322. case ItemFilter.IsResumable:
  323. return items.Where(item =>
  324. {
  325. var userdata = repository.GetUserData(user.Id, item.GetUserDataKey());
  326. return userdata != null && userdata.PlaybackPositionTicks > 0;
  327. });
  328. case ItemFilter.IsPlayed:
  329. return items.Where(item => item.IsPlayed(currentUser));
  330. case ItemFilter.IsUnplayed:
  331. return items.Where(item => item.IsUnplayed(currentUser));
  332. case ItemFilter.IsFolder:
  333. return items.Where(item => item.IsFolder);
  334. case ItemFilter.IsNotFolder:
  335. return items.Where(item => !item.IsFolder);
  336. case ItemFilter.IsRecentlyAdded:
  337. return items.Where(item => (DateTime.UtcNow - item.DateCreated).TotalDays <= 10);
  338. }
  339. return items;
  340. }
  341. /// <summary> Applies the additional filters. </summary>
  342. /// <param name="request"> The request. </param>
  343. /// <param name="i"> Zero-based index of the. </param>
  344. /// <param name="user"> The user. </param>
  345. /// <param name="isPreFiltered"> true if this object is pre filtered. </param>
  346. /// <param name="libraryManager"> Manager for library. </param>
  347. /// <returns> true if it succeeds, false if it fails. </returns>
  348. private bool ApplyAdditionalFilters(BaseReportRequest request, BaseItem i, User user, bool isPreFiltered, ILibraryManager libraryManager)
  349. {
  350. var video = i as Video;
  351. if (!isPreFiltered)
  352. {
  353. var mediaTypes = request.GetMediaTypes();
  354. if (mediaTypes.Length > 0)
  355. {
  356. if (!(!string.IsNullOrEmpty(i.MediaType) && mediaTypes.Contains(i.MediaType, StringComparer.OrdinalIgnoreCase)))
  357. {
  358. return false;
  359. }
  360. }
  361. if (request.IsPlayed.HasValue)
  362. {
  363. var val = request.IsPlayed.Value;
  364. if (i.IsPlayed(user) != val)
  365. {
  366. return false;
  367. }
  368. }
  369. // Exclude item types
  370. var excluteItemTypes = request.GetExcludeItemTypes();
  371. if (excluteItemTypes.Length > 0 && excluteItemTypes.Contains(i.GetType().Name, StringComparer.OrdinalIgnoreCase))
  372. {
  373. return false;
  374. }
  375. // Include item types
  376. var includeItemTypes = request.GetIncludeItemTypes();
  377. if (includeItemTypes.Length > 0 && !includeItemTypes.Contains(i.GetType().Name, StringComparer.OrdinalIgnoreCase))
  378. {
  379. return false;
  380. }
  381. if (request.IsInBoxSet.HasValue)
  382. {
  383. var val = request.IsInBoxSet.Value;
  384. if (i.Parents.OfType<BoxSet>().Any() != val)
  385. {
  386. return false;
  387. }
  388. }
  389. // Filter by Video3DFormat
  390. if (request.Is3D.HasValue)
  391. {
  392. var val = request.Is3D.Value;
  393. if (video == null || val != video.Video3DFormat.HasValue)
  394. {
  395. return false;
  396. }
  397. }
  398. if (request.IsHD.HasValue)
  399. {
  400. var val = request.IsHD.Value;
  401. if (video == null || val != video.IsHD)
  402. {
  403. return false;
  404. }
  405. }
  406. if (request.IsUnidentified.HasValue)
  407. {
  408. var val = request.IsUnidentified.Value;
  409. if (i.IsUnidentified != val)
  410. {
  411. return false;
  412. }
  413. }
  414. if (request.IsLocked.HasValue)
  415. {
  416. var val = request.IsLocked.Value;
  417. if (i.IsLocked != val)
  418. {
  419. return false;
  420. }
  421. }
  422. if (request.HasOverview.HasValue)
  423. {
  424. var filterValue = request.HasOverview.Value;
  425. var hasValue = !string.IsNullOrEmpty(i.Overview);
  426. if (hasValue != filterValue)
  427. {
  428. return false;
  429. }
  430. }
  431. if (request.HasImdbId.HasValue)
  432. {
  433. var filterValue = request.HasImdbId.Value;
  434. var hasValue = !string.IsNullOrEmpty(i.GetProviderId(MetadataProviders.Imdb));
  435. if (hasValue != filterValue)
  436. {
  437. return false;
  438. }
  439. }
  440. if (request.HasTmdbId.HasValue)
  441. {
  442. var filterValue = request.HasTmdbId.Value;
  443. var hasValue = !string.IsNullOrEmpty(i.GetProviderId(MetadataProviders.Tmdb));
  444. if (hasValue != filterValue)
  445. {
  446. return false;
  447. }
  448. }
  449. if (request.HasTvdbId.HasValue)
  450. {
  451. var filterValue = request.HasTvdbId.Value;
  452. var hasValue = !string.IsNullOrEmpty(i.GetProviderId(MetadataProviders.Tvdb));
  453. if (hasValue != filterValue)
  454. {
  455. return false;
  456. }
  457. }
  458. if (request.IsYearMismatched.HasValue)
  459. {
  460. var filterValue = request.IsYearMismatched.Value;
  461. if (UserViewBuilder.IsYearMismatched(i, libraryManager) != filterValue)
  462. {
  463. return false;
  464. }
  465. }
  466. if (request.HasOfficialRating.HasValue)
  467. {
  468. var filterValue = request.HasOfficialRating.Value;
  469. var hasValue = !string.IsNullOrEmpty(i.OfficialRating);
  470. if (hasValue != filterValue)
  471. {
  472. return false;
  473. }
  474. }
  475. if (request.IsPlaceHolder.HasValue)
  476. {
  477. var filterValue = request.IsPlaceHolder.Value;
  478. var isPlaceHolder = false;
  479. var hasPlaceHolder = i as ISupportsPlaceHolders;
  480. if (hasPlaceHolder != null)
  481. {
  482. isPlaceHolder = hasPlaceHolder.IsPlaceHolder;
  483. }
  484. if (isPlaceHolder != filterValue)
  485. {
  486. return false;
  487. }
  488. }
  489. if (request.HasSpecialFeature.HasValue)
  490. {
  491. var filterValue = request.HasSpecialFeature.Value;
  492. var movie = i as IHasSpecialFeatures;
  493. if (movie != null)
  494. {
  495. var ok = filterValue
  496. ? movie.SpecialFeatureIds.Count > 0
  497. : movie.SpecialFeatureIds.Count == 0;
  498. if (!ok)
  499. {
  500. return false;
  501. }
  502. }
  503. else
  504. {
  505. return false;
  506. }
  507. }
  508. if (request.HasSubtitles.HasValue)
  509. {
  510. var val = request.HasSubtitles.Value;
  511. if (video == null || val != video.HasSubtitles)
  512. {
  513. return false;
  514. }
  515. }
  516. if (request.HasParentalRating.HasValue)
  517. {
  518. var val = request.HasParentalRating.Value;
  519. var rating = i.CustomRating;
  520. if (string.IsNullOrEmpty(rating))
  521. {
  522. rating = i.OfficialRating;
  523. }
  524. if (val)
  525. {
  526. if (string.IsNullOrEmpty(rating))
  527. {
  528. return false;
  529. }
  530. }
  531. else
  532. {
  533. if (!string.IsNullOrEmpty(rating))
  534. {
  535. return false;
  536. }
  537. }
  538. }
  539. if (request.HasTrailer.HasValue)
  540. {
  541. var val = request.HasTrailer.Value;
  542. var trailerCount = 0;
  543. var hasTrailers = i as IHasTrailers;
  544. if (hasTrailers != null)
  545. {
  546. trailerCount = hasTrailers.GetTrailerIds().Count;
  547. }
  548. var ok = val ? trailerCount > 0 : trailerCount == 0;
  549. if (!ok)
  550. {
  551. return false;
  552. }
  553. }
  554. if (request.HasThemeSong.HasValue)
  555. {
  556. var filterValue = request.HasThemeSong.Value;
  557. var themeCount = 0;
  558. var iHasThemeMedia = i as IHasThemeMedia;
  559. if (iHasThemeMedia != null)
  560. {
  561. themeCount = iHasThemeMedia.ThemeSongIds.Count;
  562. }
  563. var ok = filterValue ? themeCount > 0 : themeCount == 0;
  564. if (!ok)
  565. {
  566. return false;
  567. }
  568. }
  569. if (request.HasThemeVideo.HasValue)
  570. {
  571. var filterValue = request.HasThemeVideo.Value;
  572. var themeCount = 0;
  573. var iHasThemeMedia = i as IHasThemeMedia;
  574. if (iHasThemeMedia != null)
  575. {
  576. themeCount = iHasThemeMedia.ThemeVideoIds.Count;
  577. }
  578. var ok = filterValue ? themeCount > 0 : themeCount == 0;
  579. if (!ok)
  580. {
  581. return false;
  582. }
  583. }
  584. // Apply tag filter
  585. var tags = request.GetTags();
  586. if (tags.Length > 0)
  587. {
  588. var hasTags = i as IHasTags;
  589. if (hasTags == null)
  590. {
  591. return false;
  592. }
  593. if (!(tags.Any(v => hasTags.Tags.Contains(v, StringComparer.OrdinalIgnoreCase))))
  594. {
  595. return false;
  596. }
  597. }
  598. // Apply official rating filter
  599. var officialRatings = request.GetOfficialRatings();
  600. if (officialRatings.Length > 0 && !officialRatings.Contains(i.OfficialRating ?? string.Empty))
  601. {
  602. return false;
  603. }
  604. // Apply genre filter
  605. var genres = request.GetGenres();
  606. if (genres.Length > 0 && !(genres.Any(v => i.Genres.Contains(v, StringComparer.OrdinalIgnoreCase))))
  607. {
  608. return false;
  609. }
  610. // Filter by VideoType
  611. var videoTypes = request.GetVideoTypes();
  612. if (videoTypes.Length > 0 && (video == null || !videoTypes.Contains(video.VideoType)))
  613. {
  614. return false;
  615. }
  616. var imageTypes = request.GetImageTypes().ToList();
  617. if (imageTypes.Count > 0)
  618. {
  619. if (!(imageTypes.Any(i.HasImage)))
  620. {
  621. return false;
  622. }
  623. }
  624. // Apply studio filter
  625. var studios = request.GetStudios();
  626. if (studios.Length > 0 && !studios.Any(v => i.Studios.Contains(v, StringComparer.OrdinalIgnoreCase)))
  627. {
  628. return false;
  629. }
  630. // Apply studio filter
  631. var studioIds = request.GetStudioIds();
  632. if (studioIds.Length > 0 && !studioIds.Any(id =>
  633. {
  634. var studioItem = libraryManager.GetItemById(id);
  635. return studioItem != null && i.Studios.Contains(studioItem.Name, StringComparer.OrdinalIgnoreCase);
  636. }))
  637. {
  638. return false;
  639. }
  640. // Apply year filter
  641. var years = request.GetYears();
  642. if (years.Length > 0 && !(i.ProductionYear.HasValue && years.Contains(i.ProductionYear.Value)))
  643. {
  644. return false;
  645. }
  646. // Apply person filter
  647. var personIds = request.GetPersonIds();
  648. if (personIds.Length > 0)
  649. {
  650. var names = personIds
  651. .Select(libraryManager.GetItemById)
  652. .Select(p => p == null ? "-1" : p.Name)
  653. .ToList();
  654. if (!(names.Any(v => _libraryManager.GetPeople(i).Select(p => p.Name).Contains(v, StringComparer.OrdinalIgnoreCase))))
  655. {
  656. return false;
  657. }
  658. }
  659. // Apply person filter
  660. if (!string.IsNullOrEmpty(request.Person))
  661. {
  662. var personTypes = request.GetPersonTypes();
  663. if (personTypes.Length == 0)
  664. {
  665. if (!(_libraryManager.GetPeople(i).Any(p => string.Equals(p.Name, request.Person, StringComparison.OrdinalIgnoreCase))))
  666. {
  667. return false;
  668. }
  669. }
  670. else
  671. {
  672. var types = personTypes;
  673. var ok = new[] { i }.Any(item =>
  674. _libraryManager.GetPeople(i).Any(p =>
  675. p.Name.Equals(request.Person, StringComparison.OrdinalIgnoreCase) && (types.Contains(p.Type, StringComparer.OrdinalIgnoreCase) || types.Contains(p.Role, StringComparer.OrdinalIgnoreCase))));
  676. if (!ok)
  677. {
  678. return false;
  679. }
  680. }
  681. }
  682. }
  683. if (request.MinCommunityRating.HasValue)
  684. {
  685. var val = request.MinCommunityRating.Value;
  686. if (!(i.CommunityRating.HasValue && i.CommunityRating >= val))
  687. {
  688. return false;
  689. }
  690. }
  691. if (request.MinCriticRating.HasValue)
  692. {
  693. var val = request.MinCriticRating.Value;
  694. var hasCriticRating = i as IHasCriticRating;
  695. if (hasCriticRating != null)
  696. {
  697. if (!(hasCriticRating.CriticRating.HasValue && hasCriticRating.CriticRating >= val))
  698. {
  699. return false;
  700. }
  701. }
  702. else
  703. {
  704. return false;
  705. }
  706. }
  707. // Artists
  708. if (!string.IsNullOrEmpty(request.ArtistIds))
  709. {
  710. var artistIds = request.ArtistIds.Split('|');
  711. var audio = i as IHasArtist;
  712. if (!(audio != null && artistIds.Any(id =>
  713. {
  714. var artistItem = libraryManager.GetItemById(id);
  715. return artistItem != null && audio.HasAnyArtist(artistItem.Name);
  716. })))
  717. {
  718. return false;
  719. }
  720. }
  721. // Artists
  722. if (!string.IsNullOrEmpty(request.Artists))
  723. {
  724. var artists = request.Artists.Split('|');
  725. var audio = i as IHasArtist;
  726. if (!(audio != null && artists.Any(audio.HasAnyArtist)))
  727. {
  728. return false;
  729. }
  730. }
  731. // Albums
  732. if (!string.IsNullOrEmpty(request.Albums))
  733. {
  734. var albums = request.Albums.Split('|');
  735. var audio = i as Audio;
  736. if (audio != null)
  737. {
  738. if (!albums.Any(a => string.Equals(a, audio.Album, StringComparison.OrdinalIgnoreCase)))
  739. {
  740. return false;
  741. }
  742. }
  743. var album = i as MusicAlbum;
  744. if (album != null)
  745. {
  746. if (!albums.Any(a => string.Equals(a, album.Name, StringComparison.OrdinalIgnoreCase)))
  747. {
  748. return false;
  749. }
  750. }
  751. var musicVideo = i as MusicVideo;
  752. if (musicVideo != null)
  753. {
  754. if (!albums.Any(a => string.Equals(a, musicVideo.Album, StringComparison.OrdinalIgnoreCase)))
  755. {
  756. return false;
  757. }
  758. }
  759. return false;
  760. }
  761. // Min index number
  762. if (request.MinIndexNumber.HasValue)
  763. {
  764. if (!(i.IndexNumber.HasValue && i.IndexNumber.Value >= request.MinIndexNumber.Value))
  765. {
  766. return false;
  767. }
  768. }
  769. // Min official rating
  770. if (!string.IsNullOrEmpty(request.MinOfficialRating))
  771. {
  772. var level = _localization.GetRatingLevel(request.MinOfficialRating);
  773. if (level.HasValue)
  774. {
  775. var rating = i.CustomRating;
  776. if (string.IsNullOrEmpty(rating))
  777. {
  778. rating = i.OfficialRating;
  779. }
  780. if (!string.IsNullOrEmpty(rating))
  781. {
  782. var itemLevel = _localization.GetRatingLevel(rating);
  783. if (!(!itemLevel.HasValue || itemLevel.Value >= level.Value))
  784. {
  785. return false;
  786. }
  787. }
  788. }
  789. }
  790. // Max official rating
  791. if (!string.IsNullOrEmpty(request.MaxOfficialRating))
  792. {
  793. var level = _localization.GetRatingLevel(request.MaxOfficialRating);
  794. if (level.HasValue)
  795. {
  796. var rating = i.CustomRating;
  797. if (string.IsNullOrEmpty(rating))
  798. {
  799. rating = i.OfficialRating;
  800. }
  801. if (!string.IsNullOrEmpty(rating))
  802. {
  803. var itemLevel = _localization.GetRatingLevel(rating);
  804. if (!(!itemLevel.HasValue || itemLevel.Value <= level.Value))
  805. {
  806. return false;
  807. }
  808. }
  809. }
  810. }
  811. // LocationTypes
  812. if (!string.IsNullOrEmpty(request.LocationTypes))
  813. {
  814. var vals = request.LocationTypes.Split(',');
  815. if (!vals.Contains(i.LocationType.ToString(), StringComparer.OrdinalIgnoreCase))
  816. {
  817. return false;
  818. }
  819. }
  820. // ExcludeLocationTypes
  821. if (!string.IsNullOrEmpty(request.ExcludeLocationTypes))
  822. {
  823. var vals = request.ExcludeLocationTypes.Split(',');
  824. if (vals.Contains(i.LocationType.ToString(), StringComparer.OrdinalIgnoreCase))
  825. {
  826. return false;
  827. }
  828. }
  829. if (!string.IsNullOrEmpty(request.AlbumArtistStartsWithOrGreater))
  830. {
  831. var ok = new[] { i }.OfType<IHasAlbumArtist>()
  832. .Any(p => string.Compare(request.AlbumArtistStartsWithOrGreater, p.AlbumArtists.FirstOrDefault(), StringComparison.CurrentCultureIgnoreCase) < 1);
  833. if (!ok)
  834. {
  835. return false;
  836. }
  837. }
  838. // Filter by Series Status
  839. if (!string.IsNullOrEmpty(request.SeriesStatus))
  840. {
  841. var vals = request.SeriesStatus.Split(',');
  842. var ok = new[] { i }.OfType<Series>().Any(p => p.Status.HasValue && vals.Contains(p.Status.Value.ToString(), StringComparer.OrdinalIgnoreCase));
  843. if (!ok)
  844. {
  845. return false;
  846. }
  847. }
  848. // Filter by Series AirDays
  849. if (!string.IsNullOrEmpty(request.AirDays))
  850. {
  851. var days = request.AirDays.Split(',').Select(d => (DayOfWeek)Enum.Parse(typeof(DayOfWeek), d, true));
  852. var ok = new[] { i }.OfType<Series>().Any(p => p.AirDays != null && days.Any(d => p.AirDays.Contains(d)));
  853. if (!ok)
  854. {
  855. return false;
  856. }
  857. }
  858. if (request.MinPlayers.HasValue)
  859. {
  860. var filterValue = request.MinPlayers.Value;
  861. var game = i as Game;
  862. if (game != null)
  863. {
  864. var players = game.PlayersSupported ?? 1;
  865. var ok = players >= filterValue;
  866. if (!ok)
  867. {
  868. return false;
  869. }
  870. }
  871. else
  872. {
  873. return false;
  874. }
  875. }
  876. if (request.MaxPlayers.HasValue)
  877. {
  878. var filterValue = request.MaxPlayers.Value;
  879. var game = i as Game;
  880. if (game != null)
  881. {
  882. var players = game.PlayersSupported ?? 1;
  883. var ok = players <= filterValue;
  884. if (!ok)
  885. {
  886. return false;
  887. }
  888. }
  889. else
  890. {
  891. return false;
  892. }
  893. }
  894. if (request.ParentIndexNumber.HasValue)
  895. {
  896. var filterValue = request.ParentIndexNumber.Value;
  897. var episode = i as Episode;
  898. if (episode != null)
  899. {
  900. if (episode.ParentIndexNumber.HasValue && episode.ParentIndexNumber.Value != filterValue)
  901. {
  902. return false;
  903. }
  904. }
  905. var song = i as Audio;
  906. if (song != null)
  907. {
  908. if (song.ParentIndexNumber.HasValue && song.ParentIndexNumber.Value != filterValue)
  909. {
  910. return false;
  911. }
  912. }
  913. }
  914. if (request.AiredDuringSeason.HasValue)
  915. {
  916. var episode = i as Episode;
  917. if (episode == null)
  918. {
  919. return false;
  920. }
  921. if (!Series.FilterEpisodesBySeason(new[] { episode }, request.AiredDuringSeason.Value, true).Any())
  922. {
  923. return false;
  924. }
  925. }
  926. if (!string.IsNullOrEmpty(request.MinPremiereDate))
  927. {
  928. var date = DateTime.Parse(request.MinPremiereDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  929. if (!(i.PremiereDate.HasValue && i.PremiereDate.Value >= date))
  930. {
  931. return false;
  932. }
  933. }
  934. if (!string.IsNullOrEmpty(request.MaxPremiereDate))
  935. {
  936. var date = DateTime.Parse(request.MaxPremiereDate, null, DateTimeStyles.RoundtripKind).ToUniversalTime();
  937. if (!(i.PremiereDate.HasValue && i.PremiereDate.Value <= date))
  938. {
  939. return false;
  940. }
  941. }
  942. return true;
  943. }
  944. /// <summary> Applies the paging. </summary>
  945. /// <param name="request"> The request. </param>
  946. /// <param name="items"> The items. </param>
  947. /// <returns> IEnumerable{BaseItem}. </returns>
  948. private IEnumerable<BaseItem> ApplyPaging(GetItems request, IEnumerable<BaseItem> items)
  949. {
  950. // Start at
  951. if (request.StartIndex.HasValue)
  952. {
  953. items = items.Skip(request.StartIndex.Value);
  954. }
  955. // Return limit
  956. if (request.Limit.HasValue)
  957. {
  958. items = items.Take(request.Limit.Value);
  959. }
  960. return items;
  961. }
  962. }
  963. }