GetPetWorkCommand.php 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: PHP
  5. * Date: 2016/11/23
  6. * Time: 9:11
  7. */
  8. class GetPetWorkCommand extends CConsoleCommand {
  9. public function run($args){
  10. error_reporting(E_ERROR);
  11. ini_set('memory_limit', '256M');
  12. //ini_set('mongo.long_as_object',1);
  13. set_time_limit(0);
  14. self::getPet();
  15. }
  16. public function getPet(){
  17. $count = 0;
  18. $page = intval(Yii::app()->redis->get('petPage'));
  19. if (empty($page)) $page =1;
  20. while($page) {
  21. if ($count >= 200) {
  22. Yii::app()->redis->set('petPage', intval(--$page));
  23. exit;
  24. }
  25. //获取商家id
  26. $res = CommonFn::simple_http("http://deal.wozhua.mobi/api/kennel/list?user_id=546b16f50eb9fb494f8b4664&page=".$page."&rows=10");
  27. $res = json_decode($res,true);
  28. //var_dump($res);
  29. if ($res['success']) {
  30. $list = $res['data']['list'];
  31. foreach ($list as $key => $value) {
  32. $kennel = $value['id'];
  33. //获取对应商家的petid
  34. $resources = CommonFn::simple_http("http://deal.wozhua.mobi/api/pet/list?user_id=546b16f50eb9fb494f8b4664&kennel=".$kennel."&page=".$page++."&rows=20");
  35. $resources = json_decode($resources,true);
  36. if ($resources['success']) {
  37. $petsList = $resources['data']['list'];
  38. foreach ($petsList as $k => $pet) {
  39. $count++;
  40. //获取pet详情
  41. $tmp = json_decode(CommonFn::simple_http("http://deal.wozhua.mobi/api/pet/info?user_id=546b16f50eb9fb494f8b4664&pet_id=" . $pet['id']), true);
  42. $tmp = $tmp['data'];
  43. if (!empty($tmp)) {
  44. if (!empty(DealPet::model()->get(new MongoId($tmp['id'])))) {
  45. $dealPet = DealPet::model()->get(new MongoId($tmp['id']));
  46. } else {
  47. $dealPet = new DealPet();
  48. }
  49. $dealPet->_id = new MongoId($tmp['id']);
  50. $dealPet->is_one_pay = 0;
  51. $dealPet->name = $tmp['name'];
  52. $dealPet->status = $tmp['status'];
  53. $dealPet->price = $tmp['price'];
  54. foreach ($tmp['pics'] as $v){
  55. $dealPet->pics[] = $v;
  56. }
  57. $dealPet->root_parent = new MongoId($tmp['root_praent']);
  58. $dealPet->kennel = new MongoId($tmp['kennel']);
  59. $dealPet->pet_type = new MongoId($tmp['pet_type']);
  60. $dealPet->birth_date = intval($tmp['birth_date']);
  61. $dealPet->gender = $tmp['gender'];
  62. $dealPet->tags = $tmp['tags'];
  63. $dealPet->father_info = $tmp['father_info'];
  64. $dealPet->mother_info = $tmp['mother_info'];
  65. $dealPet->desc = $tmp['desc'];
  66. $dealPet->vaccine_info = $tmp['vaccine_info'];
  67. $dealPet->add_time = $tmp['add_time'];
  68. $dealPet->sort_weight = $tmp['sort_weight'];
  69. $dealPet->delivery_time = $tmp['delivery_time'];
  70. $dealPet->delivery_date = $tmp['delivery_date'];
  71. $dealPet->deworming_info = $tmp['deworming_info'];
  72. $dealPet->hair_color = $tmp['hair_color'];
  73. $dealPet->video = $tmp['video'];
  74. $dealPet->carriage = $tmp['carriage'];
  75. $dealPet->last_modify = $tmp['last_modify'];
  76. $dealPet->view_count = $tmp['view_count'];
  77. $dealPet->contact_count = $tmp['contact_count'];
  78. $dealPet->region = $tmp['region'];
  79. $dealPet->last_deny_reason = $tmp['last_deny_reason'];
  80. var_dump($dealPet->save());
  81. sleep(3);
  82. }
  83. }
  84. sleep(3);
  85. }
  86. }
  87. }
  88. }
  89. }
  90. }