feat: 实现媒体上传

- 图片上传API
- 视频上传API

payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/enumeration/WechatPayV3Type.java

@@ -54,7 +54,18 @@ public enum WechatPayV3Type {
      * @since 1.0.3.RELEASE
      */
     FUND_FLOW_BILL(HttpMethod.GET, "%s/v3/bill/fundflowbill"),
-
+    /**
+     * 图片上传API.
+     *
+     * @since 1.0.14.RELEASE
+     */
+    MERCHANT_MEDIA_IMG(HttpMethod.POST, "%s/v3/merchant/media/upload"),
+    /**
+     * 视频上传API.
+     *
+     * @since 1.0.14.RELEASE
+     */
+    MERCHANT_MEDIA_VIDEO(HttpMethod.POST, "%s/v3/merchant/media/video_upload"),
     //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
     /**

payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatApiProvider.java

@@ -234,4 +234,14 @@ public class WechatApiProvider {
         return new WechatPartnerSpecialMchApi(wechatPayClient, tenantId);
     }
 
+    /**
+     * 其它能力-媒体上传
+     *
+     * @param tenantId the tenant id
+     * @return the wechat media api
+     */
+    public WechatMediaApi mediaApi(String tenantId){
+        return new WechatMediaApi(wechatPayClient, tenantId);
+    }
+
 }

payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatMediaApi.java

@@ -0,0 +1,111 @@
+/*
+ *  Copyright 2019-2021 felord.cn
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       https://www.apache.org/licenses/LICENSE-2.0
+ *  Website:
+ *       https://felord.cn
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package cn.felord.payment.wechat.v3;
+
+import cn.felord.payment.wechat.enumeration.WeChatServer;
+import cn.felord.payment.wechat.enumeration.WechatPayV3Type;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import lombok.SneakyThrows;
+import org.bouncycastle.jcajce.provider.digest.SHA256;
+import org.bouncycastle.util.encoders.Hex;
+import org.springframework.http.MediaType;
+import org.springframework.http.RequestEntity;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.util.StringUtils;
+import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.net.URI;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 其它能力-媒体上传
+ *
+ * @author felord.cn
+ * @since 1.0.14.RELEASE
+ */
+public class WechatMediaApi extends AbstractApi {
+
+    /**
+     * Instantiates a new Abstract api.
+     *
+     * @param wechatPayClient the wechat pay client
+     * @param tenantId        the tenant id
+     */
+    public WechatMediaApi(WechatPayClient wechatPayClient, String tenantId) {
+        super(wechatPayClient, tenantId);
+    }
+
+    /**
+     * 图片上传API
+     *
+     * @param file the file
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> mediaImageUpload(MultipartFile file) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.client().withType(WechatPayV3Type.MERCHANT_MEDIA_IMG, file)
+                .function(this::uploadFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+
+    /**
+     * 视频上传API
+     *
+     * @param file the file
+     * @return the wechat response entity
+     */
+    public WechatResponseEntity<ObjectNode> mediaVideoUpload(MultipartFile file) {
+        WechatResponseEntity<ObjectNode> wechatResponseEntity = new WechatResponseEntity<>();
+        this.client().withType(WechatPayV3Type.MERCHANT_MEDIA_VIDEO, file)
+                .function(this::uploadFunction)
+                .consumer(wechatResponseEntity::convert)
+                .request();
+        return wechatResponseEntity;
+    }
+    @SneakyThrows
+    private RequestEntity<?> uploadFunction(WechatPayV3Type type, MultipartFile file) {
+
+        Map<String, Object> meta = new LinkedHashMap<>(2);
+
+        String originalFilename = file.getOriginalFilename();
+        String filename = StringUtils.hasText(originalFilename) ? originalFilename : file.getName();
+        meta.put("filename", filename);
+
+        byte[] digest = SHA256.Digest.getInstance("SHA-256").digest(file.getBytes());
+        meta.put("sha256", Hex.toHexString(digest));
+        MultiValueMap<Object, Object> body = new LinkedMultiValueMap<>();
+        body.add("meta", meta);
+        body.add("file", file.getResource());
+        // 签名
+        String metaStr = this.getMapper().writeValueAsString(meta);
+
+        URI uri = UriComponentsBuilder.fromHttpUrl(type.uri(WeChatServer.CHINA))
+                .build()
+                .toUri();
+        return RequestEntity.post(uri)
+                .header("Content-Type", MediaType.MULTIPART_FORM_DATA_VALUE)
+                .header("Meta-Info", metaStr)
+                .header("Pay-TenantId", tenantId())
+                .body(body);
+    }
+}

payment-spring-boot-autoconfigure/src/main/java/cn/felord/payment/wechat/v3/WechatPayClient.java

@@ -96,6 +96,7 @@ public class WechatPayClient {
          * The V3 pay type.
          */
         private final WechatPayV3Type wechatPayV3Type;
+
         /**
          * The Rest operations.
          */
@@ -216,7 +217,9 @@ public class WechatPayClient {
             HttpHeaders headers = requestEntity.getHeaders();
 
             String body = requestEntity.hasBody() ? Objects.requireNonNull(requestEntity.getBody()).toString() : "";
-            if (WechatPayV3Type.MARKETING_IMAGE_UPLOAD.pattern().contains(canonicalUrl)) {
+            if (WechatPayV3Type.MARKETING_IMAGE_UPLOAD.pattern().contains(canonicalUrl) ||
+                    WechatPayV3Type.MERCHANT_MEDIA_IMG.pattern().contains(canonicalUrl) ||
+                    WechatPayV3Type.MERCHANT_MEDIA_VIDEO.pattern().contains(canonicalUrl)) {
                 body = Objects.requireNonNull(headers.get("Meta-Info")).get(0);
             }