nexusphp/app/Jobs/GenerateTemporaryInvite.php

<?php

namespace App\Jobs;

use App\Models\Invite;
use App\Repositories\ToolRepository;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Str;
use Nexus\Database\NexusDB;

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

    private int $count;

    private string $idRedisKey;

    private int $days;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(string $idRedisKey, int $days, int $count)
    {
        $this->idRedisKey = $idRedisKey;
        $this->days = $days;
        $this->count = $count;
    }

    public $tries = 1;

    public $timeout = 1800;

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $beginTimestamp = microtime(true);
        $toolRep = new ToolRepository();
        $idStr = NexusDB::cache_get($this->idRedisKey);
        $logPrefix = "idRedisKey: " . $this->idRedisKey;
        if (empty($idStr)) {
            do_log("$logPrefix, no idStr...");
            return;
        }
        $idArr = explode(",", $idStr);
        $count = count($idArr);
        $logPrefix .= ", count: $count";
        do_log("$logPrefix, going to handle...");
        $now = Carbon::now();
        $expiredAt = Carbon::now()->addDays($this->days);
        foreach ($idArr as $uid) {
            try {
                $hashArr = $toolRep->generateUniqueInviteHash([], $this->count, $this->count);
                $data = [];
                foreach($hashArr as $hash) {
                    $data[] = [
                        'inviter' => $uid,
                        'invitee' => '',
                        'hash' => $hash,
                        'valid' => 0,
                        'expired_at' => $expiredAt,
                        'created_at' => $now,
                    ];
                }
                if (!empty($data)) {
                    Invite::query()->insert($data);
                }
                do_log("$logPrefix, success add $this->count temporary invite ($this->days days) to $uid");
            } catch (\Exception $exception) {
                do_log("$logPrefix, fail add $this->count temporary invite ($this->days days) to $uid: " . $exception->getMessage(), 'error');
            }
        }
        NexusDB::cache_del($this->idRedisKey);
        do_log("$logPrefix, handle done, cost time: " . (microtime(true) - $beginTimestamp) . " seconds.");
    }

    /**
     * Handle a job failure.
     *
     * @param  \Throwable  $exception
     * @return void
     */
    public function failed(\Throwable $exception)
    {
        do_log("failed: " . $exception->getMessage() . $exception->getTraceAsString(), 'error');
    }

}