as2252258/kiri-wchat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

add

Browse Source
This commit is contained in:
as2252258
2018-07-19 19:18:22 +08:00
parent b0d857f6c2
commit a14272b5aa
3 changed files with 127 additions and 87 deletions
Download Patch File Download Diff File Expand all files Collapse all files
wx/Base.php
+3
View File
@@ -100,6 +100,9 @@ abstract class Base
*/ */
public $app_secret = ''; public $app_secret = '';
public $ssl_cert = '';
public $ssl_key = '';
/** /**
* @var string * @var string
*/ */
wx/Http.php
+9 -5
View File
@@ -15,7 +15,7 @@ class Http
* *
* @return Result * @return Result
*/ */
private function request($url, $pushType = 'get', $data = [], callable $callback = NULL) private function request($url, $pushType = 'get', $data = [], callable $callback = NULL, $isSSL = FALSE)
{ {
if ( if (
@@ -25,7 +25,7 @@ class Http
$url = $this->url . '/' . $url; $url = $this->url . '/' . $url;
} }
return $this->curl_push($url, $pushType, $data, $callback); return $this->curl_push($url, $pushType, $data, $callback, $isSSL);
} }
/** /**
@@ -36,7 +36,7 @@ class Http
* @return Result * @return Result
* curl请求 * curl请求
*/ */
public function curl_push($url, $type = 'get', $data = [], callable $callback = NULL) public function curl_push($url, $type = 'get', $data = [], callable $callback = NULL, $isSSL = FALSE)
{ {
$_data = $this->paramEncode($data); $_data = $this->paramEncode($data);
if ($type == 'get' && is_array($_data)) { if ($type == 'get' && is_array($_data)) {
@@ -50,6 +50,10 @@ class Http
if (!empty($this->header)) { if (!empty($this->header)) {
curl_setopt($ch, CURLOPT_HTTPHEADER, $this->header); curl_setopt($ch, CURLOPT_HTTPHEADER, $this->header);
} }
if ($isSSL && is_array($isSSL)) {
curl_setopt($ch, CURLOPT_SSLCERT, $isSSL[0]);
curl_setopt($ch, CURLOPT_SSLKEY, $isSSL[1]);
}
curl_setopt($ch, CURLOPT_NOBODY, FALSE); curl_setopt($ch, CURLOPT_NOBODY, FALSE);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 1);// 超时设置 curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 1);// 超时设置
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);//返回内容 curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);//返回内容
@@ -133,14 +137,14 @@ class Http
* *
* @return Result * @return Result
*/ */
public static function post($url, $data = [], callable $callback = NULL, array $header = NULL) public static function post($url, $data = [], callable $callback = NULL, array $header = NULL, $isSSl = FALSE)
{ {
static $_class = NULL; static $_class = NULL;
if ($_class == NULL) $_class = new Http(); if ($_class == NULL) $_class = new Http();
if (!empty($header)) { if (!empty($header)) {
$_class->setHeaders($header); $_class->setHeaders($header);
} }
return $_class->request($url, 'post', $data, $callback); return $_class->request($url, 'post', $data, $callback, $isSSl);
} }
/** /**
wx/Recharge.php
+115 -82
View File
@@ -5,90 +5,123 @@
* Date: 2018/3/26 0026 * Date: 2018/3/26 0026
* Time: 10:22 * Time: 10:22
*/ */
namespace wchat; namespace wchat;
class Recharge extends Base class Recharge extends Base
{ {
/** @var Recharge */ /** @var Recharge */
private static $recharge; private static $recharge;
private $money = 0; private $money = 0;
private $orderNo; private $orderNo;
private $data = []; private $data = [];
/** /**
* @param int $money * @param int $money
* @param string $orderNo * @param string $orderNo
* @return bool|Result * @return bool|Result
*/ */
public function payment(int $money, string $orderNo, $openId = null) public function payment(int $money, string $orderNo, $openId = NULL)
{ {
$_this = $this; $_this = $this;
if ($money < 0) { if ($money < 0) {
return new Result(['code' => 500, 'message' => '充值金额不能小于0.']); return new Result(['code' => 500, 'message' => '充值金额不能小于0.']);
} }
$this->money = $money; $this->money = $money;
$this->orderNo = $orderNo; $this->orderNo = $orderNo;
$this->data['openid'] = $openId; $this->data['openid'] = $openId;
return Http::post($this->createPayUrl(), $this->builder(), return Http::post($this->createPayUrl(), $this->builder(),
function ($result, $body) use ($_this) { function ($result, $body) use ($_this) {
$data = $_this->toArray($result); $data = $_this->toArray($result);
if(isset($data['sign'])){ if (isset($data['sign'])) {
$sign = $data['sign']; $sign = $data['sign'];
unset($data['sign']); unset($data['sign']);
$_sign = $_this->sign($data); $_sign = $_this->sign($data);
} }
$return = []; $return = [];
if (!isset($sign) || $sign != $_sign) { if (!isset($sign) || $sign != $_sign) {
$return['code'] = -1; $return['code'] = -1;
$return['message'] = $data['return_msg'] ?? '返回数据签名验证失败'; $return['message'] = $data['return_msg'] ?? '返回数据签名验证失败';
} else { } else {
if ($data['return_code'] == 'FAIL') { if ($data['return_code'] == 'FAIL') {
$return['code'] = -1; $return['code'] = -1;
$return['message'] = $data['return_msg']; $return['message'] = $data['return_msg'];
} else { } else {
$return['code'] = 0; $return['code'] = 0;
$return['data'] = $data; $return['data'] = $data;
$return['data']['postBody'] = $body; $return['data']['postBody'] = $body;
} }
} }
return $return; return $return;
}, ['Content-Type' => 'text/xml'] }, ['Content-Type' => 'text/xml']
); );
} }
/**
/** * @return string
* @return string */
*/ protected function builder()
protected function builder() {
{ $data = [
$data = [ 'appid' => $this->app_id,
'appid' => $this->app_id, 'mch_id' => $this->mch_id,
'mch_id' => $this->mch_id, 'nonce_str' => $this->random(32),
'nonce_str' => $this->random(32), 'body' => $this->body,
'body' => $this->body, 'out_trade_no' => $this->orderNo,
'out_trade_no' => $this->orderNo, 'total_fee' => $this->money,
'total_fee' => $this->money, 'sign_type' => $this->sign_type,
'sign_type' => $this->sign_type, 'spbill_create_ip' => $_SERVER['REMOTE_ADDR'],
'spbill_create_ip' => $_SERVER['REMOTE_ADDR'], 'notify_url' => $this->notify_url,
'notify_url' => $this->notify_url, 'trade_type' => $this->trade_type,
'trade_type' => $this->trade_type, ];
];
$data = array_merge($data, $this->data);
$data = array_merge($data, $this->data);
$data['sign'] = $this->sign($data);
$data['sign'] = $this->sign($data);
return $this->toXml($data);
return $this->toXml($data); }
}
private function createPayUrl()
private function createPayUrl() {
{ return $this->mch_host . '/pay/unifiedorder';
return $this->mch_host . '/pay/unifiedorder'; }
}
/**
* @param $money
* @param $openid
* @param $order
* @param $REMOTE_ADDR
* @return Result
*
* 提现
*/
public function tx($money, $openid, $order, $REMOTE_ADDR)
{
$array = [
'nonce_str' => $this->random(32),
'partner_trade_no' => $order,
'mchid' => $this->mch_id,
'mch_appid' => $this->app_id,
'openid' => $openid,
'check_name' => 'NO_CHECK',
'amount' => $money * 100,
'spbill_create_ip' => $REMOTE_ADDR,
'desc' => '看世界杯集球星卡，一起瓜分现金红包。',
];
$transfers = 'https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers';
$array['sign'] = $this->sign($array);
return Http::post($transfers, $this->toXml($array), function ($data) {
return $this->toArray($data);
}, NULL, [$this->ssl_cert, $this->ssl_key]);
}
} }