From 0dabaa505e4463498665a1eb6ab95979578beab3 Mon Sep 17 00:00:00 2001
From: Philip Häusler
Date: Wed, 26 Dec 2012 14:02:27 +0100
Subject: #28 begin log
---
includes/pages/admin_import.php | 522 ++++++++++++++++++++--------------------
1 file changed, 262 insertions(+), 260 deletions(-)
(limited to 'includes/pages/admin_import.php')
diff --git a/includes/pages/admin_import.php b/includes/pages/admin_import.php
index 5ac62d2d..9a31d5cd 100644
--- a/includes/pages/admin_import.php
+++ b/includes/pages/admin_import.php
@@ -1,279 +1,281 @@
';
- $html .= $step == "input" ? '1. Input' : '1. Input';
- $html .= ' » ';
- $html .= $step == "check" ? '2. Validate' : '2. Validate';
- $html .= ' » ';
- $html .= $step == "import" ? '3. Import' : '3. Import';
- $html .= '
';
-
- $import_file = '../import/import_' . $user['UID'] . '.xml';
-
- switch ($step) {
- case "input" :
- $ok = false;
- if ($test_handle = fopen('../import/tmp', 'w')) {
- fclose($test_handle);
- unlink('../import/tmp');
- } else {
- $msg = error("Webserver has no write-permission on import directory.", true);
- }
-
- if (isset ($_REQUEST['submit'])) {
- $ok = true;
- if (isset ($_REQUEST['user']) && $_REQUEST['user'] != "" && isset ($_REQUEST['password']) && $_REQUEST['password'] != "") {
- $fp = fsockopen("ssl://$PentabarfXMLhost", 443, $errno, $errstr, 5);
-
- if (!$fp) {
- $ok = false;
- $msg = error("File 'https://$PentabarfXMLhost/$PentabarfXMLpath" . $_REQUEST["url"] . "' not readable!" . "[$errstr ($errno)]", true);
- } else {
- $fileOut = fopen($import_file, "w");
- $head = 'GET /' . $PentabarfXMLpath . $_REQUEST["url"] . ' HTTP/1.1' . "\r\n" .
- 'Host: ' . $PentabarfXMLhost . "\r\n" .
- 'User-Agent: Engelsystem' . "\r\n" .
- 'Authorization: Basic ' .
- base64_encode($_REQUEST["user"] . ':' . $_REQUEST["password"]) . "\r\n" .
- "\r\n";
- fputs($fp, $head);
- $Zeilen = -1;
- echo "";
- while (!feof($fp)) {
- $Temp = fgets($fp, 1024);
-
- // show header
- if ($Zeilen == -1) {
- echo $Temp;
- }
-
- // ende des headers
- if ($Temp == "\r\n") {
- echo "
\n";
- $Zeilen = 0;
- $Temp = "";
- }
-
- //file ende?
- if ($Temp == "0\r\n")
- break;
-
- if (($Zeilen > -1) && ($Temp != "ffb\r\n")) {
- //steuerzeichen ausfiltern
- if (strpos("#$Temp", "\r\n") > 0)
- $Temp = substr($Temp, 0, strlen($Temp) - 2);
- if (strpos("#$Temp", "1005") > 0)
- $Temp = "";
- if (strpos("#$Temp", "783") > 0)
- $Temp = "";
- //schreiben in file
- fputs($fileOut, $Temp);
- $Zeilen++;
- }
- }
- fclose($fileOut);
- fclose($fp);
- $msg .= success("Es wurden $Zeilen Zeilen eingelesen.", true);
- }
- }
- elseif (isset ($_FILES['xcal_file']) && ($_FILES['xcal_file']['error'] == 0)) {
- if (move_uploaded_file($_FILES['xcal_file']['tmp_name'], $import_file)) {
- libxml_use_internal_errors(true);
- if (simplexml_load_file($import_file) === false) {
- $ok = false;
- $msg = error("No valid xml/xcal file provided.", true);
- unlink($import_file);
- }
- } else {
- $ok = false;
- $msg = error("File upload went wrong.", true);
- }
- } else {
- $ok = false;
- $msg = error("Please provide some data.", true);
- }
- }
-
- if ($ok)
- header("Location: " . page_link_to('admin_import') . "&step=check");
- else
- $html .= template_render('../templates/admin_import_input.html', array (
- 'link' => page_link_to('admin_import'),
- 'msg' => $msg,
- 'url' => "https://$PentabarfXMLhost/$PentabarfXMLpath"
- ));
- break;
-
- case "check" :
- if (!file_exists($import_file))
- header("Location: " . page_link_to('admin_import'));
-
- list ($rooms_new, $rooms_deleted) = prepare_rooms($import_file);
- list ($events_new, $events_updated, $events_deleted) = prepare_events($import_file);
-
- $html .= template_render('../templates/admin_import_check.html', array (
- 'link' => page_link_to('admin_import'),
- 'rooms_new' => count($rooms_new) == 0 ? "None |
" : table_body($rooms_new),
- 'rooms_deleted' => count($rooms_deleted) == 0 ? "None |
" : table_body($rooms_deleted),
- 'events_new' => count($events_new) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_new)),
- 'events_updated' => count($events_updated) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_updated)),
- 'events_deleted' => count($events_deleted) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_deleted))
- ));
- break;
-
- case "import" :
- if (!file_exists($import_file))
- header("Location: " . page_link_to('admin_import'));
-
- list ($rooms_new, $rooms_deleted) = prepare_rooms($import_file);
- foreach ($rooms_new as $room) {
- sql_query("INSERT INTO `Room` SET `Name`='" . sql_escape($room) . "', `FromPentabarf`='Y', `Show`='Y'");
- $rooms_import[trim($room)] = sql_id();
- }
- foreach ($rooms_deleted as $room)
- sql_query("DELETE FROM `Room` WHERE `Name`='" . sql_escape($room) . "' LIMIT 1");
-
- list ($events_new, $events_updated, $events_deleted) = prepare_events($import_file);
- foreach ($events_new as $event)
- sql_query("INSERT INTO `Shifts` SET `name`='" .
- sql_escape($event['name']) . "', `start`=" . sql_escape($event['start']) . ", `end`=" . sql_escape($event['end']) . ", `RID`=" . sql_escape($event['RID']) . ", `PSID`=" . sql_escape($event['PSID']) . ", `URL`='" . sql_escape($event['URL']) . "'");
-
- foreach ($events_updated as $event)
- sql_query("UPDATE `Shifts` SET `name`='" .
- sql_escape($event['name']) . "', `start`=" . sql_escape($event['start']) . ", `end`=" . sql_escape($event['end']) . ", `RID`=" . sql_escape($event['RID']) . ", `PSID`=" . sql_escape($event['PSID']) . ", `URL`='" . sql_escape($event['URL']) . "' WHERE `PSID`=" . sql_escape($event['PSID']) . " LIMIT 1");
-
- foreach ($events_deleted as $event)
- sql_query("DELETE FROM `Shifts` WHERE `PSID`=" .
- sql_escape($event['PSID']) . " LIMIT 1");
-
- unlink($import_file);
-
- $html .= template_render('../templates/admin_import_import.html', array ());
- break;
- }
-
- return $html;
+ global $PentabarfXMLhost, $PentabarfXMLpath;
+ global $rooms_import;
+ global $user;
+ $html = "";
+
+ $step = "input";
+ if (isset ($_REQUEST['step']))
+ $step = $_REQUEST['step'];
+
+ $html .= '';
+ $html .= $step == "input" ? '1. Input' : '1. Input';
+ $html .= ' » ';
+ $html .= $step == "check" ? '2. Validate' : '2. Validate';
+ $html .= ' » ';
+ $html .= $step == "import" ? '3. Import' : '3. Import';
+ $html .= '
';
+
+ $import_file = '../import/import_' . $user['UID'] . '.xml';
+
+ switch ($step) {
+ case "input" :
+ $ok = false;
+ if ($test_handle = fopen('../import/tmp', 'w')) {
+ fclose($test_handle);
+ unlink('../import/tmp');
+ } else {
+ $msg = error("Webserver has no write-permission on import directory.", true);
+ }
+
+ if (isset ($_REQUEST['submit'])) {
+ $ok = true;
+ if (isset ($_REQUEST['user']) && $_REQUEST['user'] != "" && isset ($_REQUEST['password']) && $_REQUEST['password'] != "") {
+ $fp = fsockopen("ssl://$PentabarfXMLhost", 443, $errno, $errstr, 5);
+
+ if (!$fp) {
+ $ok = false;
+ $msg = error("File 'https://$PentabarfXMLhost/$PentabarfXMLpath" . $_REQUEST["url"] . "' not readable!" . "[$errstr ($errno)]", true);
+ } else {
+ $fileOut = fopen($import_file, "w");
+ $head = 'GET /' . $PentabarfXMLpath . $_REQUEST["url"] . ' HTTP/1.1' . "\r\n" .
+ 'Host: ' . $PentabarfXMLhost . "\r\n" .
+ 'User-Agent: Engelsystem' . "\r\n" .
+ 'Authorization: Basic ' .
+ base64_encode($_REQUEST["user"] . ':' . $_REQUEST["password"]) . "\r\n" .
+ "\r\n";
+ fputs($fp, $head);
+ $Zeilen = -1;
+ echo "";
+ while (!feof($fp)) {
+ $Temp = fgets($fp, 1024);
+
+ // show header
+ if ($Zeilen == -1) {
+ echo $Temp;
+ }
+
+ // ende des headers
+ if ($Temp == "\r\n") {
+ echo "
\n";
+ $Zeilen = 0;
+ $Temp = "";
+ }
+
+ //file ende?
+ if ($Temp == "0\r\n")
+ break;
+
+ if (($Zeilen > -1) && ($Temp != "ffb\r\n")) {
+ //steuerzeichen ausfiltern
+ if (strpos("#$Temp", "\r\n") > 0)
+ $Temp = substr($Temp, 0, strlen($Temp) - 2);
+ if (strpos("#$Temp", "1005") > 0)
+ $Temp = "";
+ if (strpos("#$Temp", "783") > 0)
+ $Temp = "";
+ //schreiben in file
+ fputs($fileOut, $Temp);
+ $Zeilen++;
+ }
+ }
+ fclose($fileOut);
+ fclose($fp);
+ $msg .= success("Es wurden $Zeilen Zeilen eingelesen.", true);
+ }
+ }
+ elseif (isset ($_FILES['xcal_file']) && ($_FILES['xcal_file']['error'] == 0)) {
+ if (move_uploaded_file($_FILES['xcal_file']['tmp_name'], $import_file)) {
+ libxml_use_internal_errors(true);
+ if (simplexml_load_file($import_file) === false) {
+ $ok = false;
+ $msg = error("No valid xml/xcal file provided.", true);
+ unlink($import_file);
+ }
+ } else {
+ $ok = false;
+ $msg = error("File upload went wrong.", true);
+ }
+ } else {
+ $ok = false;
+ $msg = error("Please provide some data.", true);
+ }
+ }
+
+ if ($ok)
+ header("Location: " . page_link_to('admin_import') . "&step=check");
+ else
+ $html .= template_render('../templates/admin_import_input.html', array (
+ 'link' => page_link_to('admin_import'),
+ 'msg' => $msg,
+ 'url' => "https://$PentabarfXMLhost/$PentabarfXMLpath"
+ ));
+ break;
+
+ case "check" :
+ if (!file_exists($import_file))
+ header("Location: " . page_link_to('admin_import'));
+
+ list ($rooms_new, $rooms_deleted) = prepare_rooms($import_file);
+ list ($events_new, $events_updated, $events_deleted) = prepare_events($import_file);
+
+ $html .= template_render('../templates/admin_import_check.html', array (
+ 'link' => page_link_to('admin_import'),
+ 'rooms_new' => count($rooms_new) == 0 ? "None |
" : table_body($rooms_new),
+ 'rooms_deleted' => count($rooms_deleted) == 0 ? "None |
" : table_body($rooms_deleted),
+ 'events_new' => count($events_new) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_new)),
+ 'events_updated' => count($events_updated) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_updated)),
+ 'events_deleted' => count($events_deleted) == 0 ? "None | | | | |
" : table_body(shifts_printable($events_deleted))
+ ));
+ break;
+
+ case "import" :
+ if (!file_exists($import_file))
+ header("Location: " . page_link_to('admin_import'));
+
+ list ($rooms_new, $rooms_deleted) = prepare_rooms($import_file);
+ foreach ($rooms_new as $room) {
+ sql_query("INSERT INTO `Room` SET `Name`='" . sql_escape($room) . "', `FromPentabarf`='Y', `Show`='Y'");
+ $rooms_import[trim($room)] = sql_id();
+ }
+ foreach ($rooms_deleted as $room)
+ sql_query("DELETE FROM `Room` WHERE `Name`='" . sql_escape($room) . "' LIMIT 1");
+
+ list ($events_new, $events_updated, $events_deleted) = prepare_events($import_file);
+ foreach ($events_new as $event)
+ sql_query("INSERT INTO `Shifts` SET `name`='" .
+ sql_escape($event['name']) . "', `start`=" . sql_escape($event['start']) . ", `end`=" . sql_escape($event['end']) . ", `RID`=" . sql_escape($event['RID']) . ", `PSID`=" . sql_escape($event['PSID']) . ", `URL`='" . sql_escape($event['URL']) . "'");
+
+ foreach ($events_updated as $event)
+ sql_query("UPDATE `Shifts` SET `name`='" .
+ sql_escape($event['name']) . "', `start`=" . sql_escape($event['start']) . ", `end`=" . sql_escape($event['end']) . ", `RID`=" . sql_escape($event['RID']) . ", `PSID`=" . sql_escape($event['PSID']) . ", `URL`='" . sql_escape($event['URL']) . "' WHERE `PSID`=" . sql_escape($event['PSID']) . " LIMIT 1");
+
+ foreach ($events_deleted as $event)
+ sql_query("DELETE FROM `Shifts` WHERE `PSID`=" .
+ sql_escape($event['PSID']) . " LIMIT 1");
+
+ engelsystem_log("Pentabarf import done");
+
+ unlink($import_file);
+
+ $html .= template_render('../templates/admin_import_import.html', array ());
+ break;
+ }
+
+ return $html;
}
function prepare_rooms($file) {
- global $rooms_import;
- $data = read_xml($file);
-
- // Load rooms from db for compare with input
- $rooms = sql_select("SELECT * FROM `Room` WHERE `FromPentabarf`='Y'");
- $rooms_db = array ();
- $rooms_import = array ();
- foreach ($rooms as $room) {
- $rooms_db[] = $room['Name'];
- $rooms_import[$room['Name']] = $room['RID'];
- }
-
- $events = $data->vcalendar->vevent;
- $rooms_pb = array ();
- foreach ($events as $event) {
- $rooms_pb[] = $event->location;
- if (!isset ($rooms_import[trim($event->location)]))
- $rooms_import[trim($event->location)] = trim($event->location);
- }
- $rooms_pb = array_unique($rooms_pb);
-
- $rooms_new = array_diff($rooms_pb, $rooms_db);
- $rooms_deleted = array_diff($rooms_db, $rooms_pb);
-
- return array (
- $rooms_new,
- $rooms_deleted
- );
+ global $rooms_import;
+ $data = read_xml($file);
+
+ // Load rooms from db for compare with input
+ $rooms = sql_select("SELECT * FROM `Room` WHERE `FromPentabarf`='Y'");
+ $rooms_db = array ();
+ $rooms_import = array ();
+ foreach ($rooms as $room) {
+ $rooms_db[] = $room['Name'];
+ $rooms_import[$room['Name']] = $room['RID'];
+ }
+
+ $events = $data->vcalendar->vevent;
+ $rooms_pb = array ();
+ foreach ($events as $event) {
+ $rooms_pb[] = $event->location;
+ if (!isset ($rooms_import[trim($event->location)]))
+ $rooms_import[trim($event->location)] = trim($event->location);
+ }
+ $rooms_pb = array_unique($rooms_pb);
+
+ $rooms_new = array_diff($rooms_pb, $rooms_db);
+ $rooms_deleted = array_diff($rooms_db, $rooms_pb);
+
+ return array (
+ $rooms_new,
+ $rooms_deleted
+ );
}
function prepare_events($file) {
- global $rooms_import;
- $data = read_xml($file);
-
- $rooms = sql_select("SELECT * FROM `Room`");
- $rooms_db = array ();
- foreach ($rooms as $room)
- $rooms_db[$room['Name']] = $room['RID'];
-
- $events = $data->vcalendar->vevent;
- $shifts_pb = array ();
- foreach ($events as $event) {
- $event_pb = $event->children("http://pentabarf.org");
- $event_id = trim($event_pb-> {
- 'event-id' });
- $shifts_pb[$event_id] = array (
- 'start' => DateTime :: createFromFormat("Ymd\THis", $event->dtstart)->getTimestamp(),
- 'end' => DateTime :: createFromFormat("Ymd\THis", $event->dtend)->getTimestamp(),
- 'RID' => $rooms_import[trim($event->location)],
- 'name' => trim($event->summary),
- 'URL' => trim($event->url),
- 'PSID' => $event_id
- );
- }
-
- $shifts = sql_select("SELECT * FROM `Shifts` WHERE `PSID` IS NOT NULL ORDER BY `start`");
- $shifts_db = array ();
- foreach ($shifts as $shift)
- $shifts_db[$shift['PSID']] = $shift;
-
- $shifts_new = array ();
- $shifts_updated = array ();
- foreach ($shifts_pb as $shift)
- if (!isset ($shifts_db[$shift['PSID']]))
- $shifts_new[] = $shift;
- else {
- $tmp = $shifts_db[$shift['PSID']];
- if ($shift['name'] != $tmp['name'] || $shift['start'] != $tmp['start'] || $shift['end'] != $tmp['end'] || $shift['RID'] != $tmp['RID'] || $shift['URL'] != $tmp['URL'])
- $shifts_updated[] = $shift;
- }
-
- $shifts_deleted = array ();
- foreach ($shifts_db as $shift)
- if (!isset ($shifts_pb[$shift['PSID']]))
- $shifts_deleted[] = $shift;
-
- return array (
- $shifts_new,
- $shifts_updated,
- $shifts_deleted
- );
+ global $rooms_import;
+ $data = read_xml($file);
+
+ $rooms = sql_select("SELECT * FROM `Room`");
+ $rooms_db = array ();
+ foreach ($rooms as $room)
+ $rooms_db[$room['Name']] = $room['RID'];
+
+ $events = $data->vcalendar->vevent;
+ $shifts_pb = array ();
+ foreach ($events as $event) {
+ $event_pb = $event->children("http://pentabarf.org");
+ $event_id = trim($event_pb-> {
+ 'event-id' });
+ $shifts_pb[$event_id] = array (
+ 'start' => DateTime :: createFromFormat("Ymd\THis", $event->dtstart)->getTimestamp(),
+ 'end' => DateTime :: createFromFormat("Ymd\THis", $event->dtend)->getTimestamp(),
+ 'RID' => $rooms_import[trim($event->location)],
+ 'name' => trim($event->summary),
+ 'URL' => trim($event->url),
+ 'PSID' => $event_id
+ );
+ }
+
+ $shifts = sql_select("SELECT * FROM `Shifts` WHERE `PSID` IS NOT NULL ORDER BY `start`");
+ $shifts_db = array ();
+ foreach ($shifts as $shift)
+ $shifts_db[$shift['PSID']] = $shift;
+
+ $shifts_new = array ();
+ $shifts_updated = array ();
+ foreach ($shifts_pb as $shift)
+ if (!isset ($shifts_db[$shift['PSID']]))
+ $shifts_new[] = $shift;
+ else {
+ $tmp = $shifts_db[$shift['PSID']];
+ if ($shift['name'] != $tmp['name'] || $shift['start'] != $tmp['start'] || $shift['end'] != $tmp['end'] || $shift['RID'] != $tmp['RID'] || $shift['URL'] != $tmp['URL'])
+ $shifts_updated[] = $shift;
+ }
+
+ $shifts_deleted = array ();
+ foreach ($shifts_db as $shift)
+ if (!isset ($shifts_pb[$shift['PSID']]))
+ $shifts_deleted[] = $shift;
+
+ return array (
+ $shifts_new,
+ $shifts_updated,
+ $shifts_deleted
+ );
}
function read_xml($file) {
- global $xml_import;
- if (!isset ($xml_import))
- $xml_import = simplexml_load_file($file);
- return $xml_import;
+ global $xml_import;
+ if (!isset ($xml_import))
+ $xml_import = simplexml_load_file($file);
+ return $xml_import;
}
function shifts_printable($shifts) {
- global $rooms_import;
- $rooms = array_flip($rooms_import);
-
- uasort($shifts, 'shift_sort');
-
- $shifts_printable = array ();
- foreach ($shifts as $shift)
- $shifts_printable[] = array (
- 'day' => date("l, Y-m-d", $shift['start']),
- 'start' => date("H:i", $shift['start']),
- 'name' => shorten($shift['name']),
- 'end' => date("H:i", $shift['end']),
- 'room' => $rooms[$shift['RID']]
- );
- return $shifts_printable;
+ global $rooms_import;
+ $rooms = array_flip($rooms_import);
+
+ uasort($shifts, 'shift_sort');
+
+ $shifts_printable = array ();
+ foreach ($shifts as $shift)
+ $shifts_printable[] = array (
+ 'day' => date("l, Y-m-d", $shift['start']),
+ 'start' => date("H:i", $shift['start']),
+ 'name' => shorten($shift['name']),
+ 'end' => date("H:i", $shift['end']),
+ 'room' => $rooms[$shift['RID']]
+ );
+ return $shifts_printable;
}
function shift_sort($a, $b) {
- return ($a['start'] < $b['start']) ? -1 : 1;
+ return ($a['start'] < $b['start']) ? -1 : 1;
}
?>
--
cgit v1.2.3-70-g09d2