ReportsService.cs 44 KB

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