yansongda / pay

src/Plugin/Unipay/StartPlugin.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
 
         $certs['cert_id'] = $ssl['serialNumber'] ?? '';
 
-        Pay::get(ConfigInterface::class)->set('unipay.'.$tenant.'.certs', $certs);
+        Pay::get(ConfigInterface::class)->set('unipay.' . $tenant . '.certs', $certs);
 
         return $certs['cert_id'];
     }

src/Plugin/Unipay/ResponseHtmlPlugin.php

Spacing +2 added lines, -2 removed lines

@@ -35,9 +35,9 @@
 
     protected function buildHtml(string $endpoint, array $payload): Response
     {
-        $sHtml = "<form id='pay_form' name='pay_form' action='".$endpoint."' method='POST'>";
+        $sHtml = "<form id='pay_form' name='pay_form' action='" . $endpoint . "' method='POST'>";
         foreach ($payload as $key => $val) {
-            $sHtml .= "<input type='hidden' name='".$key."' value='".$val."'/>";
+            $sHtml .= "<input type='hidden' name='" . $key . "' value='" . $val . "'/>";
         }
         $sHtml .= "<input type='submit' value='ok' style='display:none;'></form>";
         $sHtml .= "<script>document.forms['pay_form'].submit();</script>";

src/Functions.php

Spacing +14 added lines, -14 removed lines

@@ -49,7 +49,7 @@ 
         $direction = Pay::get($direction);
 
         $direction = is_string($direction) ? Pay::get($direction) : $direction;
-    } catch (ContainerException|ServiceNotFoundException) {
+    } catch (ContainerException | ServiceNotFoundException) {
     }
 
     if (!$direction instanceof DirectionInterface) {
@@ -70,8 +70,8 @@ 
         return file_get_contents($key);
     }
 
-    return "-----BEGIN RSA PRIVATE KEY-----\n".
-        wordwrap($key, 64, "\n", true).
+    return "-----BEGIN RSA PRIVATE KEY-----\n" .
+        wordwrap($key, 64, "\n", true) .
         "\n-----END RSA PRIVATE KEY-----";
 }
 
@@ -175,7 +175,7 @@ 
         return $url;
     }
 
-    return Wechat::URL[$config['mode'] ?? Pay::MODE_NORMAL].$url;
+    return Wechat::URL[$config['mode'] ?? Pay::MODE_NORMAL] . $url;
 }
 
 /**
@@ -194,7 +194,7 @@ 
 
 function get_wechat_type_key(array $params): string
 {
-    $key = ($params['_type'] ?? 'mp').'_app_id';
+    $key = ($params['_type'] ?? 'mp') . '_app_id';
 
     if ('app_app_id' === $key) {
         $key = 'app_id';
@@ -239,10 +239,10 @@ 
     $buff = '';
 
     foreach ($payload as $k => $v) {
-        $buff .= ('sign' != $k && '' != $v && !is_array($v)) ? $k.'='.$v.'&' : '';
+        $buff .= ('sign' != $k && '' != $v && !is_array($v)) ? $k . '=' . $v . '&' : '';
     }
 
-    $sign = md5($buff.'key='.$key);
+    $sign = md5($buff . 'key=' . $key);
 
     return $upper ? strtoupper($sign) : $sign;
 }
@@ -255,7 +255,7 @@ 
  * @throws InvalidSignException
  * @throws ServiceNotFoundException
  */
-function verify_wechat_sign(ResponseInterface|ServerRequestInterface $message, array $params): void
+function verify_wechat_sign(ResponseInterface | ServerRequestInterface $message, array $params): void
 {
     if ($message instanceof ServerRequestInterface && 'localhost' === $message->getUri()->getHost()) {
         return;
@@ -267,7 +267,7 @@ 
     $sign = $message->getHeaderLine('Wechatpay-Signature');
     $body = (string) $message->getBody();
 
-    $content = $timestamp."\n".$random."\n".$body."\n";
+    $content = $timestamp . "\n" . $random . "\n" . $body . "\n";
     $public = get_wechat_config($params)['wechat_public_cert_path'][$wechatSerial] ?? null;
 
     if (empty($sign)) {
@@ -329,7 +329,7 @@ 
     }
 
     Pay::get(ConfigInterface::class)->set(
-        'wechat.'.get_tenant($params).'.wechat_public_cert_path',
+        'wechat.' . get_tenant($params) . '.wechat_public_cert_path',
         ((array) ($wechatConfig['wechat_public_cert_path'] ?? [])) + ($certs ?? []),
     );
 
@@ -360,7 +360,7 @@ 
     }
 
     foreach ($config['wechat_public_cert_path'] as $serialNo => $cert) {
-        file_put_contents($path.'/'.$serialNo.'.crt', $cert);
+        file_put_contents($path . '/' . $serialNo . '.crt', $cert);
     }
 }
 
@@ -392,7 +392,7 @@ 
 /**
  * @throws DecryptException
  */
-function decrypt_wechat_resource_aes_256_gcm(string $ciphertext, string $secret, string $nonce, string $associatedData): array|string
+function decrypt_wechat_resource_aes_256_gcm(string $ciphertext, string $secret, string $nonce, string $associatedData): array | string
 {
     $decrypted = openssl_decrypt(
         substr($ciphertext, 0, -Wechat::AUTH_TAG_LENGTH_BYTE),
@@ -453,7 +453,7 @@ 
     $publicKey = $config['wechat_public_cert_path'][$serialNo] ?? null;
 
     if (empty($publicKey)) {
-        throw new InvalidParamsException(Exception::PARAMS_WECHAT_SERIAL_NOT_FOUND, '参数异常: 微信公钥序列号为找到 -'.$serialNo);
+        throw new InvalidParamsException(Exception::PARAMS_WECHAT_SERIAL_NOT_FOUND, '参数异常: 微信公钥序列号为找到 -' . $serialNo);
     }
 
     return $publicKey;
@@ -511,7 +511,7 @@ 
         return $url;
     }
 
-    return Unipay::URL[$config['mode'] ?? Pay::MODE_NORMAL].$url;
+    return Unipay::URL[$config['mode'] ?? Pay::MODE_NORMAL] . $url;
 }
 
 /**

src/Provider/AbstractProvider.php

Spacing +3 added lines, -3 removed lines

@@ -33,7 +33,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function shortcut(string $shortcut, array $params = []): null|Collection|MessageInterface|Rocket
+    public function shortcut(string $shortcut, array $params = []): null | Collection | MessageInterface | Rocket
     {
         if (!class_exists($shortcut) || !in_array(ShortcutInterface::class, class_implements($shortcut))) {
             throw new InvalidParamsException(Exception::PARAMS_SHORTCUT_NOT_FOUND, "参数异常: [{$shortcut}] 未实现 `ShortcutInterface`");
@@ -49,7 +49,7 @@ 
      * @throws ContainerException
      * @throws InvalidParamsException
      */
-    public function pay(array $plugins, array $params): null|Collection|MessageInterface|Rocket
+    public function pay(array $plugins, array $params): null | Collection | MessageInterface | Rocket
     {
         Logger::info('[AbstractProvider] 即将进行 pay 操作', func_get_args());
 
@@ -107,7 +107,7 @@ 
         } catch (Throwable $e) {
             Logger::error('[AbstractProvider] 请求支付服务商 API 出错', ['message' => $e->getMessage(), 'rocket' => $rocket->toArray(), 'trace' => $e->getTrace()]);
 
-            throw new InvalidResponseException(Exception::REQUEST_RESPONSE_ERROR, '响应异常: 请求支付服务商 API 出错 - '.$e->getMessage(), [], $e);
+            throw new InvalidResponseException(Exception::REQUEST_RESPONSE_ERROR, '响应异常: 请求支付服务商 API 出错 - ' . $e->getMessage(), [], $e);
         }
 
         Logger::info('[AbstractProvider] 请求支付服务商 API 成功', ['response' => ['status' => $response->getStatusCode(), 'headers' => $response->getHeaders(), 'body' => (string) $response->getBody()], 'rocket' => $rocket->toArray()]);

src/Provider/Wechat.php

Spacing +8 added lines, -8 removed lines

@@ -55,9 +55,9 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function __call(string $shortcut, array $params): null|Collection|MessageInterface
+    public function __call(string $shortcut, array $params): null | Collection | MessageInterface
     {
-        $plugin = '\\Yansongda\\Pay\\Shortcut\\Wechat\\'.Str::studly($shortcut).'Shortcut';
+        $plugin = '\\Yansongda\\Pay\\Shortcut\\Wechat\\' . Str::studly($shortcut) . 'Shortcut';
 
         return $this->shortcut($plugin, ...$params);
     }
@@ -67,7 +67,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function query(array $order): Collection|Rocket
+    public function query(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('wechat', __METHOD__, $order, null));
 
@@ -77,7 +77,7 @@ 
     /**
      * @throws InvalidParamsException
      */
-    public function cancel(array $order): Collection|Rocket
+    public function cancel(array $order): Collection | Rocket
     {
         throw new InvalidParamsException(Exception::PARAMS_METHOD_NOT_SUPPORTED, '参数异常: 微信不支持 cancel API');
     }
@@ -87,7 +87,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function close(array $order): Collection|Rocket
+    public function close(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('wechat', __METHOD__, $order, null));
 
@@ -101,7 +101,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function refund(array $order): Collection|Rocket
+    public function refund(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('wechat', __METHOD__, $order, null));
 
@@ -112,7 +112,7 @@ 
      * @throws ContainerException
      * @throws InvalidParamsException
      */
-    public function callback(null|array|ServerRequestInterface $contents = null, ?array $params = null): Collection|Rocket
+    public function callback(null | array | ServerRequestInterface $contents = null, ?array $params = null): Collection | Rocket
     {
         $request = $this->getCallbackParams($contents);
 
@@ -142,7 +142,7 @@ 
         );
     }
 
-    protected function getCallbackParams(null|array|ServerRequestInterface $contents = null): ServerRequestInterface
+    protected function getCallbackParams(null | array | ServerRequestInterface $contents = null): ServerRequestInterface
     {
         if (is_array($contents) && isset($contents['body'], $contents['headers'])) {
             return new ServerRequest('POST', 'http://localhost', $contents['headers'], $contents['body']);

src/Provider/Unipay.php

Spacing +8 added lines, -8 removed lines

@@ -42,9 +42,9 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function __call(string $shortcut, array $params): null|Collection|MessageInterface|Rocket
+    public function __call(string $shortcut, array $params): null | Collection | MessageInterface | Rocket
     {
-        $plugin = '\\Yansongda\\Pay\\Shortcut\\Unipay\\'.Str::studly($shortcut).'Shortcut';
+        $plugin = '\\Yansongda\\Pay\\Shortcut\\Unipay\\' . Str::studly($shortcut) . 'Shortcut';
 
         return $this->shortcut($plugin, ...$params);
     }
@@ -54,7 +54,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function query(array $order): Collection|Rocket
+    public function query(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('unipay', __METHOD__, $order, null));
 
@@ -66,7 +66,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function cancel(array $order): Collection|Rocket
+    public function cancel(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('unipay', __METHOD__, $order, null));
 
@@ -76,7 +76,7 @@ 
     /**
      * @throws InvalidParamsException
      */
-    public function close(array $order): Collection|Rocket
+    public function close(array $order): Collection | Rocket
     {
         throw new InvalidParamsException(Exception::PARAMS_METHOD_NOT_SUPPORTED, '参数异常: 银联不支持 close API');
     }
@@ -86,7 +86,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function refund(array $order): Collection|Rocket
+    public function refund(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('unipay', __METHOD__, $order, null));
 
@@ -97,7 +97,7 @@ 
      * @throws ContainerException
      * @throws InvalidParamsException
      */
-    public function callback(null|array|ServerRequestInterface $contents = null, ?array $params = null): Collection|Rocket
+    public function callback(null | array | ServerRequestInterface $contents = null, ?array $params = null): Collection | Rocket
     {
         $request = $this->getCallbackParams($contents);
 
@@ -123,7 +123,7 @@ 
         );
     }
 
-    protected function getCallbackParams(null|array|ServerRequestInterface $contents = null): Collection
+    protected function getCallbackParams(null | array | ServerRequestInterface $contents = null): Collection
     {
         if (is_array($contents)) {
             return Collection::wrap($contents);

src/Provider/Alipay.php

Spacing +9 added lines, -10 removed lines

@@ -48,9 +48,9 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function __call(string $shortcut, array $params): null|Collection|MessageInterface|Rocket
+    public function __call(string $shortcut, array $params): null | Collection | MessageInterface | Rocket
     {
-        $plugin = '\\Yansongda\\Pay\\Shortcut\\Alipay\\'.Str::studly($shortcut).'Shortcut';
+        $plugin = '\\Yansongda\\Pay\\Shortcut\\Alipay\\' . Str::studly($shortcut) . 'Shortcut';
 
         return $this->shortcut($plugin, ...$params);
     }
@@ -60,7 +60,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function query(array $order): Collection|Rocket
+    public function query(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('alipay', __METHOD__, $order, null));
 
@@ -72,7 +72,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function cancel(array $order): Collection|Rocket
+    public function cancel(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('alipay', __METHOD__, $order, null));
 
@@ -84,7 +84,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function close(array $order): Collection|Rocket
+    public function close(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('alipay', __METHOD__, $order, null));
 
@@ -96,7 +96,7 @@ 
      * @throws InvalidParamsException
      * @throws ServiceNotFoundException
      */
-    public function refund(array $order): Collection|Rocket
+    public function refund(array $order): Collection | Rocket
     {
         Event::dispatch(new Event\MethodCalled('alipay', __METHOD__, $order, null));
 
@@ -107,7 +107,7 @@ 
      * @throws ContainerException
      * @throws InvalidParamsException
      */
-    public function callback(null|array|ServerRequestInterface $contents = null, ?array $params = null): Collection
+    public function callback(null | array | ServerRequestInterface $contents = null, ?array $params = null): Collection
     {
         $request = $this->getCallbackParams($contents);
 
@@ -130,15 +130,14 @@ 
         );
     }
 
-    protected function getCallbackParams(array|ServerRequestInterface $contents = null): Collection
+    protected function getCallbackParams(array | ServerRequestInterface $contents = null): Collection
     {
         if (is_array($contents)) {
             return Collection::wrap($contents);
         }
 
         if ($contents instanceof ServerRequestInterface) {
-            return Collection::wrap('GET' === $contents->getMethod() ? $contents->getQueryParams() :
-                $contents->getParsedBody());
+            return Collection::wrap('GET' === $contents->getMethod() ? $contents->getQueryParams() : $contents->getParsedBody());
         }
 
         $request = ServerRequest::fromGlobals();

src/Plugin/Alipay/V2/ResponseHtmlPlugin.php

Spacing +4 added lines, -5 removed lines

@@ -23,8 +23,7 @@ 
         $radar = $rocket->getRadar();
 
         $response = 'GET' === $radar->getMethod() ?
-            $this->buildRedirect($radar->getUri()->__toString(), $rocket->getPayload()) :
-            $this->buildHtml($radar->getUri()->__toString(), $rocket->getPayload());
+            $this->buildRedirect($radar->getUri()->__toString(), $rocket->getPayload()) : $this->buildHtml($radar->getUri()->__toString(), $rocket->getPayload());
 
         $rocket->setDestination($response);
 
@@ -35,7 +34,7 @@ 
 
     protected function buildRedirect(string $endpoint, Collection $payload): Response
     {
-        $url = $endpoint.(!str_contains($endpoint, '?') ? '?' : '&').$payload->query();
+        $url = $endpoint . (!str_contains($endpoint, '?') ? '?' : '&') . $payload->query();
 
         $content = sprintf(
             '<!DOCTYPE html>
@@ -58,10 +57,10 @@ 
 
     protected function buildHtml(string $endpoint, Collection $payload): Response
     {
-        $sHtml = "<form id='alipay_submit' name='alipay_submit' action='".$endpoint."' method='POST'>";
+        $sHtml = "<form id='alipay_submit' name='alipay_submit' action='" . $endpoint . "' method='POST'>";
         foreach ($payload->all() as $key => $val) {
             $val = str_replace("'", '&apos;', $val);
-            $sHtml .= "<input type='hidden' name='".$key."' value='".$val."'/>";
+            $sHtml .= "<input type='hidden' name='" . $key . "' value='" . $val . "'/>";
         }
         $sHtml .= "<input type='submit' value='ok' style='display:none;'></form>";
         $sHtml .= "<script>document.forms['alipay_submit'].submit();</script>";

src/Plugin/Alipay/V2/ResponsePlugin.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 
         $destination = $rocket->getDestination();
         $payload = $rocket->getPayload();
-        $resultKey = str_replace('.', '_', $payload->get('method')).'_response';
+        $resultKey = str_replace('.', '_', $payload->get('method')) . '_response';
 
         if (should_do_http_request($rocket->getDirection()) && $destination instanceof Collection) {
             $rocket->setDestination(new Collection(array_merge(