updatetungvung.php

<?php
/*
 * Gui vung de update
 * vi du: updatetungvung.php?vung=xo-so-mien-bac
 */
include('../simplehtmldom/simple_html_dom.php');

function GetDataXSMB($strLink)
{

    // -----------------------------------------------------------------------------

    // Retrieve the DOM from a given URL
    $html = file_get_html($strLink);

    $i          = 0;
    $timeupdate = array();
    foreach ($html->find('span[style="font-size:14px; color:#fff; "]') as $e) {
        $timeupdate[$i++] = $e->innertext;
    }

    $i       = 0;
    $product = array();
    foreach ($html->find('td[class="number_kq"]') as $e) {
        $product[$i++] = $e->innertext;
    }

    $response["products"] = array();
    for ($i = 4; $i >= 0; $i--) {
        $kqmb["Time"] = $timeupdate[$i];
        //$j=$i*9;
        $j            = $i * 8;

        $kqmb["DB"] = $product[$j++];
        $kqmb["G1"] = $product[$j++];
        $kqmb["G2"] = $product[$j++];
        $kqmb["G3"] = $product[$j++];
        $kqmb["G4"] = $product[$j++];
        $kqmb["G5"] = $product[$j++];
        $kqmb["G6"] = $product[$j++];
        $kqmb["G7"] = $product[$j++];
        //$kqmb["G8"]=$product[$j++];

        array_push($response["products"], $kqmb);

        $ketqua   = $kqmb["DB"] . "," . $kqmb["G1"] . "," . $kqmb["G2"] . "," . $kqmb["G3"] . "," . $kqmb["G4"] . "," . $kqmb["G5"] . "," . $kqmb["G6"] . "," . $kqmb["G7"]; // . "," . $kqmb["G8"];
        $thoigian = $kqmb["Time"];

        $thoigian = trim($thoigian);
        $tg       = explode(" ", $thoigian);
        $thoigian = $tg[1];

        //echo  $thoigian . "   " . $ketqua . "<br/>";


        require_once __DIR__ . '/db_config.php';
        $conn = mysql_connect(DB_SERVER, DB_USER, DB_PASSWORD) or die("Can't connect this database");
        mysql_select_db(DB_DATABASE, $conn);
        // mysql inserting a new row
        $ketqua   = str_replace(" ", "", $ketqua);
        $thoigian = str_replace(" ", "", $thoigian);
        if (strlen($thoigian) == 10) {
            $sql   = "SELECT * FROM xosomienbac WHERE thoigian='$thoigian'";
            $query = mysql_query($sql);
            if (mysql_num_rows($query) == 0) {
                $result = mysql_query("INSERT INTO xosomienbac(ketqua, thoigian) VALUES('$ketqua', '$thoigian')");
                echo "Da insert $thoigian --> $ketqua <br>";
            } else {
                $result = mysql_query("UPDATE xosomienbac SET ketqua='$ketqua' WHERE thoigian='$thoigian'");
                echo "Da update $thoigian --> $ketqua <br>";
            }
        }

    }
}

function GetData($strLink, $strBang)
{
    // Retrieve the DOM from a given URL
    $html = file_get_html($strLink);

    $i          = 0;
    $timeupdate = array();
    foreach ($html->find('span[style="font-size:14px; color:#fff; "]') as $e) {
        $timeupdate[$i++] = $e->innertext;
    }

    $i       = 0;
    $product = array();
    foreach ($html->find('td[class="number_kq"]') as $e) {
        $product[$i++] = $e->innertext;
    }

    $response["products"] = array();
    for ($i = 4; $i >= 0; $i--) {
        $kqmb["Time"] = $timeupdate[$i];
        $j            = $i * 9;

        $kqmb["DB"] = $product[$j++];
        $kqmb["G1"] = $product[$j++];
        $kqmb["G2"] = $product[$j++];
        $kqmb["G3"] = $product[$j++];
        $kqmb["G4"] = $product[$j++];
        $kqmb["G5"] = $product[$j++];
        $kqmb["G6"] = $product[$j++];
        $kqmb["G7"] = $product[$j++];
        $kqmb["G8"] = $product[$j++];

        array_push($response["products"], $kqmb);

        $ketqua   = $kqmb["DB"] . "," . $kqmb["G1"] . "," . $kqmb["G2"] . "," . $kqmb["G3"] . "," . $kqmb["G4"] . "," . $kqmb["G5"] . "," . $kqmb["G6"] . "," . $kqmb["G7"] . "," . $kqmb["G8"];
        $thoigian = $kqmb["Time"];

        $thoigian = trim($thoigian);
        $tg       = explode(" ", $thoigian);
        $thoigian = $tg[1];

        require_once __DIR__ . '/db_config.php';
        $conn = mysql_connect(DB_SERVER, DB_USER, DB_PASSWORD) or die("Can't connect this database");
        mysql_select_db(DB_DATABASE, $conn);
        // mysql inserting a new row
        $ketqua   = str_replace(" ", "", $ketqua);
        $thoigian = str_replace(" ", "", $thoigian);
        if (strlen($thoigian) == 10) {
            $sql   = "SELECT * FROM " . $strBang . " WHERE thoigian='$thoigian'";
            $query = mysql_query($sql);
            if (mysql_num_rows($query) == 0) {
                $result = mysql_query("INSERT INTO $strBang (ketqua, thoigian) VALUES('$ketqua', '$thoigian')");
                echo "Da insert $thoigian --> $ketqua <br>";
            } else {
                $result = mysql_query("UPDATE $strBang SET ketqua='$ketqua' WHERE thoigian='$thoigian'");
                echo "Da update $thoigian --> $ketqua <br>";
            }
        }

    }
}

if (isset($_GET["vung"])) {
    $vung = $_GET["vung"]; // noi lay ket qua xo so
} else {
    $vung = "xo-so-mien-bac";
}

$bang = $vung;
$link = "http://ketquaxoso.24h.com.vn/" . $bang . "/page1";
$bang = str_replace("-", "", $bang);
echo $bang . " - " . $link . "</br>";

if ($bang == "xosomienbac") {
    GetDataXSMB($link);
} else {
    GetData($link, $bang);
}

echo "Update finish";
?>