<?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;
use Illuminate\Support\Facades\DB;

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

    /**
     * Материализованные представления, которые нужно обновить.
     *
     * @var string[]
     */
    protected array $views = [
        'mv_medicalhistory_summary',
        'mv_migrationpatient_details',
        'mv_surgical_operations',
        'mv_reanimation_summary',
    ];

    /**
     * Время ожидания выполнения задачи (секунды).
     */
    public int $timeout = 1800;

    /**
     * Размер temp_buffers на время обновления каждого представления.
     */
    protected string $tempBuffers = '512MB';

    public function handle(): void
    {
        foreach ($this->views as $view) {
            // CONCURRENTLY использует временные таблицы и local (temp) buffers для
            // diff'а старых и новых данных. На больших представлениях стандартного
            // temp_buffers (8MB) не хватает — PostgreSQL падает с "no empty local
            // buffer available". temp_buffers можно изменить только до первого
            // обращения к временным таблицам в сессии, поэтому под каждое
            // представление берём свежее соединение и сразу поднимаем temp_buffers.
            DB::reconnect();
            DB::statement("SET temp_buffers = '{$this->tempBuffers}'");

            // CONCURRENTLY не блокирует чтение представления во время обновления,
            // но требует наличия уникального индекса на представлении и не может
            // выполняться внутри транзакции (DB::statement работает в autocommit).
            DB::statement("REFRESH MATERIALIZED VIEW CONCURRENTLY {$view}");
            DB::statement("ANALYZE {$view}");
        }
    }
}