Subversion-Projekte lars-tiefland.ci

<?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;
        }
}