<?php

namespace App\Http\Controllers\Api\Ekosistem;

use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use Illuminate\Http\Resources\Json\AnonymousResourceCollection;
use Illuminate\Http\JsonResponse;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\DB;

use App\Models\Ekosistem\TabelBasisData;
use App\Models\Ekosistem\KolomBasisData;
use App\Models\Ekosistem\ValueBasisData;
use App\Models\Core\Program;

class ValueBasisDataController extends Controller
{
    /**
     * Display a listing of the resource.
     */
    public function index(Request $request, string $tabelId): JsonResponse
    {
        if (!Gate::any(['super_admin', 'admin', 'fasilitator'])) {
            abort(403);
        }

        $perPage = $request->query('per_page', 10); 
        $search = strtolower($request->query('search', ''));

        $program = null;
        $programList = Program::get();
        if (app()->has('SystemProgram')) {
            $program = app('SystemProgram');
        } else {
            if ($request->has('program_id') && $request->query('program_id')) {
                $programId = $request->query('program_id');
                $program = Program::find($programId);
                if (!$program) {
                    abort(400, 'Program tidak ditemukan.');
                }
            }
        }

        $tabel = TabelBasisData::with('kolom')
            ->whereHas('kolom', function ($query) {
                $query->where('is_active', true);
            })
            ->find($tabelId);
        if (!$tabel) {
            abort(404, 'Data tabel tidak ditemukan.');
        }
        $kolom = KolomBasisData::where('tabel_id', $tabelId)
            ->where('is_active', true)
            ->when('is_browse', function ($q) {
                $q->where('is_browse', true);
            })
            ->orderBy('urutan', 'asc')
            ->get();
        if ($kolom->isEmpty()) {
            abort(404, 'Data kolom tidak ditemukan untuk tabel ini.');
        }

        $selects = [];
        foreach ($kolom as $k) {
            if ($k->tipe == 'boolean') {
                $selects[] = "
                    MAX(
                        CASE 
                            WHEN kolom_id = {$k->id} 
                            THEN CASE 
                                WHEN value_boolean = true THEN 'Ya' 
                                WHEN value_boolean = false THEN 'Tidak' 
                                ELSE NULL 
                            END
                            ELSE NULL
                        END
                    ) AS \"{$k->kolom}\"
                ";
            } elseif ($k->tipe == 'foreign_key') {
                $selects[] = "
                    MAX(
                        CASE 
                            WHEN kolom_id = {$k->id} 
                            THEN (select {$k->relasi_kolom_label} from {$k->relasi_tabel} where {$k->relasi_kolom_id} = value_relasi)
                            ELSE NULL
                        END
                    ) AS \"{$k->kolom}\"
                ";
            } elseif ($k->tipe == 'enum') {
                $selects[] = "
                    MAX(
                        CASE 
                            WHEN kolom_id = {$k->id} 
                            AND value_enum IS NOT NULL
                            THEN (
                                SELECT elem->>'label'
                                FROM ekosistem_basis_data_kolom k,
                                    jsonb_array_elements(k.enum_opsi::jsonb) AS elem
                                WHERE k.id = kolom_id
                                AND elem->>'value' = value_enum
                                LIMIT 1
                            )
                            ELSE NULL
                        END
                    ) AS \"{$k->kolom}\"
                ";
            } else {
                $selects[] = "
                    MAX(
                        CASE 
                            WHEN kolom_id = {$k->id} 
                            THEN value_{$k->tipe}
                            ELSE NULL
                        END
                    ) AS \"{$k->kolom}\"
                ";
            }
        }

        $base = ValueBasisData::query()
            ->join('core_program', 'core_program.id', '=', 'ekosistem_basis_data_value.program_id')
            ->where('tabel_id', $tabelId)
            ->when($program, function ($query) use ($program) {
                $query->where('program_id', $program->id);
            })
            ->selectRaw("
                core_program.id AS program_id,
                core_program.nama AS program_nama,
                tabel_id,
                value_id,
                " . implode(",\n", $selects) . "
            ")
            ->groupBy('core_program.id', 'core_program.nama', 'tabel_id', 'value_id')
            ->orderBy('value_id', 'asc');

        $values = DB::query()->fromSub($base, 'pivot')
            ->when($search, function ($query) use ($search, $kolom) {
                $query->where(function ($q) use ($search, $kolom) {
                    foreach ($kolom as $k) {
                        if ($k->tipe == 'text' || $k->tipe == 'varchar') {
                            $q->orWhereRaw("lower({$k->kolom}) LIKE ?", ["%$search%"]);
                        }   
                    }
                });
            })
            ->paginate($perPage);

        return response()->json($values);
    }

    /**
     * Store a newly created resource in storage.
     */
    public function store(Request $request, string $tabelId): JsonResponse
    {
        if (!Gate::any(['super_admin', 'admin', 'fasilitator'])) {
            abort(403);
        }

        $tabel = TabelBasisData::whereHas('kolom', function ($query) {
                $query->where('is_active', true);
            })->find($tabelId);
        if (!$tabel) {
            abort(404, 'Data tabel tidak ditemukan.');
        }
        $kolom = KolomBasisData::where('tabel_id', $tabelId)
            ->where('is_active', true)->get();
        if ($kolom->isEmpty()) {
            abort(404, 'Data kolom tidak ditemukan untuk tabel ini.');
        }
        if (app()->has('SystemProgram')) {
            $program = app('SystemProgram');
        } else {
            if ($request->has('program_id') && $request->query('program_id')) {
                $programId = $request->query('program_id');
                $program = Program::find($programId);
                if (!$program) {
                    abort(400, 'Program tidak ditemukan.');
                }
            } else {
                abort(400, 'Program tidak ditemukan.');    
            }
        }

        $validationRules = [];
        foreach ($kolom as $k) {
            if ($k->validasi && is_array($k->validasi)) {
                $validationRules[$k->kolom] = $k->validasi;
            } else {
                $validationRules[$k->kolom] = ['nullable'];
            }
        }
        $validated = $request->validate($validationRules);

        DB::transaction(function () use ($program, $tabelId, $validated, $kolom) {
            $maxId = ValueBasisData::where('tabel_id', $tabelId)
                ->where('program_id', $program->id)
                ->whereNotNull('value_id')
                ->max('value_id');
            foreach ($kolom as $k) {
                $values = [ 
                    'program_id' => $program->id,
                    'tabel_id' => (int)$tabelId,
                    'kolom_id' => $k->id,
                    'value_id' => ($maxId ?? 0) + 1,
                    'created_by' => auth()->id(),
                    'updated_by' => auth()->id(),
                ];
                if ($k->tipe == 'foreign_key') {
                    $values['value_relasi'] = $validated[$k->kolom] ?? null;
                } else {
                    $values['value_' . $k->tipe] = $validated[$k->kolom] ?? null;
                }
                
                ValueBasisData::create($values);
            }
        });

        return response()->json(['message' => 'Data berhasil disimpan.']);
    }

    /**
     * Display the specified resource.
     */
    public function show(string $id)
    {
        //
    }

    /**
     * Update the specified resource in storage.
     */
    public function update(Request $request, string $tabelId, string $id): JsonResponse
    {
        if (!Gate::any(['super_admin', 'admin', 'fasilitator'])) {
            abort(403);
        }

        $tabel = TabelBasisData::whereHas('kolom', function ($query) {
                $query->where('is_active', true);
            })->find($tabelId);
        if (!$tabel) {
            abort(404, 'Data tabel tidak ditemukan.');
        }
        $kolom = KolomBasisData::where('tabel_id', $tabelId)
            ->where('is_active', true)->get();
        if ($kolom->isEmpty()) {
            abort(404, 'Data kolom tidak ditemukan untuk tabel ini.');
        }
        if (app()->has('SystemProgram')) {
            $program = app('SystemProgram');
        } else {
            if ($request->has('program_id') && $request->query('program_id')) {
                $programId = $request->query('program_id');
                $program = Program::find($programId);
                if (!$program) {
                    abort(400, 'Program tidak ditemukan.');
                }
            } else {
                abort(400, 'Program tidak ditemukan.');    
            }
        }

        $values = ValueBasisData::query()
            ->where('tabel_id', $tabelId)
            ->where('value_id', $id)
            ->where('program_id', $program->id)
            ->get();
        if ($values->isEmpty()) {
            abort(404, 'Data tidak ditemukan.');
        }

        $validationRules = [];
        foreach ($kolom as $k) {
            if ($k->validasi && is_array($k->validasi)) {
                $validationRules[$k->kolom] = $k->validasi;
            } else {
                $validationRules[$k->kolom] = ['nullable'];
            }
        }
        $validated = $request->validate($validationRules);

        DB::transaction(function () use ($program, $tabelId, $validated, $kolom, $id, $values) {
            foreach ($validated as $kol => $val) {
                $k = $kolom->where('kolom', $kol)->first();
                if (!$k) {
                    continue;
                }
                $v = $values->where('kolom_id', $k->id)->first();
                if (!$v) {
                    $vals = [ 
                        'program_id' => $program->id,
                        'tabel_id' => (int)$tabelId,
                        'kolom_id' => $k->id,
                        'value_id' => $id,
                        'created_by' => auth()->id(),
                        'updated_by' => auth()->id(),
                    ];
                    if ($k->tipe == 'foreign_key') {
                        $vals['value_relasi'] = $validated[$k->kolom] ?? null;
                    } else {
                        $vals['value_' . $k->tipe] = $validated[$k->kolom] ?? null;
                    }
                    ValueBasisData::create($vals);
                } else {
                    $v->update([
                        'value_' . ($k->tipe == 'foreign_key' ? 'relasi' : $k->tipe) => $val,
                        'updated_by' => auth()->id(),
                    ]);
                }
            }
        });

        return response()->json(['message' => 'Data berhasil diperbarui.']);
    }

    /**
     * Remove the specified resource from storage.
     */
    public function destroy(Request $request, string $tabelId, string $id): JsonResponse
    {
        if (!Gate::any(['super_admin', 'admin', 'fasilitator'])) {
            abort(403);
        }

        $tabel = TabelBasisData::whereHas('kolom', function ($query) {
                $query->where('is_active', true);
            })->find($tabelId);
        if (!$tabel) {
            abort(404, 'Data tabel tidak ditemukan.');
        }
        $kolom = KolomBasisData::where('tabel_id', $tabelId)->get();
        if ($kolom->isEmpty()) {
            abort(404, 'Data kolom tidak ditemukan untuk tabel ini.');
        }
        if (app()->has('SystemProgram')) {
            $program = app('SystemProgram');
        } else {
            if ($request->has('program_id') && $request->query('program_id')) {
                $programId = $request->query('program_id');
                $program = Program::find($programId);
                if (!$program) {
                    abort(400, 'Program tidak ditemukan.');
                }
            } else {
                abort(400, 'Program tidak ditemukan.');    
            }
        }

        $values = ValueBasisData::query()
            ->where('tabel_id', $tabelId)
            ->where('value_id', $id)
            ->where('program_id', $program->id)
            ->get();
        if ($values->isEmpty()) {
            abort(404, 'Data tidak ditemukan.');
        }

        ValueBasisData::query()
            ->where('tabel_id', $tabelId)
            ->where('value_id', $id)
            ->where('program_id', $program->id)
            ->delete();

        return response()->json(['message' => 'Data berhasil dihapus.']);
    }
}