summaryrefslogtreecommitdiff
path: root/includes/pages/admin_import.php
diff options
context:
space:
mode:
authorPhilip Häusler <msquare@notrademark.de>2012-12-26 14:02:27 +0100
committerPhilip Häusler <msquare@notrademark.de>2012-12-26 14:02:27 +0100
commit0dabaa505e4463498665a1eb6ab95979578beab3 (patch)
treecf2080c39ed5e03f1d27f6d405dc5d0131679c31 /includes/pages/admin_import.php
parent213b6261c8fe6de5e405243f7e2179bdd3a1a271 (diff)
#28 begin log
Diffstat (limited to 'includes/pages/admin_import.php')
-rw-r--r--includes/pages/admin_import.php522
1 files changed, 262 insertions, 260 deletions
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 @@
<?php
function admin_import() {
- global $PentabarfXMLhost, $PentabarfXMLpath;
- global $rooms_import;
- global $user;
- $html = "";
-
- $step = "input";
- if (isset ($_REQUEST['step']))
- $step = $_REQUEST['step'];
-
- $html .= '<p>';
- $html .= $step == "input" ? '<b>1. Input</b>' : '1. Input';
- $html .= ' &raquo; ';
- $html .= $step == "check" ? '<b>2. Validate</b>' : '2. Validate';
- $html .= ' &raquo; ';
- $html .= $step == "import" ? '<b>3. Import</b>' : '3. Import';
- $html .= '</p>';
-
- $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 "<pre>";
- while (!feof($fp)) {
- $Temp = fgets($fp, 1024);
-
- // show header
- if ($Zeilen == -1) {
- echo $Temp;
- }
-
- // ende des headers
- if ($Temp == "\r\n") {
- echo "</pre>\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 ? "<tr><td>None</td></tr>" : table_body($rooms_new),
- 'rooms_deleted' => count($rooms_deleted) == 0 ? "<tr><td>None</td></tr>" : table_body($rooms_deleted),
- 'events_new' => count($events_new) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : table_body(shifts_printable($events_new)),
- 'events_updated' => count($events_updated) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : table_body(shifts_printable($events_updated)),
- 'events_deleted' => count($events_deleted) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : 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 .= '<p>';
+ $html .= $step == "input" ? '<b>1. Input</b>' : '1. Input';
+ $html .= ' &raquo; ';
+ $html .= $step == "check" ? '<b>2. Validate</b>' : '2. Validate';
+ $html .= ' &raquo; ';
+ $html .= $step == "import" ? '<b>3. Import</b>' : '3. Import';
+ $html .= '</p>';
+
+ $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 "<pre>";
+ while (!feof($fp)) {
+ $Temp = fgets($fp, 1024);
+
+ // show header
+ if ($Zeilen == -1) {
+ echo $Temp;
+ }
+
+ // ende des headers
+ if ($Temp == "\r\n") {
+ echo "</pre>\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 ? "<tr><td>None</td></tr>" : table_body($rooms_new),
+ 'rooms_deleted' => count($rooms_deleted) == 0 ? "<tr><td>None</td></tr>" : table_body($rooms_deleted),
+ 'events_new' => count($events_new) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : table_body(shifts_printable($events_new)),
+ 'events_updated' => count($events_updated) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : table_body(shifts_printable($events_updated)),
+ 'events_deleted' => count($events_deleted) == 0 ? "<tr><td>None</td><td></td><td></td><td></td><td></td></tr>" : 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;
}
?>