GetPetWorkCommand.php 5.3 KB

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