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')); } //删除当前用户的缓存数据 protected function cleanAllFilesCache() { if (empty(FSC::$app['user_id'])) {return false;} $prefix = FSC::$app['user_id']; $cacheKey = "{$prefix}_allFilesTree"; Common::cleanFileCache($cacheKey); $cacheKey = "{$prefix}_allFilesData"; Common::cleanFileCache($cacheKey); return true; } /* * 参数: * content: 从抖音或其它平台复制出来的视频分享内容,或者视频网址 * title: 视频标题 * tag: 分类名称 * tagid: 分类id * 其中title、tag和tagid为可选值。 * 针对任意网址增加权限控制,只允许特殊用户可以使用。 */ public function actionAddfav() { $ip = $this->getUserIp(); $check_key = "addfav_{$ip}"; $check_time = 60; //1 分钟内 $max_time_in_minutes = 10; //最多 10 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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 = Common::getShareUrlFromContent($content); $platform = Html::getShareVideosPlatform($shareUrl); if (!in_array($platform, FSC::$app['config']['tajian']['supportedPlatforms'])) { $code = 0; $err = '目前只支持抖音、快手、西瓜视频和Bilibili的分享网址哦!'; } //支持平台之外的网址分享权限控制 if ($platform == '其它' && Common::isVipUser($loginedUser) == false) { $code = 0; $err = '你还不是VIP哦,不能分享支持平台之外的网址哦!如需开通特权,请联系客服邮箱。'; } $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 = '保存完成,系统开始自动处理,1 - 3 分钟后刷新就能看到新添加的收藏了。'; if (!$done) { $msg = ''; $err = '收藏保存失败,请确认分享网址格式正确并稍后重试!'; $code = 0; }else { //更新统计数据 $stats = TajianStats::init(); TajianStats::increase('video'); $saved = TajianStats::save(); //清空缓存 $this->cleanAllFilesCache(); } } return $this->renderJson(compact('code', 'msg', 'err')); } protected function getVideoId($url) { return md5($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']; $addTaskRes = $this->addHeroUnionTask($shareUrl, $heroUnionConfig['supportedPlatforms'][$platformName]); if (empty($addTaskRes) || empty($addTaskRes['code'])) { $this->logError("Add herounion task failed: " . json_encode($addTaskRes)); $done = false; } } } 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 ? json_decode($res['result'], true) : 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 = <<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'])) { //如果任务成功抓取到数据 //清空缓存 $this->cleanAllFilesCache(); $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_key = "sendsmscode_{$ip}"; $check_time = 300; //5 分钟内 $max_time_in_minutes = 3; //最多 3 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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_key = "createuser_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 5; //最多 5 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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_key = "login_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 5; //最多 5 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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_key = "setnickname_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 5; //最多 5 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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_key = "savetags_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 10; //最多 10 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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)) { //清空缓存 $this->cleanAllFilesCache(); $msg = "分类已保存"; $code = 1; }else { $err = '分类保存失败,请稍后重试'; } } } return $this->renderJson(compact('code', 'msg', 'err')); } //删除分类 public function actionDeletetag() { $ip = $this->getUserIp(); $check_key = "deltag_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 10; //最多 10 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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(); //清空缓存 $this->cleanAllFilesCache(); $msg = "分类已删除"; $code = 1; }else { $err = '分类删除失败,请稍后重试'; } } } return $this->renderJson(compact('code', 'msg', 'err')); } //添加分类 public function actionAddtag() { $ip = $this->getUserIp(); $check_key = "addtag_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 15; //最多 15 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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(); //清空缓存 $this->cleanAllFilesCache(); $msg = "分类已添加"; $code = 1; }else { $err = '添加分类失败,请稍后重试'; } } } } return $this->renderJson(compact('code', 'msg', 'err')); } //视频管理:把视频从分类中删除、添加视频到某个分类、删除视频 public function actionDeletefav() { $ip = $this->getUserIp(); $check_key = "delfav_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 60; //最多 60 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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(); //清空缓存 $this->cleanAllFilesCache(); $msg = "视频已删除"; $code = 1; }else { $err = '视频删除失败,请稍后重试'; } } } return $this->renderJson(compact('code', 'msg', 'err')); } public function actionUpdatefavstag() { $ip = $this->getUserIp(); $check_key = "updatefavtag_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 60; //最多 60 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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) { //清空缓存 $this->cleanAllFilesCache(); $msg = "操作完成"; $code = 1; }else { $err = '操作失败,请稍后重试'; } } } return $this->renderJson(compact('code', 'msg', 'err')); } //创建收藏夹 public function actionCreatedir() { $ip = $this->getUserIp(); $check_key = "createdir_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 30; //最多 30 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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,请求地址有误'); } //VIP身份判断 $isVipUser = Common::isVipUser($loginedUser); //返回给视图的变量 $code = 0; $msg = ''; $err = ''; //用户提交的数据检查 $postParams = $this->post(); if (!empty($postParams)) { $new_nickname = $this->post('nickname', ''); if (empty($new_nickname)) { $err = "请填写新账号的昵称"; }else { $new_nickname = Common::cleanSpecialChars($new_nickname); } if (empty($err)) { //如果数据检查通过,尝试保存 //已经创建的收藏夹数量检查 //普通用户:每个手机号最多创建 3 个收藏夹 $max_num = !empty(FSC::$app['config']['tajian']['max_dir_num']) ? FSC::$app['config']['tajian']['max_dir_num'] : 3; //VIP用户:每个手机号最多创建 20 个收藏夹 if ($isVipUser) { //vip用户判断 $max_num = !empty(FSC::$app['config']['tajian']['max_dir_num_vip']) ? FSC::$app['config']['tajian']['max_dir_num_vip'] : 20; } $myDirs = Common::getMyDirs($loginedUser['cellphone'], $loginedUser['username']); if (count($myDirs) >= $max_num) { $err = "你已经创建了 {$max_num} 个账号,已达到最大数量"; }else { $new_dir = Common::getNewFavDir($loginedUser['cellphone']); $saved = Common::createNewFavDir($loginedUser['cellphone'], $loginedUser['username'], $new_dir, $new_nickname); if ($saved !== false) { //清空缓存 $this->cleanAllFilesCache(); $msg = "新账号创建完成"; $code = 1; }else { $err = "{$new_dir} 创建失败,请稍后重试"; } } } } return $this->renderJson(compact('code', 'msg', 'err')); } //账号共享接口 public function actionSharedir() { $ip = $this->getUserIp(); $check_key = "sharedir_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 10; //最多 10 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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)) { $friends_cellphone = $this->post('cellphone', ''); $share_dir = $this->post('dir', ''); if (empty($friends_cellphone) || Common::isCellphoneNumber($friends_cellphone) == false) { $err = "请填写正确的手机号码"; }else if (empty($share_dir)) { $err = "请选择要共享的账号"; }else if ($friends_cellphone == $loginedUser['cellphone']) { $err = "只能共享给朋友,不能共享给自己哦"; } //只能共享属于自己的账号 if (empty($err)) { $isMine = Common::isMyFavDir($loginedUser['cellphone'], $loginedUser['username'], $share_dir); if (empty($isMine)) { $err = '只能共享自己的账号,朋友共享给你的账号不能再共享给他人'; }else { //检查朋友的账号是否存在 $friend_exist = Common::getUserDataDir($friends_cellphone, $loginedUser['username']); if (empty($friend_exist)) { $err = "{$friends_cellphone} 还没注册哦,请朋友先注册吧"; } } } if (empty($err)) { //如果数据检查通过,尝试保存 $saved = Common::saveUserDirMap($friends_cellphone, $loginedUser['username'], $share_dir); if ($saved !== false) { //保存共享记录 Common::saveMyShareDirs($loginedUser['cellphone'], $loginedUser['username'], $friends_cellphone, $share_dir); $msg = "账号共享完成"; $code = 1; }else { $err = "账号共享失败,请稍后重试"; } } } return $this->renderJson(compact('code', 'msg', 'err')); } //删除一个账号共享 public function actionDelsharedir() { $ip = $this->getUserIp(); $check_key = "delsharedir_{$ip}"; $check_time = 120; //2 分钟内 $max_time_in_minutes = 10; //最多 10 次 $isUserGotRequestLimit = $this->requestLimit($check_key, $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)) { $friends_cellphone = $this->post('cellphone', ''); $share_dir = $this->post('dir', ''); if (empty($friends_cellphone) || Common::isCellphoneNumber($friends_cellphone) == false) { $err = "请填写正确的手机号码"; }else if (empty($share_dir)) { $err = "请选择要取消共享的账号"; }else if ($friends_cellphone == $loginedUser['cellphone']) { $err = "不能取消自己的账号哦"; } //只能取消属于自己的账号 if (empty($err)) { $isMine = Common::isMyFavDir($loginedUser['cellphone'], $loginedUser['username'], $share_dir); if (empty($isMine)) { $err = '只能取消共享自己的账号'; }else { //检查朋友的账号是否存在 $friend_exist = Common::getUserDataDir($friends_cellphone, $loginedUser['username']); if (empty($friend_exist)) { $err = "{$friends_cellphone} 还没注册哦,请朋友先注册吧"; } } } if (empty($err)) { //如果数据检查通过,尝试保存 $saved = Common::deleteFromMyShareDirs($loginedUser['cellphone'], $loginedUser['username'], $friends_cellphone, $share_dir); if ($saved !== false) { //删除共享给朋友的,修改朋友的账号映射关系 Common::deleteSharedFavDir($friends_cellphone, $loginedUser['username'], $share_dir); $msg = "取消账号共享完成"; $code = 1; }else { $err = "取消账号共享失败,请稍后重试"; } } } return $this->renderJson(compact('code', 'msg', 'err')); } }