Action.php

<?php
if (!defined('__TYPECHO_ROOT_DIR__')) exit;

// header('Access-Control-Allow-Origin: *');

class JSON_Action extends Typecho_Widget implements Widget_Interface_Do {
   
    private $db;
    private $res;

    const LACK_PARAMETER = "Not found";
    
    public function __construct($request, $response, $params = NULL) {
        parent::__construct($request, $response, $params);

        $this->db = Typecho_Db::get();
        $this->res = new Typecho_Response();


        if(method_exists($this, $this->request->type))
            call_user_func(array($this, $this->request->type));
        else $this->defaults();
    }
    
    private function defaults() {
        $this->export(null);
    }
    private function count() {
        $select =  $this->db->select("COUNT(*) AS counts")
            ->from('table.contents')
            ->where('type = ?', 'post')
            ->where('status = ?','publish')
            ->where('created < ?', time());
        $res = $this->db->fetchRow($select);
        return $this->export($res);

    }
    //文章参数 pageSize, page, authorId, created, cid, category, commentsNumMax, commentsNumMin, allowComment
    private function posts() {
        $pageSize = (int) self::GET('pageSize', 1000);
        $page = (int) self::GET('page', 1);
        $authorId = self::GET('authorId', 0);
        $offset = $pageSize * ( $page - 1 );
        
        $select = $this->db->select('cid', 'title', 'created', 'type', 'slug', 'text', 'authorId')->from('table.contents')
            ->where('type = ?', 'post')
            ->where('status = ?', 'publish')
            ->where('created < ?', time())
            ->order('table.contents.created', Typecho_Db::SORT_DESC)
            ->offset($offset)
            ->limit($pageSize);
        // 根据cid偏移获取文章
        if(isset($_GET['cid'])) {
            $cid = self::GET('cid');
            $select->where('cid > ?', $cid);
        } 
        // 根据时间偏移获取文章
        if(isset($_GET['created'])) {
            $created = self::GET('created');
            $select->where('created > ?', $created);
        }
        // 根据分类或标签获取文章
        if(isset($_GET['category']) || isset($_GET['tag'])) {
            $name = isset($_GET['category']) ? $_GET['category'] : $_GET['tag'];
            $resource = $this->db->fetchAll(
                $this->db->select('cid')->from('table.relationships')
                ->join('table.metas', 'table.metas.mid = table.relationships.mid', Typecho_Db::LEFT_JOIN)
                ->where('slug = ?', $name)
            ); 
            $cids = array();
            foreach($resource as $item) $cids[] = $item['cid'];
            $select->where('cid IN ?', $cids);
        }
        // 是否限制作者
        if($authorId) $select->where('authorId = ?', $authorId);
        //是否限制评论数
        if(isset($_GET['commentsNumMax'])) {
            $commentsNumMax = self::GET('commentsNumMax');
            $select->where('commentsNum < ?', $commentsNumMax);
        }
        if(isset($_GET['commentsNumMin'])) {
            $commentsNumMin = self::GET('commentsNumMin');
            $select->where('commentsNum > ?', $commentsNumMin);
        }
        //限制获取是否允许评论的文章
        if(isset($_GET['allowComment'])) {
            $allowComment = self::GET('allowComment');
            $select->where('allowComment = ?', $allowComment);
        }
        $posts = $this->db->fetchAll($select);
        $result = array();
        foreach($posts as $post) {
            $post = $this->widget("Widget_Abstract_Contents")->push($post);
            $post['author'] = $this->db->fetchAll($this->db->select('uid', 'name', 'mail', 'url', 'screenName')->from('table.users')->where('uid = ?', $post['authorId']));
            $post['tag'] = $this->db->fetchAll($this->db->select('name')->from('table.metas')
			->join('table.relationships', 'table.metas.mid = table.relationships.mid', Typecho_DB::LEFT_JOIN)
			->where('table.relationships.cid = ?', $post['cid'])
			->where('table.metas.type = ?', 'tag'));
            $fields=$this->db->fetchAll($this->db->select('name','str_value')->from('table.fields')->where('cid = ?', $post['cid']))?$this->db->fetchAll($this->db->select('name','str_value')->from('table.fields')->where('cid = ?', $post['cid'])):array(array("name"=>"null","str_value"=>"https://i0.hdslb.com/bfs/article/a2ae2ed735a899ff319a6112c8de60512ad04d11.jpg@942w_590h_progressive.jpg"));
            foreach($fields as $field) {
            $newfields[$field['name']]=$field['str_value'];
            }
            $post['fields'] = $newfields;
            $result[] = $post;
        }
        $this->export($result);
    }
    //页面参数 content
    private function pageList() {
        $content = self::GET('content', false);

        $this->widget('Widget_Contents_Page_List')->to($pages);
        $pageList = array();
        while($pages->next()) {
            $page = array(
                "title" => $pages->title,
                "slug" => $pages->slug,
                "permalink" => $pages->permalink
            );
            if($content) {
                $page['content'] = $pages->text;
                $page['commentsNum'] = $pages->commentsNum;
            }
            $pageList[] = $page;
        }
        $this->export($pageList);
    }
    //单篇参数 cid, slug
    private function single() {
        if(!isset($_GET['cid']) && !isset($_GET['slug']))
            $this->export(self::LACK_PARAMETER, 404);

        $select = $this->db->select('cid', 'title', 'created', 'type', 'slug', 'text')->from('table.contents');
        if(isset($_GET['cid'])) $select->where('cid = ?', $_GET['cid']);
        if(isset($_GET['slug'])) $select->where('slug = ?', $_GET['slug']);
        $post = $this->db->fetchRow($select);
        $post = $this->widget("Widget_Abstract_Contents")->push($post);
        
        $this->export($post);
    }
    private function post() {
        $this->single();
    }
    private function page() {
        $this->single();
    }
    //相关文章参数 authorId, cid
    private function relatedPosts() {
        if(!isset($_GET['authorId']) && !isset($_GET['cid'])) {
            $this->export(self::LACK_PARAMETER, 404);
        }

        $authorId = self::GET('authorId');
        $limit = self::GET('limit', 5);
        $type = self::GET('type');
        $cid = self::GET('cid');
        $parameter = http_build_query(compact("authorId", "limit", "type", "cid"));

        $this->widget("Widget_Contents_Related_Author", $parameter)->to($posts);
        $relatedPosts = array();
        while($posts->next()) {
            $relatedPosts[] = array(
                "title" => $posts->title,
                "text" => $posts->text,
                "created" => $posts->created,
                "permalink" => $posts->permalink,
                "author" => $posts->author
            );
        }
        $this->export($relatedPosts);
    }
    //最近文章参数 pageSize
    private function recentPost() {
        $pageSize = self::GET('pageSize', 10);

        $this->widget("Widget_Contents_Post_Recent", "pageSize={$pageSize}")->to($post);
        $recentPost = array();
        while($post->next()) {
            $recentPost[] = array(
                "cid" => $post->cid,
                "title" => $post->title,
                "permalink" => $post->permalink
            );
        }
        $this->export($recentPost);
    }
    //评论参数 pageSize, parentId, ignoreAuthor, showCommentOnly
    private function recentComments() {
        $pageSize = self::GET('pageSize', 10);
        $parentId = self::GET('parentId', 0);
        $ignoreAuthor = self::GET('ignoreAuthor', false);
        $showCommentOnly = self::GET('showCommentOnly', false);
        $parameter = http_build_query(compact("pageSize", "parentId", "ignoreAuthor", "showCommentOnly"));

        $this->widget("Widget_Comments_Recent", $parameter)->to($comments);
        $recentComments = array();
        while($comments->next()) {
            $recentComments[] = array(
                "permalink" => $comments->permalink,
                "authorId" => $comments->authorId,
                "ownerId" => $comments->ownerId,
                "created" => $comments->created,
                "author" => $comments->author,
                "parent" => $comments->parent,
                "agent" => $comments->agent,
                "coid" => $comments->coid,
                "mail" => $comments->mail,
                "type" => $comments->type,
                "text" => $comments->text,
                "url" => $comments->url,
                "cid" => $comments->cid,
                "ip" => $comments->ip
            );
        }
        $this->export($recentComments);
    }
    //分类参数 ignore, childMode
    private function categoryList() {
        $ignores = explode(',', self::GET('ignore'));
        $childMode = self::GET('childMode', false);

        $this->widget("Widget_Metas_Category_List")->to($category);
        $categoryList = array();
        if($childMode) $parent = array();
        while($category->next()) {
            if(in_array($category->mid, $ignores)) continue;

            $cate = array(
                "name" => $category->name,
                "slug" => $category->slug,
                "count" => $category->count,
                "permalink" => $category->permalink
            );
            if($childMode) {
                $mid = $category->mid;
                $parentId = $category->parent;
                if($parentId) {
                    $parent[$parentId]['child'][] = $cate;
                } else {
                    $parent[$mid] = isset($parent[$mid]) ? array_merge($parent[$mid], $cate) : $cate;
                }
            } else $categoryList[] = $cate;
        }
        if($childMode) $categoryList = array_values($parent);
        $this->export($categoryList);
    }
    //标签参数 sort, ignoreZeroCount, desc, limit
    private function tagCloud() {
        $sort = self::GET('sort', 'count');
        $ignoreZeroCount = self::GET('ignoreZeroCount', false);
        $desc = self::GET('desc', true);
        $limit = self::GET('limit', 0);
        $tagCloud = array();
        $this->widget("Widget_Metas_Tag_Cloud", "sort={$sort}&ignoreZeroCount={$ignoreZeroCount}&desc={$desc}&limit={$limit}")->to($tags);
        while($tags->next()) {
            $tagCloud[] = array(
                "name" => $tags->name,
                "count" => $tags->count,
                "permalink" => $tags->permalink
            );
        }
        $this->export($tagCloud);
    }
    //归档参数 format, type, limit
    private function archive() {
        $format = self::GET('format', 'Y-m');
        $type = self::GET('type', 'month');
        $limit = self::GET('limit', 0);

        $select = $this->db->select('created')->from('table.contents')
        ->where('type = ?', 'post')
        ->where('table.contents.status = ?', 'publish')
        ->where('table.contents.created < ?', time())
        ->order('table.contents.created', Typecho_Db::SORT_DESC);

        $resource = $this->db->query($select);
        $offset = 0;
        $result = array();
        while($post = $this->db->fetchRow($resource)) {
            $timeStamp = $post['created'] + $offset;
            $date = date($format, $timeStamp);
            if(isset($result[$date])) {
                $result[$date]['count'] ++;
            } else {
                $result[$date]['year'] = date('Y', $timeStamp);
                $result[$date]['month'] = date('m', $timeStamp);
                $result[$date]['day'] = date('d', $timeStamp);
                $result[$date]['date'] = $date;
                $result[$date]['count'] = 1;
            }
        }

        if($limit>0) $result = array_slice($result, 0, $limit);
        foreach($result as &$row) {
            $row['permalink'] = Typecho_Router::url('archive_'.$type, $row, $this->widget('Widget_Options')->index);
        }

        $this->export($result);
    }
/**
    //用户参数 user
    private function info() {
        $user = self::GET('user', 0);

        $arr = array("theme", "charset","contentType","gzip","generator","title","description","keywords","rewrite","frontPage","frontArchive","commentsRequireMail","commentsWhite");
        $select = $this->db->select()->from('table.options')->where("user = ?", $user);
        foreach($arr as $name) $select->orWhere("name = ?", $name);
        $resource = $this->db->fetchAll($select);
        
        $result = array();
        foreach($resource as $option) $result[$option['name']] = $option['value'];


        $this->export($result);
    }
    //系统升级接口(未测试)
    private function upgrade() {
        $generator = $this->widget("Widget_Options")->generator;
        $generator = explode(' ', $generator);
        $now = $generator[1];

        $curl = curl_init("https://github.com/typecho/typecho/releases");
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        $github = curl_exec($curl);
        curl_close($curl);

        $page = explode("<h1 class=\"release-title\">", $github);
        $page = explode("</h1>", $page[1]);
        $page = explode(">", $page[0]);
        $page = explode("<", $page[1]);
        $page = explode(" ", $page[0]);
        $latest = str_replace(array("(", ")"), array("/", ""), $page[1]);

        if($latest>=$now) {
            $download = explode("/releases/download", $github);
            $download = explode("\"", $download[1]);
            $url = "https://github.com/typecho/typecho/releases/download".$download[0];
            $this->update($url);
        } else $this->export("You are now in the latest version($now)!");
    }
    private function update($url) {
        set_time_limit(0);
        $curl = curl_init($url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        $result = curl_exec($curl);
        curl_close($curl);

        $result = explode("https", $result);
        $result = explode("\"", $result[1]);
        $downloadUrl = "https".$result[0];

        $curl = curl_init($downloadUrl);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($curl, CURLOPT_REFERER, "https://github.com");
        curl_exec($curl);
        curl_close($curl);
    }
*/
    public function export($data = array(), $status = 200) {
        $this->res->throwJson(array('status'=>$status, 'data'=>$data));
        exit();
    }
    public static function GET($key, $default = '') {
        return isset($_GET[$key]) ? $_GET[$key] : $default;
    }
    public function action() {
        $this->on($this->request);
    }
}
?>