RefillPhone.php 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134
  1. <?php
  2. namespace refill\chuka;
  3. require_once(BASE_HELPER_RAPI_PATH . '/chuka/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['customerId'] = config::customerId;
  15. $params['number'] = $phone;
  16. $params['checkItemFacePrice'] = $amount;
  17. $params['orderno'] = $order_sn;
  18. $params['notify_url'] = config::NOTIFY_URL;
  19. $params['timestamp'] = time();
  20. $params['amt'] = 1;
  21. $params['overtime'] = 20;
  22. return $params;
  23. }
  24. public function add($card_no, $card_type, $amount, $params)
  25. {
  26. $params = $this->req_params($card_no, $amount, $params['order_sn']);
  27. $productNo = $this->getproductNo($amount);
  28. if($productNo === 0) {
  29. return [false, '商品编号错误', false];
  30. }
  31. $params['itemId'] = $productNo;
  32. $sign = $this->sign($params);
  33. $params['sign'] = $sign;
  34. $resp = http_request(config::ORDER_URL, $params , 'POST' , false , config::ExtHeaders);
  35. if ($resp === false) {
  36. return [false, '系统错误', true];
  37. } else {
  38. Log::record($resp, Log::DEBUG);
  39. $resp = $this->xmlToArray($resp);
  40. if($resp['code'] == 1) {
  41. return [true, $resp['data']['tradeNo'], false];
  42. }
  43. return [false , $resp['message'], false];
  44. }
  45. }
  46. public function query($refill_info)
  47. {
  48. $params['orderno'] = $refill_info['order_sn'];
  49. $params['customerId'] = config::customerId;
  50. $params['timestamp'] = time();
  51. $sign = $this->sign($params);
  52. $params['sign'] = $sign;
  53. $resp = http_request(config::QUERY_URL, $params , 'POST' , false , config::ExtHeaders);
  54. if ($resp === false) {
  55. return [false, '系统错误'];
  56. } else {
  57. Log::record($resp, Log::DEBUG);
  58. $resp = $this->xmlToArray($resp);
  59. if ($resp['code'] == 1) {
  60. $order_state = -1;
  61. $data = $resp['data'];
  62. if ($data['status'] == 'success') {
  63. $order_state = ORDER_STATE_SUCCESS;
  64. } elseif ($data['status'] == 'failed') {
  65. $order_state = ORDER_STATE_CANCEL;
  66. } elseif ($data['status'] == 'wait') {
  67. $order_state = ORDER_STATE_SEND;
  68. }
  69. if ($order_state == -1) {
  70. return [false, $resp['msg']];
  71. }
  72. return [true, $order_state];
  73. } else {
  74. return [false, $resp['message']];
  75. }
  76. }
  77. }
  78. private function sign($params)
  79. {
  80. $content = '';
  81. ksort($params);
  82. foreach ($params as $key => $val){
  83. if (false === $this->check_empty($val) && "@" != substr($val, 0, 1)) {
  84. $content .= "{$key}={$val}&";
  85. }
  86. }
  87. $content .= "key=".config::API_KEY;
  88. return strtoupper(md5($content));
  89. }
  90. private function getproductNo(int $amount)
  91. {
  92. switch ($amount){
  93. case 20:
  94. $productNo = 'lt20';
  95. break;
  96. case 30:
  97. $productNo = 'lt30';
  98. break;
  99. case 50:
  100. $productNo = 'lt50';
  101. break;
  102. case 100:
  103. $productNo = 'lt100';
  104. break;
  105. default:
  106. $productNo = 0;
  107. }
  108. return $productNo;
  109. }
  110. /**
  111. * 作用:将xml转为array
  112. */
  113. public function xmlToArray($xml)
  114. {
  115. //将XML转为array
  116. $array_data = json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
  117. return $array_data;
  118. }
  119. }