From 4aa6278f7fd40fdcbbde2be5c7e0e68c3117b44e Mon Sep 17 00:00:00 2001 From: Jacek Kowalski <Jacek@jacekk.info> Date: Fri, 12 Feb 2016 23:18:17 +0000 Subject: [PATCH] [mod_tv] Lepsza obsługa błędów przy okresowym pobieraniu danych --- data/lotto/pobierz.php | 280 +++++++++++++++++++++++++++++++------------------------ 1 files changed, 159 insertions(+), 121 deletions(-) diff --git a/data/lotto/pobierz.php b/data/lotto/pobierz.php index 2260d8b..73e7aeb 100644 --- a/data/lotto/pobierz.php +++ b/data/lotto/pobierz.php @@ -2,25 +2,41 @@ echo STAR.'Pobieranie danych...'; class lotto { + // Zawartość strony http://lotto.pl/wyniki-gier + // jako obiekt DOMDocument protected $strona = NULL; + // Powiązany DOMXPath + protected $xpath = NULL; + // Specjalne zachowania dla gier + const NONE = 0; + const PLUS = 1; + const LOTTOPLUS = 2; + const EKSTRA = 3; + + // Lista gier. protected $gry = array( - 'lotto' => array(6, FALSE, 'dl'), - 'mini-lotto' => array(5, FALSE, 'el'), - 'kaskada' => array(12, FALSE, 'ka'), - 'multi-multi' => array(20, TRUE, 'mm'), - 'joker' => array(5, FALSE, 'jk') + // nazwa + 'lotto', 'mini-lotto', + 'kaskada', 'multi-multi', + 'joker', 'ekstra-pensja' ); + // Spróbuj pobrać stronę http://lotto.pl/wyniki-gier + // do zmiennej $this->strona z użyciem pliku cache. function __construct() { $cache = 'lotto_cache.txt'; + // Sprawdź, czy da się skorzystać z pliku cache. if( ( !file_exists($cache) AND !is_writable(dirname($cache)) ) OR ( file_exists($cache) AND !(is_writable($cache)) ) ) { + // Nie, nie da się. $cache = ''; } else { + // Tak, da się. + // Sprawdź, czy dane są aktualne. if(@filemtime($cache)<strtotime('yesterday 22:45') && time()<=strtotime('14:30')) { $recent = FALSE; } @@ -34,156 +50,178 @@ } } + $strona = ''; + $this->strona = new DOMDocument(); + if($cache == '' OR !$recent) { - $this->strona = @file_get_contents('http://lotto.pl/wyniki-gier'); - if(!$this->strona) { + // Dane są nieaktualne, więc pobieramy je ponownie + $strona = @file_get_contents('http://lotto.pl/wyniki-gier'); + if(!$strona) { throw new Exception('Nie udało się pobrać wyników.'); } + // Można zapisać do cache'a... if($cache != '') { - file_put_contents($cache, $this->strona); + // ...więc zapamiętujemy arkusz. + file_put_contents($cache, $strona); } + + @$this->strona->loadHtml($strona); } else { - $this->strona = file_get_contents($cache); - } - } - - protected function szukaj_poczatku($tresc, $poczatek = 0) { - return strpos($this->strona, $tresc, $poczatek); - } - - protected function szukaj_konca($tresc, $poczatek = 0) { - $pozycja = strpos($this->strona, $tresc, $poczatek); - - if($pozycja !== FALSE) { - $pozycja += strlen($tresc); + // Dane w cache są aktualne, więc załaduj je. + @$this->strona->loadHtmlFile($cache); } - return $pozycja; + $this->xpath = new DOMXPath($this->strona); } + // Znajduje odpowiedni element w pliku HTML lub zwraca błąd. + protected function wytnij($zapytanie, $gdzie = NULL, $blad = 'Brak danych') { + $rezultat = $this->xpath->query($zapytanie, $gdzie); + if(!$rezultat OR $rezultat->length <= 0) { + throw new Exception($blad); + } + return $rezultat; + } + + // Zwraca wynik gry (domyślnie lotto). function wynik($gra = 'lotto') { $wyniki = $this->wyniki($gra, 1); + if(!isset($wyniki[0])) { + throw new Exception('Brak wyników dla gry.'); + } return $wyniki[0]; } - function wyniki($gra = 'lotto', $liczba = 100) { - if(!isset($this->gry[$gra])) { + // Zwraca $liczba ostatnich wyników gry (domyślnie lotto), + // jednak nie więcej niż 5 (tyle jest na stronie Totalizatora). + function wyniki($gra = 'lotto', $zwroc = 1000) { + if(!in_array($gra, $this->gry)) { throw new Exception('Podana gra liczbowa nie jest obsługiwana.'); } - $wyniki = array(); - $poczatek = $this->szukaj_konca('<div class="start-wyniki_'.$gra.'">'); - if($poczatek === FALSE) { - throw new Exception('Nie znaleziono wyników dla gry '.$gra.' na stronie.'); + $rezultaty = array(); + + $dane = $this->wytnij('//div[@class="start-wyniki_'.$gra.'"]', NULL, + 'Nie znaleziono na stronie wyników dla gry '.$gra); + $dane = $dane->item(0); + + + $daty = $this->wytnij('div[contains(concat(" ", @class, " "), " wyniki_data ")]', $dane, + 'Nie znaleziono informacji o losowanu gry '.$gra); + $wyniki = $this->wytnij('div[contains(concat(" ", @class, " "), " glowna_wyniki_'.$gra.' ")]', $dane, + 'Nie znaleziono wyników losowania gry '.$gra); + + $plusy = NULL; + try { + $plusy = $this->wytnij('div[@class="wynik_'.$gra.'_plus"]', $dane); + } catch(Exception $e) {} + + $lottoplusy = NULL; + try { + $lottoplusy = $this->wytnij('//div[@class="glowna_wyniki_'.$gra.'plus"]', $dane); + } catch(Exception $e) {} + + for($l = 0; $l < $daty->length && $l < $wyniki->length && $l < $zwroc; $l++) { + $rezultat = array(); + + // Znajdź $l-tą datę losowania i jego wynik + $data = $daty->item($l); + $wynik = $wyniki->item($l); + + try { + // Znajdź datę i godzinę + $data = $this->wytnij('strong', $data, 'Nie znaleziono '.$l.' daty losowania gry '.$gra); + $rezultat['data'] = trim($data->item(0)->textContent); + if($data->length > 1) { + $rezultat['godzina'] = trim($data->item(1)->textContent); + } + + // Znajdź poszczególne liczby w wyniku + $liczby = $this->wytnij('div[@class="wynik_'.$gra.'"]', $wynik, + 'Nie znaleziono liczb w '.$l.' losowaniu gry '.$gra); + $rezultat['liczby'] = array(); + foreach($liczby as $liczba) { + $rezultat['liczby'][] = trim($liczba->textContent); + } + } catch(Exception $e) { + break; + } + + try { + // Szukamy plusa + if($plusy && $plusy->length > $l) { + $rezultat['plus'] = trim($plusy->item($l)->textContent); + } + } catch(Exception $e) {} + + try { + // Szukamy ekstra liczby + $ekstra = $this->wytnij('div[@class="wynik_'.strtr($gra, '-', '_').'"]', $wynik, + 'Nie znaleziono ekstra w '.$l.' losowaniu gry '.$gra); + $rezultat['ekstra'] = trim($ekstra->item(0)->textContent); + } catch(Exception $e) {} + + try { + // Szukamy lottoplusa + if($lottoplusy && $lottoplusy->length > $l) { + $liczby = $this->wytnij('div[@class="wynik_'.$gra.'plus"]', $lottoplusy->item($l), + 'Nie znaleziono liczb w '.$l.' losowaniu gry '.$gra.'plus'); + $rezultat['plus'] = array(); + foreach($liczby as $liczba) { + $rezultat['plus'][] = trim($liczba->textContent); + } + } + } catch(Exception $e) {} + + $rezultaty[] = $rezultat; } - for($l = 0; $l < $liczba; $l++) { - $poczatek = $this->szukaj_konca('<div class="wyniki_data">', $poczatek); - if($poczatek === FALSE) { - break; + return $rezultaty; + } + + protected $skroty = array( + 'lotto' => 'dl', 'mini-lotto' => 'el', + 'kaskada' => 'ka', 'multi-multi' => 'mm', + 'joker' => 'jk', 'ekstra-pensja' => 'ep' + ); + + function pobierz_jeden($skrot, $wynik) { + $last_data = @file_get_contents('./last_'.$skrot.'.txt'); + if($last_data != $wynik['data']) { + foreach($wynik['liczby'] as $i => $liczba) { + $wynik[$i+1] = $liczba; } - - $wynik = array(); - - $poczatek = $this->szukaj_konca('<strong>', $poczatek); - if($poczatek === FALSE) { - break; - } - $koniec = $this->szukaj_poczatku('</strong>', $poczatek); - $wynik['data'] = substr($this->strona, $poczatek, $koniec-$poczatek); - if($poczatek === FALSE) { - break; - } - $poczatek = $this->szukaj_konca('<strong>', $poczatek); - $koniec = $this->szukaj_poczatku('</strong>', $poczatek); - $wynik['godzina'] = substr($this->strona, $poczatek, $koniec-$poczatek); - - $poczatek = $this->szukaj_konca('<div class="glowna_wyniki_'.$gra.'">', $poczatek); - if($poczatek === FALSE) { - break; - } - - $wynik['liczby'] = array(); - for($i = 0; $i < $this->gry[$gra][0]; $i++) { - $poczatek = $this->szukaj_konca('<div class="wynik_'.$gra.'">', $poczatek); - $koniec = $this->szukaj_poczatku('</div>', $poczatek); - $wynik['liczby'][] = substr($this->strona, $poczatek, $koniec-$poczatek); - } - - if($this->gry[$gra][1]) { - $poczatek = $this->szukaj_konca('<div class="wynik_'.$gra.'_plus">', $poczatek); - $koniec = $this->szukaj_poczatku('</div>', $poczatek); - $wynik['plus'] = substr($this->strona, $poczatek, $koniec-$poczatek); - } - - $wyniki[] = $wynik; + file_put_contents('./last_'.$skrot.'.txt', $wynik['data']); + file_put_contents('./'.$skrot.'.txt', serialize($wynik)); + file_put_contents('./archiwum/'.$skrot.'_'.date('j.m.Y', strtotime($wynik['data'])).'.txt', serialize($wynik)); + echo OK; + } else { + echo NOT; } - - return $wyniki; } function pobierz() { - foreach($this->gry as $gra => $data) { + foreach($this->gry as $gra) { echo STAR.'Wyniki gry '.$gra.'...'; if($gra == 'multi-multi') { + echo "\n"; $wyniki = $this->wyniki($gra, 2); - $wynik = $wyniki[0]; - $skrot = $data[2].substr($wynik['godzina'], 0, 2); - $last_data = @file_get_contents('./last_'.$skrot.'.txt'); - if($last_data != $wynik['data']) { - $output = array(); - $output['data'] = $wynik['data']; - for($i = 0; $i < $data[0]; $i++) { - $output[$i+1] = $wynik['liczby'][$i]; + foreach($wyniki as $wynik) { + $godzina = substr($wynik['godzina'], 0, 2); + echo ' '.STAR.'godzina '.$godzina.'...'; + if($godzina == '21') { + $godzina = '22'; } - if($data[1]) { - $output['plus'] = $wynik['plus']; - } - file_put_contents('./last_'.$skrot.'.txt', $output['data']); - file_put_contents('./'.$skrot.'.txt', serialize($output)); - file_put_contents('./archiwum/'.$skrot.'_'.date('j.m.Y', strtotime($output['data'])).'.txt', serialize($output)); + $skrot = $this->skroty[$gra].$godzina; + + $this->pobierz_jeden($skrot, $wynik); } - - $wynik = $wyniki[1]; - $skrot = $data[2].substr($wynik['godzina'], 0, 2); - $last_data = @file_get_contents('./last_'.$skrot.'.txt'); - if($last_data != $wynik['data']) { - $output = array(); - $output['data'] = $wynik['data']; - for($i = 0; $i < $data[0]; $i++) { - $output[$i+1] = $wynik['liczby'][$i]; - } - if($data[1]) { - $output['plus'] = $wynik['plus']; - } - file_put_contents('./last_'.$skrot.'.txt', $output['data']); - file_put_contents('./'.$skrot.'.txt', serialize($output)); - file_put_contents('./archiwum/'.$skrot.'_'.date('j.m.Y', strtotime($output['data'])).'.txt', serialize($output)); - } + } else { + $this->pobierz_jeden($this->skroty[$gra], $this->wynik($gra)); } - else - { - $wynik = $this->wynik($gra); - $skrot = $data[2]; - $last_data = @file_get_contents('./last_'.$skrot.'.txt'); - if($last_data != $wynik['data']) { - $output = array(); - $output['data'] = $wynik['data']; - for($i = 0; $i < $data[0]; $i++) { - $output[$i+1] = $wynik['liczby'][$i]; - } - if($data[1]) { - $output['plus'] = $wynik['plus']; - } - file_put_contents('./last_'.$skrot.'.txt', $output['data']); - file_put_contents('./'.$skrot.'.txt', serialize($output)); - file_put_contents('./archiwum/'.$skrot.'_'.date('j.m.Y', strtotime($output['data'])).'.txt', serialize($output)); - } - } - echo OK; } } } -- Gitblit v1.9.1