RefillPhone.php 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. <?php
  2. namespace refill\duojing;
  3. require_once(BASE_HELPER_RAPI_PATH . '/duojing/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['appKey'] = config::appKey;
  15. $params['orderId'] = $order_sn;
  16. $params['mobile'] = $phone;
  17. $params['amount'] = $amount;
  18. $params['notifyUrl'] = config::NOTIFY_URL;
  19. return $params;
  20. }
  21. public function add($card_no, $card_type, $amount, $params,&$net_errno = 0)
  22. {
  23. $order_sn = $params['order_sn'];
  24. $params = $this->req_params($card_no, $amount, $order_sn);
  25. $sign = $this->sign($params);
  26. $params['sign'] = $sign;
  27. $resp = http_request(config::ORDER_URL, $params, 'POST', false, config::ExtHeaders, $net_errno);
  28. if (empty($resp)) {
  29. return [false, '网络错误', true];
  30. }
  31. else
  32. {
  33. Log::record($resp, Log::DEBUG);
  34. $resp = json_decode($resp, true);
  35. if (empty($resp)) {
  36. return [false, '网络错误', true];
  37. } elseif ($resp['return_code'] === 0 && $resp['result_code'] === 'SUCCESS') {
  38. return [true, $resp['data']['number'], false];
  39. } else {
  40. return [false, $resp['return_msg'], false];
  41. }
  42. }
  43. }
  44. public function query($refill_info)
  45. {
  46. $params['appKey'] = config::appKey;
  47. $params['orderId'] = $refill_info['order_sn'];
  48. $sign = $this->sign($params);
  49. $params['sign'] = $sign;
  50. $resp = http_request(config::QUERY_URL, $params, 'POST', false, config::ExtHeaders);
  51. if (empty($resp)) {
  52. return [false, '网络错误'];
  53. }
  54. else
  55. {
  56. Log::record($resp, Log::DEBUG);
  57. $resp = json_decode($resp, true);
  58. if (empty($resp)) {
  59. return [false, '网络错误'];
  60. }
  61. if($resp['return_code'] === 0 && $resp['result_code'] === 'SUCCESS')
  62. {
  63. $status = $resp['data']['status'];
  64. if ($status === 'SUCCESS') {
  65. $order_state = ORDER_STATE_SUCCESS;
  66. } elseif ($status === 'FAIL') {
  67. $order_state = ORDER_STATE_CANCEL;
  68. } elseif ($status === 'WAIT') {
  69. $order_state = ORDER_STATE_SEND;
  70. } else {
  71. return [false, $status];
  72. }
  73. return [true, $order_state];
  74. }
  75. elseif($resp['return_code'] === 11009 && (time() - $refill_info['commit_time'] > 600)) {
  76. return [true, ORDER_STATE_NOEXIST];
  77. }
  78. else {
  79. return [false, $resp['return_msg']];
  80. }
  81. }
  82. }
  83. public function balance()
  84. {
  85. $params['appKey'] = config::appKey;
  86. $params['time'] = date("Y-m-d H:i:s");
  87. $sign = $this->sign($params);
  88. $params['sign'] = $sign;
  89. $resp = http_request(config::BALANCE_URL, $params, 'POST', false, config::ExtHeaders);
  90. if(empty($resp)) {
  91. return [false, '网络错误'];
  92. }
  93. else
  94. {
  95. Log::record($resp, Log::DEBUG);
  96. $resp = json_decode($resp, true);
  97. if (empty($resp)) {
  98. return [false, '网络错误'];
  99. }
  100. elseif($resp['return_code'] === 0 && $resp['result_code'] === 'SUCCESS') {
  101. return [true, $resp['data']['surplus']];
  102. }
  103. else {
  104. return [false, $resp['return_msg']];
  105. }
  106. }
  107. }
  108. private function sign($params)
  109. {
  110. $content = '';
  111. ksort($params);
  112. foreach ($params as $key => $val){
  113. if(false === $this->check_empty($val)) {
  114. $content .= "{$key}={$val}&";
  115. }
  116. }
  117. $content .= "key=".config::KEY;
  118. return strtoupper(md5($content));
  119. }
  120. }