RefillPhone.php 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149
  1. <?php
  2. namespace refill\yunling;
  3. require_once(BASE_HELPER_RAPI_PATH . '/yunling/config.php');
  4. use refill;
  5. use Log;
  6. class RefillPhone extends refill\IRefillPhone
  7. {
  8. public function __construct($cfgs)
  9. {
  10. parent::__construct($cfgs);
  11. }
  12. private function req_params(int $phone, int $amount, string $order_sn)
  13. {
  14. $params['userid'] = config::USER_ID;
  15. $params['productid'] = '';
  16. $params['productType'] = '1';
  17. $params['price'] = $amount;
  18. $params['num'] = 1;
  19. $params['mobile'] = $phone;
  20. $params['spordertime'] = date("YmdHis");
  21. $params['sporderid'] = $order_sn;
  22. $params['back_url'] = config::NOTIFY_URL;
  23. return $params;
  24. }
  25. public function add($card_no, $card_type, $amount, $params)
  26. {
  27. $order_sn = $params['order_sn'];
  28. $params = $this->req_params($card_no, $amount, $order_sn);
  29. $params['operator'] = config::operator[$card_type];
  30. $region = $this->getPhoneInfo($card_no);
  31. if($region === false) {
  32. return [false, '归属地获取失败', false];
  33. }
  34. $params['region'] = $region;
  35. $sign = $this->sign($params);
  36. $params['sign'] = $sign;
  37. $resp = http_request(config::ORDER_URL, $params);
  38. if ($resp === false) {
  39. return [false, '网络错误', true];
  40. }
  41. else
  42. {
  43. Log::record($resp, Log::DEBUG);
  44. $resp = $this->xmlToArray($resp);
  45. $resultno = intval($resp['resultno']);
  46. if (in_array($resultno, [0,1,2])) {
  47. return [true, $resp['orderid'], false];
  48. } else {
  49. return [false, $resp['message'], false];
  50. }
  51. }
  52. }
  53. public function query($refill_info)
  54. {
  55. $params['sporderid'] = $refill_info['order_sn'];
  56. $params['userid'] = config::USER_ID;
  57. $resp = http_request(config::QUERY_URL, $params);
  58. if ($resp === false) {
  59. return [false, '网络错误'];
  60. }
  61. else
  62. {
  63. Log::record($resp, Log::DEBUG);
  64. $resp = $this->xmlToArray($resp);
  65. $resultno = intval($resp['resultno']);
  66. if ($resultno === 1) {
  67. $order_state = ORDER_STATE_SUCCESS;
  68. $updata['official_sn'] = $resp['supnumber'];
  69. Model('refill_order')->edit($refill_info['order_id'], $updata);
  70. } elseif ($resultno === 9) {
  71. $order_state = ORDER_STATE_CANCEL;
  72. } elseif (in_array($resultno, [0,2])) {
  73. $order_state = ORDER_STATE_SEND;
  74. } else {
  75. return [false, $resp['message']];
  76. }
  77. return [true, $order_state];
  78. }
  79. }
  80. private function sign($params)
  81. {
  82. $userid = config::USER_ID;
  83. $key = config::KEY;
  84. $content = "userid={$userid}&productid={$params['productid']}&price={$params['price']}&num={$params['num']}&mobile={$params['mobile']}&spordertime={$params['spordertime']}";
  85. $content .= "&sporderid={$params['sporderid']}&key={$key}";
  86. return md5($content);
  87. }
  88. public function xmlToArray($xml)
  89. {
  90. //禁止引用外部xml实体
  91. libxml_disable_entity_loader(true);
  92. $xmlstring = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
  93. $val = json_decode(json_encode($xmlstring), true);
  94. return $val;
  95. }
  96. private function getPhoneInfo($phone)
  97. {
  98. $url = "https://tcc.taobao.com/cc/json/mobile_tel_segment.htm?tel={$phone}";
  99. $resp = http_request($url); //获取API返回 的数据
  100. $resp = mb_convert_encoding($resp, 'UTF-8', 'UTF-8,GBK,GB2312,BIG5'); //解决中文乱码
  101. $datas = explode('=', $resp);
  102. if(count($datas) == 2)
  103. {
  104. $body = trim($datas[1]);
  105. if(preg_match_all("/(\w+):'([^']+)/", $body, $m)) {
  106. $res = array_combine($m[1], $m[2]);
  107. return $this->formatProvince($res['province']);
  108. }
  109. }
  110. return false;
  111. }
  112. public function formatProvince(string $province) : string
  113. {
  114. if(empty($province)) {
  115. return '';
  116. }
  117. $checkArr = ["省","市","自治区","特别行政区"];
  118. for($i = 0; $i < count($checkArr); $i++) {
  119. if(strpos($province, $checkArr[$i]) === false) {
  120. continue;
  121. } else {
  122. $province = mb_strcut($province, 0, strrpos($province, $checkArr[$i]));
  123. }
  124. }
  125. return $province;
  126. }
  127. }