Default Changelist

.gitignore

@@ -1,3 +1,4 @@
 /.idea/php.xml
 vendor/
 composer.lock
+.idea/*

wchat/base/Subject.php

@@ -162,6 +162,13 @@ abstract class Subject extends Multiprogramming
 
 		$client = new Client($this->getHost(), 443, true);
 		$client->withHeader(['Content-Type' => 'application/json; charset=utf-8']);
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->post($this->getUrl() . '?access_token=' . $access_token, $params);
 		$client->close();
 

wchat/base/Template.php

@@ -133,6 +133,13 @@ abstract class Template extends Multiprogramming
 
 		$client = new Client($this->getHost(), 443, true);
 		$client->withHeader(['Content-Type' => 'application/json; charset=utf-8']);
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->post($this->getUrl() . '?access_token=' . $access_token, $params);
 		$client->close();
 

wchat/common/Config.php

@@ -107,11 +107,19 @@ class Config
 
     private string $remote_addr = '127.0.0.1';
 
+
+    private string $proxyHost = '';
+    private int    $proxyPort = 0;
+
     private string $ssl_cert = '';
     private string $ssl_key  = '';
     private string $ssl_ca   = '';
     private int    $port     = 443;
 
+
+    private string $mchCert = '';
+    private string $mchKey = '';
+
     /**
      * @var string
      */
@@ -120,6 +128,38 @@ class Config
     private string $agent        = '';
     private bool   $usrSwoole    = false;
 
+    /**
+     * @return string
+     */
+    public function getMchCert(): string
+    {
+        return $this->mchCert;
+    }
+
+    /**
+     * @param string $mchCert
+     */
+    public function setMchCert(string $mchCert): void
+    {
+        $this->mchCert = $mchCert;
+    }
+
+    /**
+     * @return string
+     */
+    public function getMchKey(): string
+    {
+        return $this->mchKey;
+    }
+
+    /**
+     * @param string $mchKey
+     */
+    public function setMchKey(string $mchKey): void
+    {
+        $this->mchKey = $mchKey;
+    }
+
     /**
      * @return string
      */
@@ -152,6 +192,39 @@ class Config
         $this->serial_no = $serial_no;
     }
 
+    /**
+     * @param string $proxyHost
+     */
+    public function setProxyHost(string $proxyHost): void
+    {
+        $this->proxyHost = $proxyHost;
+    }
+
+
+    /**
+     * @param int $proxyPort
+     */
+    public function setProxyPort(int $proxyPort): void
+    {
+        $this->proxyPort = $proxyPort;
+    }
+
+    /**
+     * @return string
+     */
+    public function getProxyHost(): string
+    {
+        return $this->proxyHost;
+    }
+
+    /**
+     * @return int
+     */
+    public function getProxyPort(): int
+    {
+        return $this->proxyPort;
+    }
+
     /**
      * @return string
      */

wchat/qq/Account.php

@@ -27,6 +27,13 @@ class Account extends SmallProgram
 
 		$client = new Client('api.q.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->get('sns/jscode2session', $param);
 		$client->close();
 

wchat/qq/Recharge.php

@@ -52,6 +52,13 @@ class Recharge extends SmallProgram
         $client = new Client('qpay.qq.com', 443, true);
         $client->withHeader(['Content-Type' => 'application/xml']);
         $client->withBody($this->builder());
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->post($this->uniformer);
         $client->close();
 

wchat/qq/Redhat.php

@@ -303,6 +303,11 @@ class Redhat extends SmallProgram
         $client->withSslKeyFile($this->config->getSslKey());
         $client->withSslCertFile($this->config->getSslCert());
         $client->withCa($this->config->getSslCa());
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->sendUrl, http_build_query($this->generate()));
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {
@@ -336,6 +341,11 @@ class Redhat extends SmallProgram
 		$requestParam['sign'] = $this->builderSign($requestParam);
 		$client = new Client('qpay.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->searchUrl, $requestParam);
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/qq/SecCheck.php

@@ -37,6 +37,11 @@ class SecCheck extends SmallProgram
 		];
 		$client = new Client('api.q.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'multipart/form-data']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->upload($path, $data);
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {
@@ -64,6 +69,11 @@ class SecCheck extends SmallProgram
 
 		$client = new Client('api.q.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($url, ['appid' => $this->config->getAppid(), 'content' => $content]);
 		$client->close();
 

wchat/qq/Token.php

@@ -22,6 +22,11 @@ class Token extends SmallProgram
 		];
 		$client = new Client('api.q.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->get('/api/getToken', $query);
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/qq/pay/Cash_Bonus.php

@@ -91,6 +91,13 @@ class Cash_Bonus extends SmallProgram
 		$client->withSslCertFile($this->getConfig()->getSslCert());
 		$client->withSslKeyFile($this->getConfig()->getSslKey());
 		$client->withCa($this->getConfig()->getSslCa());
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->post($this->_cash, $this->orderConfig($mch_billno, $openId, $price));
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/qq/pay/Enterprise_payment.php

@@ -77,6 +77,13 @@ class Enterprise_payment extends SmallProgram
 		$client->withSslCertFile($this->getConfig()->getSslCert());
 		$client->withSslKeyFile($this->getConfig()->getSslKey());
 		$client->withCa($this->getConfig()->getSslCa());
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
         $client->post($this->_cash, $this->orderConfig($mch_billno, $openId, $price));
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/wx/Account.php

@@ -30,6 +30,9 @@ class Account extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        if (!empty($this->getConfig()->getProxyHost()) && $this->getConfig()->getProxyPort() > 0) {
+            $client->withProxyHost("192.168.0.57")->withProxyPort(12286);
+        }
 		$client->get('sns/jscode2session', $param);
 		$client->close();
 
@@ -59,6 +62,9 @@ class Account extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        if (!empty($this->getConfig()->getProxyHost()) && $this->getConfig()->getProxyPort() > 0) {
+            $client->withProxyHost("192.168.0.57")->withProxyPort(12286);
+        }
 		$client->get('cgi-bin/user/info', $query);
 		$client->close();
 
@@ -112,6 +118,12 @@ class Account extends SmallProgram
 		$sendBody['width'] = $width;
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($url . $this->getConfig()->getAccessToken(), $sendBody);
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/wx/Message.php

@@ -261,6 +261,11 @@ class Message extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'multipart/form-data']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($url, $data);
 		$client->close();
 
@@ -297,6 +302,11 @@ class Message extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($url, $this->msgData);
 		$client->close();
 

wchat/wx/PublicTemplate.php

@@ -148,6 +148,11 @@ class PublicTemplate extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($url, $default);
 		$client->close();
 

wchat/wx/SecCheck.php

@@ -36,6 +36,11 @@ class SecCheck extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'multipart/form-data']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->upload($this->_url . '?access_token=' . $access_token, [
 			'media' => new \CURLFile($path)
 		]);
@@ -66,6 +71,11 @@ class SecCheck extends SmallProgram
 		$requestUrl = $this->_mediaCheckAsync . $this->config->getAccessToken();
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($requestUrl, ['media_url' => $url, 'media_type' => $type]);
 		$client->close();
 
@@ -104,6 +114,11 @@ class SecCheck extends SmallProgram
 
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($requestUrl, ['content' => $content]);
 		$client->close();
 

wchat/wx/Token.php

@@ -22,6 +22,11 @@ class Token extends SmallProgram
 		];
 		$client = new Client('api.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->get('cgi-bin/token', $query);
 		$client->close();
 		if (!in_array($client->getStatusCode(), [101, 200, 201])) {

wchat/wx/V2/WxV2AppPayment.php

@@ -34,6 +34,11 @@ class WxV2AppPayment extends SmallProgram
 
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->withBody($this->sign($body));
 		$client->post($this->uniformed);
 		$client->close();

wchat/wx/V2/WxV2PayJsApi.php

@@ -37,6 +37,11 @@ class WxV2PayJsApi extends SmallProgram
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
 		$client->withBody($this->sign($body));
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->uniformed);
 		$client->close();
 
@@ -83,6 +88,11 @@ class WxV2PayJsApi extends SmallProgram
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
 		$client->withBody($this->sign($body));
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->uniformed);
 		$client->close();
 
@@ -129,6 +139,11 @@ class WxV2PayJsApi extends SmallProgram
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
 		$client->withBody($this->sign($body));
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->uniformed);
 		$client->close();
 
@@ -175,6 +190,11 @@ class WxV2PayJsApi extends SmallProgram
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
 		$client->withBody($this->sign($body));
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->uniformed);
 		$client->close();
 

wchat/wx/V2/WxV2Withdrawal.php

@@ -40,6 +40,11 @@ class WxV2Withdrawal extends SmallProgram
 		$client = new Client('api.mch.weixin.qq.com', 443, true);
 		$client->withHeader(['Content-Type' => 'application/json']);
 		$client->withBody($body = Help::toXml($array));
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
 		$client->post($this->transfers);
 		$client->close();
 

wchat/wx/V3/TransferBatches.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace wchat\wx\V3;
+
+use Exception;
+use JetBrains\PhpStorm\ArrayShape;
+use Kiri\Client;
+use Kiri\CurlClient;
+use wchat\wx\SmallProgram;
+
+class TransferBatches extends SmallProgram
+{
+    use WxV3PaymentTait;
+
+
+    /**
+     * @param TransferDetail $detail
+     * @return array
+     * @throws Exception
+     */
+    #[ArrayShape([])]
+    public function request(TransferDetail $detail): array
+    {
+        $body                         = [];
+        $body['appid']                = $this->getConfig()->getAppid();
+        $body['out_batch_no']         = $detail->out_detail_no;
+        $body["batch_name"]           = $this->getConfig()->getBody();
+        $body["body"]                 = $this->getConfig()->getBody();
+        $body["batch_remark"]         = $this->getConfig()->getBody();
+        $body["total_amount"]         = $detail->transfer_amount;
+        $body["total_num"]            = 1;
+        $body["transfer_detail_list"] = [$detail->toArray()];
+
+        $sign = $this->signature('POST', '/v3/transfer/batches', $json = json_encode($body, JSON_UNESCAPED_UNICODE));
+
+        $client = new Client('api.mch.weixin.qq.com', 443, TRUE);
+        $client->withAddedHeader('Authorization', $sign)->withContentType('application/json')
+               ->withAgent('application/json')->withBody($json)->withAddedHeader("Accept", "*/*");
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
+        $client->post('/v3/transfer/batches');
+        $client->close();
+
+        $data = json_decode($client->getBody(), TRUE);
+        if (json_last_error() != JSON_ERROR_NONE) {
+            return ['code' => $client->getStatusCode(), 'message' => $client->getBody()];
+        } else {
+            return $data;
+        }
+    }
+}

wchat/wx/V3/TransferDetail.php

@@ -24,6 +24,14 @@ class TransferDetail
     #[ArrayShape(['out_detail_no' => "string", 'transfer_amount' => "float|int", 'transfer_remark' => "string", 'openid' => "string", 'user_name' => "string"])]
     public function toArray(): array
     {
+        if (empty($this->user_name)) {
+            return [
+                'out_detail_no'   => $this->out_detail_no,
+                'transfer_amount' => $this->transfer_amount,
+                'transfer_remark' => $this->transfer_remark,
+                'openid'          => $this->openid,
+            ];
+        }
         return [
             'out_detail_no'   => $this->out_detail_no,
             'transfer_amount' => $this->transfer_amount,

wchat/wx/V3/WxV3AppPayment.php

@@ -31,8 +31,15 @@ class WxV3AppPayment extends SmallProgram
 
         $client = new Client('api.mch.weixin.qq.com', 443, TRUE);
         $client->withAddedHeader('Authorization', $sign)->withContentType('application/json')
-			->withAgent('application/json')->withBody($json)
+               ->withAgent('application/json')->withBody($json)->withAddedHeader("Accept", "*/*");
-			->post('/v3/pay/transactions/components');
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
+        $client->post('/v3/pay/transactions/components');
         $client->close();
 
         $json = json_decode($client->getBody(), TRUE);

wchat/wx/V3/WxV3NativePayment.php

@@ -4,7 +4,6 @@ namespace wchat\wx\V3;
 
 use Exception;
 use Kiri\Client;
-use Kiri\Message\Stream;
 use JetBrains\PhpStorm\ArrayShape;
 use wchat\wx\SmallProgram;
 
@@ -32,8 +31,15 @@ class WxV3NativePayment extends SmallProgram
 
         $client = new Client('api.mch.weixin.qq.com', 443, TRUE);
         $client->withAddedHeader('Authorization', $sign)->withContentType('application/json')
-            ->withAgent('application/json')->withBody(new Stream($json))
+            ->withAgent('application/json')->withBody($json)->withAddedHeader("Accept", "*/*");
-            ->post('/v3/pay/transactions/native');
+
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
+        $client->post('/v3/pay/transactions/native');
         $client->close();
 
         $json = json_decode($client->getBody(), TRUE);

wchat/wx/V3/WxV3Payment.php

@@ -4,7 +4,6 @@ namespace wchat\wx\V3;
 
 use Exception;
 use Kiri\Client;
-use Kiri\Message\Stream;
 use wchat\wx\SmallProgram;
 
 class WxV3Payment extends SmallProgram
@@ -32,10 +31,16 @@ class WxV3Payment extends SmallProgram
 
         $client = new Client('api.mch.weixin.qq.com', 443, TRUE);
         $client->withAddedHeader('Authorization', $sign)
-	        ->withContentType('application/json')
+	        ->withContentType('application/json')->withAddedHeader('User-Agent', 'application/json')
-            ->withAddedHeader('User-Agent', 'application/json')
+	        ->withBody($json)->withAddedHeader("Accept", "*/*");
-	        ->withBody(new Stream($json))
+
-            ->post('/v3/pay/transactions/jsapi');
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
+        $client->post('/v3/pay/transactions/jsapi');
         $client->close();
 
         $json = json_decode($client->getBody(), TRUE);

wchat/wx/V3/WxV3PaymentTait.php

@@ -39,7 +39,10 @@ trait WxV3PaymentTait
      */
     public function signature(string $http_method, string $canonical_url, string $body = ''): string
     {
-		$message = $http_method . "\n" . $canonical_url . "\n" . ($time = time()) . "\n" . ($rand = md5(random_bytes(32))) . "\n" . $body . "\n";
+        $rand    = md5(random_bytes(32));
+        $time    = time();
+
+        $message = sprintf("%s\n%s\n%d\n%s\n%s\n", $http_method, $canonical_url, $time, $rand, $body);
 
         $sign = $this->openssl_signature($message);
 
@@ -54,7 +57,7 @@ trait WxV3PaymentTait
      */
     public function openssl_signature($body): string
     {
-		$pem = file_get_contents($this->getConfig()->getSslCert());
+        $pem = file_get_contents($this->getConfig()->getMchKey());
 
         $mch_private_key = openssl_get_privatekey($pem);
 

wchat/wx/V3/WxV3Withdrawal.php

@@ -31,10 +31,16 @@ class WxV3Withdrawal extends SmallProgram
 
         $client = new Client('api.mch.weixin.qq.com', 443, TRUE);
         $client->withAddedHeader('Authorization', $sign)
-			->withContentType('application/json')
+               ->withContentType('application/json')->withAddedHeader('User-Agent', 'application/json')
-			->withAddedHeader('User-Agent', 'application/json')
+               ->withBody($json)->withAddedHeader("Accept", "*/*");
-			->withBody(new Stream($json))
+
-			->post('/v3/pay/transactions/batches');
+        $proxyHost = $this->getConfig()->getProxyHost();
+        $proxyPort = $this->getConfig()->getProxyPort();
+        if (!empty($proxyHost) && $proxyPort > 0) {
+            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
+        }
+
+        $client->post('/v3/pay/transactions/batches');
         $client->close();
 
         $json = json_decode($client->getBody(), TRUE);