portal-api/app/Jobs/VirtualMachine/Sync/SyncFolder.php

<?php

namespace App\Jobs\VirtualMachine\Sync;

use App\Http\Services\vCenter as ServiceVCenter;
use App\Models\ModuleDatacenter;
use App\Models\ModuleFolder;
use App\Models\vCenter;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

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

    protected $vCenter = null;
    protected $data = null;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
        $this->data = vCenter::select('id', 'host', 'user', 'password', 'token')->get();
        $this->vCenter = new ServiceVCenter;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        foreach ($this->data as $item) {
            if (!$item->token) {
                $token = $this->vCenter->loginServer($item);
                if ($token) {
                    vCenter::where('id', $item->id)->update(['token' => $token]);
                    $item->token = $token;
                }
            }

            if (!$item->token) {
                continue;
            }

            $this->vCenter->setConnection($item->host, $item->token);

            $dataCenter = ModuleDatacenter::where('vcenter_id', $item->id)->select('id', 'datacenter_id')->get();
            foreach ($dataCenter as $_item) {
                $folder = $this->vCenter->getAllFolder($_item['datacenter_id']);

                if ($folder === "Login_Again") {
                    $token = $this->vCenter->loginServer($item);
                    if ($token) {
                        vCenter::where('id', $item->id)->update(['token' => $token]);
                        $this->vCenter->setConnection($item->host, $token);
                    }
                    $folder = $this->vCenter->getAllFolder($_item['datacenter_id']);
                }

                if (!is_array($folder)) {
                    continue;
                }

                $syncedFolderIds = [];
                foreach ($folder as $_subItem) {
                    $record = ModuleFolder::updateOrCreate(
                        ['folder' => $_subItem['folder'], 'module_datacenter_id' => $_item['id']],
                        ['name' => $_subItem['name'], 'type' => $_subItem['type']]
                    );
                    $syncedFolderIds[] = $record->id;
                }

                // Remove stale folders no longer in vCenter
                ModuleFolder::where('module_datacenter_id', $_item['id'])
                    ->whereNotIn('id', $syncedFolderIds)
                    ->delete();
            }

        }
        // Notify success via Telegram
        (new \App\Http\Services\Telegram())->SendJobRunInfo('SyncFolder', 'Success', [
            'message' => 'Sync folder completed successfully',
            'synced_vcenters' => $this->data->count(),
        ]);
    }
}