Subversion-Projekte lars-tiefland.ci

<?php

class Preise_model extends CI_Model
{
        public function get($id)
        {
                $preise = array();
                $sql = "SELECT
                                id,
                                language,
                                preis,
                                preis_index,
                                staffel
                        FROM
                                preise
                        WHERE
                                artikel_id=".$id."
                ";
                $res = $this->db->query($sql);
                while ($row = $res->unbuffered_row('array'))
                {
                        $row["staffel"] = unserialize($row["staffel"]);
                        $preise[$row['preis_index']] = $row;
                }
                return $preise;
        }
        public function save($daten)
        {
                foreach ($daten as $preisIndex => $preisDaten)
                {
                        $sql = "SELECT
                                        id
                                FROM
                                        preise
                                WHERE
                                        preis_index=".$preisIndex."
                                AND
                                        artikel_id=".$this->input->post('ID')."
                        ";
                        $res = $this->db->query($sql);
                        if (!$res->num_rows())
                        {
                                $sql = "INSERT INTO
                                                preise
                                        SET
                                                preis_index=".$preisIndex.",
                                                preis=".$preisDaten["preis"].",
                                                artikel_id=".$this->input->post("ID")."
                                ";
                        }
                        else
                        {
                                $sql = "
                                        UPDATE
                                                preise
                                        SET
                                                preis=".$preisDaten["preis"]."
                                        WHERE
                                                artikel_id=".$this->input->post('ID')."
                                        AND
                                                preisIndex=".$preisIndex."
                                ";
                        }
                        $res = $this->db->query($sql);
                }
                return $res;
        }
}