github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-08-22 14:13:40 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Fix plexivity_import.py

Browse source
This commit is contained in:
JonnyWong16 2023-04-21 16:20:15 -07:00
commit 8f19a48d03
No known key found for this signature in database
GPG key ID: B1F1F9807184697A
1 changed files with 24 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

48
plexpy/plexivity_import.py
View file

@ -304,27 +304,27 @@ def import_from_plexivity(database_file=None, table_name=None, import_ignore_int
logger.debug("Tautulli Importer :: Unable to refresh the users list. Aborting import.")
return None
query = 'SELECT id AS id, ' \
'time AS started, ' \
'stopped, ' \
'null AS user_id, ' \
'user, ' \
'ip_address, ' \
'paused_counter, ' \
'platform AS player, ' \
'null AS platform, ' \
'null as machine_id, ' \
'null AS media_type, ' \
'null AS view_offset, ' \
'xml, ' \
'rating as content_rating,' \
'summary,' \
'title AS full_title,' \
'(case when orig_title_ep = "n/a" then orig_title else ' \
'orig_title_ep end) as title,' \
'(case when orig_title_ep != "n/a" then orig_title else ' \
'null end) as grandparent_title ' \
'FROM ' + table_name + ' ORDER BY id'
query = "SELECT id AS id, " \
"time AS started, " \
"stopped, " \
"null AS user_id, " \
"user, " \
"ip_address, " \
"paused_counter, " \
"platform AS player, " \
"null AS platform, " \
"null as machine_id, " \
"null AS media_type, " \
"null AS view_offset, " \
"xml, " \
"rating as content_rating," \
"summary," \
"title AS full_title," \
"(case when orig_title_ep = 'n/a' then orig_title else " \
"orig_title_ep end) as title," \
"(case when orig_title_ep != 'n/a' then orig_title else " \
"null end) as grandparent_title " \
"FROM " + table_name + " ORDER BY id"
result = connection.execute(query)
@ -456,9 +456,9 @@ def import_users():
logger.debug("Tautulli Importer :: Importing Plexivity Users...")
monitor_db = database.MonitorDatabase()
query = 'INSERT OR IGNORE INTO users (user_id, username) ' \
'SELECT user_id, user ' \
'FROM session_history WHERE user_id != 1 GROUP BY user_id'
query = "INSERT OR IGNORE INTO users (user_id, username) " \
"SELECT user_id, user " \
"FROM session_history WHERE user_id != 1 GROUP BY user_id"
try:
monitor_db.action(query)