RefillPhone.php 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186
  1. <?php
  2. namespace refill\app;
  3. require_once(BASE_HELPER_RAPI_PATH . '/app/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(string $order_sn, string $product_code)
  13. {
  14. $params['AppKey'] = config::APP_KEY;
  15. $params['TimesTamp'] = time();
  16. $params['ProductCode'] = 'PLM100024'; //产品编码需传入
  17. $params['BuyCount'] = 1;
  18. $params['MOrderID'] = $order_sn;
  19. $params['CustomerIP'] = config::API_IP;
  20. $params['IsCallback'] = 1;
  21. $params['CallBackUrl'] = config::NOTIFY_URL;
  22. $params['Version'] = '1.0';
  23. return $params;
  24. }
  25. //直充提单
  26. public function add($card_no, $card_type, $amount, $params)
  27. {
  28. $order_sn = $params['order_sn'];
  29. $product_code = $params['product_code'];
  30. $params = $this->req_params($order_sn,$product_code);
  31. $params['ChargeAccount'] = $card_no;
  32. $params['ChargeAccountType'] = 1;//账号类型1 手机号,2 QQ号,3 微信号
  33. $sign = $this->sign($params);
  34. $params['Sign'] = $sign;
  35. $resp = http_request(config::ORDER_URL, $params);
  36. if (empty($resp)) {
  37. return [false, '网络错误', true];
  38. }
  39. else
  40. {
  41. Log::record($resp, Log::DEBUG);
  42. $resp = json_decode($resp, true);
  43. if (empty($resp)) {
  44. return [false, '网络错误', true];
  45. } elseif ($resp['Code'] == 999) {
  46. return [true, $resp['OrderModel']['OrderId'], false];
  47. } else {
  48. return [false, $resp['Msg'], false];
  49. }
  50. }
  51. }
  52. public function CardOrderAdd($card_no, $card_type, $amount, $params)
  53. {
  54. $order_sn = $params['order_sn'];
  55. $product_code = $params['product_code'];
  56. $params = $this->req_params($order_sn,$product_code);
  57. $params['PublicKey'] = $this->CT_RSA($params['order_id']);
  58. $sign = $this->sign($params);
  59. $params['Sign'] = $sign;
  60. $resp = http_request(config::CARD_ORDER_URL, $params);
  61. if (empty($resp)) {
  62. return [false, '网络错误', true];
  63. }
  64. else
  65. {
  66. Log::record($resp, Log::DEBUG);
  67. $resp = json_decode($resp, true);
  68. if (empty($resp)) {
  69. return [false, '网络错误', true];
  70. } elseif ($resp['Code'] == 999) {
  71. return [true, $resp['OrderModel']['OrderId'], false];
  72. } else {
  73. return [false, $resp['Msg'], false];
  74. }
  75. }
  76. }
  77. private function CT_RSA($order_id)
  78. {
  79. //创建公私钥
  80. $res = openssl_pkey_new();
  81. //获取私钥
  82. openssl_pkey_export($res, $private_key);
  83. //获取公钥
  84. $public_key = openssl_pkey_get_details($res)['key'];
  85. $rsa = [
  86. 'public_key' => $public_key,
  87. 'private_key' => $private_key,
  88. ];
  89. $rsa_json = json_encode($rsa);
  90. Log::record("rsa info : {$rsa_json}");
  91. //公钥私钥与订单绑定,加rsa字段
  92. $updata['public_key'] = $public_key;
  93. $updata['private_key'] = $private_key;
  94. Model('refill_order')->edit($order_id, $updata);
  95. return $public_key;
  96. }
  97. public function query($refill_info)
  98. {
  99. $params['AppKey'] = config::APP_KEY;
  100. $params['TimesTamp'] = time();
  101. $params['MOrderID'] = $refill_info['order_sn'];
  102. $params['Version'] = '1.0';
  103. $content = config::APP_KEY . $params['TimesTamp'] . $params['Version'] . $params['MOrderID'] . config::App_Secret;
  104. $params['Sign'] = strtoupper(md5($content));
  105. $resp = http_request(config::QUERY_URL, $params);
  106. if (empty($resp)) {
  107. return [false, '网络错误', []];
  108. }
  109. else
  110. {
  111. Log::record($resp, Log::DEBUG);
  112. $resp = json_decode($resp, true);
  113. if (empty($resp)) {
  114. return [false, '网络错误', []];
  115. }
  116. elseif ($resp['Code'] == 999)
  117. {
  118. $status = intval($resp['Data']['OrderState']);
  119. $card_data = [];
  120. if ($status === 2) {
  121. if(!empty($resp['Data']['CardData'])) {
  122. $private_key = $refill_info['private_key'];
  123. $cards = $this->rsa_decode($resp['Data']['CardData'],$private_key);
  124. $card_data = [];
  125. foreach ($cards as $card) {
  126. $card_data[] = json_decode($card, true);
  127. }
  128. //需返回卡密信息
  129. }
  130. $order_state = ORDER_STATE_SUCCESS;
  131. } elseif ($status === 3) {
  132. $order_state = ORDER_STATE_CANCEL;
  133. } elseif (in_array($status, [1,4])) {
  134. $order_state = ORDER_STATE_SEND;
  135. } else {
  136. return [false, $resp['Message'], $card_data];
  137. }
  138. return [true, $order_state, $card_data];
  139. }
  140. else
  141. {
  142. return [false, $resp['Message'], []];
  143. }
  144. }
  145. }
  146. private function rsa_decode($card_data,$private_key)
  147. {
  148. $res = openssl_pkey_get_private($private_key);
  149. //使用私钥解密数据
  150. openssl_private_decrypt($card_data, $decrypted, $res);
  151. return $decrypted;
  152. }
  153. private function sign($params)
  154. {
  155. $content = config::APP_KEY . $params['BuyCount'] . $params['CallBackUrl'] . $params['ChargeAccount'] . $params['CustomerIP'] . $params['MOrderID'];
  156. $content .= $params['ProductCode'] . $params['TimesTamp'] . $params['Version'] . config::App_Secret;
  157. return strtoupper(md5($content));
  158. }
  159. }