<?php

use Monolog\Logger;
use Monolog\Handler\StreamHandler;

/**
* check_admission.php
*
* @author André Noack <noack@data-quest.de>, Suchi & Berg GmbH <info@data-quest.de>
* @access public
* @since  2.4
*/

class CheckAdmissionJob extends CronJob
{
    public static function getName()
    {
        return _('Losverfahren überprüfen');
    }

    public static function getDescription()
    {
        return _('Überprüft, ob Losverfahren anstehen und führt diese aus');
    }

    public static function getParameters()
    {
        return [
            'verbose' => [
                'type'        => 'boolean',
                'default'     => false,
                'status'      => 'optional',
                'description' => _('Sollen Ausgaben erzeugt werden (sind später im Log des Cronjobs sichtbar)'),
            ],
            'send_messages' => [
                'type'        => 'boolean',
                'default'     => true,
                'status'      => 'optional',
                'description' => _('Sollen interne Nachrichten an alle betroffenen Nutzer gesendet werden)'),
            ],
            'send_applications_to_owner' => [
                'type'        => 'boolean',
                'default'     => false,
                'status'      => 'optional',
                'description' => _('Die Liste mit Anmeldungen an die Person senden, der das Anmeldeset gehört.')
            ]
        ];
    }

    public function setUp()
    {
        require_once 'lib/classes/admission/CourseSet.php';
        if (empty($GLOBALS['ABSOLUTE_URI_STUDIP'])) {
            throw new Exception('To use check_admission job you MUST set correct values for $ABSOLUTE_URI_STUDIP in config_local.inc.php!');
        }
    }

    public function execute($last_result, $parameters = [])
    {
        $verbose = $parameters['verbose'];

        $query = "SELECT DISTINCT cr.set_id
                  FROM courseset_rule AS cr
                  INNER JOIN coursesets USING(set_id)
                  WHERE type = 'ParticipantRestrictedAdmission'
                    AND algorithm_run = 0";
        $sets = DBManager::get()->fetchFirst($query);
        if (count($sets) > 0) {
            if ($verbose) {
                echo date('r') . ' - Starting seat distribution ' . chr(10);

                $oldLogger = Log::getInstance();
                $logdir = $GLOBALS['TMP_PATH'] . '/seat_distribution_logs';
                @mkdir($logdir);
                $logfile = $logdir . '/' .  date('Y-m-d-H-i') . '_seat_distribution.log';

                if (is_dir($logdir)) {
                    Log::setInstance(
                        new Logger('seat-distributions', [new StreamHandler($logfile, Logger::DEBUG)])
                    );
                    echo 'logging to ' . $logfile . chr(10);
                } else {
                    echo 'could not create directory ' . $logdir . chr(10);
                }
            }
            $i = 0;
            foreach ($sets as $set_id) {
                $courseset = new CourseSet($set_id);
                if ($courseset->isSeatDistributionEnabled() && !$courseset->hasAlgorithmRun() && $courseset->getSeatDistributionTime() < time()) {
                    if ($verbose) {
                        echo ++$i . ' ' . $courseset->getId() . ' : ' . $courseset->getName() . chr(10);
                        $applicants = AdmissionPriority::getPriorities($set_id);
                        $courses = SimpleCollection::createFromArray(Course::findMany($courseset->getCourses()))->toGroupedArray('seminar_id', words('name veranstaltungsnummer'));
                        $captions = [_("Nachname"), _("Vorname"), _("Nutzername"),_('Nutzer-ID'), _('Veranstaltung-ID'), _("Veranstaltung"), _("Nummer"), _("Priorität")];
                        $data = [];
                        $users = User::findEachMany(function($user) use ($courses,$applicants,&$data) {
                            $app_courses = $applicants[$user->id];
                            asort($app_courses);
                            foreach ($app_courses as $course_id => $prio) {
                                $row = [];
                                $row[] = $user->nachname;
                                $row[] = $user->vorname;
                                $row[] = $user->username;
                                $row[] = $user->id;
                                $row[] = $course_id;
                                $row[] = $courses[$course_id]['name'];
                                $row[] = $courses[$course_id]['veranstaltungsnummer'];
                                $row[] = $prio;
                                $data[] = $row;
                            }
                        }, array_keys($applicants), 'ORDER BY Nachname,Vorname');
                        $applicants_file = $GLOBALS['TMP_PATH'] . '/seat_distribution_logs/applicants_' . $set_id . '.csv';
                        if (array_to_csv($data, $applicants_file, $captions)) {
                            echo 'applicants written to ' . $applicants_file . chr(10);
                            if ($parameters['send_applications_to_owner']) {
                                //Send a mail to the owner of the course set:
                                $owner = User::find($courseset->getUserId());
                                if ($owner) {
                                    setTempLanguage($owner->id);
                                    $mail = new StudipMail();
                                    $mail->addRecipient($owner->email)
                                        ->setSubject(
                                            sprintf(_('Das Stud.IP Anmeldeset %s wird gelost'), $courseset->getName()))
                                        ->setBodyText(sprintf(
                                            _('Ihr Anmeldeset %s wird jetzt gelost. Im Anhang finden Sie die Liste der Anmeldungen.'),
                                            $courseset->getName()
                                        ))
                                        ->addFileAttachment($applicants_file)
                                        ->send();
                                    restoreLanguage();
                                }
                            }
                        }
                    }
                    $courseset->distributeSeats();
                }
            }
            if ($verbose) {
                Log::setInstance($oldLogger);
            }
        } else {
            if ($verbose) {
                echo date('r') . ' - Nothing to do' . chr(10);
            }
        }
    }
}