feat: 增加微信v2支付中签约插件 (#763)

src/Plugin/Wechat/Papay/PayContractOrderPlugin.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace Yansongda\Pay\Plugin\Wechat\Papay;
+
+use Yansongda\Pay\Plugin\Wechat\GeneralV2Plugin;
+use Yansongda\Pay\Rocket;
+
+class PayContractOrderPlugin extends GeneralV2Plugin
+{
+    protected function getUri(Rocket $rocket): string
+    {
+        return 'pay/contractorder';
+    }
+}

src/Plugin/Wechat/Pay/Common/InvokePrepayV2Plugin.php

@@ -0,0 +1,119 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yansongda\Pay\Plugin\Wechat\Pay\Common;
+
+use Closure;
+use Yansongda\Pay\Contract\PluginInterface;
+use Yansongda\Pay\Exception\Exception;
+use Yansongda\Pay\Exception\InvalidConfigException;
+use Yansongda\Pay\Exception\InvalidResponseException;
+
+use function Yansongda\Pay\get_wechat_config;
+
+use Yansongda\Pay\Logger;
+use Yansongda\Pay\Pay;
+use Yansongda\Pay\Rocket;
+use Yansongda\Supports\Collection;
+use Yansongda\Supports\Config;
+use Yansongda\Supports\Str;
+
+class InvokePrepayV2Plugin implements PluginInterface
+{
+    /**
+     * @throws \Yansongda\Pay\Exception\ContainerException
+     * @throws \Yansongda\Pay\Exception\InvalidResponseException
+     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
+     * @throws \Exception
+     */
+    public function assembly(Rocket $rocket, Closure $next): Rocket
+    {
+        /* @var Rocket $rocket */
+        $rocket = $next($rocket);
+
+        Logger::debug('[wechat][InvokePrepayPlugin] 插件开始装载', ['rocket' => $rocket]);
+
+        $prepayId = $rocket->getDestination()->get('prepay_id');
+
+        if (is_null($prepayId)) {
+            Logger::error('[wechat][InvokePrepayPlugin] 预下单失败：响应缺少 prepay_id 参数，请自行检查参数是否符合微信要求', $rocket->getDestination()->all());
+
+            throw new InvalidResponseException(Exception::RESPONSE_MISSING_NECESSARY_PARAMS, 'Prepay Response Error: Missing PrepayId', $rocket->getDestination()->all());
+        }
+
+        $config = $this->getInvokeConfig($rocket, $prepayId);
+
+        $rocket->setDestination($config);
+
+        Logger::info('[wechat][InvokePrepayPlugin] 插件装载完毕', ['rocket' => $rocket]);
+
+        return $rocket;
+    }
+
+    /**
+     * @throws \Yansongda\Pay\Exception\ContainerException
+     * @throws \Yansongda\Pay\Exception\InvalidConfigException
+     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
+     */
+    protected function getSign(Collection $invokeConfig, array $params): string
+    {
+        $secret = get_wechat_config($params)['mch_secret_key_v2'] ?? null;
+        if (empty($secret)) {
+            throw new InvalidConfigException(Exception::WECHAT_CONFIG_ERROR, 'Missing Wechat Config -- [mch_secret_key_v2]');
+        }
+
+        $data = $invokeConfig->toArray();
+        ksort($data);
+        $contents = '';
+        foreach ($data as $key => $datum) {
+            $contents .= $key.'='.$datum.'&';
+        }
+        $contents .= 'key='.$secret;
+
+        return md5($contents);
+    }
+
+    /**
+     * @throws \Yansongda\Pay\Exception\ContainerException
+     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
+     * @throws \Exception
+     */
+    protected function getInvokeConfig(Rocket $rocket, string $prepayId): Config
+    {
+        $config = new Config([
+            'appId' => $this->getAppId($rocket),
+            'timeStamp' => time().'',
+            'nonceStr' => Str::random(32),
+            'package' => 'prepay_id='.$prepayId,
+            'signType' => 'MD5',
+        ]);
+
+        $config->set('paySign', $this->getSign($config, $rocket->getParams()));
+
+        return $config;
+    }
+
+    /**
+     * @throws \Yansongda\Pay\Exception\ContainerException
+     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
+     */
+    protected function getAppId(Rocket $rocket): string
+    {
+        $config = get_wechat_config($rocket->getParams());
+        $payload = $rocket->getPayload();
+
+        if (Pay::MODE_SERVICE === ($config['mode'] ?? null) && $payload->has('sub_appid')) {
+            return $payload->get('sub_appid', '');
+        }
+
+        return $config[$this->getConfigKey($rocket->getParams())] ?? '';
+    }
+
+    protected function getConfigKey(array $params): string
+    {
+        $type = $params['_type'] ?? 'mp';
+
+        return $type.'_app_id';
+    }
+}

src/Plugin/Wechat/Shortcut/PapayShortcut.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace Yansongda\Pay\Plugin\Wechat\Shortcut;
+
+use Yansongda\Pay\Contract\ShortcutInterface;
+use Yansongda\Pay\Plugin\ParserPlugin;
+use Yansongda\Pay\Plugin\Wechat\Papay\PayContractOrderPlugin;
+use Yansongda\Pay\Plugin\Wechat\Pay\Common\InvokePrepayV2Plugin;
+use Yansongda\Pay\Plugin\Wechat\PreparePlugin;
+use Yansongda\Pay\Plugin\Wechat\RadarSignPlugin;
+
+/**
+ * 支付中签约.
+ */
+class PapayShortcut implements ShortcutInterface
+{
+    public function getPlugins(array $params): array
+    {
+        return [
+            PreparePlugin::class,
+            PayContractOrderPlugin::class,
+            RadarSignPlugin::class,
+            InvokePrepayV2Plugin::class,
+            ParserPlugin::class,
+        ];
+    }
+}