php/www/protected/commands/TempCommand.php

<?php
class TempCommand extends CConsoleCommand{
    public function run($args) {
        error_reporting(E_ALL);
        ini_set('memory_limit', '256M');
        set_time_limit(0); 
        $end_time = time();
        $criteria = new EMongoCriteria();
        $start_time = $end_time - 86400*30;
        $criteria->register_time('>=',$start_time);
        $criteria->register_time('<',$end_time);
        $cursor = RUser::model()->findAll($criteria);
        $i=1;
        $docs_to_upload = array();
        foreach ($cursor as $user) {
            $i++;
            if($i%1000 == 0){
                $result = Service::factory('SearchService')->addUser($docs_to_upload);
                var_dump($result);
                sleep(3);
                $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;
        }
        $result = Service::factory('SearchService')->addUser($docs_to_upload);
        $docs_to_upload = array();
        echo "end_user:";
        var_dump($result);
        

    }
}