56 lines
1.6 KiB
PHP
56 lines
1.6 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace App\Services\News;
|
||
|
|
|
||
|
|
use App\Models\News as NewsArticle;
|
||
|
|
use App\Services\Data\Contracts\NewsProviderInterface;
|
||
|
|
use Carbon\Carbon;
|
||
|
|
use Illuminate\Support\Str;
|
||
|
|
|
||
|
|
class ImportNewsFromRemoteProvider
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* @var NewsProviderInterface
|
||
|
|
*/
|
||
|
|
private $newsProvider;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @var NewsArticle
|
||
|
|
*/
|
||
|
|
private $newsArticle;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param NewsProviderInterface $newsProvider
|
||
|
|
* @param NewsArticle $newsArticle
|
||
|
|
*/
|
||
|
|
public function __construct(
|
||
|
|
NewsProviderInterface $newsProvider,
|
||
|
|
NewsArticle $newsArticle
|
||
|
|
) {
|
||
|
|
$this->newsProvider = $newsProvider;
|
||
|
|
$this->newsArticle = $newsArticle;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function execute()
|
||
|
|
{
|
||
|
|
$newArticles = $this->newsProvider->getArticles()->map(function($article) {
|
||
|
|
$article['slug'] = Str::slug(Str::limit($article['title'], 50));
|
||
|
|
$article['meta'] = json_encode($article['meta']);
|
||
|
|
$article['created_at'] = Carbon::now();
|
||
|
|
$article['updated_at'] = Carbon::now();
|
||
|
|
return $article;
|
||
|
|
});
|
||
|
|
|
||
|
|
$existing = $this->newsArticle->whereIn('slug', $newArticles->pluck('slug'))->get();
|
||
|
|
|
||
|
|
// filter out already existing articles
|
||
|
|
$newArticles = $newArticles->filter(function($newArticle) use($existing) {
|
||
|
|
return ! $existing->first(function($existingArticle) use($newArticle) {
|
||
|
|
return $existingArticle['title'] === $newArticle['title'] || $existingArticle['slug'] === $newArticle['slug'];
|
||
|
|
});
|
||
|
|
})->unique('slug');
|
||
|
|
|
||
|
|
$this->newsArticle->insert($newArticles->toArray());
|
||
|
|
}
|
||
|
|
}
|