Ego_Progress.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_Progress {
    private $log;
 
    private $value;
 
    private $alreadyExists = false;
 
    public function __construct($name, $reset = true, $create = true) {
        $path = $GLOBALS['egotec_conf']['log_dir'].'progress/';
        if (!Ego_System::file_exists($path)) {
            Ego_System::mkdir($path);
        }
        $this->log = $path.md5($name);
 
        // Fortschritt zurücksetzen
        if ($reset) {
            $this->clear();
        }
 
        // Daten des Fortschritts ermitteln
        if (!Ego_System::file_exists($this->log)) {
            if ($create) {
                // Logdatei anlegen, wenn diese nicht existiert
                $this->value = array(
                    'name' => $name,
                    'start' => 0,
                    'end' => 0,
                    'limit' => 0,
                    'current' => 0,
                    'message' => '',
                    'data' => array()
                );
                $this->update(true);
            }
        } else {
            $this->alreadyExists = true;
            $this->value = json_decode(Ego_System::file_get_contents($this->log), true);
        }
    }
 
    private function reload() {
        $this->value = json_decode(Ego_System::file_get_contents($this->log), true);
    }
 
    public function hasFinished() {
        return $this->value['current'] >= $this->value['limit'] && !empty($this->value['end']);
    }
 
    public function hasEnded() {
        $this->reload();
        return !empty($this->value['end']);
    }
 
    public function getValue() {
        return $this->value;
    }
 
    public function getValueByKey($key) {
        return $this->value[$key];
    }
 
    private function update($force = false) {
        if ($force || $this->stillExists()) {
            Ego_System::file_put_contents($this->log, json_encode($this->value, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT));
        }
    }
 
    public function setLimit($limit) {
        $this->value['limit'] = $limit;
        $this->update();
    }
 
    public function setMessage($message = '') {
        $this->value['message'] = $message;
        $this->update();
    }
 
    public function setData($data = array()) {
        $this->value['data'] = $data;
        $this->update();
    }
 
    public function setContinue($data) {
        $this->value['continue'] = $data;
        $this->value['continue']['_ref'] = md5(microtime());
        $this->update();
    }
 
    public function clearContinue() {
        if (!empty($this->value['continue'])) {
            unset($this->value['continue']);
            $this->update();
        }
    }
 
    public function getContinue($clear = true) {
        if (!empty($this->value['continue'])) {
            $continue = $this->value['continue'];
            if ($clear) {
                $this->clearContinue();
            }
            return $continue;
        }
        return null;
    }
 
    public function increase($message = '', $data = array(), $amount = 1) {
        $this->value['current'] += $amount;
        if (!empty($message)) {
            $this->value['message'] = $message;
        }
        if (!empty($data)) {
            $this->value['data'] = $data;
        }
        $this->update();
    }
 
    public function start($message = '', $data = array()) {
        $this->value['start'] = time();
        if (!empty($message)) {
            $this->value['message'] = $message;
        }
        if (!empty($data)) {
            $this->value['data'] = $data;
        }
        $this->update();
    }
 
    public function end($message = '', $data = array()) {
        $this->value['end'] = time();
        $this->value['current'] = $this->value['limit'];
        if (!empty($message)) {
            $this->value['message'] = $message;
        }
        if (!empty($data)) {
            $this->value['data'] = $data;
        }
        $this->update();
    }
 
    public function error($message = '', $data = array()) {
        $this->value['error'] = true;
        $this->end($message, $data);
    }
 
    public function clear() {
        @unlink($this->log);
    }
 
    public function exists() {
        return $this->alreadyExists;
    }
 
    public function stillExists() {
        return Ego_System::file_exists($this->log);
    }
}
?>