This commit is contained in:
@@ -82,7 +82,13 @@ async def get_movies_list(dependencies: dict,
|
|||||||
|
|
||||||
if has_date is not None:
|
if has_date is not None:
|
||||||
if has_date:
|
if has_date:
|
||||||
|
if db.db_type == "postgresql":
|
||||||
|
where_conditions.append("dateadded IS NOT NULL")
|
||||||
|
else:
|
||||||
where_conditions.append("dateadded IS NOT NULL AND dateadded != ''")
|
where_conditions.append("dateadded IS NOT NULL AND dateadded != ''")
|
||||||
|
else:
|
||||||
|
if db.db_type == "postgresql":
|
||||||
|
where_conditions.append("dateadded IS NULL")
|
||||||
else:
|
else:
|
||||||
where_conditions.append("(dateadded IS NULL OR dateadded = '')")
|
where_conditions.append("(dateadded IS NULL OR dateadded = '')")
|
||||||
|
|
||||||
|
|||||||
@@ -190,7 +190,7 @@ class MovieProcessor:
|
|||||||
if not has_video:
|
if not has_video:
|
||||||
_log("WARNING", f"No video files found in: {movie_path}")
|
_log("WARNING", f"No video files found in: {movie_path}")
|
||||||
self.db.upsert_movie_dates(imdb_id, None, None, None, False)
|
self.db.upsert_movie_dates(imdb_id, None, None, None, False)
|
||||||
return
|
return "processed"
|
||||||
|
|
||||||
# TIER 1: Check database first (fastest - local lookup)
|
# TIER 1: Check database first (fastest - local lookup)
|
||||||
existing = self.db.get_movie_dates(imdb_id)
|
existing = self.db.get_movie_dates(imdb_id)
|
||||||
|
|||||||
Reference in New Issue
Block a user