feat(work): 封装部分企业微信接口

src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientExecuteCgibinCorpGroupExtensions.cs

@@ -25,8 +25,8 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
             if (client is null) throw new ArgumentNullException(nameof(client));
             if (request is null) throw new ArgumentNullException(nameof(request));
 
-            if (!request.AgentId.HasValue)
-                request.AgentId = client.AgentId;
+            if (!request.ParentAgentId.HasValue)
+                request.ParentAgentId = client.AgentId;
 
             IFlurlRequest flurlReq = client
                 .CreateRequest(HttpMethod.Post, "cgi-bin", "corpgroup", "corp", "list_app_share_info")

src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientExecuteCgibinExtensions.cs

@@ -25,7 +25,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
             if (request is null) throw new ArgumentNullException(nameof(request));
 
             IFlurlRequest flurlReq = client
-                .CreateRequest(HttpMethod.Get, "cgi-bin", "token")
+                .CreateRequest(HttpMethod.Get, "cgi-bin", "gettoken")
                 .SetOptions(request)
                 .SetQueryParam("corpid", client.CorpId)
                 .SetQueryParam("corpsecret", client.AgentSecret);
@@ -75,5 +75,50 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
 
             return await client.SendRequestAsync<Models.CgibinGetApiDomainIpResponse>(flurlReq, cancellationToken: cancellationToken);
         }
+
+        /// <summary>
+        /// <para>异步调用 [GET] /cgi-bin/get_jsapi_ticket 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90136/90506 </para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90144/90539 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinGetJsapiTicketResponse> ExecuteCgibinGetJsapiTicketAsync(this WechatWorkClient client, Models.CgibinGetJsapiTicketRequest 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, "cgi-bin", "get_jsapi_ticket")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestAsync<Models.CgibinGetJsapiTicketResponse>(flurlReq, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [GET] /cgi-bin/ticket/get 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90136/90506 </para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90144/90539 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinTicketGetResponse> ExecuteCgibinTicketGetAsync(this WechatWorkClient client, Models.CgibinTicketGetRequest 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, "cgi-bin", "ticket", "get")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken)
+                .SetQueryParam("type", request.Type);
+
+            return await client.SendRequestAsync<Models.CgibinTicketGetResponse>(flurlReq, cancellationToken: cancellationToken);
+        }
     }
 }

src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientExecuteCgibinExternalPayExtensions.cs

@@ -0,0 +1,124 @@
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Flurl;
+using Flurl.Http;
+
+namespace SKIT.FlurlHttpClient.Wechat.Work
+{
+    public static class WechatWorkClientExecuteCgibinExternalPayExtensions
+    {
+        #region Merchant
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/externalpay/addmerchant 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90135/93666 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinExternalPayAddMerchantResponse> ExecuteCgibinExternalPayAddMerchantAsync(this WechatWorkClient client, Models.CgibinExternalPayAddMerchantRequest 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.Post, "cgi-bin", "externalpay", "addmerchant")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinExternalPayAddMerchantResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/externalpay/getmerchant 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90135/93666 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinExternalPayGetMerchantResponse> ExecuteCgibinExternalPayGetMerchantAsync(this WechatWorkClient client, Models.CgibinExternalPayGetMerchantRequest 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.Post, "cgi-bin", "externalpay", "getmerchant")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinExternalPayGetMerchantResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/externalpay/delmerchant 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90135/93666 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinExternalPayDeleteMerchantResponse> ExecuteCgibinExternalPayDeleteMerchantAsync(this WechatWorkClient client, Models.CgibinExternalPayDeleteMerchantRequest 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.Post, "cgi-bin", "externalpay", "delmerchant")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinExternalPayDeleteMerchantResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/externalpay/set_mch_use_scope 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90135/93666 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinExternalPaySetMerchantUseScopeResponse> ExecuteCgibinExternalPaySetMerchantUseScopeAsync(this WechatWorkClient client, Models.CgibinExternalPaySetMerchantUseScopeRequest 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.Post, "cgi-bin", "externalpay", "set_mch_use_scope")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinExternalPaySetMerchantUseScopeResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+        #endregion
+
+        #region Bill
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/externalpay/get_bill_list 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90135/93667 </para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90143/93727 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinExternalPayGetBillListResponse> ExecuteCgibinExternalPayGetBillListAsync(this WechatWorkClient client, Models.CgibinExternalPayGetBillListRequest 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.Post, "cgi-bin", "externalpay", "get_bill_list")
+                .SetOptions(request)
+                .SetQueryParam("access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinExternalPayGetBillListResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+        #endregion
+    }
+}

src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientExecuteCgibinServiceExtensions.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Net.Http;
+using System.Net.Http.Headers;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -263,7 +264,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
             if (request is null) throw new ArgumentNullException(nameof(request));
 
             IFlurlRequest flurlReq = client
-                .CreateRequest(HttpMethod.Get, "cgi-bin", "service", "get_register_code")
+                .CreateRequest(HttpMethod.Post, "cgi-bin", "service", "get_register_code")
                 .SetOptions(request)
                 .SetQueryParam("provider_access_token", request.AccessToken);
 
@@ -284,12 +285,144 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
             if (request is null) throw new ArgumentNullException(nameof(request));
 
             IFlurlRequest flurlReq = client
-                .CreateRequest(HttpMethod.Get, "cgi-bin", "service", "get_register_info")
+                .CreateRequest(HttpMethod.Post, "cgi-bin", "service", "get_register_info")
                 .SetOptions(request)
                 .SetQueryParam("provider_access_token", request.AccessToken);
 
             return await client.SendRequestWithJsonAsync<Models.CgibinServiceGetRegisterInfoResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
         }
         #endregion
+
+        #region Media
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/service/media/upload 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90143/91883 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinServiceMediaUploadResponse> ExecuteCgibinServiceMediaUploadAsync(this WechatWorkClient client, Models.CgibinServiceMediaUploadRequest 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))
+            {
+                string ext = "";
+                if ("image".Equals(request.Type))
+                    ext = ".png";
+                else if ("voice".Equals(request.Type))
+                    ext = ".mp3";
+                else if ("video".Equals(request.Type))
+                    ext = ".mp4";
+
+                request.FileName = Guid.NewGuid().ToString("N").ToLower() + ext;
+            }
+
+            if (string.IsNullOrEmpty(request.FileContentType))
+            {
+                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(".png", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "image/png";
+                else if (request.FileName!.EndsWith(".gif", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "image/gif";
+                else if (request.FileName!.EndsWith(".mp3", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "audio/mpeg";
+                else if (request.FileName!.EndsWith(".amr", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "audio/amr";
+                else if (request.FileName!.EndsWith(".mp4", StringComparison.OrdinalIgnoreCase))
+                    request.FileContentType = "video/mp4";
+                else
+                    request.FileContentType = "application/octet-stream";
+            }
+
+            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\"", "\"" + 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;
+            IFlurlRequest flurlReq = client
+                .CreateRequest(HttpMethod.Post, "cgi-bin", "service", "media", "upload")
+                .SetOptions(request)
+                .SetQueryParam("provider_access_token", request.AccessToken)
+                .SetQueryParam("type", request.Type);
+
+            return await client.SendRequestAsync<Models.CgibinServiceMediaUploadResponse>(flurlReq, content: httpContent, cancellationToken: cancellationToken);
+        }
+        #endregion
+
+        #region Contact
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/service/contact/id_translate 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90143/91846 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinServiceContactIdTranslateResponse> ExecuteCgibinServiceContactIdTranslateAsync(this WechatWorkClient client, Models.CgibinServiceContactIdTranslateRequest 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.Post, "cgi-bin", "service", "contact", "id_translate")
+                .SetOptions(request)
+                .SetQueryParam("provider_access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinServiceContactIdTranslateResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+
+        /// <summary>
+        /// <para>异步调用 [POST] /cgi-bin/service/contact/sort 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90143/92093 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinServiceContactSortResponse> ExecuteCgibinServiceContactSortAsync(this WechatWorkClient client, Models.CgibinServiceContactSortRequest 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.Post, "cgi-bin", "service", "contact", "sort")
+                .SetOptions(request)
+                .SetQueryParam("provider_access_token", request.AccessToken);
+
+            return await client.SendRequestWithJsonAsync<Models.CgibinServiceContactSortResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
+        }
+        #endregion
+
+        #region Batch
+        /// <summary>
+        /// <para>异步调用 [GET] /cgi-bin/service/batch/getresult 接口。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90143/91882 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public static async Task<Models.CgibinServiceBatchGetResultResponse> ExecuteCgibinServiceBatchGetResultAsync(this WechatWorkClient client, Models.CgibinServiceBatchGetResultRequest 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, "cgi-bin", "service", "batch", "getresult")
+                .SetOptions(request)
+                .SetQueryParam("provider_access_token", request.AccessToken)
+                .SetQueryParam("jobid", request.JobId);
+
+            return await client.SendRequestAsync<Models.CgibinServiceBatchGetResultResponse>(flurlReq, cancellationToken: cancellationToken);
+        }
+        #endregion
     }
 }

src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientParameterExtensions.cs

@@ -0,0 +1,77 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Linq;
+using System.Net.Http;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Web;
+using Flurl;
+using Flurl.Http;
+
+namespace SKIT.FlurlHttpClient.Wechat.Work
+{
+    /// <summary>
+    /// 为 <see cref="WechatWorkClient"/> 提供客户端调起 JS-SDK 签名的扩展方法。
+    /// </summary>
+    public static class WechatWorkClientParameterExtensions
+    {
+        /// <summary>
+        /// <para>生成客户端 JS-SDK `wx.config` 所需的参数。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90136/90506 </para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90144/90539 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="jsapiTicket"></param>
+        /// <param name="url"></param>
+        /// <returns></returns>
+        public static IDictionary<string, string> GenerateParametersForJssdkConfigRequest(this WechatWorkClient client, string jsapiTicket, string url)
+        {
+            if (client is null) throw new ArgumentNullException(nameof(client));
+            if (jsapiTicket is null) throw new ArgumentNullException(nameof(jsapiTicket));
+            if (url is null) throw new ArgumentNullException(nameof(url));
+
+            string timestamp = DateTimeOffset.Now.ToLocalTime().ToUnixTimeSeconds().ToString();
+            string nonce = Guid.NewGuid().ToString("N");
+            string sign = Security.SHA1Utility.Hash($"jsapi_ticket={jsapiTicket}&noncestr={nonce}&timestamp={timestamp}&url={url.Split('#')[0]}").ToLower();
+
+            return new ReadOnlyDictionary<string, string>(new Dictionary<string, string>()
+            {
+                { "appId", client.CorpId },
+                { "timestamp", timestamp },
+                { "nonceStr", nonce },
+                { "signature", sign }
+            });
+        }
+
+        /// <summary>
+        /// <para>生成客户端 JS-SDK `wx.agentConfig` 所需的参数。</para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90000/90136/90506 </para>
+        /// <para>REF: https://open.work.weixin.qq.com/api/doc/90001/90144/90539 </para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="jsapiTicket"></param>
+        /// <param name="url"></param>
+        /// <returns></returns>
+        public static IDictionary<string, string> GenerateParametersForJssdkAgentConfigRequest(this WechatWorkClient client, string jsapiTicket, string url)
+        {
+            if (client is null) throw new ArgumentNullException(nameof(client));
+            if (jsapiTicket is null) throw new ArgumentNullException(nameof(jsapiTicket));
+            if (url is null) throw new ArgumentNullException(nameof(url));
+
+            string timestamp = DateTimeOffset.Now.ToLocalTime().ToUnixTimeSeconds().ToString();
+            string nonce = Guid.NewGuid().ToString("N");
+            string sign = Security.SHA1Utility.Hash($"jsapi_ticket={jsapiTicket}&noncestr={nonce}&timestamp={timestamp}&url={url.Split('#')[0]}").ToLower();
+
+            return new ReadOnlyDictionary<string, string>(new Dictionary<string, string>()
+            {
+                { "corpid", client.CorpId },
+                { "agentid", client.AgentId?.ToString() ?? string.Empty },
+                { "timestamp", timestamp },
+                { "nonceStr", nonce },
+                { "signature", sign }
+            });
+        }
+    }
+}