Хранение большого количества файлов

<?php

class BigFiles
{
    const FLAG_DELETED = 0x08000000; // Пока только флаг "Удалён"

    /** @var mysqli $_db */
    protected $_db       = null;
    protected $_webRoot  = '';
    protected $_realRoot = '';

    function __construct(mysqli $db = null) {
        $this->_db = $db;
    }

    /**
     * Установка/чтение корня для URL-ов
     * @param string $v  Значение
     * @return string
     */
    public function webRoot($v = null) {
        if (!is_null($v)) {
            $this->_webRoot = $v;
        }
        return $this->_webRoot;
    }

    /**
     * Установка/чтение корня для файлов
     * @param string $v  Значение
     * @return string
     */
    public function realRoot($v = null) {
        if (!is_null($v)) {
            $this->_realRoot = $v;
        }
        return $this->_realRoot;
    }

    /**
     * Загрузка файла
     * @param array  $data    Данные запроса
     * @param string $url     URL виртуальной папки
     * @param string $eType   Тип сущности
     * @param int    $eID     ID сущности
     * @param mixed  $meta    Мета-данные
     * @param int    $access  Доступ
     * @param int    $flags   Флаги
     * @param int    $fileID  ID существующего файла
     * @return bool
     * @throws Exception
     */
    public function upload(array $data, $url, $eType = '', $eID = null, $meta = null, $access = 127, $flags = 0, $fileID = 0) {
        $meta = is_array($meta) ? serialize($meta) : $meta;
        if (empty($data['tmp_name']) || empty($data['name'])) {
            $fid = intval($fileID);
            if (empty($fid)) {
                return false;
            }
            $meta = empty($meta) ? 'null' : "'" . $this->_db->real_escape_string($meta) . "'";
            $q = "`meta`={$meta},`updated`=now()";
            $this->_db->query("UPDATE `files` SET {$q} WHERE (`id` = {$fid}) AND (`entity_type` = '{$eType}')");
            return $fid;
        }
        // File data
        $meta  = empty($meta) ? 'null' : "'" . $this->_db->real_escape_string($meta) . "'";
        $finfo = finfo_open(FILEINFO_MIME_TYPE);
        $mime  = finfo_file($finfo , $data['tmp_name']);
        finfo_close($finfo);
        // FID, file name
        if (empty($fileID)) {
            $eID = empty($eID) ? 'null' : intval($eID);
            $q = <<<sql
insert into `files` set
    `mime`       = '{$mime}',
    `entity`     = {$eID},
    `entityType` = '{$eType}',
    `created`    = now(),
    `access`     = {$access},
    `flags`      = {$flags}
sql;
            $this->_db->query($q);
            $fid = $this->_db->insert_id;
            list($ffs, $fhn) = self::fid($fid);
            $url = $this->_webRoot . $url . '/' . $fid;
            $fdir = $this->_realRoot . $ffs;
            self::validateDir($fdir);
            $index = self::getIndex($fdir);
            $index[$fhn] = array($fhn, $mime, $url, ($eID == 'null' ? 0 : $eID), $access, $flags);
            self::setIndex($fdir, $index);
            $fname = $ffs . '/' . $fhn . '.file';
        } else {
            $fid = intval($fileID);
            $fname = $this->fileName($fid);
        }
        // Move file
        $fdir = $this->_realRoot . $fname;
        if (!move_uploaded_file($data['tmp_name'], $fdir)) {
            throw new Exception('Upload error');
        }
        $q = '`md5`=\'' . md5_file($fdir) . '\',`sha1`=\'' . sha1_file($fdir) . '\','
           . '`size`=' . filesize($fdir) . ',`meta`=' . $meta . ','
           . (empty($fileID) ? "`url`='{$url}',`file`='{$fname}'" : '`updated`=now()');
        $this->_db->query("UPDATE `files` SET {$q} WHERE (`id` = {$fid}) AND (`entity_type` = '{$eType}')");
        return $fid;
    }

    /**
     * Чтение файла
     * @param string $url         URL
     * @param string $basicGroup  Базовая группа пользователя
     * @throws Exception
     */
    public function read($url, $basicGroup = 'anonimous') {
        if (!ctype_alnum(str_replace(array('/', '.', '-', '_'), '', $url))) {
            header('HTTP/1.1 400 Bad Request');
            exit;
        }
        $url = $this->_db->real_escape_string($url);
        $q = "SELECT * FROM `files` WHERE `url` = '{$url}' ORDER BY `created` ASC";
        if ($result = $this->_db->query($q)) {
            $vars = array();
            $ints = array('id', 'entity', 'size', 'access', 'flags');
            while ($row = $result->fetch_assoc()) {
                foreach ($ints as $i) {
                    $row[$i] = intval($row[$i]);
                }
                $fid = $row['id'];
                $vars[$fid] = $row;
            }
            if (empty($vars)) {
                header('HTTP/1.1 404 Not Found');
                exit;
            }
            $deleted = false;
            $access  = true;
            $found   = '';
            $mime    = '';
            foreach ($vars as $fdata) {
                $flags   = intval($fdata['flags']);
                $deleted = ($flags & self::FLAG_DELETED) != 0;
                $access  = self::granted($basicGroup, $fdata['access']);
                if (!$access || $deleted) {
                    continue;
                }
                $found   = $fdata['file'];
                $mime    = $fdata['mime'];
            }
            if (empty($found)) {
                if ($deleted) {
                    header('HTTP/1.1 410 Gone');
                    exit;
                } elseif (!$access) {
                    header('HTTP/1.1 403 Forbidden');
                    exit;
                }
            } else {
                header('Content-type: ' . $mime . '; charset=utf-8');
                readfile($this->_realRoot . $found);
                exit;
            }
        }
        header('HTTP/1.1 404 Not Found');
        exit;
    }

    /**
     * Удаление файла (файлов) из хранилища
     * @param mixed $fid  Идентификатор(ы)
     * @return bool
     * @throws Exception
     */
    public function delete($fid) {
        $fid = is_array($fid) ? implode(',', $fid) : $fid;
        $q = "delete from `table` where `id` in ({$fid})";
        $this->_db->query($q);
        $result = true;
        foreach ($fid as $fid_i) {
            list($ffs, $fhn) = self::fid($fid_i);
            $fdir = $this->_realRoot . $ffs;
            $index = self::getIndex($fdir);
            unset($index[$fhn]);
            self::setIndex($fdir, $index);
            $result &= unlink($fdir . '/'. $fhn . '.file');
        }
        return $result;
    }

    /**
     * Помечает файл(ы) флагом "удалено"
     * @param int  $fid    Идентификатор(ы)
     * @param bool $value  Значение флага
     * @return bool
     */
    public function setDeleted($fid, $value=true) {
        $fid = is_array($fid) ? implode(',', $fid) : $fid;
        $o = $value ? ' | ' . self::FLAG_DELETED : ' & ' . (~self::FLAG_DELETED);
        $this->_db->query("update `files` set `flags` = `flags` {$o} where `id` in ({$fid})");
        return true;
    }

    /**
     * Имя файла
     * @param int $fid  Идентификатор
     * @return string
     * @throws Exception
     */
    public function fileName($fid) {
        list($ffs, $fhn) = self::fid($fid);
        self::validateDir($this->_realRoot . $ffs);
        return $ffs . '/' . $fhn . '.file';
    }

    /**
     * Обработка идентификатора файла.
     * Возвращает массив с папкой к файлу и шестнадцатиричное представление младшего байта.
     * @param int $fid  Идентификатор файла
     * @return array
     */
    public static function fid($fid) {
        $ffs = str_split(str_pad(dechex($fid), 16, '0', STR_PAD_LEFT), 2);
        $fhn = array_pop($ffs);
        $ffs = implode('/', $ffs);
        return array($ffs, $fhn);
    }

    /**
     * Проверка каталога файла
     * @param string $f  Полный путь к каталогу
     * @return bool
     * @throws Exception
     */
    public static function validateDir($f) {
        if (!is_dir($f)) {
            if (!mkdir($f, 0700, true)) {
                throw new Exception('cannot make dir: ' . $f);
            }
        }
        return true;
    }

    /**
     * Чтение резервного индекса
     * @param string $f  Полный путь к файлу резервного индекса
     * @return array
     */
    public static function getIndex($f) {
        $index = array();
        if (file_exists($f . '/.index')) {
            $_ = file($f . '/.index');
            foreach ($_ as $_i) {
                $row = trim($_i);
                $row = explode('|', $row);
                array_walk($row, 'trim');
                $rid = $row[0];
                $index[$rid] = $row;
            }
        }
        return $index;
    }

    /**
     * Запись резервного индекса
     * @param string $f      Полный путь к файлу резервного индекса
     * @param array  $index  Массив данных индекса
     * @return bool
     */
    public static function setIndex($f, array $index) {
        $_ = array();
        foreach ($index as $row) {
            $_[] = implode('|', $row);
        }
        return file_put_contents($f . '/.index', implode("\r\n", $_));
    }

    /**
     * Проверка доступности
     * @param string $group  Название группы (см. ниже)
     * @param int    $value  Значение доступов
     * @return bool
     */
    public static function granted($group, $value=0) {
        $groups = array('anonimous', 'user', 'manager', 'admin', 'inactive', 'blocked', 'deleted');
        if ($group == 'root') {
            return true;
        }
        foreach ($groups as $groupID => $groupName) {
            if ($groupName == $group) {
                return (((1 << $groupID) & $value) != 0);
            }
        }
        return false;
    }
}