RefillOil.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. <?php
  2. namespace refill\jumi_sec;
  3. require_once(BASE_HELPER_RAPI_PATH . '/jumi_sec/config.php');
  4. use refill;
  5. use Log;
  6. class RefillOil extends refill\IRefillPhone
  7. {
  8. public function __construct($cfgs)
  9. {
  10. parent::__construct($cfgs);
  11. }
  12. private function req_params(int $card_no, string $order_sn, int $amount)
  13. {
  14. $params['appid'] = config::APP_ID;
  15. $params['order'] = $order_sn;
  16. $params['card'] = $card_no;
  17. $params['api_product'] = 'zshcz_zc';
  18. $params['cash'] = $amount;
  19. $params['time'] = time();
  20. $params['notify'] = config::NOTIFY_URL;
  21. return $params;
  22. }
  23. public function add($card_no, $card_type, $amount, $params,&$net_errno = 0)
  24. {
  25. $params = $this->req_params($card_no, $params['order_sn'], $amount);
  26. $sign = $this->sign($params);
  27. $params['signature'] = $sign;
  28. $resp = http_request(config::ORDER_URL, $params, 'POST', false, [], $net_errno);
  29. if (empty($resp)) {
  30. return [false, '系统错误', true];
  31. }
  32. else
  33. {
  34. Log::record($resp, Log::DEBUG);
  35. $resp = json_decode($resp ,true);
  36. if (empty($resp)) {
  37. return [false, '系统错误', true];
  38. } elseif ($resp['code'] === 1) {
  39. return [true, $resp['data']['order'], false];
  40. } else {
  41. return [false, $resp['info'], false];
  42. }
  43. }
  44. }
  45. public function query($refill_info)
  46. {
  47. $params['appid'] = config::APP_ID;
  48. $params['merchant_order_id'] = $refill_info['order_sn'];
  49. $params['time'] = time();
  50. $sign = $this->sign($params);
  51. $params['signature'] = $sign;
  52. $resp = http_request(config::QUERY_URL, $params, 'POST');
  53. if (empty($resp)) {
  54. return [false, '系统错误'];
  55. }
  56. else
  57. {
  58. Log::record($resp, Log::DEBUG);
  59. $resp = json_decode($resp, true);
  60. if (empty($resp))
  61. {
  62. return [false, '系统错误'];
  63. }
  64. elseif ($resp['code'] === 1)
  65. {
  66. $data = $resp['data'];
  67. $status = $data['status'];
  68. if ($status === 2) {
  69. $order_state = ORDER_STATE_SUCCESS;
  70. } elseif ($status === 3) {
  71. $order_state = ORDER_STATE_CANCEL;
  72. } elseif (in_array($status, [1, 4], true)) {
  73. $order_state = ORDER_STATE_SEND;
  74. } else {
  75. return [false, $resp['info']];
  76. }
  77. return [true, $order_state];
  78. }
  79. elseif ($resp['code'] === -101 && (time() - $refill_info['commit_time'] > 600))
  80. {
  81. return [true, ORDER_STATE_NOEXIST];
  82. }
  83. else
  84. {
  85. return [false, $resp['info']];
  86. }
  87. }
  88. }
  89. public function balance()
  90. {
  91. $params['appid'] = config::APP_ID;
  92. $params['time'] = time();
  93. $sign = $this->sign($params);
  94. $params['signature'] = $sign;
  95. $resp = http_request(config::BALANCE_URL, $params, 'POST');
  96. if (empty($resp)) {
  97. return [false, '系统错误'];
  98. } else {
  99. Log::record($resp, Log::DEBUG);
  100. $resp = json_decode($resp ,true);
  101. if (empty($resp)) {
  102. return [false, '系统错误', true];
  103. } elseif ($resp['code'] === 1) {
  104. return [true, $resp['data']['account'], false];
  105. } else {
  106. return [false, $resp['info'], false];
  107. }
  108. }
  109. }
  110. private function sign($params)
  111. {
  112. $token = config::TOKEN;
  113. ksort($params);
  114. $content = '';
  115. foreach ($params as $key => $value) {
  116. if($this->check_empty($value) === false) {
  117. $content .= "{$key}={$value}&";
  118. }
  119. }
  120. $content .= "token={$token}";
  121. return md5($content);
  122. }
  123. }