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();
            }
        } else {
            $this->alreadyExists = true;
            $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 getValue() {
        return $this->value;
    }

    public function getValueByKey($key) {
        return $this->value[$key];
    }

    private function update() {
        Ego_System::file_put_contents($this->log, json_encode($this->value));
    }

    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 getContinue() {
        if (!empty($this->value['continue'])) {
            $continue = $this->value['continue'];
            unset($this->value['continue']);
            $this->update();
            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 clear() {
        @unlink($this->log);
    }

    public function exists() {
        return $this->alreadyExists;
    }
}
?>