5balls
/
Bengelsystem
mirror of https://github.com/iridos/Bengelsystem.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
Bengelsystem/html/SQL.php

1041 lines
38 KiB
PHP
Raw Permalink Blame History

<?php
require_once 'konfiguration.php';
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
function ConnectDB()
{
$db_link = mysqli_connect(
MYSQL_HOST,
MYSQL_BENUTZER,
MYSQL_KENNWORT,
MYSQL_DATENBANK
);
DatenbankAufDeutsch($db_link);
return $db_link;
}
function debug_sql($sql, $types, $params) {#stmtnoneed
$i = 0;
$parts = explode('?', $sql);
$reconstructed = '';
foreach ($parts as $part) {
$reconstructed .= $part;
if ($i < strlen($types)) {
$val = $params[$i];
$type = $types[$i];
if ($type === 's') {
$reconstructed .= "'" . addslashes($val) . "'";
} else {
$reconstructed .= $val;
}
$i++;
}
}
return str_replace(["\n", "\r"], ' ', $reconstructed);
}
function stmt_prepare_and_execute($db_link, $sql, $types = "", ...$params) {#stmt-func
try {
$stmt = mysqli_prepare($db_link, $sql);
if ($types !== "") {
mysqli_stmt_bind_param($stmt, $types, ...$params);
}
if (!mysqli_stmt_execute($stmt)) {
$err = "Execute failed: " . mysqli_stmt_error($stmt) . "\nSQL: $sql";
$err .= debug_sql($sql, $types, $params);
error_log($err);
echo nl2br($err);
return false;
}
} catch (mysqli_sql_exception $e) {
$err = "MySQLi Error: " . $e->getMessage() . "\n";
$err .= debug_sql($sql, $types, $params);
error_log($err);
echo nl2br($err); // Optional: für saubere HTML-Darstellung
return false;
}
return $stmt;
}
function CreateHelfer($db_link, $HelferName, $HelferEmail, $HelferHandy, $HelferPasswort, $HelferLevel = 1) #stmt
{
$HelferPasswort = "€" . $HelferPasswort . "ß";
$PasswortHash = password_hash($HelferPasswort, PASSWORD_DEFAULT);
// Prepared Statement erstellen
$sql = "INSERT INTO Helfer (Name, Email, Handy, Status, BildFile, DoReport, Passwort, HelferLevel)
VALUES (?, ?, ?, 1, '', 0, ?, ?)";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ssssi", $HelferName, $HelferEmail, $HelferHandy, $PasswortHash, $HelferLevel);
if (!$stmt) { error_log("Fehler in CreateHelfer, kein stmt"); return null; }
$result = mysqli_stmt_affected_rows($stmt);
if ($result !== 1) { error_log("CreateHelfer: Unerwartete Anzahl betroffener Zeilen ($result)"); }
error_log(date('Y-m-d H:i') . " CreateHelfer: $HelferName angelegt mit Email $HelferEmail Handy $HelferHandy ($result)\n", 3, LOGFILE);
return $result ?: null;
}
// Testet fuer urllogin, ob Helfer bereits existiert
function HelferIstVorhanden($db_link, $Email)#stmt
{
$sql = "SELECT COUNT(HelferID) AS Anzahl FROM Helfer WHERE Email = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
error_log("Fehler beim Vorbereiten des Statements: " . mysqli_error($db_link));
return false;
}
mysqli_stmt_bind_param($stmt, "s", $Email);
mysqli_stmt_execute($stmt);
$result = mysqli_stmt_get_result($stmt);
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
mysqli_stmt_close($stmt);
return $zeile['Anzahl'] ?? 0;
}
//TODO: pruefen, ob Helfer bereits eingeloggt
function HelferLogin($db_link, $HelferEmail, $HelferPasswort, $HelferStatus)#stmt
{
$sql = "SELECT HelferID, Admin, Name, Passwort, HelferLevel FROM Helfer WHERE Email = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "s", $HelferEmail);
if (!$stmt) { error_log("Fehler in HelferLogin, kein stmt"); die('Login ungültige Abfrage');}
$result = mysqli_stmt_get_result($stmt);
while ($zeile = mysqli_fetch_array($result, MYSQLI_ASSOC)) {
$HelferPasswort = "€" . $HelferPasswort . "ß";
if (password_verify($HelferPasswort, $zeile['Passwort'])) {
$_SESSION["HelferID"] = $zeile['HelferID'];
$_SESSION["HelferName"] = $zeile['Name'];
$_SESSION["HelferEmail"] = $HelferEmail;
$_SESSION["AdminStatus"] = $zeile['Admin'];
if( $_SESSION["AdminStatus"] == 1) {
$_SESSION["AdminID"] = $zeile['HelferID'];
}
$_SESSION["HelferLevel"] = $zeile['HelferLevel'];
mysqli_stmt_close($stmt);
return 1;
} else {
echo "Falsches Passwort<br>";
mysqli_stmt_close($stmt);
return 0;
}
}
mysqli_stmt_close($stmt);
return 0;
}
// Liste der Helfer fuer Admin-Seite
//TODO: HelferLevel
function HelferListe($db_link)#stmt
{
$sql = "SELECT HelferID, Name FROM Helfer";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
echo "Helferliste ungültige Abfrage";
die('Ungültige Abfrage: ' . mysqli_error($db_link));
}
mysqli_stmt_execute($stmt);
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function Helferdaten($db_link, $HelferID)#stmt
{
$sql = "SELECT * FROM Helfer Where HelferID = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
echo "Helferdaten: Fehler beim Vorbereiten des Statements<br>\n";
die('Prepare failed: ' . mysqli_error($db_link));
}
mysqli_stmt_bind_param($stmt, "i", $HelferID);
if (!mysqli_stmt_execute($stmt)) {
echo "Helferdaten: Fehler bei der Ausführung<br>\n";
die('Execution failed: ' . mysqli_stmt_error($stmt));
}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function HelferdatenAendern($db_link, $HelferName, $HelferEmail, $HelferHandy, $HelferNewPasswort, $HelferID, $HelferLevel = -1, $HelferIsAdmin = -1, $AdminID = 0)#stmt
{
$result = false;
if ($HelferLevel == -1) { $HelferLevel = $_SESSION["HelferLevel"]; }
if ($HelferNewPasswort == "") {
if ($HelferIsAdmin == -1) {
$sql = "UPDATE Helfer SET Name = ?, Email = ?, Handy = ?, HelferLevel = ? WHERE HelferId = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
die("Prepare failed: " . mysqli_error($db_link));
}
mysqli_stmt_bind_param($stmt, "ssssi", $HelferName, $HelferEmail, $HelferHandy, $HelferLevel, $HelferID);
} else {
$sql = "UPDATE Helfer SET Name = ?, Email = ?, Handy = ?, Admin = ?, HelferLevel = ? WHERE HelferId = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
die("Prepare failed: " . mysqli_error($db_link));
}
mysqli_stmt_bind_param($stmt, "ssssii", $HelferName, $HelferEmail, $HelferHandy, $HelferIsAdmin, $HelferLevel, $HelferID);
}
if (!mysqli_stmt_execute($stmt)) {
die("Execute failed: " . mysqli_stmt_error($stmt));
}
$result = true;
echo "<li>Helferdaten geändert</li>";
$log_prefix = ($AdminID != 0) ? "(Admin $AdminID) " : "";
error_log(date('Y-m-d H:i') . " {$log_prefix}Helferdaten update: Name: $HelferName (HelferID:$HelferID) Email: $HelferEmail Handy: $HelferHandy HelferLevel: $HelferLevel Admin: $HelferIsAdmin\n", 3, LOGFILE);
mysqli_stmt_close($stmt);
} else {
$HelferNewPasswort = "€" . $HelferNewPasswort . "ß";
$PasswortHash = password_hash($HelferNewPasswort, PASSWORD_DEFAULT);
if ($HelferIsAdmin == -1) {
$sql = "UPDATE Helfer SET Name = ?, Email = ?, Handy = ?, HelferLevel = ?, Passwort = ? WHERE HelferId = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) {
die("Prepare failed: " . mysqli_error($db_link));
}
mysqli_stmt_bind_param($stmt, "sssssi", $HelferName, $HelferEmail, $HelferHandy, $HelferLevel, $PasswortHash, $HelferID);
} else {
$sql = "UPDATE Helfer SET Name = ?, Email = ?, Handy = ?, HelferLevel = ?, Passwort = ?, Admin = ? WHERE HelferId = ?";
$stmt = mysqli_prepare($db_link, $sql);
if (!$stmt) { die("Prepare failed: " . mysqli_error($db_link)); }
mysqli_stmt_bind_param($stmt, "ssssssi", $HelferName, $HelferEmail, $HelferHandy, $HelferLevel, $PasswortHash, $HelferIsAdmin, $HelferID);
}
if (!mysqli_stmt_execute($stmt)) { die("HelferdatenAendern failed: " . mysqli_stmt_error($stmt)); }
$result = true;
echo "<li>Passwort geändert</li>";
if ($AdminID != 0) {
error_log(date('Y-m-d H:i') . "(Admin $AdminID) Helferdaten update: Name: $HelferName (HelferID:$HelferID) Email: $HelferEmail Handy: $HelferHandy HelferLevel: $HelferLevel Passwort: neu gesetzt\n", 3, LOGFILE);
} else {
error_log(date('Y-m-d H:i') . "Helferdaten update: Name: $HelferName (HelferID:$HelferID) Email: $HelferEmail Handy: $HelferHandy HelferLevel: $HelferLevel Passwort: neu gesetzt\n", 3, LOGFILE);
}
$log_prefix = ($AdminID != 0) ? "(Admin $AdminID) " : "";
error_log(date('Y-m-d H:i') . " {$log_prefix}Helferdaten update: Name: $HelferName (HelferID:$HelferID) Email: $HelferEmail Handy: $HelferHandy HelferLevel: $HelferLevel Passwort: neu gesetzt\n", 3, LOGFILE);
mysqli_stmt_close($stmt);
}
$_SESSION["HelferName"] = $HelferName;
$_SESSION["HelferEmail"] = $HelferEmail;
return $result;
}
function AlleSchichten($db_link, $Sort, $HelferLevel = 1)#stmt
{
$sql = "SELECT SchichtID,Was,DATE_FORMAT(Von,'%a %H:%i') AS Ab,";
$sql .= "DATE_FORMAT(Bis,'%a %H:%i') AS Bis,C AS Ist,DATE_FORMAT(Von,'%W %d %M') AS Tag,Soll ";
$sql .= "FROM Dienst,SchichtUebersicht WHERE Dienst.DienstID=SchichtUebersicht.DienstID AND Dienst.Helferlevel=? ";
$sql .= ($Sort == '1')
? " ORDER BY Von"
: " ORDER BY Was,Von";
$stmt = mysqli_prepare($db_link,$sql);
if (!$stmt) { die("Alleschichten prepare failed " . mysqli_error($db_link)); }
mysqli_stmt_bind_param($stmt, "i", $HelferLevel);
if(!mysqli_stmt_execute($stmt)){die ( "AlleSchichten fehlgeschlagen. sort: $Sort err: " . mysqli_stmt_error($stmt));}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function AlleSchichtenCount($db_link, $HelferLevel = -1, $DienstID = -1)#stmt
{
$sql = "SELECT SUM(Soll) AS Anzahl FROM SchichtUebersicht
JOIN Dienst ON SchichtUebersicht.DienstID = Dienst.DienstID WHERE 1=1";
$params = [];
$types = "";
if ($HelferLevel != -1) {
$sql .= " AND HelferLevel = ?";
$params[] = $HelferLevel;
$types .= "i";
}
if ($DienstID != -1) {
$sql .= " AND Dienst.DienstID = ?";
$params[] = $DienstID;
$types .= "i";
}
$stmt = stmt_prepare_and_execute($db_link, $sql, $types, ...$params);
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
return $zeile['Anzahl'] ?? 0;
}
function AlleBelegteSchichtenCount($db_link, $HelferLevel = -1, $DienstID = -1)#stmt
{
$sql = "SELECT COUNT(HelferID) AS Anzahl
FROM EinzelSchicht
JOIN Schicht ON EinzelSchicht.SchichtID = Schicht.SchichtID
JOIN Dienst ON Schicht.DienstID = Dienst.DienstID
WHERE 1=1";
$params = [];
$types = '';
if ($HelferLevel != -1) {
$sql .= " AND HelferLevel = ?";
$params[] = $HelferLevel;
$types .= 'i';
}
if ($DienstID != -1) {
$sql .= " AND Dienst.DienstID = ?";
$params[] = $DienstID;
$types .= 'i';
}
$stmt = stmt_prepare_and_execute($db_link, $sql, $types, ...$params);
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
return $zeile['Anzahl'];
}
function AlleBelegteSchichtenCountMitSurplus($db_link, $HelferLevel = -1, $DienstID = -1) {
$sql = "SELECT
SUM(LEAST(Soll, Belegt)) AS Besetzt,
SUM(GREATEST(0, Belegt - Soll)) AS Ueberbelegt
FROM (
SELECT
Schicht.SchichtID,
COUNT(EinzelSchicht.HelferID) AS Belegt,
Schicht.Soll
FROM Schicht
LEFT JOIN EinzelSchicht ON EinzelSchicht.SchichtID = Schicht.SchichtID
JOIN Dienst ON Schicht.DienstID = Dienst.DienstID
WHERE 1=1";
$params = [];
$types = "";
if ($HelferLevel != -1) {
$sql .= " AND Dienst.HelferLevel = ?";
$params[] = $HelferLevel;
$types .= "i";
}
if ($DienstID != -1) {
$sql .= " AND Dienst.DienstID = ?";
$params[] = $DienstID;
$types .= "i";
}
$sql .= " GROUP BY Schicht.SchichtID, Schicht.Soll
) AS Belegung";
$stmt = stmt_prepare_and_execute($db_link, $sql, $types, ...$params);
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
return [
'besetzt' => (int)($zeile['Besetzt'] ?? 0),
'ueberbelegt' => (int)($zeile['Ueberbelegt'] ?? 0)
];
}
function AlleSchichtenImZeitbereich($db_link, $Von, $Bis, $HelferLevel = -1)#stmt
{
//debug only error_log("AlleSchichtenImZeitbereich Abfrage: $Von, $Bis, $HelferLevel");
// SchichtID, Was, Ab, Bis, Ist, Tag, Soll - Ist und Soll sind die HelferStunden
# bei -1 nicht in Suche einschliessen
$sql_helferlevel = ($HelferLevel == -1)
? ""
: "and Dienst.HelferLevel = ?";
$sql = "SELECT SchichtID,Was,
DATE_FORMAT(Von,'%a %H:%i') AS Ab,
DATE_FORMAT(Bis,'%a %H:%i') AS Bis,
C AS Ist,
DATE_FORMAT(Von,'%W %d %M') As Tag,
Soll,
Dienst.DienstID
FROM Dienst,SchichtUebersicht
WHERE Von >= ? and Von < ? and Dienst.DienstID=SchichtUebersicht.DienstID $sql_helferlevel
ORDER BY Was,Von";
if ($HelferLevel == -1)
{
$stmt = stmt_prepare_and_execute($db_link, $sql, "ss", $Von, $Bis);
$debugmsg = debug_sql($sql, "ss", [$Von, $Bis]);
} else {
$stmt = stmt_prepare_and_execute($db_link, $sql, "ssi", $Von, $Bis, $HelferLevel);
$debugmsg = debug_sql($sql, "ssi", [$Von, $Bis, $HelferLevel]);
}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
if(!$result){error_log("AlleSchichtenImZeitBereich Fehler");error_log("AlleSchichtenImZeitbereich $debugmsg");}
return $result ?: null;
}
function AlleSchichtenEinesHelfers($db_link, $HelferID)#stmt
{
$sql = "SELECT EinzelSchicht.SchichtID ,EinzelSchichtID,Was,
DATE_FORMAT(Von,'%a %H:%i') AS Ab,
DATE_FORMAT(Bis,'%a %H:%i') AS Bis
FROM EinzelSchicht,Schicht,Dienst
WHERE EinzelSchicht.SchichtID=Schicht.SchichtID
AND Schicht.DienstID = Dienst.DienstID
AND HelferID=?
ORDER BY Von";
$stmt = mysqli_prepare($db_link,$sql);
if(!$stmt) { die("AlleSchichtenEinesHelfers prepare failed " . mysqli_error($db_link));}
mysqli_stmt_bind_param($stmt, "i", $HelferID);
if(!mysqli_stmt_execute($stmt)){
die("AlleSchichtenEinesHelfers execute failed HelferId $HelferID" . mysqli_stmt_error($stmt));
}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function HelferLoeschen($db_link, $HelferID, $AdminID)#stmt
{
$result = Helferdaten($db_link, $HelferID);
$HelferName = "(unbekannt)";
while ($zeile = mysqli_fetch_array($result, MYSQLI_ASSOC)) {
$HelferName = $zeile['Name'];
}
$result = AlleSchichtenEinesHelfers($db_link, $HelferID);
$AnzahlHelferschichten = mysqli_num_rows($result);
if ($AnzahlHelferschichten > 0) {
echo "Helfer $HelferName hat noch $AnzahlHelferschichten Schichten. Bitte erst die Schichten löschen<br>";
return -1;
}
$stmt = mysqli_prepare($db_link, "DELETE FROM Helfer WHERE HelferID = ?");
if (!$stmt) {
echo "Helfer $HelferName konnte nicht gelöscht werden<br>";
die("HelferLoeschen prepare failed: " . mysqli_error($db_link));
}
mysqli_stmt_bind_param($stmt, "i", $HelferID);
if (!mysqli_stmt_execute($stmt)) {
echo "Helfer $HelferName konnte nicht gelöscht werden<br>";
die("HelferLoeschen execute failed: " . mysqli_stmt_error($stmt));
}
echo "Helfer $HelferName (HelferID:$HelferID) wurde erfolgreich gelöscht<br>";
error_log(date('Y-m-d H:i') . "(Admin $AdminID) Helfer gelöscht: Name: $HelferName (HelferID:$HelferID)\n", 3, LOGFILE);
return 1;
}
function SchichtIdArrayEinesHelfers($db_link, $HelferID)#stmt
{
// Array, um Zeilen mit von mir belegten Schichten in der Schichtuebersicht einfaerben zu koennenn
$stmt = mysqli_prepare($db_link, "SELECT SchichtID FROM EinzelSchicht WHERE HelferID = ?");
if (!$stmt) {
$err = "Fehler in SchichtIdArrayEinesHelfers " . mysqli_error($db_link);
error_log($err);
echo $err;
die($err);
}
mysqli_stmt_bind_param($stmt, "i", $HelferID);
if (!mysqli_stmt_execute($stmt)) {
echo "HelferID $HelferID konnte nicht gefunden werden<br>";
$err = "SchichtIdArrayEinesHelfers execute failed: " . mysqli_stmt_error($stmt);
error_log($err);
echo $err;
die("SchichtIdArrayEinesHelfers execute failed: " . mysqli_stmt_error($stmt));
}
$result = mysqli_stmt_get_result($stmt);
$schichtIDs = array();
while ($zeile = mysqli_fetch_array($result, MYSQLI_NUM)) {
$schichtIDs[] = $zeile[0];
}
mysqli_stmt_close($stmt);
return($schichtIDs);
}
function AlleSchichtenEinesHelfersVonJetzt($db_link, $HelferID) #stmt2
{
$sql = "SELECT EinzelSchicht.SchichtID, EinzelSchichtID, Was,
DATE_FORMAT(Von,'%a %H:%i') AS Ab,
DATE_FORMAT(Bis,'%a %H:%i') AS Bis
FROM EinzelSchicht, Schicht, Dienst
WHERE EinzelSchicht.SchichtID = Schicht.SchichtID
AND Schicht.DienstID = Dienst.DienstID
AND HelferID = ?
AND Bis > ?
ORDER BY Von";
$jetzt = date("Y-m-d H:i:s");
// is : HelferID -> integer Zeitstempel -> String
$stmt = stmt_prepare_and_execute($db_link, $sql, "is", $HelferID, $jetzt);
if (!$stmt) {
error_log("AlleSchichtenEinesHelfersVonJetzt: Fehler beim Prepare/Execute.");
return null;
}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result ?: null;
}
#
function SchichtenSummeEinesHelfers($db_link, $HelferID) #stmt
{
$sql = "
SELECT
COUNT(*) AS Anzahl,
SUM(TIME_TO_SEC(Schicht.Dauer)) AS Dauer
FROM EinzelSchicht
JOIN Schicht ON EinzelSchicht.SchichtID = Schicht.SchichtID
JOIN Dienst ON Schicht.DienstID = Dienst.DienstID
WHERE HelferID = ?
";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $HelferID);
if (!$stmt) {
error_log("Fehler in SchichtenSummeEinesHelfers");
return false;
}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function LogSchichtEingabe($db_link, $HelferID, $SchichtID, $EinzelSchichtID, $Aktion, $AdminID = 0) #stmt2
{
$sql = "SELECT Schicht.Von, Schicht.Bis, Dienst.Was, Helfer.Name
FROM EinzelSchicht
JOIN Schicht ON EinzelSchicht.SchichtID = Schicht.SchichtID
JOIN Dienst ON Schicht.DienstID = Dienst.DienstID
JOIN Helfer ON EinzelSchicht.HelferID = Helfer.HelferID
WHERE EinzelSchicht.HelferID = ?
AND ( Schicht.SchichtID = ? OR EinzelSchicht.EinzelSchichtID = ?)
";
$types = "iii";
$stmt = stmt_prepare_and_execute($db_link, $sql, $types, $HelferID,$SchichtID,$EinzelSchichtID);
if (!$stmt) {error_log("Fehler in LogSchichtEingabe");}
$result = mysqli_stmt_get_result($stmt);
$num_rows = mysqli_num_rows($result);
if ($num_rows> 1) {
echo "LogSchichtEingabe: Es wurden mehr als eine Zeile zurueckgegeben\n <br>";
// Fehler geht ins normale Error-Management, nicht ins Logfile
//error_log(date('Y-m-d H:i') . " HelferSchichtZuweisen: Es wurden mehr als eine Zeile zurueckgegben.\n", 0);
//error_log(date('Y-m-d H:i') . "sql query: XXX $sql XXX sql query end");
//error_log(date('Y-m-d H:i') . print_r(mysqli_fetch_assoc($result),true));
# wir lassen mehrfachauswahl des selben Dienstes zu, deshalb hier die Daten und Logging auskommentiert, denn das wird zum ok-Fall
} elseif ($num_rows == 1) {
//Regelfall ist $num_rows == 1, keine Ausgabe
} else {
echo "Es wurde keine Zeile zurueckgegeben.";
error_log("LogSchichtEingabe: keine Zeile aus Abfrage erhalten");
$err = debug_sql($sql, $types, [$HelferID,$SchichtID,$EinzelSchichtID]);
error_log($err);
error_log($result);
}
$row = mysqli_fetch_assoc($result);
$Von = $row["Von"] ?? "-";
$Bis = $row["Bis"] ?? "-";
$Was = $row["Was"] ?? "-";
$HelferName = $row["Name"] ?? "-";
if( $Von === "-" and $Bis === "-" ){
error_log("Leere Zeiten werden geloggt. Parameter logging-Aufruf (HelferID:$HelferID): $HelferID, $SchichtID, $EinzelSchichtID, $Aktion, $AdminID");
}
$logline = date('Y-m-d H:i') . " HelferSchicht: ";
if ($AdminID == 0) {
$logline .= "$HelferName (HelferID:$HelferID) hat Dienst $Was von $Von bis $Bis $Aktion.";
} else {
$logline .= "Admin:$AdminID hat von $HelferName (HelferID:$HelferID) den Dienst $Was von $Von bis $Bis $Aktion.";
}
error_log($logline . "\n", 3, LOGFILE);
}
function HelferSchichtZuweisen($db_link, $HelferID, $SchichtID, $AdminID = 0)#stmt2
{
// Abfrage, ob bereits eine Einzelschicht in der selben Schicht vom Helfer existiert
$sql = "SELECT EinzelSchichtID from EinzelSchicht WHERE SchichtID=? and HelferID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ii", $SchichtID, $HelferID);
if (!$stmt) {error_log("Fehler in HelferSchichtZuweisen Schichtabfrage");}
$result = mysqli_stmt_get_result($stmt);
if (mysqli_num_rows($result) > 0) {
echo "HelferSchichtZuweisen: Schicht existiert bereits!";
// abgeschaltet, damit Mehrfacheintraege fuer Familien moeglich sind
//return false;
}
// Helfer Schicht zuweisen
$sql = "INSERT INTO EinzelSchicht(SchichtID,HelferID) VALUES (?,?)";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ii", $SchichtID, $HelferID);
LogSchichtEingabe($db_link, $HelferID, $SchichtID, -1, "eingetragen", $AdminID);
return true;
}
function HelferVonSchichtLoeschen($db_link, $HelferID, $EinzelSchichtID, $AdminID = 0)#stmt2
{
// Log vor Löschen, damit Einzelschicht abgefragt werden kann
LogSchichtEingabe($db_link, $HelferID, -1, $EinzelSchichtID, "entfernt", $AdminID);
// Lösche Einzelschicht
$sql = "DELETE FROM EinzelSchicht WHERE EinzelSchichtID = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $EinzelSchichtID);
if (!$stmt) {error_log("Fehler in HelferVonSchichtLoeschen"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
return $result;
}
function HelferVonSchichtLoeschen_SchichtID($db_link, $HelferID, $SchichtID, $AdminID = 0)#stmt2
{
// Log vor Löschen, damit Einzelschicht abgefragt werden kann
LogSchichtEingabe($db_link, $HelferID, $SchichtID, -1, "entfernt", $AdminID);
// Lösche Einzelschicht
$sql = "DELETE FROM EinzelSchicht WHERE SchichtID = ? AND HelferID = ? limit 1;";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ii", $SchichtID,$HelferID);
if (!$stmt) {error_log("Fehler in HelferVonSchichtLoeschen_SchichtID"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
return $result;
}
function DetailSchicht($db_link, $InfoSchichtID)#stmt2
{
$sql = "SELECT Was,Wo,Info,Name,Handy,Email,DATE_FORMAT(Dauer,'%H:%i') AS Dauer
FROM Dienst
JOIN Schicht ON Dienst.DienstID = Schicht.DienstID
LEFT JOIN Helfer ON Helfer.HelferID = Dienst.Leiter
WHERE SchichtID = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $InfoSchichtID);
if (!$stmt) {error_log("Fehler in DetailSchicht"); return false;}
$result = mysqli_stmt_get_result($stmt);
if (!$result) {error_log("Kein Resultat in DetailSchicht"); return false;}
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
return $zeile;
}
function BeteiligteHelfer($db_link, $InfoSchichtID)#stmt2
{
$sql = "SELECT Helfer.HelferID, Name, Handy
FROM EinzelSchicht, Helfer
WHERE EinzelSchicht.HelferID = Helfer.HelferID
AND SchichtID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $InfoSchichtID);
if (!$stmt) {error_log("Fehler in BeteiligteHelfer"); return false;}
$result = mysqli_stmt_get_result($stmt);
// Kein Fehler wenn leeres Resultat
return $result;
}
function GetDienste($db_link)
{
$sql = "SELECT DienstID, Was, Wo, Info, Leiter, ElternDienstID, HelferLevel FROM Dienst order By Was";
$stmt = stmt_prepare_and_execute($db_link, $sql);
if (!$stmt) {error_log("Fehler in GetDienste"); return false;}
$result = mysqli_stmt_get_result($stmt);
if (!$result) {error_log("Keine Dienste gefunden"); return false;}
return $result;
}
function GetDiensteChilds($db_link, $DienstID)#stmt2
{
$sql = "SELECT DienstID, Was, Wo, Info, Leiter FROM Dienst where ElternDienstID=? ORDER BY Was";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $DienstID);
if (!$stmt) {error_log("Fehler in GetDiensteChilds"); return false;}
$result = mysqli_stmt_get_result($stmt);
return $result;
}
function ChangeDienst($db_link, $DienstID, $Was, $Wo, $Info, $Leiter, $Gruppe, $HelferLevel)#stmt2
{
$sql = "UPDATE Dienst SET Was=?, Wo=?, Info=?, Leiter=?, ElternDienstID=?, HelferLevel=? where DienstID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "sssiiii",$Was, $Wo, $Info, $Leiter, $Gruppe, $HelferLevel, $DienstID);
if (!$stmt) {error_log("Fehler in ChangeDienst"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
return $result;
}
function NewDienst($db_link, $DienstID, $Was, $Wo, $Info, $Leiter, $Gruppe, $HelferLevel)#stmt2
{
// $DienstID
// $Was //Name des Dienstes
// $Wo //Ort
// $Info //vollstaendige Beschreibung
// $Leiter // int HelferID des Leiters
// $Gruppe // ??
// $HelferLevel // int (1,2) Teilnehmer oder Dauerhelfer
$sql = "INSERT INTO Dienst (Was, Wo, Info, Leiter, ElternDienstID, HelferLevel) VALUES (?, ?, ?, ?, ?, ?)";
$stmt = stmt_prepare_and_execute($db_link, $sql, "sssiii", $Was, $Wo, $Info, $Leiter, $Gruppe, $HelferLevel);
$HelferName = $_SESSION["HelferName"] ?? "unbekannt";
$HelferID = $_SESSION["HelferID"] ?? 0;
if (!$stmt) {
$err = mysqli_error($db_link);
echo "Fehler NewDienst: $err";
$full_sql = debug_sql($sql, "sssiii", [$Was, $Wo, $Info, $Leiter, $Gruppe, $HelferLevel]);
error_log(date('Y-m-d H:i') . " NeueSchicht: $HelferName (ID:$HelferID) konnte Schicht nicht anlegen mit Anfrage $full_sql Grund: $err\n", 3, LOGFILE);
die();
} else {
error_log(date('Y-m-d H:i') . " NeueSchicht: $HelferName (HelferID:$HelferID) hat Dienst angelegt mit Was: $Was Wo: $Wo Info: $Info Leiter: $Leiter Gruppe: $Gruppe HelferLevel: $HelferLevel\n", 3, LOGFILE);
}
$result = mysqli_stmt_affected_rows($stmt);
return $result;
}
function DeleteDienst($db_link, $DienstID, $Rekursiv)#stmt2
{
if ($Rekursiv) {
//TODO
return false;
} else {
// Pruefen ob noch Schichten eingetragen sind
$sql = "SELECT SchichtID FROM Schicht where DienstID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $DienstID);
if (!$stmt) {error_log("Fehler in DeleteDienst select"); return false;}
$result = mysqli_stmt_get_result($stmt);
if (mysqli_num_rows($result) == 0) {
// Eintrag löschen
$sql = "DELETE FROM Dienst where DienstID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $DienstID);
if (!$stmt) {error_log("Fehler in DeleteDienst delete"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
return true;
} else {
return false;
}
}
}
function GetDiensteForDay($db_link, $HelferLevel, $datestring)#stmt2
{
// TeilnehmerSchichtenAusdruck2
$unixtime = strtotime($datestring);
$date1 = date('Y-m-d', $unixtime + 24 * 60 * 60);
$date2 = date('Y-m-d', $unixtime);
$sql = "
SELECT DienstId, Was, Wo, Info,
MIN(Von) AS MinVon, MAX(Bis) AS MaxBis
FROM Dienst
INNER JOIN Schicht
USING (DienstID)
WHERE HelferLevel=?
GROUP BY DienstID
HAVING MinVon<?
AND MaxBis>?
ORDER BY MIN(Von) ASC";
$stmt = stmt_prepare_and_execute($db_link, $sql, "iss", $HelferLevel, $date1, $date2);
if (!$stmt) {error_log("Fehler in GetDiensteForDay select"); return false;}
$result = mysqli_stmt_get_result($stmt);
return $result;
}
function GetSchichtenForDienstForDay($db_link, $DienstID, $datestring)#stmt2
{
// TeilnehmerSchichtenAusdruck2
$unixtime = strtotime($datestring);
$date1 = date('Y-m-d', $unixtime + 24 * 60 * 60);
$date2 = date('Y-m-d', $unixtime);
$sql = "
SELECT Von, Bis, Soll, Name, Handy
FROM Schicht
LEFT JOIN EinzelSchicht
USING (SchichtID)
LEFT JOIN Helfer
USING (HelferID)
WHERE DienstID=?
AND Von<?
AND Bis>?
ORDER BY Von";
$stmt = stmt_prepare_and_execute($db_link, $sql, "iss", $DienstID, $date1, $date2);
if (!$stmt) {error_log("Fehler in GetSchichtenForDiensteForDay select"); return false;}
$result = mysqli_stmt_get_result($stmt);
return $result;
}
function GetSchichtenEinesDienstes($db_link, $DienstID)#stmt2
{
$sql = "
SELECT SchichtID,Von,Bis,Soll,DATE_FORMAT(Von,'%a %H:%i')
AS TagVon, DATE_FORMAT(Von,'%H:%i') AS ZeitVon,
DATE_FORMAT(Bis,'%H:%i') AS ZeitBis, DATE_FORMAT(Dauer,'%H:%i')
AS Dauer FROM Schicht
WHERE DienstID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $DienstID);
if (!$stmt) {error_log("Fehler in GetSchichtenEinesDienstes"); return false;}
$result = mysqli_stmt_get_result($stmt);
return $result;
}
function ChangeSchicht($db_link, $SchichtID, $Von, $Bis, $Soll, $Dauer)#stmt2
{
$sql = "
UPDATE Schicht
SET Von=?, Bis=?, Soll=?, Dauer=?
WHERE SchichtID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ssiii", $Von, $Bis, $Soll, $Dauer, $SchichtID);
if (!$stmt) {error_log("Fehler in ChangeSchicht"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
return $result;
}
function NewSchicht($db_link, $DienstID, $Von, $Bis, $Soll, $Dauer, $HelferName) #stmt2
{
$sql = "INSERT INTO Schicht (DienstID, Von, Bis, Soll, Dauer) values (?,?,?,?,?)";
$stmt = stmt_prepare_and_execute($db_link, $sql, "issii", $DienstID, $Von, $Bis, $Soll, $Dauer);
if (!$stmt) {error_log("Fehler in NewSchicht"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
if ($result != 1) {
echo "Keine Schicht erstellt";
$full_sql = debug_sql($sql, "issii", [ $DienstID, $Von, $Bis, $Soll, $Dauer ]);
$err = " NeueSchicht: $HelferName konnte Schicht nicht angelegt mit $full_sql \n";
error_log(date('Y-m-d H:i') . $err , 3, LOGFILE);
die('Ungueltige Abfrage: ' . $err);
} else {
//TODO: DienstID aufloesen
error_log(date('Y-m-d H:i') . " NeueSchicht: $HelferName hat Schicht angelegt mit DienstID $DienstID, Von $Von Bis $Bis Soll $Soll \n", 3, LOGFILE);
}
}
function DeleteSchicht($db_link, $SchichtID, $Rekursiv)#stmt2
{
if ($Rekursiv) {
// TODO rekursives loeschen
return false;
} else {
// Pruefen ob noch Helfer auf der Schicht eingetragen sind
$sql = "SELECT Name FROM EinzelSchicht JOIN Helfer ON Helfer.HelferID = EinzelSchicht.HelferID WHERE SchichtID = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $SchichtID);
if (!$stmt) {error_log("Fehler in DeleteSchicht select"); return false;}
$result = mysqli_stmt_get_result($stmt);
if (mysqli_num_rows($result) === 0) {
// Eintrag löschen
$sql = "DELETE FROM Schicht where SchichtID=?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $SchichtID);
if (!$stmt) {error_log("Fehler in DeleteSchicht select"); return false;}
$result = mysqli_stmt_affected_rows($stmt);
if ($result === 0) {
$err = "Fehler in DeleteSchicht nichts gelöscht";
error_log($err);
echo $err;
error_log(debug_sql($sql, "i", [$SchichtID]));
return false;
}
return true;
} else {
return false; // Es sind noch Helfer eingetragen
}
}
}
function AlleHelferSchichtenUebersicht($db_link, $HelferLevel)
{
$sql = "
SELECT
Helfer.HelferID AS AliasHelferID, -- Alias für HelferID
Helfer.HelferLevel,
Name,
Email,
Handy,
Was,
COALESCE(SUM(Dauer)/10000, 0) AS Dauer
FROM
Helfer
LEFT JOIN
EinzelSchicht ON Helfer.HelferID = EinzelSchicht.HelferID
LEFT JOIN
Schicht ON EinzelSchicht.SchichtID = Schicht.SchichtID
LEFT JOIN
Dienst ON Schicht.DienstID = Dienst.DienstID
WHERE Helfer.HelferLevel = ?
GROUP BY
Helfer.HelferID,
Was";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $HelferLevel);
if (!$stmt) {error_log("Fehler in AlleHelferSchichtenUebersicht select"); return false;}
$result = mysqli_stmt_get_result($stmt);
mysqli_stmt_close($stmt);
return $result;
}
function DatenbankAufDeutsch($db_link)#stmt_brauchtnicht
{
$sql = "SET lc_time_names = 'de_DE'";
$result = mysqli_query($db_link, $sql);
if (! $result) {
echo "ungueltiges umstellen auf Deutsch";
die('Ungueltige Abfrage: ' . mysqli_error($db_link));
}
}
function LastInsertId($db_link)
{
$sql = "SELECT LAST_INSERT_ID()";
$result = mysqli_query($db_link, $sql);
if (! $result) {
echo "ungueltige Last InsertID";
die('Ungueltige Abfrage: ' . mysqli_error($db_link));
}
$zeile = mysqli_fetch_array($result, MYSQLI_ASSOC);
return $zeile['LAST_INSERT_ID()'];
}
function HelferLevel($db_link)
{
$sql = "select HelferLevel, HelferLevelBeschreibung, linkcode from HelferLevel order by HelferLevel";
$result = mysqli_query($db_link, $sql);
if (! $result) {
echo "Konnte HelferLevel nicht abfragen";
die('Ungueltige Abfrage: ' . mysqli_error($db_link));
}
return $result;
}
function alleHelferLevel($db_link)
{
$alleHelferLevel = array();
$result = HelferLevel($db_link);
while ($zeile = mysqli_fetch_array($result, MYSQLI_ASSOC)) {
$HelferLevel = $zeile['HelferLevel'];
$HelferLevelBeschreibung = $zeile['HelferLevelBeschreibung'];
$alleHelferLevel[$HelferLevel] = $HelferLevelBeschreibung;
};
return $alleHelferLevel;
}
function HelferLevelAusEinladung($db_link, string $linkcode): array|false {
$sql = "SELECT HelferLevel, HelferLevelBeschreibung FROM HelferLevel WHERE linkcode = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "s", $linkcode);
$result = mysqli_stmt_get_result($stmt);
if (!$result || $result->num_rows === 0) {
return false;
}
return $result->fetch_assoc();
}
function AlleHelferLevelAlles($db_link)
{
$result = HelferLevel($db_link);
$alle = [];
while ($zeile = mysqli_fetch_array($result, MYSQLI_ASSOC)) {
$level = $zeile['HelferLevel'];
$alle[$level] = [
'HelferLevelBeschreibung' => $zeile['HelferLevelBeschreibung'],
'linkcode' => $zeile['linkcode'],
];
}
return $alle;
}
function HelferLevelUpdate($db_link, int $level, string $beschreibung, string $linkcode): bool {
$sql = "UPDATE HelferLevel SET HelferLevelBeschreibung = ?, linkcode = ? WHERE HelferLevel = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ssi", $beschreibung, $linkcode, $level);
if (!$stmt) {
return false;
}
mysqli_stmt_close($stmt);
return true;
}
function HelferLevelInsert($db_link, string $beschreibung, string $linkcode): bool {
$sql = "INSERT INTO HelferLevel (HelferLevelBeschreibung, linkcode) VALUES (?, ?)";
$stmt = stmt_prepare_and_execute($db_link, $sql, "ss", $beschreibung, $linkcode);
return $stmt !== false;
}
function HelferLevelDelete($db_link, int $level): bool {
$sql = "DELETE FROM HelferLevel WHERE HelferLevel = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $level);
return $stmt !== false;
}
function AnzahlAccountsMitHelferLevel($db_link, int $level): int {
$sql = "SELECT COUNT(*) AS Anzahl FROM Helfer WHERE HelferLevel = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, "i", $level);
$result = mysqli_stmt_get_result($stmt);
if ($result && ($row = mysqli_fetch_assoc($result))) {
return (int)$row['Anzahl'];
}
return 0;
}
function AnzahlDiensteMitHelferLevel($db_link, $level) {
$sql = "SELECT COUNT(*) FROM Dienst WHERE HelferLevel = ?";
$stmt = stmt_prepare_and_execute($db_link, $sql, 'i', $level);
$stmt->bind_result($anzahl);
$stmt->fetch();
return $anzahl;
}
// falls man sowohl nach HelferLevel, Beschreibung oder Invite Code filtern will
//function HelferLevelAbfrage($db_link, string $spalte, string $wert): array|false {
// // Nur bestimmte Spalten zulassen, um SQL-Injection zu verhindern
// $erlaubteSpalten = ['linkcode', 'HelferLevel', 'HelferLevelBeschreibung'];
// if (!in_array($spalte, $erlaubteSpalten, true)) {
// return false;
// }
//
// $sql = "SELECT HelferLevel, HelferLevelBeschreibung, linkcode FROM HelferLevel WHERE $spalte = ?";
// $result = stmt_prepare_and_execute($db_link, $sql, "s", $wert);
//
// if (!$result || $result->num_rows === 0) {
// return false;
// }
//
// return $result->fetch_assoc();
//}
Reference in New Issue View Git Blame Copy Permalink