machete/themes/tajian/controller/FrontapiController.php

<?php
/**
 * List Controller
 */
require_once __DIR__ . '/../../../lib/DirScanner.php';
require_once __DIR__ . '/../../../plugins/Parsedown.php';
require_once __DIR__ . '/../../../plugins/Html.php';
require_once __DIR__ . '/../../../plugins/Common.php';
require_once __DIR__ . '/../../../plugins/TajianStats.php';
require_once __DIR__ . '/SiteController.php';

Class FrontApiController extends SiteController {

    public function actionIndex() {
        $code = 0;
        $err = 'Not allowed';

        return $this->renderJson(compact('code', 'err'));
    }

    public function actionTags() {
        //获取数据
        $menus = array();        //菜单，一级目录
        $htmlReadme = '';   //Readme.md 内容，底部网站详细介绍
        $htmlCateReadme = '';   //当前目录下的Readme.md 内容
        $menus_sorted = array(); //Readme_sort.txt 说明文件内容，一级目录菜单从上到下的排序
        
        $scanner = new DirScanner();
        $scanner->setWebRoot(FSC::$app['config']['content_directory']);
        $dirTree = $scanner->scan(__DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'], 3);

        $code = 1;
        $msg = '';
        $err = '';
        
        //获取tags分类
        $noFiles = true;
        $data = $this->getTags($dirTree, $noFiles);

        return $this->renderJson(compact('code', 'msg', 'err', 'data'));
    }

    /*
     * 参数：
     * content: 从抖音或其它平台复制出来的视频分享内容，或者视频网址
     * title: 视频标题
     * tag: 分类名称
     * tagid: 分类id
     * 其中title、tag和tagid为可选值。
     */
    public function actionAddfav() {
        $ip = $this->getUserIp();
        $check_time = 60;            //1 分钟内
        $max_time_in_minutes = 10;   //最多 10 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许添加到自己的收藏夹
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }

        $content = $this->post('content', '');
        $title = $this->post('title', '');
        $tag = $this->post('tag', '');
        $tagid = $this->post('tagid', '');

        $code = 1;
        $msg = '';
        $err = '';

        if (empty($content)) {
            $code = 0;
            $err = '请粘贴填写分享内容！';
        }else {
            $content = urldecode($content);
        }

        //分享内容来源平台检查
        $shareUrl = $this->getShareUrlFromContent($content);
        $platform = Html::getShareVideosPlatform($shareUrl);
        if (!in_array($platform, FSC::$app['config']['tajian']['supportedPlatforms'])) {
            $code = 0;
            $err = '目前只支持抖音、快手、西瓜视频和Bilibili的分享网址哦！';
        }

        $tagName = '';
        if ($code == 1 && (!empty($tag) || !empty($tagid))) {        //检查分类名称或id是否存在
            $scanner = new DirScanner();
            $scanner->setWebRoot(FSC::$app['config']['content_directory']);
            $dirTree = $scanner->scan(__DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'], 3);
            //获取tags分类
            $tags = $this->getTags($dirTree);

            if (!empty($tagid) && empty($tags[$tagid])) {        //检查tagid是否存在
                $code = 0;
                $err = "分类ID {$tagid} 不存在！";
            }

            if (!empty($tag)) {        //检查tag是否存在
                $tag_exists = false;
                foreach($tags as $id => $item) {
                    if ($item['name'] == $tag) {
                        $tag_exists = true;
                        $tagName = $tag;
                        break;
                    }
                }

                if ($tag_exists == false) {
                    $code = 0;
                    $err = "分类 {$tag} 不存在！";
                }
            }

            if (empty($tagName) && !empty($tags[$tagid])) {
                $tagName = $tags[$tagid]['name'];
            }
        }

        if ($code == 1) {        //保存视频
            $done = $this->saveShareVideo($shareUrl, $title, $tagName);
            $msg = $done ? '视频保存完成，系统开始自动处理，1 - 3 分钟后刷新就能看到新添加的视频了。' : '视频保存失败，请稍后重试！';
            
            //更新统计数据
            if ($done) {
                $stats = TajianStats::init();
                TajianStats::increase('video');
                $saved = TajianStats::save();
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    protected function getVideoId($url) {
        return md5($url);
    }

    protected function getShareUrlFromContent($content) {
        $url = '';

        preg_match("/https:\/\/[\w\.]+(\/\w+){1,}\/?/i", $content, $matches);
        if (!empty($matches)) {
            $url = $matches[0];
        }

        return $url;
    }

    //保存分享视频
    protected function saveShareVideo($shareUrl, $title, $tagName) {
        $done = true;

        if (!empty($shareUrl)) {
            $video_id = $this->getVideoId($shareUrl);

            //保存url文件以及标题
            $saveUrlRes = $this->saveUrlShortCut($video_id, $shareUrl);
            $saveDescRes = $this->saveDescriptionFiles($video_id, array('title' => '处理中，请稍后刷新...'))

            //如果没有对接HeroUnion则保存本地任务文件
            if (empty(FSC::$app['config']['heroUnionEnable'])) {
                $done = $done && $this->saveBotTask($shareUrl);
            }

            if (!empty($tagName)) {
                $done = $done && $this->saveVideoToTag($video_id, $tagName);
            }

            //保存任务日志
            $this->saveTaskLog($shareUrl, $title, $tagName);

            //调用HeroUnion联盟接口，提交新的数据抓取任务
            if (!empty(FSC::$app['config']['heroUnionEnable'])) {
                $platformName = Html::getShareVideosPlatform($shareUrl);
                $heroUnionConfig = FSC::$app['config']['heroUnion'];
                $this->addHeroUnionTask($shareUrl, $heroUnionConfig['supportedPlatforms'][$platformName]);
            }
        }

        return $done;
    }

    //保存分享视频到任务文件
    protected function saveBotTask($url) {
        $task_dir = __DIR__ . '/../../../runtime/' . FSC::$app['config']['tajian']['task_dir'];
        if (!is_dir($task_dir)) {
            mkdir($task_dir, 0755, true);
        }

        $video_id = $this->getVideoId($url);
        $filepath = realpath($task_dir) . "/{$video_id}.task";
        return file_put_contents($filepath, $url) !== false;
    }

    //保存分享视频到tag分类
    //TODO: 如果高并发，需要避免数据被覆盖的问题
    protected function saveVideoToTag($video_id, $tagName) {
        if (empty($video_id) || empty($tagName)) {return false;}

        $tag_dir = __DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'] . FSC::$app['config']['tajian']['tag_dir'];
        if (!is_dir($tag_dir)) {
            mkdir($tag_dir, 0755, true);
        }

        $filepath = realpath($tag_dir) . "/{$tagName}.txt";
        if (file_exists($filepath)) {
            $content = file_get_contents($filepath);
            $videos = explode("\n", $content);
            $last_id = array_pop($videos);
            if (!empty($last_id)) {
                array_push($videos, $last_id);
            }

            if (!in_array($video_id, $videos)) {
                array_push($videos, $video_id);
            }

            return file_put_contents($filepath, implode("\n", $videos)) !== false;
        }else {
            return file_put_contents($filepath, $vidoe_id) !== false;
        }
    }

    //从分类中删除视频
    protected function deleteVideoFromTag($filename, $tagName) {
        if (empty($filename) || empty($tagName)) {return false;}

        $tag_dir = __DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'] . FSC::$app['config']['tajian']['tag_dir'];
        if (!is_dir($tag_dir)) {
            mkdir($tag_dir, 0755, true);
        }

        $filepath = realpath($tag_dir) . "/{$tagName}.txt";
        if (file_exists($filepath)) {
            $content = file_get_contents($filepath);
            $videos = explode("\n", $content);
            $last_id = array_pop($videos);
            if (!empty($last_id)) {
                array_push($videos, $last_id);
            }

            $key = array_search($filename, $videos);
            if ($key !== false) {
                unset($videos[$key]);
            }

            return file_put_contents($filepath, implode("\n", $videos)) !== false;
        }

        return false;
    }

    //保存任务日志
    protected function saveTaskLog($url, $title, $tagName) {
        $logFile = __DIR__ . '/../../../runtime/' . FSC::$app['config']['tajian']['task_log'];

        $saved = true;
        try {
            $fp = fopen($logFile, 'a');

            $content = array(
                'url' => $url,
                'title' => $title,
                'tag' => $tagName,
                'created' => time(),
            );

            if (!empty(FSC::$app['config']['multipleUserUriParse'])) {
                $content['user'] = !empty(FSC::$app['user_id']) ? FSC::$app['user_id'] : '';
            }

            fwrite($fp, json_encode($content) . "\n");
        }catch(Exception $err) {
            $saved = false;
        }

        return $saved;
    }

    protected function sign($params, $token) {                    //对参数做MD5签名
        ksort($params);
        return md5( json_encode($params, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE) . $token );
    }

    //提交视频抓取任务到HeroUnion英雄联盟
    protected function addHeroUnionTask($shareUrl, $platform) {
        $notify_prefix = '';
        if (!empty(FSC::$app['config']['multipleUserUriParse']) && !empty(FSC::$app['user_id'])) {
            $notify_prefix = '/' . FSC::$app['user_id'];
        }

        $heroUnionConfig = FSC::$app['config']['heroUnion'];
        $params = array(
            'uuid' => $heroUnionConfig['uuid'],
            'url' => $shareUrl,
            'platform' => $platform,
            'contract' => $heroUnionConfig['contract'],
            'data_mode' => $heroUnionConfig['data_mode'],
            'country' => $heroUnionConfig['country'],
            'lang' => $heroUnionConfig['lang'],
            'notify_url' => $heroUnionConfig['notify_domain'] . $notify_prefix . '/frontapi/hunotify/',
        );
        $params['sign'] = $this->sign($params, $heroUnionConfig['token']);

        $api = $heroUnionConfig['server_url'] . '/api/newtask/';
        $timeout = 10;
        $pc = false;
        $headers = array("Content-Type: application/json");
        //以json格式post数据
        $res = $this->request($api, json_encode($params), $timeout, $pc, $headers);

        return !empty($res) && $res['status'] == 200 ? $res['result'] : false;
    }

    //保存快捷方式
    protected function saveUrlShortCut($video_id, $task_url) {
        $data_dir = __DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'] . FSC::$app['config']['tajian']['data_dir'];
        if (!is_dir($data_dir)) {
            mkdir($data_dir, 0755, true);
        }

        $shortUrlContent = <<<eof
[InternetShortcut]
URL={$task_url}
eof;

        $filepath = realpath($data_dir) . "/{$video_id}.url";
        return file_put_contents($filepath, $shortUrlContent) !== false;
    }

    //保存描述文件：标题和图片
    protected function saveDescriptionFiles($video_id, $task_data) {
        $data_dir = __DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'] . FSC::$app['config']['tajian']['data_dir'];
        if (!is_dir($data_dir)) {
            mkdir($data_dir, 0755, true);
        }

        $done = true;

        try {
            $data_dir = realpath($data_dir);

            //保存标题
            $filepath_title = "{$data_dir}/{$video_id}_title.txt";
            file_put_contents($filepath_title, $task_data['title']);

            //保存图片文件
            if (!empty($task_data['cover_base64'])) {
                $filepath_cover = "{$data_dir}/{$video_id}.{$task_data['cover_type']}";
                file_put_contents($filepath_cover, base64_decode($task_data['cover_base64']));

                $filepath_desc = "{$data_dir}/{$video_id}_cover.txt";
                file_put_contents($filepath_desc, "{$video_id}.{$task_data['cover_type']}");
            }else if (!empty($task_data['cover'])) {
                $filepath_desc = "{$data_dir}/{$video_id}_cover.txt";
                file_put_contents($filepath_desc, "{$task_data['cover']}");
            }
        }catch(Exception $err) {
            $done = false;
        }

        return $done;
    }

    //删除收藏的视频相关的所有文件
    protected function deleteVideoFiles($filename) {
        $data_dir = __DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'] . FSC::$app['config']['tajian']['data_dir'];
        if (!is_dir($data_dir)) {
            return false;
        }

        $done = true;

        try {
            $data_dir = realpath($data_dir);

            //删除.url文件
            $filepath_url = "{$data_dir}/{$filename}.url";
            if (file_exists($filepath_url)) {
                unlink($filepath_url);
            }

            //删除标题
            $filepath_title = "{$data_dir}/{$filename}_title.txt";
            if (file_exists($filepath_title)) {
                unlink($filepath_title);
            }

            //删除图片文件
            $imgTypes = array('jpg', 'jpeg', 'png', 'gif', 'webp');
            foreach ($imgTypes as $cover_type) {
                $filepath_cover = "{$data_dir}/{$filename}.{$cover_type}";
                if (file_exists($filepath_cover)) {
                    unlink($filepath_cover);
                }
            }

            //删除图片描述文件
            $filepath_desc = "{$data_dir}/{$filename}_cover.txt";
            if (file_exists($filepath_desc)) {
                unlink($filepath_desc);
            }
        }catch(Exception $err) {
            $done = false;
        }

        return $done;
    }

    //HeroUnion任务数据通知回传接口
    /**
     * task_id
     * task_result
     * timestamp
     * sign
     **/
    public function actionHuNotify() {
        $task_id = $this->post('task_id', '');
        $task_result = $this->post('task_result', '');
        $timestamp = $this->post('timestamp', '');
        $sign = $this->post('sign', '');

        $code = 1;
        $msg = '';
        $err = '';

        //参数检查
        if (empty($task_id) || empty($task_result) || empty($timestamp) || empty($sign)) {
            $code = 0;
            $err = '参数缺失！';
        }

        $heroUnionConfig = FSC::$app['config']['heroUnion'];

        //验证签名
        if ($code == 1) {
            $checkParams = array(
                'task_id' => $task_id,
                'task_result' => $task_result,
                'timestamp' => $timestamp,
            );
            $mySign = $this->sign($checkParams, $heroUnionConfig['token']);

            if (strtolower($mySign) != strtolower($sign)) {
                $code = 0;
                $err = '签名验证不通过！';
            }else if (!empty($task_result['done'])) {    //如果任务成功抓取到数据
                $video_id = $this->getVideoId($task_result['url']);
                $saveUrlRes = $this->saveUrlShortCut($video_id, $task_result['url']);
                $saveDescRes = $this->saveDescriptionFiles($video_id, $task_result);
                if (!$saveUrlRes) {
                    $code = 0;
                    $err = '网址快捷方式文件保存失败！';
                }else if (!$saveDescRes) {
                    $code = 0;
                    $err = '标题文件、图片及其描述文件保存失败！';
                }else {
                    $msg = '视频相关文件保存完成。';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //TODO: 把自己的收藏视频压缩成zip包
    protected function createZip() {
        
    }

    //TODO: 打包下载自己的收藏记录
    public function actionDownloadfavs() {
        $this->createZip();
        exit;
    }

    //请求频率限制
    /**
     * key: 检查频率限制的唯一标识
     * max: 最大次数
     * time: 检查时间，单位：秒
     */
    protected function requestLimit($key, $max, $time) {
        $isLimited = false;

        try {
            if(session_status() !== PHP_SESSION_ACTIVE) {
                session_start();
            }

            $current_time = microtime(true)*1000;

            $field = md5("requestLimit_by_{$key}");
            $field_update_time = "{$field}_updated";
            if (!empty($_SESSION[$field]) && !empty($_SESSION[$field_update_time]) && $current_time - $_SESSION[$field_update_time] <= $time*1000) {
                $_SESSION[$field] ++;
            }else {
                $_SESSION[$field] = 1;
                $_SESSION[$field_update_time] = $current_time;
            }

            if ($_SESSION[$field] > $max) {
                $isLimited = true;
            }
        }catch(Exception $e) {
            $this->logError("Request limit by session failed: " . $e->getMessage());
        }

        return $isLimited;
    }

    //生成4随机数，并保存生成时间，10 分钟内有效
    protected function generateRandSmsCode($cellphone) {
        if(session_status() !== PHP_SESSION_ACTIVE) {
            session_start();
        }

        $rndCode = rand(1000, 9999);        //4位随机数

        $_SESSION['randSmsCode'] = $rndCode;
        $_SESSION['randSmsCode_created'] = time();
        $_SESSION['smsCodePhone'] = $cellphone;         //保存发送验证码的手机号码，便于在登录、注册的时候验证

        return $rndCode;
    }

    //短信验证码 10 分钟内有效
    protected function getMySmsCode($cellphone) {
        if(session_status() !== PHP_SESSION_ACTIVE) {
            session_start();
        }

        $rndCode = !empty($_SESSION['randSmsCode']) ? $_SESSION['randSmsCode'] : 0;
        $rndCode_created = !empty($_SESSION['randSmsCode_created']) ? $_SESSION['randSmsCode_created'] : 0;
        $codeSentPhoneNumber = !empty($_SESSION['smsCodePhone']) ? $_SESSION['smsCodePhone'] : 0;
        $current_time = time();

        $max_cache_time = !empty(FSC::$app['config']['sms_code_cache_time']) ? FSC::$app['config']['sms_code_cache_time'] : 600;
        if (!empty($rndCode_created) && $current_time - $rndCode_created > $max_cache_time) {
            $rndCode = 0;
        }else if (empty($codeSentPhoneNumber) || $cellphone != $codeSentPhoneNumber) {  //检查发送验证码的手机号码跟提交的是否一致
            $rndCode = 0;
        }

        return $rndCode;
    }

    //获取短信验证码
    public function actionSendsmscode() {
        $ip = $this->getUserIp();
        $check_time = 300;          //5 分钟内
        $max_time_in_minutes = 3;   //最多 3 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        $postParams = $this->post();
        if (!empty($postParams)) {
            $cellphone = $this->post('phoneNum', '');
            $action = $this->post('action', 'register');

            if (empty($cellphone) || Common::isCellphoneNumber($cellphone) == false) {
                $err = "手机号码格式错误，请填写正确的手机号码";
            }else {
                //判断是否已经注册
                $userDataDir = Common::getUserDataDir($cellphone);
                if (!empty($userDataDir) && $action == 'register') {
                    $err = '你已经注册，请直接登录';
                    return $this->renderJson(compact('code', 'msg', 'err'));
                }else if (empty($userDataDir) && $action == 'login') {
                    $err = '你还没注册，请先注册';
                    return $this->renderJson(compact('code', 'msg', 'err'));
                }


                //尝试发送短信验证码
                $params = array(
                    'phoneNumber' => $cellphone,
                    'codeNumber' => $this->generateRandSmsCode($cellphone),
                    'action' => $action,
                );
                $params['sign'] = $this->sign($params, FSC::$app['config']['service_3rd_api_key']);

                $api = FSC::$app['config']['service_3rd_api_domain'] . '/aliyun/sendverifycode/';
                $timeout = 30;      //api请求超时时长
                $pc = false;
                $headers = array("Content-Type: application/json");
                //以json格式post数据
                $res = $this->request($api, json_encode($params), $timeout, $pc, $headers);

                if (!empty($res) && $res['status'] == 200) {
                    $resData = json_decode($res['result'], true);
                    if ($resData['code'] == 1) {
                        $code = 1;
                        $msg = '短信验证码已成功发送';
                    }else {
                        $err = '短信验证码发送失败：' . $resData['message'];
                    }
                }else {
                    $err = '短信验证码发送失败，请稍后再试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //新用户注册
    public function actionCreateuser() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 5;   //最多 5 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';
        $shareUrl = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $friends_code = $this->post('friendscode', '');
            $cellphone = $this->post('username', '');
            $sms_code = $this->post('smscode', '');

            if (empty($friends_code) || empty($cellphone) || empty($sms_code)) {
                $err = "请填写注册邀请码、手机号码和短信验证码哦";
            }else if (Common::isCellphoneNumber($cellphone) == false) {
                $err = "手机号码格式错误，请填写正确的手机号码";
            }else if (Common::isFriendsCode($friends_code) == false) {
                $err = "邀请码格式错误，请填写邀请你的朋友的手机号码末 6 位，还可以加客服微信索取";
            }else if (Common::existFriendsCode($friends_code) == false) {
                $err = "邀请码不存在，请填写邀请你的朋友的手机号码末 6 位，或者加客服微信索取";
            }

            //验证短信验证码是否正确
            $mySmsCode = $this->getMySmsCode($cellphone);
            if (empty($mySmsCode) || $mySmsCode != $sms_code) {
                $err = "{$sms_code} 验证码已过期或错误，请检查是否输入正确";
            }

            if (empty($err)) {      //如果数据检查通过，尝试注册新用户
                $userDataDir = Common::getUserDataDir($cellphone);
                if (empty($userDataDir)) {
                    $newUser = Common::saveUserIntoSession($cellphone, $friends_code);
                    if (!empty($newUser)) {
                        Common::saveFriendsCode($cellphone, $friends_code);
                        Common::initUserData($cellphone, $friends_code);

                        //更新统计数据
                        $stats = TajianStats::init();
                        TajianStats::increase('user');
                        $saved = TajianStats::save();

                        $shareUrl = "/{$newUser['username']}/";
                        $msg = "注册完成，开始收藏你喜欢的视频吧，正在为你跳转到专属网址...";
                        $code = 1;
                    }else {
                        $err = '注册失败，请稍后再试';
                    }
                }else {
                    $username = Common::getMappedUsername($cellphone);
                    $shareUrl = "/{$username}/";
                    $msg = "已注册，正在为你跳转到专属网址...";
                    $code = 1;
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err', 'shareUrl'));
    }

    //用户登录
    public function actionLoginuser() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 5;   //最多 5 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';
        $shareUrl = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $cellphone = $this->post('username', '');
            $sms_code = $this->post('smscode', '');

            if (empty($cellphone) || empty($sms_code)) {
                $err = "请填写注册邀请码、手机号码和短信验证码哦";
            }else if (Common::isCellphoneNumber($cellphone) == false) {
                $err = "手机号码格式错误，请填写正确的手机号码";
            }else if (Common::getUserDataDir($cellphone) == false) {
                $err = "{$cellphone}还没注册哦，先去注册吧";
            }

            //验证短信验证码是否正确
            $mySmsCode = $this->getMySmsCode($cellphone);
            if (empty($mySmsCode) || $mySmsCode != $sms_code) {
                $err = "{$sms_code} 验证码已过期或错误，请检查是否输入正确";
            }

            if (empty($err)) {      //如果数据检查通过，尝试登录
                $newUser = Common::saveUserIntoSession($cellphone);
                if (!empty($newUser)) {
                    $shareUrl = "/{$newUser['username']}/my/";

                    $msg = "登录成功，开始收藏你喜欢的视频吧";
                    $code = 1;
                }else {
                    $err = '登录失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err', 'shareUrl'));
    }

    //昵称设置
    public function actionSetnickname() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 5;   //最多 5 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的昵称
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $nickname = $this->post('nickname', '');

            if (empty($nickname)) {
                $err = "请填写注册你的昵称";
            }else {
                $nickname = Common::cleanSpecialChars($nickname);
            }

            if (mb_strlen($nickname, 'utf-8') < 2 || mb_strlen($nickname, 'utf-8') > 5) {
                $err = "昵称至少 2 个汉字，最多 5 个汉字，请按规则填写";
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                $saved = $this->saveNickname($nickname);
                if (!empty($saved)) {
                    $msg = "昵称设置完成";
                    $code = 1;
                }else {
                    $err = '昵称设置失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //分类管理
    public function actionSavetags() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 10;   //最多 10 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的数据
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $tags = $this->post('tags', '');

            if (empty($tags)) {
                $err = "请至少保留一个分类";
            }else {
                $tags_ok = array();
                foreach($tags as $index => $tag) {
                    $tag = Common::cleanSpecialChars($tag);
                    if (!empty($tag) && !is_numeric($tag)) {
                        array_push($tags_ok, mb_substr($tag, 0, 15, 'utf-8'));
                    }
                }

                if (empty($tags_ok)) {
                    $err = "请按规则填写分类：2 - 15 个汉字、数字、英文字符";
                }else {
                    $tags = $tags_ok;
                }
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                //获取已有的分类
                $scanner = new DirScanner();
                $scanner->setWebRoot(FSC::$app['config']['content_directory']);
                $dirTree = $scanner->scan(__DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'], 3);

                $menus_sorted = array();        //Readme_sort.txt 说明文件内容，一级目录菜单从上到下的排序
                $readmeFile = $scanner->getDefaultReadme();
                if (!empty($readmeFile)) {
                    if (!empty($readmeFile['sort'])) {
                        $menus_sorted = explode("\n", $readmeFile['sort']);
                    }
                }

                //获取tags分类
                $tags_current = $this->getTags($dirTree);
                //排序
                if (!empty($menus_sorted) && !empty($tags_current)) {
                    $tags_current = $this->sortTags($menus_sorted, $tags_current);
                }
                //获取只包含分类名的数组
                $allTags = Html::getTagNames($tags_current);

                //保存
                $saved = $this->saveTags($tags, $allTags);
                if (!empty($saved)) {
                    $msg = "分类已保存";
                    $code = 1;
                }else {
                    $err = '分类保存失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //删除分类
    public function actionDeletetag() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 10;   //最多 10 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的数据
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $tag_to_delete = $this->post('tag', '');

            if (empty($tag_to_delete)) {
                $err = "参数错误，缺少tag传参";
            }else {
                $tag_to_delete = Common::cleanSpecialChars($tag_to_delete);
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                //保存
                $saved = $this->deleteTag($tag_to_delete);
                if (!empty($saved)) {
                    //更新统计数据
                    $stats = TajianStats::init();
                    TajianStats::decrease('tag');
                    $saved = TajianStats::save();

                    $msg = "分类已删除";
                    $code = 1;
                }else {
                    $err = '分类删除失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //添加分类
    public function actionAddtag() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 15;   //最多 15 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的数据
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $tag_to_add = $this->post('tag', '');

            if (empty($tag_to_add)) {
                $err = "参数错误，缺少tag传参";
            }else {
                $tag_to_add = Common::cleanSpecialChars($tag_to_add);
                $tagLen = mb_strlen($tag_to_add, 'utf-8');
                if ($tagLen < 2 || $tagLen > 15) {
                    $err = '分类名长度不符合规则，请填写 2 - 15 个汉字、数字、英文字符';
                }
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                //获取已有的分类
                $scanner = new DirScanner();
                $scanner->setWebRoot(FSC::$app['config']['content_directory']);
                $dirTree = $scanner->scan(__DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'], 3);

                //获取tags分类
                $tags_current = $this->getTags($dirTree);
                
                //获取只包含分类名的数组
                $allTags = Html::getTagNames($tags_current);
                
                //最多添加 50 个分类
                if (count($allTags) >= 50) {
                    $err = '最多添加 50 个分类，请合理规划视频分类哦';
                }else {
                    //保存
                    $saved = $this->addTag(ucfirst($tag_to_add));
                    if (!empty($saved)) {
                        //更新统计数据
                        $stats = TajianStats::init();
                        TajianStats::increase('tag');
                        $saved = TajianStats::save();

                        $msg = "分类已添加";
                        $code = 1;
                    }else {
                        $err = '添加分类失败，请稍后重试';
                    }
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    //视频管理：把视频从分类中删除、添加视频到某个分类、删除视频
    public function actionDeletefav() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 60;   //最多 60 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的数据
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $video_id = $this->post('id', '');
            $video_filename = $this->post('filename', '');

            if (empty($video_id) || empty($video_filename)) {
                $err = "参数错误，缺少id和filename传参";
            }else {
                $video_id = Common::cleanSpecialChars($video_id);
                $video_filename = Common::cleanSpecialChars($video_filename);
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                //获取已有的分类
                $scanner = new DirScanner();
                $scanner->setWebRoot(FSC::$app['config']['content_directory']);
                $dirTree = $scanner->scan(__DIR__ . '/../../../www/' . FSC::$app['config']['content_directory'], 3);

                //获取tags分类
                $tags_current = $this->getTags($dirTree);
                
                //获取当前视频的所属分类数组
                $myTags = Html::getFavsTags($video_filename, $tags_current);
                foreach ($myTags as $item) {
                    $this->deleteVideoFromTag($video_filename, $item);        //从分类中删除此视频
                }

                //删除此视频的所有文件
                $saved = $this->deleteVideoFiles($video_filename);
                if (!empty($saved)) {
                    //更新统计数据
                    $stats = TajianStats::init();
                    TajianStats::decrease('video');
                    $saved = TajianStats::save();


                    $msg = "视频已删除";
                    $code = 1;
                }else {
                    $err = '视频删除失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }

    public function actionUpdatefavstag() {
        $ip = $this->getUserIp();
        $check_time = 120;          //2 分钟内
        $max_time_in_minutes = 60;   //最多 60 次

        $isUserGotRequestLimit = $this->requestLimit($ip, $max_time_in_minutes, $check_time);
        if ($isUserGotRequestLimit) {
            $this->logError("Request limit got, ip: {$ip}");
            throw new Exception('Oops，操作太快了，请喝杯咖啡休息会吧...');
        }

        //只允许修改自己的数据
        $loginedUser = Common::getUserFromSession();
        if (empty($loginedUser['username'])) {
            throw new Exception('Oops，你还没登录哦');
        }else if (
            !empty(FSC::$app['config']['multipleUserUriParse'])
            && (empty(FSC::$app['user_id']) || FSC::$app['user_id'] != $loginedUser['username'])
        ) {
            throw new Exception('Oops，请求地址有误');
        }


        //返回给视图的变量
        $code = 0;
        $msg = '';
        $err = '';

        //用户提交的数据检查
        $postParams = $this->post();
        if (!empty($postParams)) {
            $video_id = $this->post('id', '');
            $video_filename = $this->post('filename', '');
            $tagName = $this->post('tag', '');
            $action = $this->post('do', 'remove');      //添加：add，移除：remove

            if (empty($video_id) || empty($video_filename) || empty($tagName)) {
                $err = "参数错误，缺少id、filename、tag传参";
            }else {
                $video_id = Common::cleanSpecialChars($video_id);
                $video_filename = Common::cleanSpecialChars($video_filename);
                $tagName = Common::cleanSpecialChars($tagName);
            }

            if (empty($err)) {      //如果数据检查通过，尝试保存
                $saved = false;

                if ($action == 'add') {
                    $saved = $this->saveVideoToTag($video_filename, $tagName);                    //添加视频到分类
                }else {
                    $saved = $this->deleteVideoFromTag($video_filename, $tagName);          //从分类中删除此视频
                }

                if ($saved !== false) {
                    $msg = "操作完成";
                    $code = 1;
                }else {
                    $err = '操作失败，请稍后重试';
                }
            }
        }

        return $this->renderJson(compact('code', 'msg', 'err'));
    }


}