function RemoveAuction($config, $jsonResult)
{
    $id = $_GET['auction_id'];
    $conn = new connection($config);
    $jsonResult->json_data['result_code'] = JSON::$resultCodes['ok'];
    $conn->query("DELETE FROM allegro where auction_id='" . $id . "';");
}

function AddProduct($config, $jsonResult)
{
    $cargo_id = $_GET["cargo_id"];
    $kind_id = "";
    $kind = $_GET["kind"];
    $amount = $_GET["amount"];
    $sql1 = "SELECT COUNT(name) as kind_amount , kind_id FROM kind WHERE name = '" . $kind . "';";
    $sql2 = "INSERT INTO kind(name) VALUES('" . $kind . "')";
    $conn = new connection($config);
    $jsonResult->json_data['result_code'] = JSON::$resultCodes['ok'];
    try {
        $result1 = $conn->query($sql1);
        foreach ($result1 as $row) {
            if ($row['kind_amount'] === "0") {
                $conn->query($sql2);
                $kind_id = $conn->conn->lastInsertId();
            } else {
                $kind_id = $row['kind_id'];
            }
        }
        $conn->query("INSERT INTO product(cargo_id , amount , kind_id) VALUES(" . $cargo_id . " , " . $amount . " , " . $kind_id . ")");
        $product_id = $conn->conn->lastInsertId();
        $jsonResult->json_data['result_data'] = $product_id;
    } catch (PDOException $e) {
        $jsonResult->json_data['result_code'] = JSON::$resultCodes['mysql_exception'];
    }
}

 public static function fetchOne($sql)
 {
     $con = new connection();
     $con->execute($sql);
     $con->fetch();
     return $con->rows;
 }

 function the_cat($by_name = null, $linked = null)
 {
     if ($this->is_object()) {
         if (!empty($this->cat)) {
             // Gibt die ID der Kategorie zurück
             if (null == $by_name) {
                 return $this->cat;
                 // Gibt den Titel der Kategorie zurück
             } else {
                 $db = new connection();
                 $get_the_catname = $db->query('SELECT * FROM object WHERE id=' . $this->cat);
                 $the_catname = $db->fetch_array();
                 if (null !== $linked) {
                     // Kategorie wird als Link ausgegeben
                     return '<a href="./?cat=' . $the_catname['id'] . '" rel="nofollow">' . $the_catname['title'] . '</a> ';
                 } else {
                     // Kategorie wird nicht als Link ausgegeben
                     return $the_catname['title'] . " ";
                 }
             }
         } else {
             return false;
         }
     }
 }

    function has_items($id)
    {
        $db = new connection();
        $db->query('SELECT * FROM object WHERE type="page" AND status=1 AND parent_id=' . $id);
        if ($this->has_child($id)) {
            ?>
<ul class="submenu">
<?php 
        }
        while ($result = $db->fetch_array()) {
            ?>
<li><a href='./?page_id=<?php 
            echo $result['id'];
            ?>
'><?php 
            echo $result['menu_title'];
            ?>
</a>
<?php 
            if ($this->has_items($result['id'])) {
                echo $this->has_items($result['id']);
            }
            ?>
</li>
<?php 
        }
        if ($this->has_child($id)) {
            ?>
</ul>
<?php 
        }
    }

 public static function getRowCount()
 {
     $con = new connection();
     $connection = $con->getConnection();
     $query = "select * from manufacturer";
     $result = $connection->query($query) or die(mysqli_error($connection));
     return mysqli_num_rows($result) + 10;
 }

function dateExists()
{
    $date = date('Y-m-d', strtotime($_GET['date']));
    $sql = "SELECT COUNT(*) AS count FROM ipodate WHERE ipodate = '" . mysql_escape_string($date) . "'";
    $con = new connection();
    $con->execute($sql);
    die($con->fetch());
}

 public function uploadFile($uploadclassObj)
 {
     $fileid = $uploadclassObj->getFileid();
     $upload_filename = $uploadclassObj->getFilename();
     $con = new connection();
     $connection = $con->getConnection();
     $query = "insert into uploads values(null, '{$fileid}', '{$upload_filename}')";
     $result = $connection->query($query) or die(mysqli_error($connection));
 }

 public function getUserByName($name)
 {
     $con = new connection();
     $db = $con->getConnection();
     $sql = "SELECT * FROM user WHERE name=" . $name;
     foreach ($db->query($sql) as $row) {
         $user[] = array('id' => $row['id'], 'name' => $row['name'], 'password' => $row['password'], 'mail' => $row['mail'], 'adresse' => $row['adresse'], 'tel' => $row['tel']);
     }
 }

function GetAuctionList($config, $jsonResult)
{
    $conn = new connection($config);
    $jsonResult->json_data['result_code'] = JSON::$resultCodes['ok'];
    $result = $conn->query("SELECT auction_id , name , sandbox FROM allegro;");
    foreach ($result as $row) {
        array_push($jsonResult->json_data['result_data'], array('id' => $row['auction_id'], 'name' => $row['name'], 'sandbox' => $row['sandbox']));
    }
}

function GetCargoName($config, $jsonResult)
{
    $cargo_id = $_GET['cargo_id'];
    $conn = new connection($config);
    $result = $conn->query("SELECT name FROM cargo WHERE cargo_id = " . $cargo_id . ";");
    foreach ($result as $row) {
        array_push($jsonResult->json_data["result_data"], $row['name']);
    }
    $jsonResult->json_data["result_code"] = JSON::$resultCodes['ok'];
}

function AddCargo($config, $jsonResult)
{
    $name = $_GET['name'];
    $conn = new connection($config);
    $jsonResult->json_data['result_code'] = JSON::$resultCodes['ok'];
    try {
        $conn->query("INSERT INTO cargo(name) VALUES('" . $name . "');");
    } catch (PDOException $e) {
        $jsonResult->json_data['result_code'] = JSON::$resultCodes['mysql_exception'];
    }
}

 function useralive($userid)
 {
     $con= new connection();
     $con->execute("select time from users where iduser='$userid'");
     $con->fetch();
     $time1=  $con->rows['time'];
     if ($time1<(time()-13))
     return false;
     else
     return true;
 }

function getSymbols()
{
    // get the full list of IPOs in the database
    $sql = "SELECT DISTINCT symbol FROM ipo";
    $con = new connection();
    $con->execute($sql);
    $symbols = array();
    while ($con->fetch()) {
        $symbols[] = $con->rows["symbol"];
    }
    return $symbols;
}

function getCargoListWithKinds($config, $jsonResult)
{
    $conn = new connection(new Config(null, null));
    $result = array();
    $cargoes = $conn->query("SELECT * FROM cargo");
    foreach ($cargoes as $cargo) {
        $kinds = $conn->query("SELECT DISTINCT kind.name\n                FROM product INNER JOIN kind on product.kind_id = kind.kind_id\n                WHERE cargo_id =" . $cargo['cargo_id']);
        $kinds = $kinds->fetchAll();
        array_push($result, array('name' => $cargo['name'], 'kinds' => $kinds));
    }
    $jsonResult->json_data['result_data'] = $result;
}

 public function query()
 {
     //get connection object
     $connection = new connection();
     //get query object
     $query = new query();
     //get database connection
     $pdo = $connection->connect();
     //set database connection on query object
     $query->setConnection($pdo);
     return $query;
 }

function getSymbols()
{
    // get a list of all IPOs that don't have first day open/close price set
    $sql = "SELECT DISTINCT symbol, ipodate FROM ipo WHERE closeprice = 0 OR openprice = 0";
    $con = new connection();
    $con->execute($sql);
    $symbols = array();
    while ($con->fetch()) {
        $symbols[] = array("symbol" => $con->rows["symbol"], "ipodate" => $con->rows["ipodate"]);
    }
    return $symbols;
}

function AddItems($config, $jsonResult)
{
    $conn = new connection($config);
    $product_id = $_GET['product_id'];
    $amount = $_GET['amount'];
    $jsonResult->json_data['result_code'] = JSON::$resultCodes['ok'];
    try {
        $conn->query("UPDATE product SET amount = amount + " . $amount . " WHERE product_id = " . $product_id);
    } catch (PDOException $e) {
        $jsonResult->json_data['result_code'] = JSON::$resultCodes['mysql_exception'];
    }
}

 public function getAllCategories()
 {
     $aCategories = array();
     $oConnection = new connection();
     $sSQL = "SELECT TypeID\n\t\tFROM tbproducttype";
     $oResult = $oConnection->query($sSQL);
     while ($aRow = $oConnection->fetch_array($oResult)) {
         $oCategory = new category();
         $oCategory->load($aRow["TypeID"]);
         $aCategories[] = $oCategory;
     }
     $oConnection->close_connection();
     return $aCategories;
 }

 public function load($iRecordID)
 {
     $oCon = new connection();
     $sSQL = "SELECT RecordID, Title, Artist, Price, GenreID, PhotoPath\n\t\t\t\tFROM tbrecords \n\t\t\t\tWHERE RecordID = " . $iRecordID;
     $oResultSet = $oCon->query($sSQL);
     $aRow = $oCon->fetchArray($oResultSet);
     $this->iRecordID = $aRow['RecordID'];
     $this->sTitle = $aRow['Title'];
     $this->sArtist = $aRow['Artist'];
     $this->fPrice = $aRow['Price'];
     $this->iGenreID = $aRow['GenreID'];
     $this->iPhotoPath = $aRow['PhotoPath'];
     $oCon->close();
 }