where('skip_missing_media', '!=', true)->take(500)->get(); if (! $ips->count()) { return; } foreach ($ips as $ip) { $id = $ip->user_id; $pid = $ip->profile_id; $profile = Profile::find($pid); if (! $profile) { $ip->skip_missing_media = true; $ip->save(); continue; } $exists = ImportPost::whereUserId($id) ->whereNotNull('status_id') ->where('filename', $ip->filename) ->where('creation_year', $ip->creation_year) ->where('creation_month', $ip->creation_month) ->where('creation_day', $ip->creation_day) ->exists(); if ($exists == true) { $ip->skip_missing_media = true; $ip->save(); continue; } $idk = ImportService::getId($ip->user_id, $ip->creation_year, $ip->creation_month, $ip->creation_day); if (! $idk) { $ip->skip_missing_media = true; $ip->save(); continue; } if (Storage::exists('imports/'.$id.'/'.$ip->filename) === false) { ImportService::clearAttempts($profile->id); ImportService::getPostCount($profile->id, true); $ip->skip_missing_media = true; $ip->save(); continue; } $missingMedia = false; foreach ($ip->media as $ipm) { $fileName = last(explode('/', $ipm['uri'])); $og = 'imports/'.$id.'/'.$fileName; if (! Storage::exists($og)) { $missingMedia = true; } } if ($missingMedia === true) { $ip->skip_missing_media = true; $ip->save(); continue; } $caption = $ip->caption; $status = new Status; $status->profile_id = $pid; $status->caption = $caption; $status->type = $ip->post_type; $status->scope = 'unlisted'; $status->visibility = 'unlisted'; $status->id = $idk['id']; $status->created_at = now()->parse($ip->creation_date); $status->save(); foreach ($ip->media as $ipm) { $fileName = last(explode('/', $ipm['uri'])); $ext = last(explode('.', $fileName)); $basePath = MediaPathService::get($profile); $og = 'imports/'.$id.'/'.$fileName; if (! Storage::exists($og)) { $ip->skip_missing_media = true; $ip->save(); continue; } $size = Storage::size($og); $mime = Storage::mimeType($og); $newFile = Str::random(40).'.'.$ext; $np = $basePath.'/'.$newFile; Storage::move($og, $np); $media = new Media; $media->profile_id = $pid; $media->user_id = $id; $media->status_id = $status->id; $media->media_path = $np; $media->mime = $mime; $media->size = $size; $media->save(); } $ip->status_id = $status->id; $ip->creation_id = $idk['incr']; $ip->save(); $profile->status_count = $profile->status_count + 1; $profile->save(); AccountService::del($profile->id); ImportService::clearAttempts($profile->id); ImportService::getPostCount($profile->id, true); } } }