github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-07-15 09:42:57 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Optimize home stats queries

Browse source
This commit is contained in:
JonnyWong16 2021-03-27 19:49:44 -07:00
parent 6b9cbc0a7a
commit dca5a534fd
No known key found for this signature in database
GPG key ID: B1F1F9807184697A
1 changed files with 112 additions and 114 deletions
Download patch file Download diff file Expand all files Collapse all files

226
plexpy/datafactory.py
View file

@ -22,6 +22,7 @@ from future.builtins import str
from future.builtins import object from future.builtins import object
import json import json
from datetime import datetime, timedelta
from itertools import groupby from itertools import groupby
import plexpy import plexpy
@ -309,6 +310,9 @@ class DataFactory(object):
stats_start=0, stats_count=10, stat_id='', stats_cards=None): stats_start=0, stats_count=10, stat_id='', stats_cards=None):
monitor_db = database.MonitorDatabase() monitor_db = database.MonitorDatabase()
time_range = helpers.cast_to_int(time_range)
timestamp = int((datetime.now(tz=plexpy.SYS_TIMEZONE) - timedelta(days=time_range)).timestamp())
stats_start = helpers.cast_to_int(stats_start) stats_start = helpers.cast_to_int(stats_start)
stats_count = helpers.cast_to_int(stats_count) stats_count = helpers.cast_to_int(stats_count)
if stat_id: if stat_id:
@ -331,21 +335,20 @@ class DataFactory(object):
if stat == 'top_movies': if stat == 'top_movies':
top_movies = [] top_movies = []
try: try:
query = 'SELECT t.id, t.full_title, t.year, t.rating_key, t.thumb, t.section_id, ' \ query = 'SELECT sh.id, shm.full_title, shm.year, sh.rating_key, shm.thumb, shm.section_id, ' \
't.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.art, sh.media_type, shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) AS total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) AS total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "movie" ' \ ' AND session_history.media_type = "movie" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.full_title, t.year ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY %s DESC, started DESC ' \ 'GROUP BY shm.full_title, shm.year ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_movies: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_movies: %s." % e)
@ -384,22 +387,21 @@ class DataFactory(object):
elif stat == 'popular_movies': elif stat == 'popular_movies':
popular_movies = [] popular_movies = []
try: try:
query = 'SELECT t.id, t.full_title, t.year, t.rating_key, t.thumb, t.section_id, ' \ query = 'SELECT sh.id, shm.full_title, shm.year, sh.rating_key, shm.thumb, shm.section_id, ' \
't.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.art, sh.media_type, shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'COUNT(DISTINCT t.user_id) AS users_watched, ' \ 'COUNT(DISTINCT sh.user_id) AS users_watched, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) as total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) as total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "movie" ' \ ' AND session_history.media_type = "movie" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.full_title, t.year ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY users_watched DESC, %s DESC, started DESC ' \ 'GROUP BY shm.full_title, shm.year ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY users_watched DESC, %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_movies: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_movies: %s." % e)
@ -436,21 +438,22 @@ class DataFactory(object):
elif stat == 'top_tv': elif stat == 'top_tv':
top_tv = [] top_tv = []
try: try:
query = 'SELECT t.id, t.grandparent_title, t.grandparent_rating_key, t.grandparent_thumb, t.section_id, ' \ query = 'SELECT sh.id, shm.grandparent_title, sh.grandparent_rating_key, ' \
't.year, t.rating_key, t.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.grandparent_thumb, shm.section_id, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) AS total_plays, SUM(t.d) AS total_duration ' \ 'shm.year, sh.rating_key, shm.art, sh.media_type, ' \
'shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'MAX(sh.started) AS last_watch, COUNT(sh.id) AS total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "episode" ' \ ' AND session_history.media_type = "episode" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.grandparent_title ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY %s DESC, started DESC ' \ 'GROUP BY shm.grandparent_title ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_tv: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_tv: %s." % e)
@ -489,22 +492,23 @@ class DataFactory(object):
elif stat == 'popular_tv': elif stat == 'popular_tv':
popular_tv = [] popular_tv = []
try: try:
query = 'SELECT t.id, t.grandparent_title, t.grandparent_rating_key, t.grandparent_thumb, t.section_id, ' \ query = 'SELECT sh.id, shm.grandparent_title, sh.grandparent_rating_key, ' \
't.year, t.rating_key, t.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.grandparent_thumb, shm.section_id, ' \
'COUNT(DISTINCT t.user_id) AS users_watched, ' \ 'shm.year, sh.rating_key, shm.art, sh.media_type, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) as total_plays, SUM(t.d) AS total_duration ' \ 'shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'COUNT(DISTINCT sh.user_id) AS users_watched, ' \
'MAX(sh.started) AS last_watch, COUNT(sh.id) as total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "episode" ' \ ' AND session_history.media_type = "episode" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.grandparent_title ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY users_watched DESC, %s DESC, started DESC ' \ 'GROUP BY shm.grandparent_title ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY users_watched DESC, %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_tv: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_tv: %s." % e)
@ -541,22 +545,21 @@ class DataFactory(object):
elif stat == 'top_music': elif stat == 'top_music':
top_music = [] top_music = []
try: try:
query = 'SELECT t.id, t.grandparent_title, t.original_title, t.year, ' \ query = 'SELECT sh.id, shm.grandparent_title, shm.original_title, shm.year, ' \
't.grandparent_rating_key, t.grandparent_thumb, t.section_id, ' \ 'sh.grandparent_rating_key, shm.grandparent_thumb, shm.section_id, ' \
't.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.art, sh.media_type, shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) AS total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) AS total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "track" ' \ ' AND session_history.media_type = "track" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.original_title, t.grandparent_title ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY %s DESC, started DESC ' \ 'GROUP BY shm.original_title, shm.grandparent_title ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_music: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_music: %s." % e)
@ -595,23 +598,22 @@ class DataFactory(object):
elif stat == 'popular_music': elif stat == 'popular_music':
popular_music = [] popular_music = []
try: try:
query = 'SELECT t.id, t.grandparent_title, t.original_title, t.year, ' \ query = 'SELECT sh.id, shm.grandparent_title, shm.original_title, shm.year, ' \
't.grandparent_rating_key, t.grandparent_thumb, t.section_id, ' \ 'sh.grandparent_rating_key, shm.grandparent_thumb, shm.section_id, ' \
't.art, t.media_type, t.content_rating, t.labels, t.started, t.live, t.guid, ' \ 'shm.art, sh.media_type, shm.content_rating, shm.labels, sh.started, shm.live, shm.guid, ' \
'COUNT(DISTINCT t.user_id) AS users_watched, ' \ 'COUNT(DISTINCT sh.user_id) AS users_watched, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) as total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) as total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND session_history.media_type = "track" ' \ ' AND session_history.media_type = "track" ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'GROUP BY t.original_title, t.grandparent_title ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
'ORDER BY users_watched DESC, %s DESC, started DESC ' \ 'GROUP BY shm.original_title, shm.grandparent_title ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start) 'ORDER BY users_watched DESC, %s DESC, sh.started DESC ' \
'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_music: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: popular_music: %s." % e)
@ -721,22 +723,22 @@ class DataFactory(object):
elif stat == 'top_users': elif stat == 'top_users':
top_users = [] top_users = []
try: try:
query = 'SELECT t.user, t.user_id, t.user_thumb, t.custom_thumb, t.started, ' \ query = 'SELECT sh.user, sh.user_id, u.thumb AS user_thumb, u.custom_avatar_url AS custom_thumb, ' \
'(CASE WHEN t.friendly_name IS NULL THEN t.username ELSE t.friendly_name END) ' \ 'sh.started, ' \
'(CASE WHEN u.friendly_name IS NULL THEN u.username ELSE u.friendly_name END) ' \
' AS friendly_name, ' \ ' AS friendly_name, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) AS total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) AS total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d, users.thumb AS user_thumb, users.custom_avatar_url AS custom_thumb ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' LEFT OUTER JOIN users ON session_history.user_id = users.user_id ' \ ' GROUP BY %s) AS sh ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
' >= datetime("now", "-%s days", "localtime") ' \ 'LEFT OUTER JOIN users AS u ON sh.user_id = u.user_id ' \
' GROUP BY %s) AS t ' \ 'GROUP BY sh.user_id ' \
'GROUP BY t.user_id ' \ 'ORDER BY %s DESC, sh.started DESC ' \
'ORDER BY %s DESC, started DESC ' \ 'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_users: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_users: %s." % e)
@ -777,19 +779,17 @@ class DataFactory(object):
top_platform = [] top_platform = []
try: try:
query = 'SELECT t.platform, t.started, ' \ query = 'SELECT sh.platform, sh.started, ' \
'MAX(t.started) AS last_watch, COUNT(t.id) AS total_plays, SUM(t.d) AS total_duration ' \ 'MAX(sh.started) AS last_watch, COUNT(sh.id) AS total_plays, SUM(sh.d) AS total_duration ' \
'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \ 'FROM (SELECT *, SUM(CASE WHEN stopped > 0 THEN (stopped - started) - ' \
' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \ ' (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) ' \
' AS d ' \ ' AS d ' \
' FROM session_history ' \ ' FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \ ' GROUP BY %s) AS sh ' \
' >= datetime("now", "-%s days", "localtime") ' \ 'GROUP BY sh.platform ' \
' GROUP BY %s) AS t ' \ 'ORDER BY %s DESC, sh.started DESC ' \
'GROUP BY t.platform ' \ 'LIMIT %s OFFSET %s ' % (timestamp, group_by, sort_type, stats_count, stats_start)
'ORDER BY %s DESC, started DESC ' \
'LIMIT %s OFFSET %s ' % (time_range, group_by, sort_type, stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_platforms: %s." % e) logger.warn("Tautulli DataFactory :: Unable to execute database query for get_home_stats: top_platforms: %s." % e)
@ -826,30 +826,29 @@ class DataFactory(object):
elif stat == 'last_watched': elif stat == 'last_watched':
last_watched = [] last_watched = []
try: try:
query = 'SELECT t.id, t.title, t.grandparent_title, t.full_title, t.year, ' \ query = 'SELECT sh.id, shm.title, shm.grandparent_title, shm.full_title, shm.year, ' \
't.media_index, t.parent_media_index, ' \ 'shm.media_index, shm.parent_media_index, ' \
't.rating_key, t.grandparent_rating_key, t.thumb, t.grandparent_thumb, ' \ 'sh.rating_key, shm.grandparent_rating_key, shm.thumb, shm.grandparent_thumb, ' \
't.user, t.user_id, t.custom_avatar_url as user_thumb, t.player, t.section_id, ' \ 'sh.user, sh.user_id, u.custom_avatar_url as user_thumb, sh.player, shm.section_id, ' \
't.art, t.media_type, t.content_rating, t.labels, t.live, t.guid, ' \ 'shm.art, sh.media_type, shm.content_rating, shm.labels, shm.live, shm.guid, ' \
'(CASE WHEN t.friendly_name IS NULL THEN t.username ELSE t.friendly_name END) ' \ '(CASE WHEN u.friendly_name IS NULL THEN u.username ELSE u.friendly_name END) ' \
' AS friendly_name, ' \ ' AS friendly_name, ' \
'MAX(t.started) AS last_watch, ' \ 'MAX(sh.started) AS last_watch, ' \
'((CASE WHEN t.view_offset IS NULL THEN 0.1 ELSE t.view_offset * 1.0 END) / ' \ '((CASE WHEN sh.view_offset IS NULL THEN 0.1 ELSE sh.view_offset * 1.0 END) / ' \
' (CASE WHEN t.duration IS NULL THEN 1.0 ELSE t.duration * 1.0 END) * 100) ' \ ' (CASE WHEN shm.duration IS NULL THEN 1.0 ELSE shm.duration * 1.0 END) * 100) ' \
' AS percent_complete ' \ ' AS percent_complete ' \
'FROM (SELECT *, MAX(session_history.id) FROM session_history ' \ 'FROM (SELECT *, MAX(id) FROM session_history ' \
' JOIN session_history_metadata ON session_history_metadata.id = session_history.id ' \ ' WHERE session_history.stopped >= %s ' \
' LEFT OUTER JOIN users ON session_history.user_id = users.user_id ' \
' WHERE datetime(session_history.stopped, "unixepoch", "localtime") ' \
' >= datetime("now", "-%s days", "localtime") ' \
' AND (session_history.media_type = "movie" ' \ ' AND (session_history.media_type = "movie" ' \
' OR session_history_metadata.media_type = "episode") ' \ ' OR session_history.media_type = "episode") ' \
' GROUP BY %s) AS t ' \ ' GROUP BY %s) AS sh ' \
'WHERE t.media_type == "movie" AND percent_complete >= %s ' \ 'JOIN session_history_metadata AS shm ON shm.id = sh.id ' \
' OR t.media_type == "episode" AND percent_complete >= %s ' \ 'LEFT OUTER JOIN users AS u ON sh.user_id = u.user_id ' \
'GROUP BY t.id ' \ 'WHERE sh.media_type == "movie" AND percent_complete >= %s ' \
' OR sh.media_type == "episode" AND percent_complete >= %s ' \
'GROUP BY sh.id ' \
'ORDER BY last_watch DESC ' \ 'ORDER BY last_watch DESC ' \
'LIMIT %s OFFSET %s' % (time_range, group_by, movie_watched_percent, tv_watched_percent, 'LIMIT %s OFFSET %s' % (timestamp, group_by, movie_watched_percent, tv_watched_percent,
stats_count, stats_start) stats_count, stats_start)
result = monitor_db.select(query) result = monitor_db.select(query)
except Exception as e: except Exception as e:
@ -934,11 +933,10 @@ class DataFactory(object):
most_concurrent = [] most_concurrent = []
try: try:
base_query = 'SELECT session_history.started, session_history.stopped ' \ base_query = 'SELECT sh.started, sh.stopped ' \
'FROM session_history ' \ 'FROM session_history AS sh ' \
'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \ 'JOIN session_history_media_info AS shmi ON sh.id = shmi.id ' \
'WHERE datetime(stopped, "unixepoch", "localtime") ' \ 'WHERE sh.stopped >= %s ' % timestamp
'>= datetime("now", "-%s days", "localtime") ' % time_range
title = 'Concurrent Streams' title = 'Concurrent Streams'
query = base_query query = base_query
@ -948,21 +946,21 @@ class DataFactory(object):
title = 'Concurrent Transcodes' title = 'Concurrent Transcodes'
query = base_query \ query = base_query \
+ 'AND session_history_media_info.transcode_decision = "transcode" ' + 'AND shmi.transcode_decision = "transcode" '
result = monitor_db.select(query) result = monitor_db.select(query)
if result: if result:
most_concurrent.append(calc_most_concurrent(title, result)) most_concurrent.append(calc_most_concurrent(title, result))
title = 'Concurrent Direct Streams' title = 'Concurrent Direct Streams'
query = base_query \ query = base_query \
+ 'AND session_history_media_info.transcode_decision = "copy" ' + 'AND shmi.transcode_decision = "copy" '
result = monitor_db.select(query) result = monitor_db.select(query)
if result: if result:
most_concurrent.append(calc_most_concurrent(title, result)) most_concurrent.append(calc_most_concurrent(title, result))
title = 'Concurrent Direct Plays' title = 'Concurrent Direct Plays'
query = base_query \ query = base_query \
+ 'AND session_history_media_info.transcode_decision = "direct play" ' + 'AND shmi.transcode_decision = "direct play" '
result = monitor_db.select(query) result = monitor_db.select(query)
if result: if result:
most_concurrent.append(calc_most_concurrent(title, result)) most_concurrent.append(calc_most_concurrent(title, result))