+17
-5
@@ -375,16 +375,16 @@ async def get_missing_dates_report(dependencies: dict):
|
|||||||
episodes_with_dates = db._get_first_value(cursor.fetchone())
|
episodes_with_dates = db._get_first_value(cursor.fetchone())
|
||||||
else:
|
else:
|
||||||
cursor.execute("SELECT COUNT(*) FROM movies WHERE dateadded IS NOT NULL AND dateadded != ''")
|
cursor.execute("SELECT COUNT(*) FROM movies WHERE dateadded IS NOT NULL AND dateadded != ''")
|
||||||
movies_with_dates = cursor.fetchone()[0]
|
movies_with_dates = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
cursor.execute("SELECT COUNT(*) FROM movies")
|
cursor.execute("SELECT COUNT(*) FROM movies")
|
||||||
total_movies = cursor.fetchone()[0]
|
total_movies = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
cursor.execute("SELECT COUNT(*) FROM episodes WHERE dateadded IS NOT NULL AND dateadded != ''")
|
cursor.execute("SELECT COUNT(*) FROM episodes WHERE dateadded IS NOT NULL AND dateadded != ''")
|
||||||
episodes_with_dates = cursor.fetchone()[0]
|
episodes_with_dates = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
cursor.execute("SELECT COUNT(*) FROM episodes")
|
cursor.execute("SELECT COUNT(*) FROM episodes")
|
||||||
total_episodes = cursor.fetchone()[0]
|
total_episodes = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
return {
|
return {
|
||||||
"summary": {
|
"summary": {
|
||||||
@@ -443,11 +443,17 @@ async def get_dashboard_stats(dependencies: dict):
|
|||||||
episodes_no_valid_source = db._get_first_value(cursor.fetchone())
|
episodes_no_valid_source = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
# Recent activity (last 7 days)
|
# Recent activity (last 7 days)
|
||||||
|
if db.db_type == "postgresql":
|
||||||
|
cursor.execute("""
|
||||||
|
SELECT COUNT(*) FROM processing_history
|
||||||
|
WHERE processed_at > NOW() - INTERVAL '7 days'
|
||||||
|
""")
|
||||||
|
else:
|
||||||
cursor.execute("""
|
cursor.execute("""
|
||||||
SELECT COUNT(*) FROM processing_history
|
SELECT COUNT(*) FROM processing_history
|
||||||
WHERE processed_at > datetime('now', '-7 days')
|
WHERE processed_at > datetime('now', '-7 days')
|
||||||
""")
|
""")
|
||||||
recent_activity = cursor.fetchone()[0]
|
recent_activity = db._get_first_value(cursor.fetchone())
|
||||||
|
|
||||||
# Source distribution for movies
|
# Source distribution for movies
|
||||||
cursor.execute("""
|
cursor.execute("""
|
||||||
@@ -457,6 +463,9 @@ async def get_dashboard_stats(dependencies: dict):
|
|||||||
GROUP BY source
|
GROUP BY source
|
||||||
ORDER BY count DESC
|
ORDER BY count DESC
|
||||||
""")
|
""")
|
||||||
|
if db.db_type == "postgresql":
|
||||||
|
movie_sources = [{"source": list(row.values())[0], "count": list(row.values())[1]} for row in cursor.fetchall()]
|
||||||
|
else:
|
||||||
movie_sources = [{"source": row[0], "count": row[1]} for row in cursor.fetchall()]
|
movie_sources = [{"source": row[0], "count": row[1]} for row in cursor.fetchall()]
|
||||||
|
|
||||||
# Source distribution for episodes
|
# Source distribution for episodes
|
||||||
@@ -467,6 +476,9 @@ async def get_dashboard_stats(dependencies: dict):
|
|||||||
GROUP BY source
|
GROUP BY source
|
||||||
ORDER BY count DESC
|
ORDER BY count DESC
|
||||||
""")
|
""")
|
||||||
|
if db.db_type == "postgresql":
|
||||||
|
episode_sources = [{"source": list(row.values())[0], "count": list(row.values())[1]} for row in cursor.fetchall()]
|
||||||
|
else:
|
||||||
episode_sources = [{"source": row[0], "count": row[1]} for row in cursor.fetchall()]
|
episode_sources = [{"source": row[0], "count": row[1]} for row in cursor.fetchall()]
|
||||||
|
|
||||||
# Calculate total missing dates (movies + episodes)
|
# Calculate total missing dates (movies + episodes)
|
||||||
|
|||||||
Reference in New Issue
Block a user