<?php
/**
 * @copyright (C)2016-2099 Hnaoyun Inc.
 * @author XingMeng
 * @email hnxsh@foxmail.com
 * @date 2017年3月13日
 *  默认主页
 */
namespace app\admin\controller;

use core\basic\Controller;
use app\admin\model\IndexModel;
use app\common\VisitsCounter;

class IndexController extends Controller
{

    private $model;

    public function __construct()
    {
        $this->model = new IndexModel();
    }

    // 登录页面
    public function index()
    {
        if (session('sid')) {
            location(url('admin/Index/home'));
        }
        $this->assign('admin_check_code', $this->config('admin_check_code'));
        $this->display('index.html');
    }

    // 主页面
    public function home()
    {
        // 手动修改数据名称
        if (get('action') == 'moddb') {
            if ($this->modDB()) {
                alert_back('修改成功！');
            } else {
                alert_back('修改失败！');
            }
        }

        // 删除修改后老数据库（上一步无法直接修改删除）
        if (issetSession('deldb')) {
            @unlink(ROOT_PATH . session('deldb'));
            unset($_SESSION['deldb']);
        }

        $dbsecurity = true;
        // 如果是sqlite数据库，并且路径为默认的，则标记为不安全
        if (get_db_type() == 'sqlite') {
            // 数据库配置含有默认名字则进行修改
            if (strpos($this->config('database.dbname'), 'pbootcms') !== false) {
                if (get_user_ip() != '127.0.0.1' && $this->modDB()) { // 非本地测试时尝试自动修改数据库名称
                    $dbsecurity = true;
                } else {
                    $dbsecurity = false;
                }
            } elseif (file_exists(ROOT_PATH . '/data/pbootcms.db')) { // 存在多余的默认数据库文件则改名
                rename(ROOT_PATH . '/data/pbootcms.db', ROOT_PATH . '/data/' . get_uniqid() . '.db');
            }
        } elseif (file_exists(ROOT_PATH . '/data/pbootcms.db')) {
            rename(ROOT_PATH . '/data/pbootcms.db', ROOT_PATH . '/data/' . get_uniqid() . '.db');
        }

        $this->assign('dbsecurity', $dbsecurity);

        if (!session('pwsecurity')) {
            location(url('/admin/Index/ucenter'));
        }

        $this->assign('server', get_server_info());
        $this->assign('branch', $this->config('upgrade_branch') == '3.X.dev' ? '3.X.dev' : '3.X');
        $this->assign('revise', $this->config('revise_version') ?: '0');
        $this->assign('snuser', $this->config('sn_user') ?: '0');
        $this->assign('site', get_http_url());

        $this->assign('user_info', $this->model->getUserInfo(session('ucode')));

        $this->assign('sum_msg', model('admin.content.Message')->getCount());

        // 内容模型菜单
        $model = model('admin.content.Model');
        $models = $model->getModelMenu();
        foreach ($models as $key => $value) {
            $models[$key]->count = $model->getModelCount($value->mcode)->count;
        }

        $this->assign('model_msg', $models);
        $this->display('system/home.html');
    }

    // 异步登录验证
    public function login()
    {
        if (!$_POST) {
            return;
        }

        // 在安装了gd库时才执行验证码验证
        if (extension_loaded("gd") && $this->config('admin_check_code') && strtolower(post('checkcode', 'var')) != session('checkcode')) {
            json(0, '验证码错误！');
        }

        // 就收数据
        $username = post('username');
        $password = post('password');
        $checkcode = post('checkcode');
        $formcheck = post('formcheck');

        if (!preg_match('/^[\x{4e00}-\x{9fa5}\w\-\.@]+$/u', $username)) {
            json(0, '用户名含有不允许的特殊字符！');
        }

        if (!$username) {
            json(0, '用户名不能为空！');
        }

        if (!$password) {
            json(0, '密码不能为空！');
        }

        if ($this->config('admin_check_code') &&
            !$checkcode
        ) {
            json(0, '验证码不能为空！');
        }

        if (!$formcheck) {
            json(0, '表单提交校验失败,请刷新后重试！');
        }

        if (!!$time = $this->checkLoginBlack()) {
            $this->log('登录锁定!');
            json(0, '您登录失败次数太多已被锁定，请' . $time . '秒后再试！');
        }

        // 执行用户登录
        $where = array(
            'username' => $username,
            'password' => encrypt_string($password)
        );

        // 判断数据库写入权限
        if ((get_db_type() == 'sqlite') && !is_writable(ROOT_PATH . $this->config('database.dbname'))) {
            json(0, '数据库目录写入权限不足！');
        }

        if (!!$login = $this->model->login($where)) {

            session_regenerate_id(true);
            session('sid', encrypt_string(session_id() . $login->id)); // 会话标识
            session('M', M);

            session('id', $login->id); // 用户id
            session('ucode', $login->ucode); // 用户编码
            session('username', $login->username); // 用户名
            session('realname', $login->realname); // 真实名字

            if ($where['password'] != '14e1b600b1fd579f47433b88e8d85291') {
                session('pwsecurity', true);
            }

            session('acodes', $login->acodes); // 用户管理区域
            if ($login->acodes) { // 当前显示区域
                session('acode', $login->acodes[0]);
            } else {
                session('acode', '');
            }

            session('rcodes', $login->rcodes); // 用户角色代码表
            session('levels', $login->levels); // 用户权限URL列表
            session('menu_tree', $login->menus); // 菜单树
            session('area_map', $login->area_map); // 区域代码名称映射表
            session('area_tree', $login->area_tree); // 用户区域树

            $this->log('登录成功!');
            json(1, url('admin/Index/home'));
        } else {
            $this->setLoginBlack();
            $this->log('登录失败!');
            session('checkcode', mt_rand(10000, 99999)); // 登录失败，随机打乱原有验证码
            json(0, '用户名或密码错误！');
        }
    }

    // 退出登录
    public function loginOut()
    {
        session_unset();
        location(url('/admin/Index/index'));
    }

    // 用户中心，修改密码
    public function ucenter()
    {
        if ($_POST) {
            $username = post('username'); // 用户名
            $realname = post('realname'); // 真实姓名
            $cpassword = post('cpassword'); // 现在密码
            $password = post('password'); // 新密码
            $rpassword = post('rpassword'); // 确认密码

            if (!$username) {
                alert_back('用户名不能为空！');
            }
            if (!$cpassword) {
                alert_back('当前密码不能为空！');
            }

            if (!preg_match('/^[\x{4e00}-\x{9fa5}\w\-\.@]+$/u', $username)) {
                alert_back('用户名含有不允许的特殊字符！');
            }

            $data = array(
                'username' => $username,
                'realname' => $realname,
                'update_user' => $username
            );

            // 如果有修改密码，则添加数据
            if ($password) {
                if ($password != $rpassword) {
                    alert_back('确认密码不正确！');
                }
                $data['password'] = encrypt_string($password);
                if ($data['password'] != '14e1b600b1fd579f47433b88e8d85291') {
                    session('pwsecurity', true);
                } else {
                    session('pwsecurity', false);
                }
            }

            // 检查现有密码
            if ($this->model->checkUserPwd(encrypt_string($cpassword))) {
                if ($this->model->modUserInfo($data)) {
                    session('username', post('username'));
                    session('realname', post('realname'));
                    $this->log('用户资料成功！');
                    success('用户资料修改成功！', -1);
                }
            } else {
                $this->log('用户资料修改时当前密码错误！');
                alert_location('当前密码错误！', -1);
            }
        }
        $this->display('system/ucenter.html');
    }

    // 切换显示的数据区域
    public function area()
    {
        if ($_POST) {
            $acode = post('acode');
            if (in_array($acode, session('acodes'))) {
                session('acode', $acode);
                cookie('lg', $acode); // 同步切换前台语言
            }
            location(url('admin/Index/home'));
        }
    }

    // 清理缓存（常规保留 runtime/image 缩略图；仅 delall 全量清理）
    public function clearCache()
    {
        $delall = get('delall');
        // delall 会删除 runtime/data，归库失败必须中止，避免待刷访问量被抹掉
        if ($delall && ! VisitsCounter::flushAll()) {
            $this->log('清理缓存前归库访问量失败，已中止全量清理！');
            alert_back('清理缓存前归库访问量失败，已中止全量清理以避免丢失计数！', 0);
        }
        $rs = purge_runtime_cache(RUN_PATH, 'all', $delall);
        cache_config(); // 清理缓存后立即生成新的配置
        if ($rs) {
            if (extension_loaded('Zend OPcache')) {
                opcache_reset(); // 在启用了OPcache加速器时同时清理
            }
            $this->log('清理缓存成功！');
            alert_back('清理缓存成功！', 1);
        } else {
            $this->log('清理缓存失败！');
            alert_back('清理缓存失败！', 0);
        }
    }

    // 清理系统缓存（常规保留 runtime/image 与 cache；仅 delall 全量清理）
    public function clearOnlySysCache()
    {
        $delall = get('delall');
        // delall 会删除 runtime/data，归库失败必须中止，避免待刷访问量被抹掉
        if ($delall && ! VisitsCounter::flushAll()) {
            $this->log('清理缓存前归库访问量失败，已中止全量清理！');
            alert_back('清理缓存前归库访问量失败，已中止全量清理以避免丢失计数！', 0);
        }
        $rs = purge_runtime_cache(RUN_PATH, 'sys', $delall);
        cache_config(); // 清理缓存后立即生成新的配置
        if ($rs) {
            if (extension_loaded('Zend OPcache')) {
                opcache_reset(); // 在启用了OPcache加速器时同时清理
            }
            $this->log('清理缓存成功！');
            alert_back('清理缓存成功！', 1);
        } else {
            $this->log('清理缓存失败！');
            alert_back('清理缓存失败！', 0);
        }
    }
	
    // 清理会话
    public function clearSession()
    {
        ignore_user_abort(true); // 后台运行
        set_time_limit(7200);
        ob_start();
        $output['code'] = 1;
        $output['data'] = '执行成功，后台自动清理中!';
        $output['tourl'] = '';
        echo json_encode($output);
        ob_end_flush();
        flush();
        $rs = path_delete(RUN_PATH . '/session', false, array(
            'sess_' . session_id()
        ));
    }

    // 文件上传方法
    public function upload()
    {
        $upload = upload('upload');
        if (is_array($upload)) {
            json(1, $upload);
        } else {
            json(0, $upload);
        }
    }

    // 黑名单文件路径
    private function getLoginBlackFile()
    {
        return RUN_PATH . '/data/' . md5('login_black') . '.php';
    }

    // 安全读取黑名单，文件损坏时降级为空数组以便重建
    private function loadLoginBlack($ip_black)
    {
        if (! file_exists($ip_black)) {
            return array();
        }
        try {
            $data = @include $ip_black; // 数据文件被截断时会抛出 ParseError
        } catch (\Throwable $e) {
            $data = false;
        }
        if (! is_array($data)) {
            return array();
        }
        foreach ($data as $ip => $item) {
            if (! is_array($item) || ! isset($item['time']) || ! isset($item['count']) || ! is_numeric($item['time']) || ! is_numeric($item['count'])) {
                unset($data[$ip]);
            }
        }
        return $data;
    }

    // 原子写入黑名单：临时文件 + rename 替换，避免并发截断
    private function writeLoginBlack($ip_black, array $data)
    {
        check_dir(dirname($ip_black), true);
        $content = "<?php\nreturn " . var_export($data, true) . ";";
        $tmp = $ip_black . '.' . \process_instance_id() . '.' . mt_rand() . '.tmp';
        if (file_put_contents($tmp, $content, LOCK_EX) === false) {
            return false;
        }
        if (! @rename($tmp, $ip_black)) { // 同目录 rename 为原子替换
            @unlink($tmp);
            return false;
        }
        if (function_exists('opcache_invalidate')) {
            opcache_invalidate($ip_black, true); // 防止 opcache 读到旧内容
        }
        return true;
    }

    // 检查是否在黑名单
    private function checkLoginBlack()
    {
        // 读取黑名单
        $ip_black = $this->getLoginBlackFile();
        $data = $this->loadLoginBlack($ip_black);
        if ($data) {
            $user_ip = get_user_ip();
            $lock_time = $this->config('lock_time') ?: 900;
            $lock_count = $this->config('lock_count') ?: 5;
            if (isset($data[$user_ip]) && $data[$user_ip]['count'] >= $lock_count && time() - $data[$user_ip]['time'] < $lock_time) {
                return $lock_time - (time() - $data[$user_ip]['time']); // 返回剩余秒数
            }
        }
        return false;
    }

    // 添加登录黑名单
    private function setLoginBlack()
    {
        $ip_black = $this->getLoginBlackFile();
        check_dir(dirname($ip_black), true);
        $lock_time = $this->config('lock_time') ?: 900;
        $lock_max = $this->config('lock_max') ?: 1000;
        $user_ip = get_user_ip();

        // 通过锁文件串行化整个「读-改-写」过程，防止并发丢失有效记录
        $fp = @fopen($ip_black . '.lock', 'c');
        if ($fp === false || ! flock($fp, LOCK_EX)) {
            if ($fp) {
                fclose($fp);
            }
            return false;
        }

        $ok = false;
        $evictedIps = array();
        try {
            $data = $this->loadLoginBlack($ip_black);
            $now = time();

            // 写入前清理过期记录
            foreach ($data as $ip => $item) {
                if (! isset($item['time']) || ! isset($item['count']) || $now - $item['time'] >= $lock_time) {
                    unset($data[$ip]);
                }
            }

            if (isset($data[$user_ip])) {
                $data[$user_ip] = array(
                    'time' => $now,
                    'count' => $data[$user_ip]['count'] + 1
                );
            } else {
                // 满员时按 time 淘汰最旧条目（近似 LRU），为新 IP 腾出空位
                while (count($data) >= $lock_max) {
                    $oldestIp = null;
                    $oldestTime = null;
                    foreach ($data as $ip => $item) {
                        if ($oldestTime === null || $item['time'] < $oldestTime) {
                            $oldestTime = $item['time'];
                            $oldestIp = $ip;
                        }
                    }
                    if ($oldestIp === null) {
                        break;
                    }
                    unset($data[$oldestIp]);
                    $evictedIps[] = $oldestIp;
                }
                $data[$user_ip] = array(
                    'time' => $now,
                    'count' => 1
                );
            }

            $ok = $this->writeLoginBlack($ip_black, $data);
        } finally {
            flock($fp, LOCK_UN);
            fclose($fp);
        }

        if ($ok) {
            foreach ($evictedIps as $oldestIp) {
                $this->log('登录黑名单已满，淘汰最旧IP：' . $oldestIp . '，腾出给：' . $user_ip, 'warning');
            }
        }

        return $ok;
    }

    // 修改数据库名称
    private function modDB()
    {
        $file = CONF_PATH . '/database.php';
        $sname = $this->config('database.dbname');
        $dname = '/data/' . get_uniqid() . '.db';
        $sconfig = file_get_contents($file);
        $dconfig = str_replace($sname, $dname, $sconfig);
        if (file_put_contents($file, $dconfig)) {
            if (!copy(ROOT_PATH . $sname, ROOT_PATH . $dname)) {
                file_put_contents($file, $sconfig); // 回滚配置
            } else {
                session('deldb', $sname);
                return true;
            }
        }
        return false;
    }
}
