pull/691/head
Louis Vézina 5 years ago
parent 2ecd21beb0
commit 421b669801

@ -51,9 +51,9 @@ def update_series():
return return
else: else:
# Get current shows in DB # Get current shows in DB
current_shows_db = database.execute("SELECT tvdbId FROM table_shows") current_shows_db = database.execute("SELECT sonarrSeriesId FROM table_shows")
current_shows_db_list = [x['tvdbId'] for x in current_shows_db] current_shows_db_list = [x['sonarrSeriesId'] for x in current_shows_db]
current_shows_sonarr = [] current_shows_sonarr = []
series_to_update = [] series_to_update = []
series_to_add = [] series_to_add = []
@ -82,7 +82,7 @@ def update_series():
alternateTitles = None alternateTitles = None
# Add shows in Sonarr to current shows list # Add shows in Sonarr to current shows list
current_shows_sonarr.append(show['tvdbId']) current_shows_sonarr.append(show['id'])
if show['tvdbId'] in current_shows_db_list: if show['tvdbId'] in current_shows_db_list:
series_to_update.append({'title': six.text_type(show["title"]), series_to_update.append({'title': six.text_type(show["title"]),
@ -129,7 +129,7 @@ def update_series():
removed_series = list(set(current_shows_db_list) - set(current_shows_sonarr)) removed_series = list(set(current_shows_db_list) - set(current_shows_sonarr))
for series in removed_series: for series in removed_series:
database.execute("DELETE FROM table_shows WHERE tvdbId=?",(series,)) database.execute("DELETE FROM table_shows WHERE sonarrSEriesId=?",(series,))
# Update existing series in DB # Update existing series in DB
series_in_db_list = [] series_in_db_list = []

Loading…
Cancel
Save