WebSVN – lars-tiefland.ci – /backend/controllers/Scheduler.php

<?php

class Scheduler extends CI_Controller
{
    public function __construct()
    {
        parent::__construct();
    }
    public function index()
    {
        $tasks = array();
        $sql = "SELECT
                                id,
                                name,
                                art,
                                skript,
                                parameter,
                                intervall,
                                user
                        FROM
                                schnittstellen
                        WHERE
                                nutzungsart IN ('dual','automatisch')
                        AND
                                user!=''
                        ORDER BY
                                user
                ";
        $res = $this->db->query($sql);
        while ($row = $res->unbuffered_row('array')) {
            $tasks[] = $row;
        }
        $this->smarty->assign("tasks", $tasks);
        $this->smarty->view('scheduler.tpl');
    }

    public function del($id = null)
    {
        if ($id) {
            $task = $this->get_task($id);
            $this->smarty->assign("task", $task);
            $this->smarty->view('scheduler_del.tpl');
        } else {
            $sql = "
                                DELETE FROM
                                        schnittstellen
                                WHERE
                                        ID = " . $this->input->post('id') . "
                        ";
            $res = $this->db->query($sql);
            if ($res) {
                $msg = "Cronjob wurde erfolgreich gelöscht!";
            } else {
                $msg = "Leider ist ein Fehler aufgetreten.<br>";
                $msg .= "Bitte versuchen Sie es sp&auml;ter noch einmal!<br>";
                //$msg .= mysql_error();
            }
            echo $msg;
        }
    }
    public function edit($id = null)
    {
        if ($id) {
            $task = $this->get_task($id);
        } else {
            $domain = explode(".", $_SERVER["HTTP_HOST"]);
            $dom = array_shift($domain);
            $site_full = implode(".", $domain);
            if ($domain[count($domain) - 1] == "local") {
                unset($domain[count($domain) - 1]);
            }
            $site = implode(".", $domain);
            unset($out);
            if ($site != $site_full) {
                $out = substr($site, 0, 16);
            } elseif ($site_full == "weban.de") {
                $out = "www-data";
            } else {
                $cmd = "cat /etc/passwd | grep " . __SHOP__ . " | cut -d \":\" -f1";
                exec($cmd, $out);
                $out = $out[0];
            }
            $task["user"] = $out;
        }
        $rep_hours[0] = "exakt";
        $rep_hours[1] = "jede Stunde";
        $hours[0] = 0;
        $hours[1] = 1;
        for ($i = 2; $i <= 23; $i++) {
            $hours[$i] = $i;
            $rep_hours[$i] = "Alle " . $i . " Stunden";
        }
        $rep_min[0] = "exakt";
        $rep_min[1] = "jede Minute";
        for ($i = 2; $i <= 30; $i++) {
            $rep_min[$i] = "Alle " . $i . " Minuten";
        }
        for ($i = 0; $i <= 59; $i++) {
            $minutes[$i] = $i;
        }
        $nutzungsarten = array(
            "" => "",
            "dual" => "dual",
            "automatisch" => "automatisch",
            );
        $tage = array(
            "Sonntag",
            "Montag",
            "Dienstag",
            "Mittwoch",
            "Donnerstag",
            "Freitag",
            "Samstag",
            );
        for ($i = 1; $i <= 12; $i++) {
            $mon = sprintf("%02d", $i);
            $datum = "01." . $mon . "." . date("Y");
            $monate[$i] = strftime("%B", strtotime($datum));
        }
        $dom = array();
        for ($i = 1; $i <= 31; $i++) {
            $day = sprintf("%02d", $i);
            $dom[$i] = $i;
        }
        $this->smarty->assign("task", $task);
        $this->smarty->assign("monate", $monate);
        $this->smarty->assign("tage", $tage);
        $this->smarty->assign("dom", $dom);
        $this->smarty->assign("nutzungsarten", $nutzungsarten);
        $this->smarty->assign("minutes", $minutes);
        $this->smarty->assign("rep_min", $rep_min);
        $this->smarty->assign("rep_hours", $rep_hours);
        $this->smarty->assign("hours", $hours);
        $this->smarty->view('scheduler_edit.tpl');
    }

    public function save()
    {
        $intervall = $this->create_intervall();
        if (!column_exists("schnittstellen", "aktiv", $GLOBALS["webs"]["datenbank"], $this->
            db)) {
            $sql = "
                ALTER TABLE
                    schnittstellen
                ADD
                    aktiv BOOL NOT NULL DEFAULT '1' AFTER user
            ";
            $this->db->query($sql);
        }
        if (column_exists("schnittstellen", "email", $GLOBALS["webs"]["datenbank"], $this->
            db)) {
            $extra = "email='" . $this->input->post('email') . "',";
        }
        if ($this->input->post('id')) {
            $sql = "
                UPDATE
                    schnittstellen
                SET
                    " . $extra . "
                    name='" . $this->input->post("name") . "',
                    art='" . $this->input->post('art') . "',
                    user='" . $this->input->post('user') . "',
                    skript='" . $this->input->post('skript') . "',
                    parameter='" . $this->input->post('parameter') . "',
                    nutzungsart='" . $this->input->post('nutzungsart') . "',
                    aktiv = " . $this->input->post('aktiv') . ",
                    intervall='" . $intervall . "',
                    letzte_aenderung_von='" . $_SERVER["PHP_AUTH_USER"] . "'
                WHERE
                    id='" . $this->input->post('id') . "'
            ";
            $res = $this->db->query($sql);
            if ($res) {
                $msg = "Cronjob erfolgreich aktualisiert!";
            } else {
                $msg = "Leider ist ein Fehler aufgetreten.<br>";
                $msg .= "Bitte versuchen Sie es sp&auml;ter noch einmal!<br>";
                //$msg .= mysql_error();
            }
        } else {
            $sql = "
                INSERT INTO
                    schnittstellen
                SET
                    " . $extra . "
                    name='" . $this->input->post('name') . "',
                    art='" . $this->input->post('art') . "',
                    user='" . $this->input->post('user') . "',
                    skript='" . $this->input->post('skript') . "',
                    parameter='" . $this->input->post('parameter') . "',
                    nutzungsart='" . $this->input->post('nutzungsart') . "',
                    aktiv = " . $this->input->post('aktiv') . ",
                    intervall='" . $intervall . "',
                    erstellt_am=NOW(),
                    erstellt_von='" . $_SERVER["PHP_AUTH_USER"] . "',
                    letzte_aenderung_von='" . $_SERVER["PHP_AUTH_USER"] . "'

            ";
            $res = $this->db->query($sql);
            if ($res) {
                $msg = "neuen Cronjob erfolgreich angelegt!";
            } else {
                $msg = "Leider ist ein Fehler aufgetreten.<br>";
                $msg .= "Bitte versuchen Sie es sp&auml;ter noch einmal!<br>";
                //$msg .= mysql_error();
            }
        }
        echo $msg;
    }

    private function get_task($id)
    {
        $sql = "SELECT
                                *
                        FROM
                                schnittstellen
                        WHERE
                                id=" . $id . "
                ";
        $res = $this->db->query($sql);
        $task = $res->row_array();
        $intervall = $this->parse_intervall($task["intervall"]);
        $task["intervallParsed"] = $intervall;
        return $task;
    }

    private function parse_intervall($intervall)
    {
        list($minute, $hour, $dom, $mon, $dow) = explode(" ", $intervall);
        $pos = strpos($minute, "/");
        if ($pos !== false) {
            $intervallArr["min"] = null;
            $intervallArr["rep_min"] = substr($minute, $pos + 1);
        } elseif ($minute == "*") {
            $intervallArr["min"] = null;
            $intervallArr["rep_min"] = 1;
        } else {
            $intervallArr["min"] = $minute;
            $intervallArr["rep_min"] = 0;
        }
        $pos = strpos($hour, "/");
        if ($pos !== false) {
            $intervallArr["hour"] = null;
            $intervallArr["rep_hour"] = substr($hour, $pos + 1);
        } elseif ($hour == "*") {
            $intervallArr["hour"] = null;
            $intervallArr["rep_hour"] = 1;
        } else {
            $intervallArr["hour"] = explode(",", $hour);
            $intervallArr["rep_hour"] = 0;
        }
        if ($mon == "*") {
            $intervallArr["mon"] = array(
                1,
                2,
                3,
                4,
                5,
                6,
                7,
                8,
                9,
                10,
                11,
                12,
                );
        } else {
            $intervallArr["mon"] = explode(",", $mon);
        }
        if ($dow == "*") {
            $intervallArr["dow"] = array(
                0,
                1,
                2,
                3,
                4,
                5,
                6,
                );
        } else {
            $intervallArr["dow"] = explode(",", $dow);
        }
        if ($dom == "*") {
            for ($i = 1; $i <= 31; $i++) {
                $intervallArr["dom"][] = $i;
            }
        } else {
            $intervallArr["dom"] = explode(",", $dom);
        }
        return $intervallArr;
    }

    function create_intervall()
    {
        if ($this->input->post('rep_hour') != 0) {
            $hour = "*";
            if ($this->input->post('rep_hour') != 1) {
                $hour .= "/" . $this->input->post('rep_hour');
            }
        } elseif (count($this->input->post('Time_Hour')) == 24) {
            $hour = "*";
        } else {
            $hour = implode(",", $this->input->post('Time_Hour'));
        }
        if ($this->input->post('rep_min') != 0) {
            $min = "*";
            if ($this->input->post('rep_min') != 1) {
                $min .= "/" . $this->input->post('rep_min');
            }
        } elseif (count($this->input->post('Time_Minute')) == 60) {
            $min = "*";
        } else {
            $min = implode(",", $this->input->post('Time_Minute'));
        }
        if (count($this->input->post('dow')) == 7) {
            $dow = "*";
        } else {
            $dow = implode(",", $this->input->post('dow'));
        }

        if (count($this->input->post('dom')) == 31) {
            $dom = "*";
        } else {
            $dom = implode(",", $this->input->post('dom'));
        }

        if (count($this->input->post('mon')) == 12) {
            $mon = "*";
        } else {
            $mon = implode(",", $this->input->post('mon'));
        }

        $intervall = $min . " " . $hour . " " . $dom . " " . $mon . " " . $dow;
        $intervall = trim($intervall, "#");
        return $intervall;
    }
}
Subversion-Projekte lars-tiefland.ci

(root)/backend/controllers/Scheduler.php – Revision 2108
