feat(openai): 新增公众号、小程序、H5 绑定相关接口

This commit is contained in:
Fu Diwei 2021-10-09 16:57:16 +08:00
parent ef27073d5f
commit c004c3e29a
21 changed files with 377 additions and 23 deletions

View File

@ -16,7 +16,7 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiBatchReplyResponse> ExecuteOpenApiSendMessageAsync(this WechatOpenAIClient client, Models.OpenApiBatchReplyRequest request, CancellationToken cancellationToken = default)
public static async Task<Models.OpenApiBatchReplyResponse> ExecuteOpenApiBatchReplyAsync(this WechatOpenAIClient client, Models.OpenApiBatchReplyRequest request, CancellationToken cancellationToken = default)
{
if (client is null) throw new ArgumentNullException(nameof(client));
if (request is null) throw new ArgumentNullException(nameof(request));

View File

@ -0,0 +1,131 @@
using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web;
using Flurl.Http;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI
{
public static class WechatOpenAIClientExecuteOpenApiMpExtensions
{
/// <summary>
/// <para>异步调用 [POST] /openapi/getbindlink/{TOKEN} 接口。</para>
/// <para>REF: https://developers.weixin.qq.com/doc/aispeech/platform/mp/getbindlink.html </para>
/// </summary>
/// <param name="client"></param>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiGetBindLinkResponse> ExecuteOpenApiGetBindLinkAsync(this WechatOpenAIClient client, Models.OpenApiGetBindLinkRequest 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(request, HttpMethod.Post, "openapi", "getbindlink", client.Credentials.PushToken!);
return await client.SendRequestWithJsonAsync<Models.OpenApiGetBindLinkResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
}
/// <summary>
/// <para>异步调用 [POST] /openapi/getbindlist/{TOKEN} 接口。</para>
/// <para>REF: https://developers.weixin.qq.com/doc/aispeech/platform/mp/getbindlist.html </para>
/// </summary>
/// <param name="client"></param>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiGetBindListResponse> ExecuteOpenApiGetBindListAsync(this WechatOpenAIClient client, Models.OpenApiGetBindListRequest 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(request, HttpMethod.Post, "openapi", "getbindlist", client.Credentials.PushToken!);
return await client.SendRequestWithJsonAsync<Models.OpenApiGetBindListResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
}
/// <summary>
/// <para>异步调用 [POST] /openapi/unbindmp/{TOKEN} 接口。</para>
/// <para>REF: https://developers.weixin.qq.com/doc/aispeech/platform/mp/unbindmp.html </para>
/// </summary>
/// <param name="client"></param>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiUnbindMpResponse> ExecuteOpenApiUnbindMpAsync(this WechatOpenAIClient client, Models.OpenApiUnbindMpRequest 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(request, HttpMethod.Post, "openapi", "unbindmp", client.Credentials.PushToken!);
return await client.SendRequestWithJsonAsync<Models.OpenApiUnbindMpResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
}
/// <summary>
/// <para>异步调用 [POST] /openapi/geth5link/{TOKEN} 接口。</para>
/// <para>REF: https://developers.weixin.qq.com/doc/aispeech/platform/mp/getbindlist.html </para>
/// </summary>
/// <param name="client"></param>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiGetH5LinkResponse> ExecuteOpenApiGetH5LinkAsync(this WechatOpenAIClient client, Models.OpenApiGetH5LinkRequest 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(request, HttpMethod.Post, "openapi", "geth5link", client.Credentials.PushToken!);
return await client.SendRequestWithJsonAsync<Models.OpenApiGetH5LinkResponse>(flurlReq, data: request, cancellationToken: cancellationToken);
}
/// <summary>
/// <para>异步调用 [POST] /openapi/assetsupload/{TOKEN} 接口。</para>
/// <para>REF: https://developers.weixin.qq.com/doc/aispeech/platform/mp/assetsupload.html </para>
/// </summary>
/// <param name="client"></param>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public static async Task<Models.OpenApiAssetsUploadResponse> ExecuteFileUploadAsync(this WechatOpenAIClient client, Models.FileUploadRequest request, CancellationToken cancellationToken = default)
{
if (client is null) throw new ArgumentNullException(nameof(client));
if (request is null) throw new ArgumentNullException(nameof(request));
if (request.FileName == null)
request.FileName = Guid.NewGuid().ToString("N").ToLower() + ".csv";
if (request.FileContentType == null)
request.FileContentType = "text/csv";
IFlurlRequest flurlReq = client
.CreateRequest(request, HttpMethod.Post, "openapi", "assetsupload", client.Credentials.PushToken!);
using var fileContent = new ByteArrayContent(request.FileBytes ?? new byte[0]);
using var paramContent = new StringContent(
Utilities.WxBizMsgCryptor.AESEncrypt(
plainText: Utilities.XmlUtility.Serialize(request),
encodingAESKey: client.Credentials.PushEncodingAESKey!,
appId: client.Credentials.AppId!
),
Encoding.UTF8
);;
using var httpContent = new MultipartFormDataContent();
httpContent.Add(fileContent, "\"media\"", $"\"{HttpUtility.UrlEncode(request.FileName)}\"");
httpContent.Add(paramContent, "\"encrypt\"");
fileContent.Headers.ContentType = MediaTypeHeaderValue.Parse(request.FileContentType);
fileContent.Headers.ContentLength = request.FileBytes?.Length;
return await client.SendRequestAsync<Models.OpenApiAssetsUploadResponse>(flurlReq, httpContent: httpContent, cancellationToken: cancellationToken);
}
}
}

View File

@ -21,6 +21,9 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
if (client is null) throw new ArgumentNullException(nameof(client));
if (request is null) throw new ArgumentNullException(nameof(request));
if (request.AppId == null)
request.AppId = client.Credentials.AppId;
IFlurlRequest flurlReq = client
.CreateRequest(request, HttpMethod.Post, "openapi", "sendmsg", client.Credentials.PushToken!);
@ -40,6 +43,9 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
if (client is null) throw new ArgumentNullException(nameof(client));
if (request is null) throw new ArgumentNullException(nameof(request));
if (request.AppId == null)
request.AppId = client.Credentials.AppId;
IFlurlRequest flurlReq = client
.CreateRequest(request, HttpMethod.Post, "openapi", "kefustate", "get", client.Credentials.PushToken!);
@ -59,6 +65,9 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
if (client is null) throw new ArgumentNullException(nameof(client));
if (request is null) throw new ArgumentNullException(nameof(request));
if (request.AppId == null)
request.AppId = client.Credentials.AppId;
IFlurlRequest flurlReq = client
.CreateRequest(request, HttpMethod.Post, "openapi", "kefustate", "change", client.Credentials.PushToken!);

View File

@ -8,7 +8,7 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/batchreply/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiBatchReplyRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiBatchReplyRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置直播 ID。

View File

@ -8,7 +8,7 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/setautoreply/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiBatchSetAutoReplyRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiBatchSetAutoReplyRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置管理员 ID。

View File

@ -8,7 +8,7 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/generatereport/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiGenerateReportRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiGenerateReportRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置直播 ID。

View File

@ -0,0 +1,37 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/assetsupload/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiAssetsUploadRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置用户 ID。
/// </summary>
[XmlElement("userid")]
public string UserId { get; set; } = string.Empty;
/// <summary>
/// 获取或设置文件字节数组。
/// </summary>
[XmlIgnore]
public byte[] FileBytes { get; set; } = new byte[0];
/// <summary>
/// 获取或设置文件名。如果不指定将由系统自动生成。
/// </summary>
[XmlIgnore]
public string? FileName { get; set; }
/// <summary>
/// 获取或设置文件 Conent-Type。如果不指定将由系统自动生成。
/// </summary>
[XmlIgnore]
public string? FileContentType { get; set; }
}
}

View File

@ -0,0 +1,25 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/assetsupload/{TOKEN} 接口的响应。</para>
/// </summary>
public class OpenApiAssetsUploadResponse : WechatOpenAIResponse
{
/// <summary>
/// 获取或设置文件标识。
/// </summary>
[Newtonsoft.Json.JsonProperty("filekey")]
[System.Text.Json.Serialization.JsonPropertyName("filekey")]
public string FileKey { get; set; } = default!;
/// <summary>
/// 获取或设置文件 URL。
/// </summary>
[Newtonsoft.Json.JsonProperty("url")]
[System.Text.Json.Serialization.JsonPropertyName("url")]
public string Url { get; set; } = default!;
}
}

View File

@ -0,0 +1,19 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/getbindlink/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiGetBindLinkRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置直播 ID。
/// </summary>
[XmlElement("redirectlink")]
public string RedirectLink { get; set; } = string.Empty;
}
}

View File

@ -0,0 +1,18 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/getbindlink/{TOKEN} 接口的响应。</para>
/// </summary>
public class OpenApiGetBindLinkResponse : WechatOpenAIResponse
{
/// <summary>
/// 获取或设置绑定链接 URL。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]
public string Url { get; set; } = default!;
}
}

View File

@ -0,0 +1,14 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/getbindlink/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiGetBindListRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
}
}

View File

@ -0,0 +1,18 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/getbindlink/{TOKEN} 接口的响应。</para>
/// </summary>
public class OpenApiGetBindListResponse : WechatOpenAIResponse
{
/// <summary>
/// 获取或设置绑定列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("bindlist")]
[System.Text.Json.Serialization.JsonPropertyName("bindlist")]
public object[] BindList { get; set; } = default!;
}
}

View File

@ -0,0 +1,19 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/geth5link/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiGetH5LinkRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置页面标题。
/// </summary>
[XmlElement("title", IsNullable = true)]
public string? Title { get; set; }
}
}

View File

@ -0,0 +1,18 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/geth5link/{TOKEN} 接口的响应。</para>
/// </summary>
public class OpenApiGetH5LinkResponse : WechatOpenAIResponse
{
/// <summary>
/// 获取或设置机器人链接 URL。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]
public string Url { get; set; } = default!;
}
}

View File

@ -0,0 +1,20 @@
using System;
using System.Collections.Generic;
using System.Xml.Serialization;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/unbindmp/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiUnbindMpRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置微信 AppId。
/// </summary>
[Newtonsoft.Json.JsonProperty("authorizer_appid")]
[System.Text.Json.Serialization.JsonPropertyName("authorizer_appid")]
public string AuthorizerAppId { get; set; } = string.Empty;
}
}

View File

@ -0,0 +1,12 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
{
/// <summary>
/// <para>表示 [POST] /openapi/unbindmp/{TOKEN} 接口的响应。</para>
/// </summary>
public class OpenApiUnbindMpResponse : WechatOpenAIResponse
{
}
}

View File

@ -8,8 +8,14 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/kefustate/change/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiKefuStateChangeRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiKefuStateChangeRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置微信 AppId。如果不指定将使用构造 <see cref="WechatOpenAIClient"/> 时的 <see cref="WechatOpenAIClientOptions.AppId"/> 参数。
/// </summary>
[XmlElement("appid")]
public string? AppId { get; set; }
/// <summary>
/// 获取或设置用户的 OpenId。
/// </summary>

View File

@ -8,8 +8,14 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/kefustate/get/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiKefuStateGetRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiKefuStateGetRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置微信 AppId。如果不指定将使用构造 <see cref="WechatOpenAIClient"/> 时的 <see cref="WechatOpenAIClientOptions.AppId"/> 参数。
/// </summary>
[XmlElement("appid")]
public string? AppId { get; set; }
/// <summary>
/// 获取或设置用户的 OpenId。
/// </summary>

View File

@ -8,8 +8,14 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI.Models
/// <para>表示 [POST] /openapi/sendmsg/{TOKEN} 接口的请求。</para>
/// </summary>
[XmlRoot("xml")]
public class OpenApiSendMessageRequest : WechatOpenAIRequestEncryptedXmlable
public class OpenApiSendMessageRequest : WechatOpenAIRequest, WechatOpenAIRequest.Serialization.IEncryptedXmlable
{
/// <summary>
/// 获取或设置微信 AppId。如果不指定将使用构造 <see cref="WechatOpenAIClient"/> 时的 <see cref="WechatOpenAIClientOptions.AppId"/> 参数。
/// </summary>
[XmlElement("appid")]
public string? AppId { get; set; }
/// <summary>
/// 获取或设置用户的 OpenId。
/// </summary>

View File

@ -112,13 +112,11 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
{
try
{
if (data is WechatOpenAIRequestEncryptedXmlable xmlData)
if (data is WechatOpenAIRequest.Serialization.IEncryptedXmlable)
{
if (xmlData.AppId == null)
xmlData.AppId = Credentials.AppId;
string xml = Utilities.XmlUtility.Serialize(xmlData);
data = new { encrypt = Utilities.WxBizMsgCryptor.AESEncrypt(plainText: xml, encodingAESKey: Credentials.PushEncodingAESKey!, appId: xmlData.AppId!) };
string plainXml = Utilities.XmlUtility.Serialize(data);
string encryptedXml = Utilities.WxBizMsgCryptor.AESEncrypt(plainText: plainXml, encodingAESKey: Credentials.PushEncodingAESKey!, appId: Credentials.AppId!);
data = new { encrypt = encryptedXml };
}
using IFlurlResponse flurlResponse = await base.SendRequestWithJsonAsync(flurlRequest, data, cancellationToken).ConfigureAwait(false);

View File

@ -7,6 +7,13 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
/// </summary>
public abstract class WechatOpenAIRequest : IWechatRequest
{
public static class Serialization
{
public interface IEncryptedXmlable
{
}
}
/// <summary>
/// 获取或设置请求超时时间(单位:毫秒)。如果不指定将使用构造 <see cref="WechatOpenAIClient"/> 时的 <see cref="WechatOpenAIClientOptions.Timeout"/> 参数,这在需要指定特定耗时请求(比如上传或下载文件)的超时时间时很有用。
/// </summary>
@ -43,13 +50,4 @@ namespace SKIT.FlurlHttpClient.Wechat.OpenAI
[System.Xml.Serialization.SoapIgnore]
public virtual string? AccessToken { get; set; }
}
public abstract class WechatOpenAIRequestEncryptedXmlable : WechatOpenAIRequest
{
/// <summary>
/// 获取或设置微信 AppId。如果不指定将使用构造 <see cref="WechatOpenAIClient"/> 时的 <see cref="WechatOpenAIClientOptions.AppId"/> 参数。
/// </summary>
[System.Xml.Serialization.XmlElement("appid")]
public string? AppId { get; set; }
}
}