Revize 6806f46f

refs #6919: Logy

Vytvorena trida pro logovani. Vyuziti v hlavnim skriptu a ve tride Parser (pro objekty komunikujici s databazi zatim nevyuzito). Pridan ukazkovy vystupni soubor.

cron/cron.php

@@ -6 +6 @@
 require_once "process_traffic_matrix.php";
 
 function year_cron() {
+    // Stazeni dat za posledni rok.
     for ($i = 365; $i > 0; $i--) {
         $date = new DateTime();
         $date->modify("-$i day");
@@ -14 +15 @@
 }
 
 function cron() {
+    // Stazeni dat z minuleho dne.
     $date = new DateTime();
     $date->modify("-1 day");
     cron_procedure($date);
 }
 
+// Funkce, ktera je volana bud cron() nebo year_cron() a ktera stahne data pro dany den.
 function cron_procedure($date) {
     // Kvuli timeoutu.
     set_time_limit(0);
     
+    // Vytvoreni objektu pro komunikaci s DB.
     $dbh = new DB_WEB();
     $DAO = new DAO();
     $DAO->setDB($dbh);
     
+    // Objekt pro logovani.
+    $logs = new Logging();
+    
     if ($date != NULL && $DAO->controlTrafficData($date->format("Y-m-d"))) {
-        $parser = new Parser();
+        $logs->log(Logging::INFO, "Data k vybranemu dni (".$date->format("d.m.Y").") jeste v databazi nejsou.");
+        $parser = new Parser($logs);
         $parser->doWork($date->format("Ymd"));
         
         $traffic = $parser->getTraffic();
@@ -48 +56 @@
         $insertOneDay = array();
         process_traffic_matrix($parser, $traffic, $trafficOneDay, $DAO->findFirstId("zaznam_cas"), $DAO->findFirstId("zaznam"), $DAO->findFirstId("zaznam_prum_den"), $insertRTT, $insertRT, $insertOneDay, $date->format("Y-m-d"));
         $DAO->insertTrafficData($insertRTT, $insertRT, $insertOneDay);
+    } else if ($date != NULL) {
+        // Data pro vybrany den uz v databazi jsou.
+        $logs->log(Logging::WARNING, "Pro vybrany den (".$date->format("d.m.Y").") jiz data v databazi jsou.");
     }
 }
 

cron/log/cron.txt

@@ +1 @@
+21.05.2018 21:08:55.799
+--- INFO ---
+Data k vybranemu dni jeste v databazi nejsou.
+
+21.05.2018 21:08:55.811
+--- INFO ---
+ZACATEK PROCEDURY pro den 20.05.2018.
+
+21.05.2018 21:09:01.904
+--- INFO ---
+Stazeni archivu probehlo v poradku.
+
+21.05.2018 21:09:02.588
+--- INFO ---
+Extrahovani archivu v poradku dokonceno.
+
+21.05.2018 21:09:02.598
+--- INFO ---
+Zpracovavani zaznamu o doprave.
+
+21.05.2018 21:11:08.933
+--- INFO ---
+Zpracovavani zaznamu o lokacich.
+
+21.05.2018 21:11:08.945
+--- INFO ---
+Odstranovani slozky s extrahovanymi daty.
+
+21.05.2018 21:11:08.969
+--- INFO ---
+KONEC PROCEDURY.
+
+21.05.2018 21:22:56.954
+--- WARNING ---
+Pro vybrany den (20.05.2018) jiz data v databazi jsou.
+

cron/logging.php

@@ +1 @@
+<?php
+
+class Logging {
+    
+    // Zpravy jsou pouze informativni.
+    const INFO = 0;
+    // Jedna se o mene zavazne stavy - treba data pro dany den jeste neexistuji.
+    const WARNING = 1;
+    // Doslo k padu cele procedury - napr. nepovedlo se vytvorit slozku pro extrahovana data.
+    const ERROR = 2;
+    
+    // Soubor, do ktereho se budou zaznamy vkladat (defaultne ve slozce log).
+    private $log_file;
+    
+    public function __construct() {
+        $this->log_file = "log/cron.txt";
+    }
+    
+    public function log($type, $message) {
+        $type_str = "";
+        switch ($type) {
+            case self::INFO: $type_str = "INFO"; break;
+            case self::WARNING: $type_str = "WARNING"; break;
+            default: $type_str = "ERROR"; break;
+        }
+        
+        $micro_date = microtime();
+        $date_array = explode(" ", $micro_date);
+        $date = sprintf("%s.%03d", date("d.m.Y H:i:s", $date_array[1]), (int) ($date_array[0] * 1000));
+        
+        file_put_contents($this->log_file, "$date\r\n--- $type_str ---\r\n$message\r\n\r\n", FILE_APPEND);
+    }
+    
+}
+
+?>

cron/parser.php

@@ -2 +2 @@
 
 require_once "traffic.php";
 require_once "location.php";
+require_once "logging.php";
 
 class Parser {
     
@@ -26 +27 @@
     // Skoro to same jako $traffic, akorat bez rozmeru pro casove intervaly.
     private $trafficOneDay;
     
-    public function __construct() {
+    // Objekt pro logovani do souboru cron.txt ve slozce log.
+    private $logs;
+    
+    public function __construct($logs) {
         $this->name = "DOPR_D_";
         $this->path = "http://doprava.plzensky-kraj.cz/opendata/doprava/den/".$this->name;
         
@@ -37 +41 @@
         $this->intervalMilli = (int) (24 * 3600000 / $this->HOW_MANY_INTERVALS);
         $this->traffic = array();
         $this->trafficOneDay = array();
+        
+        $this->logs = $logs;
     }
     
     public function doWork($date) {
+        $this->logs->log(Logging::INFO, "ZACATEK PROCEDURY pro den ".DateTime::createFromFormat("Ymd", $date)->format("d.m.Y").".");
+        
         $zipUrl = $this->path.$date.".zip";
         $dir = "download/$date/";
         $downloaded = $dir."downloaded.zip";
@@ -54 +62 @@
             }
             
             if ($ok == 0 || $result == 1) {
+                $this->logs->log(Logging::INFO, "Zpracovavani zaznamu o doprave.");
                 $this->parse($dir.$this->name.$date.".csv", TRUE);
+                
+                $this->logs->log(Logging::INFO, "Zpracovavani zaznamu o lokacich.");
                 $this->parse($dir."Locations.csv", FALSE);
                 // return; odkomentovat v pripade, ze extrahovana data nemaji byt odstranena.
             }
             
+            $this->logs->log(Logging::INFO, "Odstranovani slozky s extrahovanymi daty.");
             $this->deleteDir($dir);
             
         }
+        
+        $this->logs->log(Logging::INFO, "KONEC PROCEDURY.");
     }
     
     private function parse($fileName, $traffic) {
@@ -128 +142 @@
                 if (mkdir($dir)) {
                     if (copy($zipUrl, $downloaded)) {
                         // Stazeni probehlo v poradku.
+                        $this->logs->log(Logging::INFO, "Stazeni archivu probehlo v poradku.");
                         return 0;
                     } else {
                         // Nepovedlo se stazeni zip souboru.
+                        $this->logs->log(Logging::ERROR, "Nepovedlo se stazeni archivu.");
                         return -1;
                     }
                 } else {
                     // Nepodarilo se vytvorit slozku pro data.
+                    $this->logs->log(Logging::ERROR, "Nepodarilo se vytvorit slozku pro data.");
                     return -2;
                 }
             } else {
                 // Data k vybranemu dni jiz byla stazena.
+                $this->logs->log(Logging::INFO, "Data k vybranemu dni jiz byla stazena.");
                 return 1;
             }
         } else {
             // Pro dany datum neexistuji data.
+            $this->logs->log(Logging::WARNING, "Pro dany datum neexistuji data.");
             return -3;
         }
     }
@@ -153 +172 @@
             $zip->extractTo($dir);
             $zip->close();
             // Extrahovani v poradku dokonceno.
+            $this->logs->log(Logging::INFO, "Extrahovani archivu v poradku dokonceno.");
             return 0;
         } else {
             // Nepovedlo se extrahovani obsahu zipu.
+            $this->logs->log(Logging::ERROR, "Pri extrahovani archivu doslo k chybe.");
             return -1;
         }
     }