��Root Mod By V1rus

Viewing: Queue.php

<?php

namespace App\Livewire\Admin\Pages\ProcessManagement\Bot;

use App\Events\PrepareOrderForProcess;
use App\Events\PrepareSheetForProcess;
use App\Models\Order;
use App\Models\ProcessBot;
use Carbon\Carbon;
use Illuminate\Support\Facades\Redis;
use Livewire\Component;
use Livewire\WithPagination;
use App\Models\OrderGroup;
use Masmerise\Toaster\Toastable;

class Queue extends Component
{
    use WithPagination;
    use Toastable;

    public $search = '';

    public $activeTab = 'bot1';

    protected $queryString = [
        'activeTab' => ['except' => 'bot1']
    ];

    public function render()
    {
        $result = $this->getProccessingOrderSheets();

        return view('livewire.admin.pages.process-management.all.bots-queues', [
            'result' => $result
        ]);
    }

    public function getProccessingOrderSheets()
    {
        $result = [];
        $botsCount = ProcessBot::OnlyAutomation()->get()->count();

        for ($i = 1; $i <= $botsCount; $i++) {
            $botQueueItems = Redis::lrange('opticut_queues:bot' . $i, 0, -1);
            if (count($botQueueItems) > 0) {
                foreach ($botQueueItems as $key => $item) {
                    try {
                        $result['bot' . $i][] = json_decode($item, true, 512, JSON_THROW_ON_ERROR);
                    } catch (\JsonException $e) {
                        throw $e;
                    }
                }
            } else {
                $result['bot' . $i] = [];
            }
        }

        return $result;
    }

    public function clearProcessingQueue($bot)
    {
        Redis::del('opticut_queues:' . $bot);
    }
}

User / IP	: 216.73.217.78
Host / Server	: 195.214.235.115 / npln.ir
System	: Linux damavand.pws-dns.net 5.14.0-503.35.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 4 05:23:43 EDT 2025 x86_64

���Root Mod By V1rus_Alfa

Viewing: Queue.php

��Root Mod By V1rus_Alfa