feat: 增加支付宝商品文件上传插件 (#1120)

Author: xiaohua037

CHANGELOG.md

@@ -1,3 +1,9 @@
+## v3.7.19
+
+### added
+
+- feat: 增加支付宝商品文件上传插件 (#1120)
+
 ## v3.7.18
 
 ### fixed

src/Plugin/Alipay/V2/AddRadarPlugin.php

@@ -5,6 +5,7 @@
 namespace Yansongda\Pay\Plugin\Alipay\V2;
 
 use Closure;
+use GuzzleHttp\Psr7\MultipartStream;
 use GuzzleHttp\Psr7\Request;
 use Yansongda\Artful\Contract\PluginInterface;
 use Yansongda\Artful\Exception\ContainerException;
@@ -35,21 +36,44 @@ public function assembly(Rocket $rocket, Closure $next): Rocket
             // 这里因为支付宝的 payload 里不包含 _method，所以需要取 params 中的
             get_radar_method(new Collection($params)) ?? 'POST',
             get_alipay_url($config, $payload),
-            $this->getHeaders(),
-            // 不能用 packer，支付宝接收的是 x-www-form-urlencoded 返回的又是 json，packer 用的是返回.
-            $payload?->query() ?? '',
+            $this->getHeaders($params),
+            // 不能用 artful 中 get_radar_body 方法
+            // 来自 AddPayloadBodyPlugin 插件通过 packer 生成的 _body
+            // 支付宝接收的是 x-www-form-urlencoded 返回的又是 json，packer 用的是返回.
+            $this->getBody($payload, $params)
         ));
 
         Logger::info('[Alipay][AddRadarPlugin] 插件装载完毕', ['rocket' => $rocket]);
 
         return $next($rocket);
     }
 
-    protected function getHeaders(): array
+    protected function getHeaders(array $params): array
     {
+        if (!empty($params['_multipart'])) {
+            return [];
+        }
+
         return [
             'Content-Type' => 'application/x-www-form-urlencoded',
             'User-Agent' => 'yansongda/pay-v3',
         ];
     }
+
+    protected function getBody(?Collection $payload, array $params): MultipartStream|string
+    {
+        if (!empty($params['_multipart'])) {
+            $multipartData = $params['_multipart'];
+            foreach ($payload as $name => $value) {
+                $multipartData[] = [
+                    'name' => $name,
+                    'contents' => $value,
+                ];
+            }
+
+            return new MultipartStream($multipartData, uniqid('alipay_', true));
+        }
+
+        return $payload?->query() ?? '';
+    }
 }

src/Plugin/Alipay/V2/Merchant/Item/FileUploadPlugin.php

@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yansongda\Pay\Plugin\Alipay\V2\Merchant\Item;
+
+use Closure;
+use Yansongda\Artful\Contract\PluginInterface;
+use Yansongda\Artful\Logger;
+use Yansongda\Artful\Rocket;
+
+/**
+ * 上传商户商品文件.
+ *
+ * @see https://opendocs.alipay.com/mini/510d4a72_alipay.merchant.item.file.upload?scene=common&pathHash=c08922b1
+ *
+ * @date 2025-10-28
+ */
+class FileUploadPlugin implements PluginInterface
+{
+    public function assembly(Rocket $rocket, Closure $next): Rocket
+    {
+        Logger::debug('[Alipay][Merchant][Item][FileUploadPlugin] 插件开始装载', ['rocket' => $rocket]);
+
+        $rocket->mergePayload(
+            array_merge(
+                [
+                    'method' => 'alipay.merchant.item.file.upload',
+                    'scene' => 'SYNC_ORDER',
+                ],
+                $rocket->getParams()
+            )
+        );
+
+        Logger::info('[Alipay][Merchant][Item][FileUploadPlugin] 插件装载完毕', ['rocket' => $rocket]);
+
+        return $next($rocket);
+    }
+}

tests/Plugin/Alipay/V2/AddRadarPluginTest.php

@@ -40,4 +40,25 @@ public function testRadarGetNormal()
         self::assertEquals('https://openapi.alipay.com/gateway.do?charset=utf-8', (string) $result->getRadar()->getUri());
         self::assertEquals('GET', $result->getRadar()->getMethod());
     }
+
+    public function testRadarHeaders()
+    {
+        $rocket = new Rocket();
+        $rocket->setParams([])->setPayload(new Collection(['name' => 'yansongda']));
+
+        $result = $this->plugin->assembly($rocket, function ($rocket) { return $rocket; });
+
+        self::assertEquals('application/x-www-form-urlencoded', $result->getRadar()->getHeaderLine('Content-Type'));
+        self::assertEquals('yansongda/pay-v3', $result->getRadar()->getHeaderLine('User-Agent'));
+    }
+
+    public function testRadarMultipart()
+    {
+        $rocket = new Rocket();
+        $rocket->setParams(['_multipart' => [['name' => 'yansongda', 'contents' => 'yansongda']]])->setPayload(new Collection(['name' => 'yansongda']));
+
+        $result = $this->plugin->assembly($rocket, function ($rocket) { return $rocket; });
+
+        self::assertEmpty($result->getRadar()->getHeaderLine('Content-Type'));
+    }
 }

tests/Plugin/Alipay/V2/Merchant/Item/FileUploadPluginTest.php

@@ -0,0 +1,44 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yansongda\Pay\Tests\Plugin\Alipay\V2\Merchant\Item;
+
+use Yansongda\Artful\Rocket;
+use Yansongda\Pay\Plugin\Alipay\V2\Merchant\Item\FileUploadPlugin;
+use Yansongda\Pay\Tests\TestCase;
+
+class FileUploadPluginTest extends TestCase
+{
+    protected FileUploadPlugin $plugin;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->plugin = new FileUploadPlugin();
+    }
+
+    public function testNormal()
+    {
+        $picUrl = 'https://cdn.jsdelivr.net/gh/yansongda/pay/web/public/images/pay.jpg';
+        $fileContent = file_get_contents($picUrl);
+        $rocket = (new Rocket())
+            ->setParams([
+                '_multipart' => [
+                    [
+                        'name' => 'file_content',
+                        'contents' => $fileContent,
+                        'filename' => basename($picUrl),
+                    ],
+                ],
+            ]);
+
+        $result = $this->plugin->assembly($rocket, function ($rocket) { return $rocket; });
+
+        $params = $result->getParams();
+        $this->assertArrayHasKey('_multipart', $params);
+        $this->assertEquals(basename($picUrl), $params['_multipart'][0]['filename']);
+        $this->assertEquals($fileContent, $params['_multipart'][0]['contents']);
+    }
+}

web/docs/v3/alipay/all.md

@@ -559,3 +559,9 @@ $result = Pay::alipay()->pay($allPlugins, $params);
 - 文字识别OCR
 
   `\Yansongda\Pay\Plugin\Alipay\V2\Member\Ocr\DetectPlugin`
+
+### 文件上传
+
+- 商品文件上传
+
+  `\Yansongda\Pay\Plugin\Alipay\V2\Merchant\Item\FileUploadPlugin`