diff options
Diffstat (limited to 'lib/cronjobs/check_admission.php')
| -rw-r--r-- | lib/cronjobs/check_admission.php | 147 |
1 files changed, 147 insertions, 0 deletions
diff --git a/lib/cronjobs/check_admission.php b/lib/cronjobs/check_admission.php new file mode 100644 index 0000000..1be4c09 --- /dev/null +++ b/lib/cronjobs/check_admission.php @@ -0,0 +1,147 @@ +<?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); + } + } + } +} |