RefillPhone.php 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. <?php
  2. namespace refill\riying;
  3. require_once(BASE_HELPER_RAPI_PATH . '/riying/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 $card_type, int $amount, string $order_sn)
  13. {
  14. $params['OrderId'] = $order_sn;
  15. $params['Account'] = $phone;
  16. $params['Amount'] = $amount;
  17. $params['ShopId'] = config::ShopId;
  18. $params['UserId'] = config::UserId;
  19. $params['Num'] = 1;
  20. $params['ProductType'] = 1;
  21. $params['Timestamp'] = $this->getMillisecond();
  22. $params['IspTypeId'] = config::Product_type[$card_type];
  23. return $params;
  24. }
  25. public function add($card_no, $card_type, $amount, $params,&$net_errno = 0)
  26. {
  27. $params = $this->req_params($card_no, $card_type, $amount, $params['order_sn']);
  28. $sign = $this->sign($params);
  29. $params['Sign'] = $sign;
  30. $resp = http_request(config::ORDER_URL, $params, 'GET', false, [], $net_errno);
  31. if (empty($resp)) {
  32. return [false, '系统错误', true];
  33. }
  34. else
  35. {
  36. Log::record($resp, Log::DEBUG);
  37. $resp = json_decode($resp ,true);
  38. if (empty($resp)) {
  39. return [false, '系统错误', true];
  40. } elseif ($resp['Code'] == 10012) {
  41. return [true, $resp['SysOrderId'], false];
  42. } else {
  43. return [false, $resp['Message'], false];
  44. }
  45. }
  46. }
  47. public function query($refill_info)
  48. {
  49. $params['ShopId'] = config::ShopId;
  50. $params['UserId'] = config::UserId;
  51. $params['Timestamp'] = $this->getMillisecond();
  52. $params['OrderId'] = $refill_info['ch_trade_no'];
  53. $content = $params['ShopId'] . $params['UserId']. $params['OrderId'] . $params['Timestamp'] . config::KEY;
  54. $params['Sign'] = md5($content);
  55. $resp = http_request(config::QUERY_URL, $params);
  56. if (empty($resp)) {
  57. return [false, '系统错误'];
  58. }
  59. else
  60. {
  61. Log::record($resp, Log::DEBUG);
  62. $resp = json_decode($resp, true);
  63. if (empty($resp)) {
  64. return [false, '系统错误'];
  65. } elseif ($resp['Code'] == 4) {
  66. $order_state = ORDER_STATE_SUCCESS;
  67. $save['official_sn'] = strtolower($resp['VoucherContent']) == 'null' ? '' : $resp['VoucherContent'];
  68. Model('refill_order')->edit($refill_info['order_id'], $save);
  69. } elseif ($resp['Code'] == 5) {
  70. $order_state = ORDER_STATE_CANCEL;
  71. } elseif ($resp['Code'] == 0) {
  72. $order_state = ORDER_STATE_SEND;
  73. } else {
  74. return [false, $resp['Message']];
  75. }
  76. return [true, $order_state];
  77. }
  78. }
  79. private function sign($params)
  80. {
  81. $key = config::KEY;
  82. $content = $params['ShopId'] . $params['UserId'] . $params['ProductType'] . $params['OrderId'] . $params['Account'];
  83. $content .= $params['Amount'] . $params['Num'] . $params['Timestamp'] . $key;
  84. return md5($content);
  85. }
  86. /**
  87. * 获取毫秒级别的时间戳
  88. */
  89. private function getMillisecond()
  90. {
  91. $cur = microtime (true);
  92. $cur = intval($cur * 1000);
  93. return $cur;
  94. }
  95. }