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); } }