4 Commits

Author SHA1 Message Date
as2252258 b92ea7df9f Default Changelist 2023-08-18 15:31:47 +08:00
as2252258 72a7c58bc4 Default Changelist 2023-07-20 17:42:42 +08:00
as2252258 e1959752e1 Default Changelist 2023-07-18 00:24:58 +08:00
as2252258 361ad4538f Default Changelist 2023-07-18 00:19:13 +08:00
4 changed files with 93 additions and 85 deletions
+1 -1
View File
@@ -21,7 +21,7 @@
},
"require": {
"php": ">= 8.0",
"game-worker/kiri-client": "dev-master",
"game-worker/kiri-client": "~v2.6",
"game-worker/kiri-container": "~v1.9",
"psr/container": "*"
},
+11 -2
View File
@@ -536,11 +536,20 @@ class Config
$this->usrSwoole = $usrSwoole;
}
/**
/**
* @param array $configs
*/
public function __construct(array $configs)
{
$this->setConfigs($configs);
}
/**
* @param array $configs
* @return $this
*/
public function setConfigs(array $configs): static
protected function setConfigs(array $configs): static
{
if (empty($configs)) {
return $this;
+80 -81
View File
@@ -10,107 +10,106 @@ namespace wchat\qq;
use Exception;
use Kiri\Client;
use wchat\common\HttpClient;
use wchat\common\Result;
use wchat\common\Help;
class Recharge extends SmallProgram
{
private $money = 0;
private float $money = 0;
private $orderNo;
private string $orderNo;
private $data = [];
private array $data = [];
private $spill_create_ip = '';
private string $spill_create_ip = '';
private $uniformer = 'https://qpay.qq.com/cgi-bin/pay/qpay_unified_order.cgi';
private string $uniformer = '/cgi-bin/pay/qpay_unified_order.cgi';
/**
* @param $value
*/
public function setSpillCreateIp($value)
{
$this->spill_create_ip = $value;
}
/**
* @param $value
*/
public function setSpillCreateIp($value)
{
$this->spill_create_ip = $value;
}
/**
* @param int $money
* @param string $orderNo
* @param string $openId
* @return Result
* @throws
*/
public function recharge(int $money, string $orderNo, string $openId = ''): Result
{
if ($money < 0) {
return new Result(code: 500, message: '充值金额不能小于0.');
}
$this->money = $money;
$this->orderNo = $orderNo;
$this->data['openid'] = $openId;
/**
* @param int $money
* @param string $orderNo
* @param string $openId
* @return Result
* @throws
*/
public function recharge(int $money, string $orderNo, string $openId = ''): Result
{
if ($money < 0) {
return new Result(code: 500, message: '充值金额不能小于0.');
}
$this->money = $money;
$this->orderNo = $orderNo;
$this->data['openid'] = $openId;
$client = new Client('qpay.qq.com', 443, true);
$client->withHeader(['Content-Type' => 'application/xml']);
$client->withBody($this->builder());
$client->post($this->uniformer);
$client->close();
$client = new Client('qpay.qq.com', 443, true);
$client->withHeader(['Content-Type' => 'application/xml']);
$client->withBody($this->builder());
$client->post($this->uniformer);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
}
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
return new Result(code: 503, message: $data['return_msg']);
}
if ($data['result_code'] != 'SUCCESS') {
return new Result(code: 504, message: $data['err_code_des']);
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
return new Result(code: 503, message: $data['return_msg']);
}
if ($data['result_code'] != 'SUCCESS') {
return new Result(code: 504, message: $data['err_code_des']);
}
return new Result(code: 0, data: $this->reception($data['prepayid']));
}
return new Result(code: 0, data: $this->reception($data['prepayid']));
}
/**
* @param string $prepay_id
* @return string
*/
public function reception(string $prepay_id): string
{
return Help::sign([
'signType' => $this->config->getSignType(),
'package' => 'prepay_id=' . $prepay_id,
'nonceStr' => Help::random(32),
'timestamp' => time()
], $this->getConfig()->getKey(), $this->getConfig()->getSignType());
}
/**
* @param string $prepay_id
* @return string
*/
public function reception(string $prepay_id): string
{
return Help::sign([
'signType' => $this->config->getSignType(),
'package' => 'prepay_id=' . $prepay_id,
'nonceStr' => Help::random(32),
'timestamp' => time()
], $this->getConfig()->getKey(), $this->getConfig()->getSignType());
}
/**
* @return string
*/
protected function builder(): string
{
$data = [
'appid' => $this->config->getAppid(),
'mch_id' => $this->config->getMchId(),
'nonce_str' => Help::random(32),
'body' => $this->config->getBody(),
'out_trade_no' => $this->orderNo,
'total_fee' => $this->money,
'spbill_create_ip' => $this->spill_create_ip,
'notify_url' => $this->config->getNotifyUrl(),
'trade_type' => $this->config->getTradeType(),
];
/**
* @return string
*/
protected function builder(): string
{
$data = [
'appid' => $this->config->getAppid(),
'mch_id' => $this->config->getMchId(),
'nonce_str' => Help::random(32),
'body' => $this->config->getBody(),
'out_trade_no' => $this->orderNo,
'total_fee' => $this->money,
'spbill_create_ip' => $this->spill_create_ip,
'notify_url' => $this->config->getNotifyUrl(),
'trade_type' => $this->config->getTradeType(),
];
$this->data = array_merge($data, $this->data);
$this->data = array_merge($data, $this->data);
$key = $this->config->getKey();
$sign_type = $this->config->getSignType();
$key = $this->config->getKey();
$sign_type = $this->config->getSignType();
$this->data['sign_type'] = $this->config->getSignType();
$this->data['sign'] = Help::sign($this->data, $key, $sign_type);
$this->data['sign_type'] = $this->config->getSignType();
$this->data['sign'] = Help::sign($this->data, $key, $sign_type);
return Help::toXml($this->data);
}
return Help::toXml($this->data);
}
}
+1 -1
View File
@@ -431,7 +431,7 @@ class Redhat extends SmallProgram
*/
public function redEnvelopes(): Result
{
$client = new Client('qpay.qq.com', 443, true);
$client = new Client('api.qpay.qq.com', 443, true);
$client->withHeader(['Content-Type' => 'application/json']);
$client->post($this->sendUrl, $this->generate());
$client->close();