nexusphp/app/Jobs/RemoveUserDonorStatus.php

<?php

namespace App\Jobs;

use App\Enums\ModelEventEnum;
use App\Models\Message;
use App\Models\User;
use App\Models\UserModifyLog;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;

class RemoveUserDonorStatus
{
    /**
     * Create a new job instance.
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        $users = User::query()
            ->with('language')
            ->where('donor', 'yes')
            ->whereNotNull('donoruntil')
            ->where('donoruntil', '!=', '0000-00-00 00:00:00')
            ->where('donoruntil', '<', now())
            ->get();
        $userModifyLogs = [];
        foreach ($users as $user) {
            $locale = $user->locale;
            $userModifyLogs[] = [
                'user_id' => $user->id,
                'content' => "donor status removed by - AutoSystem",
                'created_at' => now(),
                'updated_at' => now(),
            ];
            $user->donor = 'no';
            do_log(sprintf("update user %s => %s", $user->id, json_encode($user->getDirty())));
            $user->save();
            clear_user_cache($user->id);
            publish_model_event(ModelEventEnum::USER_UPDATED, $user->id);
            $subject = sqlesc(nexus_trans("cleanup.msg_donor_status_removed", [], $locale));
            $msg = sqlesc(nexus_trans("cleanup.msg_donor_status_removed_body", [], $locale));
            Message::add([
                'sender' => 0,
                'receiver' => $user->id,
                'added' => now(),
                'subject' => $subject,
                'msg' => $msg,
            ]);
        }
        if (!empty($userModifyLogs)) {
            UserModifyLog::query()->insert($userModifyLogs);
        }
        do_log("remove donor status if time's up, success handle user count: " . $users->count());
    }
}