mirror of https://github.com/helloxz/onenav.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
423 lines
13 KiB
423 lines
13 KiB
4 years ago
|
<?php
|
||
|
|
/**
|
||
|
|
* name:API核心类
|
||
|
|
* update:2020/12
|
||
|
|
* author:xiaoz<xiaoz93@outlook.com>
|
||
|
|
* blog:xiaoz.me
|
||
|
|
*/
|
||
|
|
class Api {
|
||
|
|
protected $db;
|
||
|
|
public function __construct($db){
|
||
|
|
$this->db = $db;
|
||
|
|
//返回json类型
|
||
|
|
header('Content-Type:application/json; charset=utf-8');
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* name:创建分类目录
|
||
|
|
*/
|
||
|
|
public function add_category($token,$name,$property = 0,$weight = 0,$description = ''){
|
||
|
|
$this->auth($token);
|
||
|
|
$data = [
|
||
|
|
'name' => $name,
|
||
|
|
'add_time' => time(),
|
||
|
|
'weight' => $weight,
|
||
|
|
'property' => $property,
|
||
|
|
'description' => $description
|
||
|
|
];
|
||
|
|
//插入分类目录
|
||
|
|
$this->db->insert("on_categorys",$data);
|
||
|
|
//返回ID
|
||
|
|
$id = $this->db->id();
|
||
|
|
//如果id为空（NULL），说明插入失败了，姑且认为是name重复导致
|
||
|
|
if( empty($id) ){
|
||
|
|
$this->err_msg(-1000,'Categorie already exist!');
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
//成功并返回json格式
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'id' => intval($id)
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 修改分类目录
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
public function edit_category($token,$id,$name,$property = 0,$weight = 0,$description = ''){
|
||
|
|
$this->auth($token);
|
||
|
|
//如果id为空
|
||
|
|
if( empty($id) ){
|
||
|
|
$this->err_msg(-1003,'The category ID cannot be empty!');
|
||
|
|
}
|
||
|
|
//如果分类名为空
|
||
|
|
elseif( empty($name) ){
|
||
|
|
$this->err_msg(-1004,'The category name cannot be empty!');
|
||
|
|
}
|
||
|
|
//更新数据库
|
||
|
|
else{
|
||
|
|
$data = [
|
||
|
|
'name' => $name,
|
||
|
|
'up_time' => time(),
|
||
|
|
'weight' => $weight,
|
||
|
|
'property' => $property,
|
||
|
|
'description' => $description
|
||
|
|
];
|
||
|
|
$re = $this->db->update('on_categorys',$data,[ 'id' => $id]);
|
||
|
|
//var_dump( $this->db->log() );
|
||
|
|
//获取影响行数
|
||
|
|
$row = $re->rowCount();
|
||
|
|
if($row) {
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => 'successful'
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$this->err_msg(-1005,'The category name already exists!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 删除分类目录
|
||
|
|
*/
|
||
|
|
public function del_category($token,$id) {
|
||
|
|
//验证授权
|
||
|
|
$this->auth($token);
|
||
|
|
//如果id为空
|
||
|
|
if( empty($id) ){
|
||
|
|
$this->err_msg(-1003,'The category ID cannot be empty!');
|
||
|
|
}
|
||
|
|
//如果分类目录下存在数据
|
||
|
|
$count = $this->db->count("on_links", [
|
||
|
|
"fid" => $id
|
||
|
|
]);
|
||
|
|
//如果分类目录下存在数据，则不允许删除
|
||
|
|
if($count > 0) {
|
||
|
|
$this->err_msg(-1006,'The category is not empty and cannot be deleted!');
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$data = $this->db->delete('on_categorys',[ 'id' => $id] );
|
||
|
|
//返回影响行数
|
||
|
|
$row = $data->rowCount();
|
||
|
|
if($row) {
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => 'successful'
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$this->err_msg(-1007,'The category delete failed!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* name:返回错误（json）
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
protected function err_msg($code,$err_msg){
|
||
|
|
$data = [
|
||
|
|
'code' => $code,
|
||
|
|
'err_msg' => $err_msg
|
||
|
|
];
|
||
|
|
//返回json类型
|
||
|
|
header('Content-Type:application/json; charset=utf-8');
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* name:验证方法
|
||
|
|
*/
|
||
|
|
protected function auth($token){
|
||
|
|
//计算正确的token：用户名 + TOKEN
|
||
|
|
$token_yes = md5(USER.TOKEN);
|
||
|
|
//如果token为空，则验证cookie
|
||
|
|
if(empty($token)) {
|
||
|
|
if( !$this->is_login() ) {
|
||
|
|
$this->err_msg(-1002,'Authorization failure!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else if($token != $token_yes){
|
||
|
|
$this->err_msg(-1002,'Authorization failure!');
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* name:添加链接
|
||
|
|
*/
|
||
|
|
public function add_link($token,$fid,$title,$url,$description = '',$weight = 0,$property = 0){
|
||
|
|
$this->auth($token);
|
||
|
|
$fid = intval($fid);
|
||
|
|
//检测链接是否合法
|
||
|
|
$this->check_link($fid,$title,$url);
|
||
|
|
//合并数据
|
||
|
|
$data = [
|
||
|
|
'fid' => $fid,
|
||
|
|
'title' => $title,
|
||
|
|
'url' => $url,
|
||
|
|
'description' => $description,
|
||
|
|
'add_time' => time(),
|
||
|
|
'weight' => $weight,
|
||
|
|
'property' => $property
|
||
|
|
];
|
||
|
|
//插入数据库
|
||
|
|
$re = $this->db->insert('on_links',$data);
|
||
|
|
//返回影响行数
|
||
|
|
$row = $re->rowCount();
|
||
|
|
//如果为真
|
||
|
|
if( $row ){
|
||
|
|
$id = $this->db->id();
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'id' => $id
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
//如果插入失败
|
||
|
|
else{
|
||
|
|
$this->err_msg(-1011,'The URL already exists!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* name:修改链接
|
||
|
|
*/
|
||
|
|
public function edit_link($token,$id,$fid,$title,$url,$description = '',$weight = 0,$property = 0){
|
||
|
|
$this->auth($token);
|
||
|
|
$fid = intval($fid);
|
||
|
|
//检测链接是否合法
|
||
|
|
$this->check_link($fid,$title,$url);
|
||
|
|
//查询ID是否存在
|
||
|
|
$count = $this->db->count('on_links',[ 'id' => $id]);
|
||
|
|
//如果id不存在
|
||
|
|
if( (empty($id)) || ($count == false) ) {
|
||
|
|
$this->err_msg(-1010,'link id not exists!');
|
||
|
|
}
|
||
|
|
//合并数据
|
||
|
|
$data = [
|
||
|
|
'fid' => $fid,
|
||
|
|
'title' => $title,
|
||
|
|
'url' => $url,
|
||
|
|
'description' => $description,
|
||
|
|
'up_time' => time(),
|
||
|
|
'weight' => $weight,
|
||
|
|
'property' => $property
|
||
|
|
];
|
||
|
|
//插入数据库
|
||
|
|
$re = $this->db->update('on_links',$data,[ 'id' => $id]);
|
||
|
|
//返回影响行数
|
||
|
|
$row = $re->rowCount();
|
||
|
|
//如果为真
|
||
|
|
if( $row ){
|
||
|
|
$id = $this->db->id();
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => 'successful'
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
//如果插入失败
|
||
|
|
else{
|
||
|
|
$this->err_msg(-1011,'The URL already exists!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 删除链接
|
||
|
|
*/
|
||
|
|
public function del_link($token,$id){
|
||
|
|
//验证token是否合法
|
||
|
|
$this->auth($token);
|
||
|
|
//查询ID是否存在
|
||
|
|
$count = $this->db->count('on_links',[ 'id' => $id]);
|
||
|
|
//如果id不存在
|
||
|
|
if( (empty($id)) || ($count == false) ) {
|
||
|
|
$this->err_msg(-1010,'link id not exists!');
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$re = $this->db->delete('on_links',[ 'id' => $id] );
|
||
|
|
if($re) {
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => 'successful'
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$this->err_msg(-1010,'link id not exists!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 验证链接合法性
|
||
|
|
*/
|
||
|
|
protected function check_link($fid,$title,$url){
|
||
|
|
//如果父及（分类）ID不存在
|
||
|
|
if( empty($fid )) {
|
||
|
|
$this->err_msg(-1007,'The category id(fid) not exist!');
|
||
|
|
}
|
||
|
|
//如果父及ID不存在数据库中
|
||
|
|
//验证分类目录是否存在
|
||
|
|
$count = $this->db->count("on_categorys", [
|
||
|
|
"id" => $fid
|
||
|
|
]);
|
||
|
|
if ( empty($count) ){
|
||
|
|
$this->err_msg(-1007,'The category not exist!');
|
||
|
|
}
|
||
|
|
//如果链接标题为空
|
||
|
|
if( empty($title) ){
|
||
|
|
$this->err_msg(-1008,'The title cannot be empty!');
|
||
|
|
}
|
||
|
|
//链接不能为空
|
||
|
|
if( empty($url) ){
|
||
|
|
$this->err_msg(-1009,'URL cannot be empty!');
|
||
|
|
}
|
||
|
|
//链接不合法
|
||
|
|
if( !filter_var($url, FILTER_VALIDATE_URL) ) {
|
||
|
|
$this->err_msg(-1010,'URL is not valid!');
|
||
|
|
}
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 查询分类目录
|
||
|
|
*/
|
||
|
|
public function category_list($page,$limit){
|
||
|
|
$offset = ($page - 1) * $limit;
|
||
|
|
//如果成功登录，则查询所有
|
||
|
|
if( $this->is_login() ){
|
||
|
|
$sql = "SELECT * FROM on_categorys ORDER BY weight DESC,id DESC LIMIT {$limit} OFFSET {$offset}";
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
$sql = "SELECT * FROM on_categorys WHERE property = 0 ORDER BY weight DESC,id DESC LIMIT {$limit} OFFSET {$offset}";
|
||
|
|
}
|
||
|
|
//统计总数
|
||
|
|
$count = $this->db->count('on_categorys','*');
|
||
|
|
//原生查询
|
||
|
|
$datas = $this->db->query($sql)->fetchAll();
|
||
|
|
$datas = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => '',
|
||
|
|
'count' => $count,
|
||
|
|
'data' => $datas
|
||
|
|
];
|
||
|
|
exit(json_encode($datas));
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 查询链接
|
||
|
|
*/
|
||
|
|
public function link_list($page,$limit,$token = ''){
|
||
|
|
$offset = ($page - 1) * $limit;
|
||
|
|
//如果成功登录，但token为空
|
||
|
|
if( ($this->is_login()) && (empty($token)) ){
|
||
|
|
//统计总数
|
||
|
|
$count = $this->db->count('on_links','*');
|
||
|
|
$sql = "SELECT *,(SELECT name FROM on_categorys WHERE id = on_links.fid) AS category_name FROM on_links ORDER BY weight DESC,id DESC LIMIT {$limit} OFFSET {$offset}";
|
||
|
|
}
|
||
|
|
|
||
|
|
//如果token验证通过
|
||
|
|
elseif( (!empty($token)) && ($this->auth($token)) ) {
|
||
|
|
//统计总数
|
||
|
|
$count = $this->db->count('on_links','*');
|
||
|
|
$sql = "SELECT *,(SELECT name FROM on_categorys WHERE id = on_links.fid) AS category_name FROM on_links ORDER BY weight DESC,id DESC LIMIT {$limit} OFFSET {$offset}";
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
//统计总数
|
||
|
|
$count = $this->db->count('on_links','*',[ 'property' => 0 ]);
|
||
|
|
$sql = "SELECT *,(SELECT name FROM on_categorys WHERE id = on_links.fid) AS category_name FROM on_links WHERE property = 0 ORDER BY weight DESC,id DESC LIMIT {$limit} OFFSET {$offset}";
|
||
|
|
}
|
||
|
|
|
||
|
|
//原生查询
|
||
|
|
$datas = $this->db->query($sql)->fetchAll();
|
||
|
|
$datas = [
|
||
|
|
'code' => 0,
|
||
|
|
'msg' => '',
|
||
|
|
'count' => $count,
|
||
|
|
'data' => $datas
|
||
|
|
];
|
||
|
|
exit(json_encode($datas));
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 验证是否登录
|
||
|
|
*/
|
||
|
|
protected function is_login(){
|
||
|
|
$key = md5(USER.PASSWORD.$this->getIP().'onenav');
|
||
|
|
//获取session
|
||
|
|
$session = $_COOKIE['key'];
|
||
|
|
//如果已经成功登录
|
||
|
|
if($session == $key) {
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 获取链接信息
|
||
|
|
*/
|
||
|
|
public function get_link_info($token,$url){
|
||
|
|
$this->auth($token);
|
||
|
|
//检查链接是否合法
|
||
|
|
//链接不合法
|
||
|
|
if( !filter_var($url, FILTER_VALIDATE_URL) ) {
|
||
|
|
$this->err_msg(-1010,'URL is not valid!');
|
||
|
|
}
|
||
|
|
//获取网站标题
|
||
|
|
$c = curl_init();
|
||
|
|
curl_setopt($c, CURLOPT_URL, $url);
|
||
|
|
curl_setopt($c, CURLOPT_RETURNTRANSFER, 1);
|
||
|
|
curl_setopt($c, CURLOPT_SSL_VERIFYPEER, false);
|
||
|
|
curl_setopt($c, CURLOPT_SSL_VERIFYHOST, false);
|
||
|
|
//设置超时时间
|
||
|
|
curl_setopt($c , CURLOPT_TIMEOUT, 10);
|
||
|
|
$data = curl_exec($c);
|
||
|
|
curl_close($c);
|
||
|
|
$pos = strpos($data,'utf-8');
|
||
|
|
if($pos===false){$data = iconv("gbk","utf-8",$data);}
|
||
|
|
preg_match("/<title>(.*)<\/title>/i",$data, $title);
|
||
|
|
|
||
|
|
$link['title'] = $title[1];
|
||
|
|
|
||
|
|
//获取网站描述
|
||
|
|
$tags = get_meta_tags($url);
|
||
|
|
$link['description'] = $tags['description'];
|
||
|
|
|
||
|
|
$data = [
|
||
|
|
'code' => 0,
|
||
|
|
'data' => $link
|
||
|
|
];
|
||
|
|
exit(json_encode($data));
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* 获取IP
|
||
|
|
*/
|
||
|
|
//获取访客IP
|
||
|
|
protected function getIP() {
|
||
|
|
if (getenv('HTTP_CLIENT_IP')) {
|
||
|
|
$ip = getenv('HTTP_CLIENT_IP');
|
||
|
|
}
|
||
|
|
elseif (getenv('HTTP_X_FORWARDED_FOR')) {
|
||
|
|
$ip = getenv('HTTP_X_FORWARDED_FOR');
|
||
|
|
}
|
||
|
|
elseif (getenv('HTTP_X_FORWARDED')) {
|
||
|
|
$ip = getenv('HTTP_X_FORWARDED');
|
||
|
|
}
|
||
|
|
elseif (getenv('HTTP_FORWARDED_FOR')) {
|
||
|
|
$ip = getenv('HTTP_FORWARDED_FOR');
|
||
|
|
}
|
||
|
|
elseif (getenv('HTTP_FORWARDED')) {
|
||
|
|
$ip = getenv('HTTP_FORWARDED');
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
$ip = $_SERVER['REMOTE_ADDR'];
|
||
|
|
}
|
||
|
|
return $ip;
|
||
|
|
}
|
||
|
|
|
||
|
|
//
|
||
|
|
}
|
||
|
|
|