caneara/tipsea

use App\Types\Job;
use App\Models\Tip;
use Illuminate\Database\Eloquent\Collection;
 
class ProcessTipsJob extends Job
{
    protected array $fields = [
        'tips.id',
        'tips.user_id',
        'tips.slug',
        'tips.summary',
        'tips.first_tag',
    ];
 
    public int $tries = 1;
 
    public function handle() : void
    {
        Tip::query()
            ->select($this->fields)
            ->join('users', 'tips.user_id', '=', 'users.id')
            ->where('shared', false)
            ->whereBetween('published_at', [now()->subDay(), now()])
            ->chunkById(50, fn($tips) => $this->process($tips));
    }
 
    public function process(Collection $tips) : void
    {
        $query = Tip::whereIn('id', $tips->pluck('id'));
 
        attempt(fn() => $query->update(['shared' => true]));
 
        $tips->each(fn($tip) => PostToSocialMediaJob::dispatch($tip));
    }
}

use App\Jobs\ProcessTipsJob;
use Illuminate\Console\Command;
 
class ProcessTipsCommand extends Command
{
    protected $signature = 'system:process-tips';
 
    protected $description = 'Publish scheduled tips and notify followers.';
 
    public function handle() : void
    {
        ProcessTipsJob::dispatch();
 
        $this->info('The tips are being processed');
    }
}