php/www/protected/commands/SearchSyncCommand.php

<?php
/**
 * 生成云搜数据源
 * @author   >
 */
class SearchSyncCommand extends CConsoleCommand{
    public function run($args) {
        error_reporting(E_ALL);
        ini_set('memory_limit', '512M');
        ignore_user_abort(true);
        set_time_limit(0);
        $criteria = new EMongoCriteria();
        // $criteria->status('==',1);
        $cursor = RUser::model()->findAll($criteria);
        $i=1;
        $docs_to_upload = array();
        foreach ($cursor as $user) {
            $i++;
            if($i < 294001){
                continue;
            }
            if($i%100 == 0){
                $result = Service::factory('SearchService')->addUser($docs_to_upload);
                var_dump($result);
                sleep(5);
                $docs_to_upload = array();
            }
            $item = array();
            $item['cmd'] = 'ADD';
            //添加文档内容
            $item["fields"] = array(
                                    'id'=>(string)$user->_id,
                                    "user_name" => $user->user_name,
                                    "status" => $user->status,
                                );
            $docs_to_upload[] = $item;
        }

        // // $end_time = strtotime(date('Y-m-d'));
        // // $start_time = $end_time - 86400*7;
        // $criteria = new EMongoCriteria();
        // // $criteria->time('>=',$start_time);
        // // $criteria->time('<',$end_time);
        // $criteria->status('==',1);
        // $cursor = Topic::model()->findAll($criteria);
        // $i=1;
        // $docs_to_upload = array();
        // foreach ($cursor as $topic) {
        //     $i++;
        //     if($i%300 == 0){
        //         $result = Service::factory('SearchService')->addTopic($docs_to_upload);
        //         var_dump($result);
        //         sleep(5);
        //         $docs_to_upload = array();
        //     }
        //     $item = array();
        //     $item['cmd'] = 'update';
        //     //添加文档内容
        //     $item["fields"] = array(
        //                             'id'=>(string)$topic->_id,
        //                             "content" => $topic->content,
        //                             "search_rank" => $topic->search_rank,
        //                             'time'=>$topic->time
        //                         );
        //     $docs_to_upload[] = $item;
        // }


        // $end_time = strtotime(date('Y-m-d'));
        // $start_time = $end_time - 86400*7;
        // $criteria = new EMongoCriteria();
        // $criteria->time('>=',$start_time);
        // $criteria->time('<',$end_time);
        // $cursor = Message::model()->findAll();
        // $i=1;
        // $docs_to_upload = array();
        // foreach ($cursor as $message) {
        //     $i++;
        //     // if($i < 2630000){
        //     //     continue;
        //     // }
        //     if($i%5000 == 0){
        //         $result = Service::factory('SearchService')->addMessage($docs_to_upload);
        //         var_dump($result);
        //         sleep(5);
        //         $docs_to_upload = array();
        //     }
        //     $item = array();
        //     $item['cmd'] = 'update';
        //     //添加文档内容
        //     $item["fields"] = array(
        //                             'id'=>(string)$message->_id,
        //                             "content" => $message->content,
        //                             'time'=>$message->time,
        //                             'status'=>$message->status,
        //                         );
        //     $docs_to_upload[] = $item;
        // }
    }
}