some progress

This commit is contained in:
2025-08-07 23:01:58 +03:00
parent e8d7e6a1c4
commit e351803db2
14 changed files with 971 additions and 226 deletions
@@ -53,7 +53,7 @@ class MovieProcessingService implements ProcessingInterface
$join->on('movies.tmdb_id', '=', 'item_to_fetch_jobs.tmdb_id');
})
->whereRaw("FIND_IN_SET('".ItemToFetchJobs::JOB_DETAILS."', item_to_fetch_jobs.jobs)")
->where('item_to_fetch_jobs.type', 'movies')
->whereIn('item_to_fetch_jobs.type', ['movies', 'movie'])
->whereNull('movies.id')
->take($batch)
->get();
@@ -84,6 +84,10 @@ class MovieProcessingService implements ProcessingInterface
private function getDetails($item)
{
$tmdbMovie = $this->moviesApi->getMovie($item->tmdb_id);
if (isset($tmdbMovie['status_code']) && $tmdbMovie['status_code'] == 34) {
echo "[N]";
return;
}
$tmdbMovie['tmdb_id'] = $tmdbMovie['id'];
Log::channel('fetch_export_items_details')->info("Processing TmdbId ".$tmdbMovie['tmdb_id']);
@@ -629,7 +633,8 @@ class MovieProcessingService implements ProcessingInterface
ItemToFetchJobs::create([
'tmdb_id' => $tmdbRecommendation['id'],
'type' => ItemToFetch::TYPE_MOVIE,
'remaining_jobs' => json_encode($jobs),
'remaining_jobs' => implode(',', $jobs),
'jobs' => implode(',', $jobs),
]);
$this->getDetails($itemToFetch);
@@ -694,7 +699,8 @@ class MovieProcessingService implements ProcessingInterface
ItemToFetchJobs::create([
'tmdb_id' => $tmdbSimilarMovie['id'],
'type' => ItemToFetch::TYPE_MOVIE,
'remaining_jobs' => json_encode($jobs),
'remaining_jobs' => implode(',', $jobs),
'jobs' => implode(',', $jobs),
]);
$this->getDetails($itemToFetch);