php/www/protected/commands/getPetUserWorkCommand.php

<?php
/**
 * Created by PhpStorm.
 * User: PHP
 * Date: 2016/11/9
 * Time: 15:31
 */
class GetPetUserWorkCommand extends CConsoleCommand{
    public function run($args) {
        error_reporting(E_ERROR);
        ini_set('memory_limit', '256M');
        //ini_set('mongo.long_as_object',1);
        set_time_limit(0);
       // $this->getPetUser();


    }
    public function getKennel(){
        $count = 0;
        $page = intval(Yii::app()->redis->get('page'));
        if (empty($page)) $page =1;
        var_dump($page);
        while($page) {
            if ($count >= 10) {
                Yii::app()->redis->set('page', intval(--$page));
                exit;
            }
            var_dump($page);
            $res = CommonFn::simple_http("http://deal.wozhua.mobi/api/kennel/list?user_id=546b16f50eb9fb494f8b4664&page=".$page++."&rows=10");
            $res = json_decode($res,true);
            if ($res['success']) {
                $list = $res['data']['list'];

                foreach ($list as $key => $value) {
                    $count++;
                    $tmp = json_decode(CommonFn::simple_http("http://deal.wozhua.mobi/api/kennel/desc?user_id=546b16f50eb9fb494f8b4664&kennel_id=" . $value['id']), true);
                    if (!empty($tmp)) {
                        $tmp = $tmp['data'];
                        if (!empty(Kennel::model()->get(new MongoId($value['id'])))) {
                            $kennel = Kennel::model()->get(new MongoId($value['id']));
                        } else {
                            $kennel = new Kennel();
                        }
                        $kennel->_id = new MongoId($value['id']);
                        $kennel->status = 0;
                        $kennel->weight = 0;
                        $kennel->name = $value['name'];
                        $kennel->avatar = $value['avatar'];
                        $kennel->region = $value['region'];
                        $kennel->video = $value['video'];
                        if ($value['is_certified']) {
                            $kennel->type = 1;
                        } else {
                            $kennel->type = 2;
                        }
                        $kennel->tags = $tmp['tags'];
                        $kennel->desc = $tmp['desc'];
                        foreach ($tmp['desc_pics'] as $v) {
                            $kennel->desc_pics[] = $v;
                        }
                        $kennel->address = $tmp['address'];
                        $kennel->phone = $tmp['phone'];
                        $kennel->favorable_rate = $tmp['favorable_rate'];
                        $kennel->comment_count = $tmp['comment_count'];
                        $kennel->favorable_count = $tmp['favorable_count'];
                        $kennel->average = $tmp['favorable_star'];
                        $success = $kennel->save();
                        if ($success) {
                            echo "success";
                        }
                        sleep(3);
                    }
                }
                sleep(3);
            }
        }
    }
    public function getPetUser(){
        $m = new MongoClient(DB_CONNETC);
        $collection = $m->selectCollection('fuwu','material');
        var_dump($collection->drop());
        $c = $m->selectCollection('fuwu','stock');
        var_dump($c->drop());
      /*  $m = new MongoClient(DB_CONNETC);
        $count = 0;
        $collection = $m->selectCollection('cute','pet_user');
        $cursor = $collection->find();
        $cursor->sort(array('id' => -1));
        $index = $cursor->getNext()['id'];
        if (empty($index)){
            $index = 1;
        }

        while($index) {
            if($count>= 50){
                exit;
            }
            $count++;
            $res = CommonFn::simple_http('http://pet.appcute.im/api/user/get?id=' . $index++);
            $d = json_decode($res, true);
            if ($d['error'] == 10000) {
                $data = $d['data'];
                if (!$collection->findOne(array('id' => $data['id']))) {
                    foreach($data['photos'] as $key => $value) {
                        $data['photos'][$key] = $value;
                    }
                    foreach ($data['contact'] as $key => $value) {
                        $data['contact'][$key] = $value;
                    }
                    foreach ($data['services'] as $key => $value) {
                        $data['services'][$key] = $value;
                    }
                    foreach ($data['area'] as $key => $value) {
                        if (is_array($data['area'][$key])){
                            foreach($data['area'][$key] as $k => $v) {
                                $data['area'][$key][$k] = $v;
                            }
                        } else {
                            $data['area'][$key] = $value;
                        }

                    }
                    $collection->insert($data);
                }
            }
            sleep(3);
        }*/
    }


    public function writeLastIndex($index){
        echo $index;
        $file = fopen(dirname(__FILE__).'/../data/petUser.json', "w") or die("Unable to open file!");
        $data['last_index'] = $index;
        fwrite($file, json_encode($data));
        fclose($file);
    }
}