<?php

declare(strict_types=1);

/*
 * This file is part of contao-weinanlieferung-bundle.
 *
 * (c) vonRotenberg
 *
 * @license commercial
 */

namespace vonRotenberg\WeinanlieferungBundle\EventListener\DataContainer;

use Contao\CoreBundle\ServiceAnnotation\Callback;
use Contao\DataContainer;
use Contao\Date;
use Contao\StringUtil;
use Doctrine\DBAL\Connection;
use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungLeseartModel;
use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungRebsorteModel;
use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungReservationModel;
use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungSlotsModel;

class WeinanlieferungReservationContainerListener
{
    /** @var Connection */
    protected $db;

    public function __construct(Connection $db)
    {
        $this->db = $db;
    }


    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.sorten.options")
     */
    public function onSortenOptionsCallback(DataContainer $dc)
    {
        $arrSorten = [];

        if (($Slot = WeinanlieferungSlotsModel::findByPk($dc->activeRecord->pid)) === null)
        {
            return $arrSorten;
        }

        $Sorten = StringUtil::deserialize($Slot->sorten,true);
        foreach($Sorten as $sorte)
        {
            $objSorte = WeinanlieferungRebsorteModel::findByPk($sorte['sorte']);
            $objLeseart = WeinanlieferungLeseartModel::findByPk($sorte['leseart']);
            $arrSorten[$objSorte->id.','.$objLeseart->id] = ($objSorte !== null  ? $objSorte->title : '') . ' ' . ($objLeseart !== null  ? $objLeseart->title : '');
        }

        return $arrSorten;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.lage.options")
     */
    public function onLageOptionsCallback(DataContainer $dc)
    {
        $arrLagen = [];

        if (($Slot = WeinanlieferungSlotsModel::findByPk($dc->activeRecord->pid)) === null || $Slot->lage === null)
        {
            return $arrLagen;
        }

        if (($Lagen = $Slot->getRelated('lage')) !== null)
        {
            $arrLagen = array_combine($Lagen->fetchEach('id'),$Lagen->fetchEach('title'));
        }

        return $arrLagen;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.ernteart.options")
     */
    public function onErnteartOptionsCallback(DataContainer $dc)
    {
        $arrErnteart = [];

        if (($Slot = WeinanlieferungSlotsModel::findByPk($dc->activeRecord->pid)) === null || $Slot->ernteart === null)
        {
            return $arrErnteart;
        }

        $Ernteart = explode(',',$Slot->ernteart);
        foreach($Ernteart as $art)
        {
            $arrErnteart[$art] = $GLOBALS['TL_LANG']['REF']['wa_ernteart'][$art] ?? $art;
        }

        return $arrErnteart;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.pid.options")
     */
    public function onPidOptionsCallback(DataContainer $dc)
    {
        if (($Slots = WeinanlieferungSlotsModel::findAllFuturePublished()) === null)
        {
            return [];
        }

        $arrData = [];
        foreach ($Slots as $slot)
        {
            $arrSorten = [];
            $intAvailableBehaelter = $slot->getAvailableBehaelter();

            $Standort = $slot->getRelated('pid');

            $Sorten = StringUtil::deserialize($slot->sorten,true);
            foreach($Sorten as $sorte)
            {
                $objSorte = WeinanlieferungRebsorteModel::findByPk($sorte['sorte']);
                $objLeseart = WeinanlieferungLeseartModel::findByPk($sorte['leseart']);
                $arrSorten[] = ($objSorte !== null  ? $objSorte->title : '') . ' ' . ($objLeseart !== null  ? $objLeseart->title : '');
            }
            $arrData[$slot->id] = Date::parse(Date::getNumericDatimFormat(),$slot->time) . ' - ' . ($Standort !== null  ? $Standort->title : $slot->pid) . ' - (' . implode(', ',$arrSorten) . ') [Verfügbare Behälter: ' . $intAvailableBehaelter . '/' . $slot->behaelter . ']';
        }

        return $arrData;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.uid.options")
     */
    public function onUidOptionsCallback(DataContainer $dc)
    {
        if (($Members = \MemberModel::findAll()) === null)
        {
            return [];
        }

        $arrData = [];
        foreach ($Members as $member)
        {
            $arrData[$member->id] = ($member->memberno !== null && $member->memberno ? $member->memberno.' ' : '') . $member->firstname . ' ' . $member->lastname . ' [' . $member->email . ']';
        }

        return $arrData;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.approved.save")
     */
    public function onApprovedSaveCallback($varValue, DataContainer $dc)
    {
        if (($Current = WeinanlieferungReservationModel::findByPk($dc->activeRecord->id)) !== null)
        {
            if ($Current->approved === '1' && $varValue !== '1')
            {
                $Current->approved_on = 0;
                $Current->save();
            } elseif ($Current->approved !== '1' && $varValue === '1')
            {
                $Current->approved_on = time();
                $Current->save();
            }
        }

        return $varValue;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.behaelter_numbers.load")
     */
    public function onBehaelterNumbersLoadCallback($varValue, DataContainer $dc)
    {
        if (!empty($varValue))
        {
            $varValue = implode(', ',\json_decode($varValue));
        }
        return $varValue;
    }

    /**
     * @Callback(table="tl_vr_wa_reservation", target="fields.behaelter_numbers.save")
     */
    public function onBehaelterNumbersSaveCallback($varValue, DataContainer $dc)
    {
        if (!empty($varValue))
        {
            $values = array_map('trim', explode(',', $varValue));

            // Get the reservation model
            $reservation = \vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungReservationModel::findByPk($dc->id);
            if ($reservation === null) {
                throw new \Exception('Reservation not found');
            }

            // Get the slot model
            $slot = $reservation->getRelated('pid');
            if ($slot === null) {
                throw new \Exception('Slot not found');
            }

            // Check if the booking is in the past
            $isInPast = $slot->time < time();

            // Only perform validation if the booking is not in the past
            if (!$isInPast) {
                // Check if the number of container numbers matches the number of booked containers
                if (count($values) != $reservation->behaelter) {
                    throw new \Exception('Die Anzahl der Behälternummern muss mit der Anzahl der gebuchten Behälter übereinstimmen.');
                }

                // Filter out the special value 9999 ("Nummer nicht bekannt") for duplicate check
                $numbersForDuplicateCheck = array_filter($values, function($number) {
                    return $number !== '9999';
                });

                // Check for duplicate numbers (excluding the special value 9999)
                if (count(array_unique($numbersForDuplicateCheck)) != count($numbersForDuplicateCheck)) {
                    throw new \Exception('Jede Nummer kann nur einmal verwendet werden.');
                }

                // Get the standort to access the number_ranges
                $standort = $slot->getRelated('pid');
                if ($standort === null) {
                    throw new \Exception('Standort not found');
                }

                // Get all used numbers from current bookings (excluding past bookings)
                $usedNumbers = [];
                $currentTime = time();

                // Get the database connection
                $sql = "SELECT r.behaelter_numbers
                        FROM tl_vr_wa_reservation r
                        JOIN tl_vr_wa_slot s ON r.pid = s.id
                        WHERE r.behaelter_numbers != ''
                        AND s.time >= ?
                        AND r.id != ?";

                $stmt = $this->db->prepare($sql);
                $stmt->bindValue(1, $currentTime);
                $stmt->bindValue(2, $dc->id);
                $result = $stmt->executeQuery();

                while ($row = $result->fetchAssociative()) {
                    $numbers = json_decode($row['behaelter_numbers'], true);
                    if (is_array($numbers)) {
                        foreach ($numbers as $number) {
                            $usedNumbers[] = $number;
                        }
                    }
                }

                // Get available numbers directly, excluding used ones
                $availableNumbers = $standort->extractNumbersFromRanges($usedNumbers);

                // Add the special option "9999" which is always valid
                $availableNumbers[] = '9999';

                // Check if all numbers are valid
                foreach ($numbersForDuplicateCheck as $number) {
                    if (!in_array($number, $availableNumbers)) {
                        throw new \Exception('Die Behälternummer "' . $number . '" ist nicht gültig oder wird bereits verwendet.');
                    }
                }
            }

            $varValue = json_encode($values);
        }
        return $varValue;
    }
}