Larave 7.0でキュー・ジョブ・スケジューラー触ってみる。取得したツイートが存在するか毎夜毎夜チェックするジョブとスケジューラー。

php artisan queue:table

php artisan migrate

php artisan make:job YOUR_JOB_NAME

<?php
namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class CheckNotFoundUrls implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public function __construct()
    {
        //
    }

    public function handle()
    {
        //ここに処理を記述
    }
}

<?php
namespace App\Jobs;

//Twitter API ライブラリ
use Abraham\TwitterOAuth\TwitterOAuth;

use App\Models\Tweets; // ツイート情報が格納されたテーブルに接続するモデル
use App\Models\JobReport;　// 自作ジョブの結果を記録しておくテーブル

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class CheckNotFoundUrls implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public function __construct()
    {
        //
    }

    public function handle()
    {
        try{
            // ツイート情報があるテーブルからツイート情報（JSON）と必要なレコードを取得
            $datas = Tweets::select('tweet_rawdata','id','user_id')->get();
            $deletedTweetOwner = array();
    
            foreach($datas as $val){
                //'tweet_rawdata'カラムはjsonなので一旦decode。
                //jsonからid_strというツイートIDを取得
                $decodeTweetData = json_decode($val->tweet_rawdata);
                $tweet_id = $decodeTweetData->id_str;

                //APIに接続するための準備（ライブラリ）をして、APIを送信
                $connection = new TwitterOAuth(env('TW_CONSUMER_KEY'), env('TW_CONSUMER_KEY_SECRET'), env('TW_ACCESS_TOKEN'), env('TW_ACCESS_TOKEN_SECRET'));
                $connection->setTimeouts(10, 15);
                $content = $connection->get("statuses/show",['id'=>intval($tweet_id)]);
    
                //請求したツイートIDのツイートが存在しないという結果ならばレコードのIDを $deletedTweetOwnerにユーザーIDを記録
                if(property_exists($content,'errors')){
                    switch($content->errors[0]->code){
                        case 144:
                            Tweets::destroy($val->id);
                            array_push($deletedTweetOwner,$val->id);
                        break;
                    }
                }
                //Dosにならないように1秒止める
                sleep(1.0);
            }
  
        }catch(\Exception $e){
            //処理が失敗したら管理者用のレポートにエラ〜メッセージを記録する。
            JobReport::reportException(0,$e->getMessage());
        }
    }
}

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;

class DispatchJob extends Command
{
    protected $signature = 'job:dispatch {job}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Dispatch job';

    public function __construct()
    {
        parent::__construct();
    }

    public function handle()
    {
        $class = '\\App\\Jobs\\' . $this->argument('job');
        dispatch(new $class());
    }
}

php artisan job:dispatch CheckNotFoundUrls

<?php

namespace App\Console;

use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
use App\Jobs\CheckNotFoundUrls; //ここで先ほど作成したジョブクラス
use DateTime;

class Kernel extends ConsoleKernel
{
    /**
     * The Artisan commands provided by your application.
     *
     * @var array
     */
    protected $commands = [
        //
    ];

    /**
     * Define the application's command schedule.
     *
     * @param  \Illuminate\Console\Scheduling\Schedule  $schedule
     * @return void
     */
    protected function schedule(Schedule $schedule)
    {
        //実行するjobをキューに投入する。そして実行時間を設定。
        $schedule->job(new CheckNotFoundUrls(),'checkUrl')->diary()
    }
}

~ $ crontab -e #これでcronの設定ファイルを編集できます。

* * * * * cd /path-to-your-project && php artisan schedule:run >> /dev/null 2>&1