GetPetWorkCommand.php 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  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. $kennelPage = intval(Yii::app()->redis->get('kennelPage'));
  19. if (empty($kennelPage)){
  20. $kennelPage = 1;
  21. }
  22. while($kennelPage) {
  23. if ($count >= 200) {
  24. Yii::app()->redis->set('kennelPage', intval(--$kennelPage));
  25. exit;
  26. }
  27. //获取商家id
  28. var_dump('kennelPage='.$kennelPage);
  29. $res = CommonFn::simple_http("http://deal.wozhua.mobi/api/kennel/list?user_id=546b16f50eb9fb494f8b4664&page=".$kennelPage++."&rows=10");
  30. $res = json_decode($res,true);
  31. //var_dump($res);
  32. if ($res['success']) {
  33. $list = $res['data']['list'];
  34. foreach ($list as $key => $value) {
  35. $kennel = $value['id'];
  36. //获取对应商家的petid
  37. $page = 1;
  38. $flag = 1;
  39. var_dump($value['id']);
  40. while ($flag) {
  41. $resources = CommonFn::simple_http("http://deal.wozhua.mobi/api/pet/list?user_id=546b16f50eb9fb494f8b4664&kennel=" . $kennel . "&page=" . $page++ . "&rows=20");
  42. $resources = json_decode($resources, true);
  43. if (empty($resources['data']['list'])){
  44. $flag = 0;
  45. } else {
  46. $petsList = $resources['data']['list'];
  47. foreach ($petsList as $k => $pet) {
  48. $count++;
  49. var_dump('count='.$count);
  50. //获取pet详情
  51. $tmp = json_decode(CommonFn::simple_http("http://deal.wozhua.mobi/api/pet/info?user_id=546b16f50eb9fb494f8b4664&pet_id=" . $pet['id']), true);
  52. $tmp = $tmp['data'];
  53. if (!empty($tmp)) {
  54. if (!empty(DealPet::model()->get(new MongoId($tmp['id'])))) {
  55. $dealPet = DealPet::model()->get(new MongoId($tmp['id']));
  56. } else {
  57. $dealPet = new DealPet();
  58. }
  59. $dealPet->_id = new MongoId($tmp['id']);
  60. $dealPet->is_one_pay = 0;
  61. $dealPet->name = $tmp['name'];
  62. $dealPet->status = $tmp['status'];
  63. $dealPet->price = $tmp['price'];
  64. foreach ($tmp['pics'] as $v) {
  65. $dealPet->pics[] = $v;
  66. }
  67. $dealPet->root_parent = new MongoId($tmp['root_praent']);
  68. $dealPet->kennel = new MongoId($tmp['kennel']);
  69. $dealPet->pet_type = new MongoId($tmp['pet_type']);
  70. $dealPet->birth_date = intval($tmp['birth_date']);
  71. $dealPet->gender = $tmp['gender'];
  72. $dealPet->tags = $tmp['tags'];
  73. $dealPet->father_info = $tmp['father_info'];
  74. $dealPet->mother_info = $tmp['mother_info'];
  75. $dealPet->desc = $tmp['desc'];
  76. $dealPet->vaccine_info = $tmp['vaccine_info'];
  77. $dealPet->add_time = $tmp['add_time'];
  78. $dealPet->sort_weight = $tmp['sort_weight'];
  79. $dealPet->delivery_time = $tmp['delivery_time'];
  80. $dealPet->delivery_date = $tmp['delivery_date'];
  81. $dealPet->deworming_info = $tmp['deworming_info'];
  82. $dealPet->hair_color = $tmp['hair_color'];
  83. $dealPet->video = $tmp['video'];
  84. $dealPet->carriage = $tmp['carriage'];
  85. $dealPet->last_modify = $tmp['last_modify'];
  86. $dealPet->view_count = $tmp['view_count'];
  87. $dealPet->contact_count = $tmp['contact_count'];
  88. $dealPet->region = $tmp['region'];
  89. $dealPet->last_deny_reason = $tmp['last_deny_reason'];
  90. var_dump($dealPet->save());
  91. sleep(3);
  92. }
  93. }
  94. sleep(3);
  95. }
  96. }
  97. }
  98. }
  99. }
  100. }
  101. }