<?php
/**
 * 抓取微博评论任务
 * @package crontab
 */

include_once(dirname(dirname(dirname(__FILE__))) . "/library/publicBase.php");

class addSpiderWeiboCommentTask {
    public function __construct() {
        $page_size = 100;

        $condition['uid'] = WEIBO_USER_ZHANG;
        $condition['spider_comment_status'] = SPIDER_COMMENT_STATUS_NO;

        $obj = new mWeibo();
        $rdobj = $obj->initRedis();
        if($rdobj->llen(_RQ_SPIDER_WEIBO_COMMENT)+0 > 0) return true;

        $j = 0;
        for($page_num=1;$page_num<=1;$page_num++) {
            $weibo_data = $obj->getWeiboList($condition, $page_num, $page_size);
            if(empty($weibo_data)) break;

            foreach($weibo_data as $data) {
                $pdata['weibo_id'] = $data['id'];
                $pdata['max_id'] = 0;

                if ($rdobj->sIsMember(_RS_SPIDER_WEIBO_COMMENT, $data['id'])) continue;
                ++$j;
                $rdobj->lpush(_RQ_SPIDER_WEIBO_COMMENT, json_encode($pdata));
                $rdobj->sAdd(_RS_SPIDER_WEIBO_COMMENT, $data['id']);
            }
        }

        if($j > 0) $obj->writeLog(ZHISHIKU_SPIDER_LOG, ZHISHIKU_SPIDER_COMMENT, '本次加入任务数:'.$j);

        return true;
    }
}

new addSpiderWeiboCommentTask();