<?php

/**
 * 文件缓存驱动器
 *
 * @author     呼吸二氧化碳 <jonwang@myqee.com>
 * @category   Module
 * @package    Cache
 * @copyright  Copyright (c) 2008-2016 myqee.com
 * @license	   http://www.myqee.com/license.html
 */
class Driver_Cache_Driver_File extends Cache_Driver
{
    /**
     * Cache目录
     *
     * @var string
     */
    protected $dir = DIR_CACHE;

    /**
     * 存储
     *
     * @var string
     */
    protected $storage = 'default';

    /**
     * 是否禁用文件写入功能
     *
     * @var boolean
     */
    protected $is_file_write_disalbed = false;

    public function __construct($config_name = 'default')
    {
        if (is_array($config_name))
        {
            $config = $config_name;
        }
        else
        {
            $config = (array)Core::config('cache/file.' . $config_name);
        }

        if (isset($config['storage']))
        {
            $this->storage  = $config['storage'];
        }

        $this->is_file_write_disalbed = Core::is_file_write_disabled();
    }

    public function __destruct()
    {

    }

    /**
     * 取得数据，支持批量取
     *
     * @param string/array $key
     * @return mixed
     */
    public function get($key)
    {
        if ($this->is_file_write_disalbed)return null;

        if (is_array($key))
        {
            # 支持多取
            $data = array();
            foreach ($key as $k=>$v)
            {
                $data[$k] = $this->get((string)$v);
            }

            return $data;
        }

        $filename = $this->get_filename_by_key($key);

        if (file_exists($filename))
        {
            $data = @file_get_contents($filename);

            if ($data && $this->get_expired_setting($key, $data))
            {
                $return = $data;
            }
            else
            {
                # 删除失效文件
                $this->delete($key);
                $return = null;
            }
        }
        else
        {
            $return = null;
        }

        if (null === $return)
        {
            if(IS_DEBUG)Core::debug()->warn($key, 'file cache mis key');
            return false;
        }
        else
        {
            if (IS_DEBUG)Core::debug()->info($key, 'file cache hit key');
        }

        return $return;
    }

    /**
     * 存数据
     *
     * @param string/array $key 支持多存
     * @param mixed $value Value 多存时此项可空
     * @param int $lifetime 有效期，默认3600，即1小时，0表示最大值30天（2592000）
     * @return boolean
     */
    public function set($key, $value = null, $lifetime = 3600)
    {
        if ($this->is_file_write_disalbed)return false;

        if (is_array($key))
        {
            # 支持多存
            $i=0;
            foreach ($key as $k => $v)
            {
                if ($this->set((string)$k, $v, $lifetime))
                {
                    $i++;
                }
            }

            $rs = $i === count($key) ? true : false;

            Core::debug()->info(array_keys($key), 'memcache set key');

            return $rs;
        }

        $filename = $this->get_filename_by_key($key);

        $value = $this->format_data($lifetime, $value);

        $rs = File::create_file($filename, $value, null, null, $this->storage);

        if (IS_DEBUG)
        {
            Core::debug()->info($key, 'file cache set key');
        }

        return $rs;
    }

    /**
     * 删除指定key的缓存，若$key===true则表示删除全部
     *
     * @param string $key
     */
    public function delete($key)
    {
        if ($this->is_file_write_disalbed)return false;

        if (true === $key)
        {
            # 删除全部
            return File::remove_dir($this->dir . $this->prefix, $this->storage);
        }

        if (is_array($key))
        {
            # 支持多取
            $data = array();
            $i = 0;
            foreach ($key as $k => $v)
            {
                if ($this->delete((string)$v))
                {
                    $i++;
                }
            }

            if (IS_DEBUG)
            {
                Core::debug()->info($key, 'file cache delete key');
            }

            return $i === count($key) ? true : false;
        }

        $filename = $this->get_filename_by_key($key);

        $rs = File::unlink($filename, $this->storage);

        if (IS_DEBUG)
        {
            Core::debug()->info($key, 'file cache delete key');
        }

        return $rs;
    }

    /**
     * 删除全部
     */
    public function delete_all()
    {
        return $this->delete(true);
    }

    /**
     * TODO 暂不支持删除过期的文件缓存
     *
     */
    public function delete_expired()
    {
        return false;
    }

    /**
     * 递减
     *
     * @param string $key
     * @param int $offset
     * @param int $lifetime 当递减失则时当作set使用
     */
    public function decrement($key, $offset = 1, $lifetime = 60)
    {
        return $this->increment($key, -$offset, $lifetime);
    }

    /**
     * 递增
     *
     * @param string $key
     * @param int $offset
     * @param int $lifetime 当递减失则时当作set使用
     */
    public function increment($key, $offset = 1, $lifetime = 60)
    {
        if ($this->is_file_write_disalbed)return false;

        $filename = $this->get_filename_by_key($key);

        if (!file_exists($filename))
        {
            # 不存在，则设置
            return $this->set($key, $offset, $lifetime);
        }

        $fh = fopen($filename, 'r+');
        if (flock($fh, LOCK_EX))
        {
            $data = trim(fread($fh, filesize($filename)));
            $expired_setting = $this->get_expired_setting($key, $data);
            if ($expired_setting)
            {
                $buffer = $data + $offset;
                $lifetime = max($expired_setting['lifetime'], $lifetime);
            }
            else
            {
                $buffer = $offset;
            }

            $data = $this->format_data($lifetime, $buffer);

            rewind($fh);
            fwrite($fh, $data);
            fflush($fh);
            ftruncate($fh, ftell($fh));
            flock($fh, LOCK_UN);

            $status = true;
        }
        else
        {
            $status = false;
        }

        @fclose($fh);

        if ($status)
        {
            # 同步文件
            File::sync($filename, $this->storage);
        }

        return $status;
    }

    /**
     * 根据KEY获取文件路径
     *
     * @param string $key
     */
    protected function get_filename_by_key($key)
    {
        return $this->dir . $this->prefix . 'cache_file_' . substr(preg_replace('#[^a-z0-9_\-]*#i', '', $key), 0, 50) . '_' . md5($key . '_&@c)ac%he_file');
    }

    protected function get_expired_setting($key, &$data)
    {
        $dataArr = explode(CRLF, $data, 3);
        /*
        $dataArr[0] - 生存期
        $dataArr[1] - 设置时候的时间
        $dataArr[2] - serialize后的数据内容
        */
        if( $dataArr[0]==0 || TIME - $dataArr[1] <= $dataArr[0]   )
        {
            $data = @unserialize($dataArr[2]);
            return array
            (
                'lifetime' => $dataArr[0],
                'settime'  => $dataArr[1],
            );
        }
        else
        {
            return false;
        }
    }

    protected function format_data($lifetime, $data)
    {
        return $lifetime . CRLF . TIME . CRLF . serialize($data);
    }

    /**
     * 设置前缀
     *
     * @param string $prefix
     * @return $this
     */
    public function set_prefix($prefix)
    {
        if ($prefix)
        {
            $this->prefix = trim($prefix, ' /_') . '/';
        }
        else
        {
            $this->prefix = '';
        }

        return $this;
    }
}