10 Commits

Author SHA1 Message Date
as2252258 09544ee4a2 Default Changelist 2023-08-18 20:24:15 +08:00
as2252258 a7c6939a9f Default Changelist 2023-08-18 19:59:46 +08:00
as2252258 0578ba384b Default Changelist 2023-08-18 19:58:45 +08:00
as2252258 7abbaaca46 Default Changelist 2023-08-18 19:50:25 +08:00
as2252258 d574ce2c42 Default Changelist 2023-08-18 19:47:48 +08:00
as2252258 2275ed92d1 Default Changelist 2023-08-18 17:47:42 +08:00
as2252258 48467b88ce Default Changelist 2023-08-18 17:40:46 +08:00
as2252258 e87728266b Default Changelist 2023-08-18 16:59:47 +08:00
as2252258 ae67dce77b Default Changelist 2023-08-18 16:58:36 +08:00
as2252258 2ff7ceb66b Default Changelist 2023-08-18 16:57:32 +08:00
18 changed files with 41 additions and 173 deletions
+1 -1
View File
@@ -21,8 +21,8 @@
},
"require": {
"php": ">= 8.0",
"game-worker/kiri-client": "~v2.6",
"game-worker/kiri-container": "~v1.9",
"game-worker/kiri-client": "~v2.8",
"psr/container": "*"
},
"require-dev": {
+1 -1
View File
@@ -166,7 +166,7 @@ abstract class Subject extends Multiprogramming
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -137,7 +137,7 @@ abstract class Template extends Multiprogramming
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -57,7 +57,7 @@ class Result
public static function init(Client $client): static
{
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -56,7 +56,7 @@ class Recharge extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
+13 -145
View File
@@ -11,12 +11,9 @@ class Redhat extends SmallProgram
{
private string $charset = 'UTF8';
private string $nonce_str = '';
private string $sign = '';
private string $mch_billno = '';
private string $mch_id = '';
private string $mch_name = '';
private string $qqappid = '';
private string $re_openid = '';
private string $total_amount = '';
private string $total_num = '';
@@ -24,12 +21,9 @@ class Redhat extends SmallProgram
private string $act_name = '';
private string $icon_id = '';
private string $banner_id = '';
private string $notify_url = '';
private string $not_send_msg = '';
private string $min_value = '';
private string $max_value = '';
private string $key = '';
private string $signType = '';
private string $sendUrl = '/cgi-bin/hongbao/qpay_hb_mch_send.cgi';
@@ -51,22 +45,6 @@ class Redhat extends SmallProgram
$this->charset = $charset;
}
/**
* @return string
*/
public function getNonceStr(): string
{
return $this->nonce_str;
}
/**
* @param string $nonce_str
*/
public function setNonceStr(string $nonce_str): void
{
$this->nonce_str = $nonce_str;
}
/**
* @return string
*/
@@ -99,22 +77,6 @@ class Redhat extends SmallProgram
$this->mch_billno = $mch_billno;
}
/**
* @return string
*/
public function getMchId(): string
{
return $this->mch_id;
}
/**
* @param string $mch_id
*/
public function setMchId(string $mch_id): void
{
$this->mch_id = $mch_id;
}
/**
* @return string
*/
@@ -131,21 +93,6 @@ class Redhat extends SmallProgram
$this->mch_name = $mch_name;
}
/**
* @return string
*/
public function getQqappid(): string
{
return $this->qqappid;
}
/**
* @param string $qqappid
*/
public function setQqappid(string $qqappid): void
{
$this->qqappid = $qqappid;
}
/**
* @return string
@@ -259,22 +206,6 @@ class Redhat extends SmallProgram
$this->banner_id = $banner_id;
}
/**
* @return string
*/
public function getNotifyUrl(): string
{
return $this->notify_url;
}
/**
* @param string $notify_url
*/
public function setNotifyUrl(string $notify_url): void
{
$this->notify_url = $notify_url;
}
/**
* @return string
*/
@@ -323,84 +254,20 @@ class Redhat extends SmallProgram
$this->max_value = $max_value;
}
/**
* @return string
*/
public function getKey(): string
{
return $this->key;
}
/**
* @param string $key
*/
public function setKey(string $key): void
{
$this->key = $key;
}
/**
* @return string
*/
public function getSignType(): string
{
return $this->signType;
}
/**
* @param string $signType
*/
public function setSignType(string $signType): void
{
$this->signType = $signType;
}
/**
* @return string
*/
public function getSendUrl(): string
{
return $this->sendUrl;
}
/**
* @param string $sendUrl
*/
public function setSendUrl(string $sendUrl): void
{
$this->sendUrl = $sendUrl;
}
/**
* @return string
*/
public function getSearchUrl(): string
{
return $this->searchUrl;
}
/**
* @param string $searchUrl
*/
public function setSearchUrl(string $searchUrl): void
{
$this->searchUrl = $searchUrl;
}
/**
* @return mixed
* 构建请求参数
*/
private function generate(): array
public function generate(): array
{
$requestParam = [];
$requestParam['charset'] = $this->getCharset();
$requestParam['nonce_str'] = $this->getNonceStr();
$requestParam['nonce_str'] = Help::random(30);
$requestParam['mch_billno'] = $this->getMchBillno();
$requestParam['mch_id'] = $this->getMchId();
$requestParam['mch_id'] = $this->config->getMchId();
$requestParam['mch_name'] = $this->getMchName();
$requestParam['qqappid'] = $this->getQqappid();
$requestParam['qqappid'] = $this->config->getAppid();
$requestParam['re_openid'] = $this->getReOpenid();
$requestParam['total_amount'] = $this->getTotalAmount() * 100;
$requestParam['min_value'] = $this->getMinValue() * 100;
@@ -409,7 +276,7 @@ class Redhat extends SmallProgram
$requestParam['wishing'] = $this->getWishing();
$requestParam['act_name'] = $this->getActName();
$requestParam['icon_id'] = $this->getIconId();
$requestParam['notify_url'] = $this->getNotifyUrl();
$requestParam['notify_url'] = $this->config->getNotifyUrl();
$requestParam['sign'] = $this->builderSign($requestParam);
@@ -423,7 +290,7 @@ class Redhat extends SmallProgram
*/
private function builderSign($requestParam): string
{
return Help::sign($requestParam, $this->getKey(), $this->getSignType());
return Help::sign($requestParam, $this->config->getKey(), $this->config->getSignType());
}
/**
@@ -432,13 +299,14 @@ class Redhat extends SmallProgram
public function redEnvelopes(): Result
{
$client = new Client('api.qpay.qq.com', 443, true);
$client->withHeader(['Content-Type' => 'application/json']);
$client->withHeader(['Content-Type' => 'application/x-www-form-urlencoded']);
$client->withSslKeyFile($this->config->getSslKey());
$client->withSslCertFile($this->config->getSslCert());
$client->post($this->sendUrl, $this->generate());
$client->withCa($this->config->getSslCa());
$client->post($this->sendUrl, http_build_query($this->generate()));
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$json = json_decode($client->getBody(), true);
if (isset($json['return_code']) && $json['return_code'] != 'SUCCESS') {
@@ -459,8 +327,8 @@ class Redhat extends SmallProgram
*/
public function searchByOrderNo($listid, $orderNo = null): Result
{
$requestParam['nonce_str'] = $this->getNonceStr();
$requestParam['mch_id'] = $this->getMchId();
$requestParam['nonce_str'] = Help::random(31);
$requestParam['mch_id'] = $this->config->getMchId();
$requestParam['listid'] = $listid;
if (!empty($orderNo)) {
$requestParam['mch_billno'] = $orderNo;
@@ -471,7 +339,7 @@ class Redhat extends SmallProgram
$client->post($this->searchUrl, $requestParam);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$json = json_decode($client->getBody(), true);
if (isset($json['result']) && $json['result'] != 'SUCCESS') {
+2 -2
View File
@@ -40,7 +40,7 @@ class SecCheck extends SmallProgram
$client->upload($path, $data);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errCode']) && $body['errCode'] != 0) {
@@ -68,7 +68,7 @@ class SecCheck extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errCode']) && $body['errCode'] != 0) {
+1 -1
View File
@@ -25,7 +25,7 @@ class Token extends SmallProgram
$client->get('/api/getToken', $query);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -94,7 +94,7 @@ class Cash_Bonus extends SmallProgram
$client->post($this->_cash, $this->orderConfig($mch_billno, $openId, $price));
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$json = json_decode($client->getBody(), true);
+1 -1
View File
@@ -80,7 +80,7 @@ class Enterprise_payment extends SmallProgram
$client->post($this->_cash, $this->orderConfig($mch_billno, $openId, $price));
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$json = json_decode($client->getBody(), true);
if (isset($json['return_code']) && $json['return_code'] != 'SUCCESS') {
+5 -5
View File
@@ -34,7 +34,7 @@ class Account extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
@@ -63,7 +63,7 @@ class Account extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
@@ -115,7 +115,7 @@ class Account extends SmallProgram
$client->post($url . $this->getConfig()->getAccessToken(), $sendBody);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (!is_null($body)) {
@@ -151,7 +151,7 @@ class Account extends SmallProgram
$client->post($url . $this->getConfig()->getAccessToken(), $sendBody);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (!is_null($body)) {
@@ -187,7 +187,7 @@ class Account extends SmallProgram
$client->post($url . $this->getConfig()->getAccessToken(), $sendBody);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (!is_null($body)) {
+2 -2
View File
@@ -267,7 +267,7 @@ class Message extends SmallProgram
$this->msgData = [];
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
@@ -303,7 +303,7 @@ class Message extends SmallProgram
$this->msgData = [];
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -152,7 +152,7 @@ class PublicTemplate extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+3 -3
View File
@@ -42,7 +42,7 @@ class SecCheck extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
@@ -70,7 +70,7 @@ class SecCheck extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
@@ -108,7 +108,7 @@ class SecCheck extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -25,7 +25,7 @@ class Token extends SmallProgram
$client->get('cgi-bin/token', $query);
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$body = json_decode($client->getBody(), true);
if (isset($body['errcode']) && $body['errcode'] != 0) {
+1 -1
View File
@@ -39,7 +39,7 @@ class WxV2AppPayment extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
+4 -4
View File
@@ -41,7 +41,7 @@ class WxV2PayJsApi extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
@@ -87,7 +87,7 @@ class WxV2PayJsApi extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
@@ -133,7 +133,7 @@ class WxV2PayJsApi extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
@@ -179,7 +179,7 @@ class WxV2PayJsApi extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());
if (isset($data['return_code']) && $data['return_code'] != 'SUCCESS') {
+1 -1
View File
@@ -44,7 +44,7 @@ class WxV2Withdrawal extends SmallProgram
$client->close();
if (!in_array($client->getStatusCode(), [101, 200, 201])) {
return new Result(code: 505, message: 'network error.');
return new Result(code: 505, message: $client->getBody());
}
$data = Help::toArray($client->getBody());