feat(wxads): 新增图片管理模块相关 API 封装

2025-12-29 18:04:42 +08:00 · 2021-06-11 21:58:41 +08:00
parent 17603584b2
commit f4d9a54abe
7 changed files with 375 additions and 0 deletions
--- a/src/SKIT.FlurlHttpClient.Wechat.Ads/Extensions/WechatAdsClientExecuteImagesExtensions.cs
+++ b/src/SKIT.FlurlHttpClient.Wechat.Ads/Extensions/WechatAdsClientExecuteImagesExtensions.cs
@@ -0,0 +1,100 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Web;
+using Flurl;
+using Flurl.Http;
+
+namespace SKIT.FlurlHttpClient.Wechat.Ads
+{
+    public static class WechatAdsClientExecuteImagesExtensions
+    {
+        /// <summary>
+        /// <para>异步调用 [POST] /images/add 接口。</para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.ImagesAddResponse> ExecuteImagesAddAsync(this WechatAdsClient client, Models.ImagesAddRequest request, CancellationToken cancellationToken = default)
+        {
+            if (client is null) throw new ArgumentNullException(nameof(client));
+            if (request is null) throw new ArgumentNullException(nameof(request));
+
+            if (string.IsNullOrEmpty(request.FileName))
+            {
+                request.FileName = Guid.NewGuid().ToString("N").ToLower();
+            }
+
+            if (string.IsNullOrEmpty(request.FileContentType))
+            {
+                if (request.FileName!.EndsWith(".swf", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "application/x-shockwave-flash";
+                else if (request.FileName!.EndsWith(".jpg", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "image/jpeg";
+                else if (request.FileName!.EndsWith(".jpeg", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "image/jpeg";
+                else if (request.FileName!.EndsWith(".gif", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "image/gif";
+                else
+                    request.FileContentType = "image/png";
+            }
+
+            if (string.IsNullOrEmpty(request.FileHash))
+            {
+                request.FileHash = Security.MD5Utility.Hash(request.FileBytes ?? new byte[0]);
+            }
+
+            string boundary = "--BOUNDARY--" + DateTimeOffset.Now.Ticks.ToString("x");
+            using var fileContent = new ByteArrayContent(request.FileBytes ?? new byte[0]);
+            using var httpContent = new MultipartFormDataContent(boundary);
+            httpContent.Add(fileContent, "\"media\"", "\"" + HttpUtility.UrlEncode(request.FileName) + "\"");
+            httpContent.Headers.ContentType = MediaTypeHeaderValue.Parse("multipart/form-data; boundary=" + boundary);
+            fileContent.Headers.ContentType = MediaTypeHeaderValue.Parse(request.FileContentType);
+            fileContent.Headers.ContentLength = request.FileBytes?.Length ?? 0;
+            IFlurlRequest flurlReq = client
+                .CreateRequest(HttpMethod.Post, "images", "add")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestAsync<Models.ImagesAddResponse>(flurlReq, content: httpContent, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [GET] /images/get 接口。</para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.ImagesGetResponse> ExecuteImagesGetAsync(this WechatAdsClient client, Models.ImagesGetRequest request, CancellationToken cancellationToken = default)
+        {
+            if (client is null) throw new ArgumentNullException(nameof(client));
+            if (request is null) throw new ArgumentNullException(nameof(request));
+
+            IFlurlRequest flurlReq = client
+                .CreateRequest(HttpMethod.Get, "images", "get")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            if (!string.IsNullOrEmpty(request.ImageId))
+                flurlReq.SetQueryParam("image_id", request.ImageId);
+
+            if (request.Filters != null && request.Filters.Any())
+                flurlReq.SetQueryParam("filtering", client.JsonSerializer.Serialize(request.Filters));
+
+            if (request.PageSize.HasValue)
+                flurlReq.SetQueryParam("page_size", request.PageSize.Value);
+
+            if (request.Page.HasValue)
+                flurlReq.SetQueryParam("page", request.Page.Value);
+
+            return await client.SendRequestAsync<Models.ImagesGetResponse>(flurlReq, cancellationToken: cancellationToken);
+        }
+    }
+}