|
|
@@ -0,0 +1,161 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace refill\blueciyuefeiy;
|
|
|
+
|
|
|
+require_once(BASE_HELPER_RAPI_PATH . '/blueciyuefeiy/config.php');
|
|
|
+
|
|
|
+use refill;
|
|
|
+use Log;
|
|
|
+
|
|
|
+class RefillPhone extends refill\IRefillPhone
|
|
|
+{
|
|
|
+ public function __construct($cfgs)
|
|
|
+ {
|
|
|
+ parent::__construct($cfgs);
|
|
|
+ }
|
|
|
+
|
|
|
+ private function req_params(int $phone, int $amount, string $order_sn)
|
|
|
+ {
|
|
|
+ $params['act'] = 'refill';
|
|
|
+ $params['op'] = 'add';
|
|
|
+ $params['mchid'] = config::MCH_ID;
|
|
|
+ $params['cardno'] = $phone;
|
|
|
+ $params['amount'] = $amount;
|
|
|
+ $params['order_sn'] = $order_sn;
|
|
|
+ $params['notifyurl'] = config::NOTIFY_URL;
|
|
|
+ return $params;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function add($card_no, $card_type, $amount, $params,&$net_errno = 0)
|
|
|
+ {
|
|
|
+ $params = $this->req_params($card_no, $amount, $params['order_sn']);
|
|
|
+ $sign = $this->sign($params);
|
|
|
+ $params['sign'] = $sign;
|
|
|
+
|
|
|
+ $resp = http_request(config::ORDER_URL, $params , 'POST' , false , [] , $net_errno);
|
|
|
+
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误', true];
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Log::record($resp, Log::DEBUG);
|
|
|
+ $resp = json_decode($resp ,true);
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误', true];
|
|
|
+ } elseif ($resp['code'] === 200) {
|
|
|
+ return [true, '', false];
|
|
|
+ } else {
|
|
|
+ return [false, $resp['message'], false];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public function query($refill_info)
|
|
|
+ {
|
|
|
+ $params['act'] = 'refill';
|
|
|
+ $params['op'] = 'query';
|
|
|
+ $params['mchid'] = config::MCH_ID;
|
|
|
+ $params['order_sn'] = $refill_info['order_sn'];
|
|
|
+ $params['sign'] = $this->sign($params);
|
|
|
+
|
|
|
+ $resp = http_request(config::ORDER_URL, $params , 'POST');
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误'];
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Log::record($resp, Log::DEBUG);
|
|
|
+ $resp = json_decode($resp, true);
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误'];
|
|
|
+ }
|
|
|
+ elseif ($resp['code'] === 200)
|
|
|
+ {
|
|
|
+ $data = $resp['datas'];
|
|
|
+ if ($data['order_state'] == '40') {
|
|
|
+ $save['ch_trade_no'] = $data['trade_no'];
|
|
|
+ $save['official_sn'] = strtolower($resp['official_sn']) == 'null' ? '' : $resp['official_sn'];
|
|
|
+ Model('refill_order')->edit($refill_info['order_id'], $save);
|
|
|
+ $order_state = ORDER_STATE_SUCCESS;
|
|
|
+ } elseif ($data['order_state'] === '0') {
|
|
|
+ Model('refill_order')->edit($refill_info['order_id'], ['ch_trade_no' => $data['trade_no']]);
|
|
|
+ $order_state = ORDER_STATE_CANCEL;
|
|
|
+ } elseif (in_array($data['order_state'], ['10', '20', '30', '50'], true)) {
|
|
|
+ $order_state = ORDER_STATE_SEND;
|
|
|
+ } else {
|
|
|
+ return [false, $resp['message']];
|
|
|
+ }
|
|
|
+ return [true, $order_state];
|
|
|
+ }
|
|
|
+ elseif ($resp['code'] === 202 && (time() - $refill_info['commit_time'] >= 600))
|
|
|
+ {
|
|
|
+ return [true, ORDER_STATE_NOEXIST];
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ return [false, $resp['message']];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public function balance()
|
|
|
+ {
|
|
|
+ $params['act'] = 'refill';
|
|
|
+ $params['op'] = 'balance';
|
|
|
+ $params['mchid'] = config::MCH_ID;
|
|
|
+ $params['sign'] = $this->sign($params);
|
|
|
+
|
|
|
+ $resp = http_request(config::ORDER_URL, $params , 'POST');
|
|
|
+
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误'];
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Log::record($resp, Log::DEBUG);
|
|
|
+ $resp = json_decode($resp, true);
|
|
|
+ if (empty($resp)) {
|
|
|
+ return [false, '系统错误'];
|
|
|
+ } elseif ($resp['code'] === 200) {
|
|
|
+ return [true, $resp['datas']['balance']];
|
|
|
+ } else {
|
|
|
+ return [false, $resp['message']];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected function check_empty($value)
|
|
|
+ {
|
|
|
+ if (!isset($value))
|
|
|
+ return true;
|
|
|
+ if ($value === null)
|
|
|
+ return true;
|
|
|
+ if (trim($value) === "")
|
|
|
+ return true;
|
|
|
+
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ private function sign($params)
|
|
|
+ {
|
|
|
+ ksort($params);
|
|
|
+
|
|
|
+ $body = "";
|
|
|
+ $i = 0;
|
|
|
+ foreach ($params as $k => $v) {
|
|
|
+ if (false === $this->check_empty($v) && "@" != substr($v, 0, 1)) {
|
|
|
+ if ($i == 0) {
|
|
|
+ $body .= "{$k}" . "=" . urlencode($v);
|
|
|
+ } else {
|
|
|
+ $body .= "&" . "{$k}" . "=" . urlencode($v);
|
|
|
+ }
|
|
|
+ $i++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $body .= "&key=".config::KEY;
|
|
|
+
|
|
|
+ return md5($body);
|
|
|
+ }
|
|
|
+}
|
