lsm/DotNetCore.SKIT.FlurlHttpClient.Wechat
1
0
Fork 0
mirror of https://gitee.com/fudiwei/DotNetCore.SKIT.FlurlHttpClient.Wechat.git synced 2025-04-05 17:37:54 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(work): 实现会话内容存档相关功能

Browse Source
This commit is contained in:
RHQYZ 2023-03-09 19:54:08 +08:00 committed by GitHub
parent 448d154b93
commit 31735b1c21
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
43 changed files with 3807 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/SKIT.FlurlHttpClient.Wechat.TenpayV3/Settings/CertificateEntry.cs
View File

@ -17,7 +17,7 @@ namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings
public string AlgorithmType { get; }
/// <summary>
/// 获取证书内容（CRT/CER 格式，即 -----BEGIN CERTIFICATE----- ... -----END CERTIFICATE）
/// 获取证书内容（CRT/CER PEM 格式，即 -----BEGIN CERTIFICATE----- ... -----END CERTIFICATE-----）
/// </summary>
public string Certificate { get; }

4
src/SKIT.FlurlHttpClient.Wechat.TenpayV3/Settings/CertificateManager.cs
View File

@ -11,7 +11,7 @@ namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings
public abstract class CertificateManager
{
/// <summary>
/// 获取存储的全部证书。
/// 获取存储的全部证书实体。
/// </summary>
/// <returns></returns>
public abstract IEnumerable<CertificateEntry> AllEntries();
@ -30,7 +30,7 @@ namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings
public abstract CertificateEntry? GetEntry(string serialNumber);
/// <summary>
/// 移除指定的证书实体。
/// 根据证书序列号移除证书实体。
/// </summary>
/// <param name="serialNumber"></param>
/// <returns></returns>

24
src/SKIT.FlurlHttpClient.Wechat.Work/Extensions/WechatWorkClientEventExtensions.cs
View File

@ -37,7 +37,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
try
{
if (string.IsNullOrEmpty(client.Credentials.PushEncodingAESKey))
throw new Exceptions.WechatWorkEventSerializationException("Decrypt event failed, because there is no encoding AES key.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to decrypt event data, because there is no encoding AES key.");
InnerEncryptedEvent encryptedEvent = client.JsonSerializer.Deserialize<InnerEncryptedEvent>(callbackJson);
callbackJson = Utilities.WxMsgCryptor.AESDecrypt(cipherText: encryptedEvent.EncryptedData, encodingAESKey: client.Credentials.PushEncodingAESKey!, out _);
@ -50,7 +50,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Deserialize event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to deserialize event data. Please see the inner exception for more details.", ex);
}
}
@ -63,7 +63,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
try
{
if (!Utilities.WxMsgCryptor.TryParseXml(callbackXml, out string? encryptedXml))
throw new Exceptions.WechatWorkEventSerializationException("Decrypt event failed, because of empty encrypted data.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to decrypt event data, because of empty encrypted data.");
callbackXml = Utilities.WxMsgCryptor.AESDecrypt(cipherText: encryptedXml!, encodingAESKey: client.Credentials.PushEncodingAESKey!, out _);
return Utilities.XmlUtility.Deserialize<TEvent>(callbackXml);
@ -74,7 +74,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Deserialize event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to deserialize event data. Please see the inner exception for more details.", ex);
}
}
@ -144,13 +144,13 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Serialize event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to serialize event data. Please see the inner exception for more details.", ex);
}
if (string.IsNullOrEmpty(client.Credentials.PushEncodingAESKey))
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed, because there is no encoding AES key.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data, because there is no encoding AES key.");
if (string.IsNullOrEmpty(client.Credentials.PushToken))
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed, because there is no token.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data, because there is no token.");
try
{
@ -178,7 +178,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data. Please see the inner exception for more details.", ex);
}
return json;
@ -202,13 +202,13 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Serialize event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to serialize event data. Please see the inner exception for more details.", ex);
}
if (string.IsNullOrEmpty(client.Credentials.PushEncodingAESKey))
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed, because there is no encoding AES key.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data, because there is no encoding AES key.");
if (string.IsNullOrEmpty(client.Credentials.PushToken))
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed, because there is no token.");
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data, because there is no token.");
try
{
@ -222,7 +222,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work
}
catch (Exception ex)
{
throw new Exceptions.WechatWorkEventSerializationException("Encrypt event failed. Please see the `InnerException` for more details.", ex);
throw new Exceptions.WechatWorkEventSerializationException("Failed to encrypt event data. Please see the inner exception for more details.", ex);
}
return xml;

4
src/SKIT.FlurlHttpClient.Wechat.Work/Models/CgibinExternalContact/GroupWelcome/CgibinExternalContactGroupWelcomeTemplateAddRequest.cs
View File

@ -1,4 +1,4 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
{
/// <summary>
/// <para>表示 [POST] /cgi-bin/externalcontact/group_welcome_template/add 接口的请求。</para>
@ -47,7 +47,7 @@
public Types.ImageMessage? Image { get; set; }
/// <summary>
/// 获取或设置图文消息信息。
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]

4
src/SKIT.FlurlHttpClient.Wechat.Work/Models/CgibinExternalContact/GroupWelcome/CgibinExternalContactGroupWelcomeTemplateEditRequest.cs
View File

@ -1,4 +1,4 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
{
/// <summary>
/// <para>表示 [POST] /cgi-bin/externalcontact/group_welcome_template/edit 接口的请求。</para>
@ -54,7 +54,7 @@
public Types.ImageMessage? Image { get; set; }
/// <summary>
/// 获取或设置图文消息信息。
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]

4
src/SKIT.FlurlHttpClient.Wechat.Work/Models/CgibinExternalContact/GroupWelcome/CgibinExternalContactGroupWelcomeTemplateGetResponse.cs
View File

@ -1,4 +1,4 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
namespace SKIT.FlurlHttpClient.Wechat.Work.Models
{
/// <summary>
/// <para>表示 [POST] /cgi-bin/externalcontact/group_welcome_template/get 接口的响应。</para>
@ -47,7 +47,7 @@
public Types.ImageMessage? Image { get; set; }
/// <summary>
/// 获取或设置图文消息信息。
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]

4
src/SKIT.FlurlHttpClient.Wechat.Work/Models/CgibinKf/CgibinKfSendMessageRequest.cs
View File

@ -260,7 +260,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work.Models
public string Name { get; set; } = string.Empty;
/// <summary>
/// 获取或设置详情地址。
/// 获取或设置详细地址。
/// </summary>
[Newtonsoft.Json.JsonProperty("address")]
[System.Text.Json.Serialization.JsonPropertyName("address")]
@ -342,7 +342,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work.Models
public Types.FileMessage? MessageContentForFile { get; set; }
/// <summary>
/// 获取或设置图文消息信息。
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]

2
src/SKIT.FlurlHttpClient.Wechat.Work/Models/CgibinKf/CgibinKfSyncMessageResponse.cs
View File

@ -368,7 +368,7 @@ namespace SKIT.FlurlHttpClient.Wechat.Work.Models
public Types.FileMessage? MessageContentForFile { get; set; }
/// <summary>
/// 获取或设置图文消息信息。
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]

45
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/IWechatWorkFinanceClient.cs Normal file
View File

@ -0,0 +1,45 @@
using System;
using System.Threading;
using System.Threading.Tasks;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance
{
public interface IWechatWorkFinanceClient : IDisposable
{
/// <summary>
/// <para>异步调用会话内容存档之获取会话记录数据接口。</para>
/// <para>REF: https://developer.work.weixin.qq.com/document/path/91774 </para>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
Task<Models.GetChatRecordsResponse> ExecuteGetChatRecordsAsync(Models.GetChatRecordsRequest request, CancellationToken cancellationToken = default);
/// <summary>
/// <para>异步调用会话内容存档之解密会话记录数据接口。</para>
/// <para>REF: https://developer.work.weixin.qq.com/document/path/91774 </para>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
Task<Models.DecryptChatRecordResponse> ExecuteDecryptChatRecordAsync(Models.DecryptChatRecordRequest request, CancellationToken cancellationToken = default);
/// <summary>
/// <para>异步调用会话内容存档之获取媒体文件分片接口。</para>
/// <para>REF: https://developer.work.weixin.qq.com/document/path/91774 </para>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
Task<Models.GetMediaFileBufferResponse> ExecuteGetMediaFileBufferAsync(Models.GetMediaFileBufferRequest request, CancellationToken cancellationToken = default);
/// <summary>
/// <para>异步调用会话内容存档之获取媒体文件接口。</para>
/// <para>REF: https://developer.work.weixin.qq.com/document/path/91774 </para>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
Task<Models.GetMediaFileResponse> ExecuteGetMediaFileAsync(Models.GetMediaFileRequest request, CancellationToken cancellationToken = default);
}
}

61
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/InteropServices/FinanceDllLinuxPInvoker.cs Normal file
View File

@ -0,0 +1,61 @@
using System;
using System.Runtime.InteropServices;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.InteropServices
{
internal static partial class FinanceDllLinuxPInvoker
{
private const string DLL_NAME = "libWeWorkFinanceSdk_C.so";
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern IntPtr NewSdk();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int Init(IntPtr sdk, string corpId, string secret);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int GetChatData(IntPtr sdk, long seq, long limit, string proxy, string passwd, long timeout, IntPtr chatData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int GetMediaData(IntPtr sdk, string indexBuf, string fileId, string proxy, string passwd, long timeout, IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int DecryptData(IntPtr sdk, string encryptKey, string encryptMsg, IntPtr msgData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern void DestroySdk(IntPtr sdk);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern IntPtr NewSlice();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern void FreeSlice(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern string GetContentFromSlice(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int GetSliceLen(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern IntPtr NewMediaData();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern void FreeMediaData(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern string GetOutIndexBuf(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern IntPtr GetData(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int GetIndexLen(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int GetDataLen(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
public static extern int IsMediaDataFinish(IntPtr mediaData);
}
}

80
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/InteropServices/FinanceDllWindowsPInvoker.cs Normal file
View File

@ -0,0 +1,80 @@
using System;
using System.Runtime.InteropServices;
using System.Security;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.InteropServices
{
internal static partial class FinanceDllWindowsPInvoker
{
private const string DLL_NAME = "WeWorkFinanceSdk.dll";
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern IntPtr NewSdk();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int Init(IntPtr sdk, string corpId, string secret);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int GetChatData(IntPtr sdk, long seq, long limit, string proxy, string passwd, long timeout, IntPtr chatData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int GetMediaData(IntPtr sdk, string indexBuf, string fileId, string proxy, string passwd, long timeout, IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int DecryptData(IntPtr sdk, string encryptKey, string encryptMsg, IntPtr msgData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern void DestroySdk(IntPtr sdk);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern IntPtr NewSlice();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern void FreeSlice(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
[return: MarshalAs(UnmanagedType.CustomMarshaler, MarshalTypeRef = typeof(UTF8Marshaler))]
public static extern string GetContentFromSlice(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int GetSliceLen(IntPtr slice);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern IntPtr NewMediaData();
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern void FreeMediaData(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern string GetOutIndexBuf(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern IntPtr GetData(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int GetIndexLen(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int GetDataLen(IntPtr mediaData);
[DllImport(DLL_NAME, SetLastError = true, CallingConvention = CallingConvention.Cdecl)]
[SuppressUnmanagedCodeSecurity]
public static extern int IsMediaDataFinish(IntPtr mediaData);
}
}

83
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/InteropServices/UTF8Marshaler.cs Normal file
View File

@ -0,0 +1,83 @@
using System;
using System.Runtime.InteropServices;
using System.Text;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.InteropServices
{
internal sealed class UTF8Marshaler : ICustomMarshaler
{
private static readonly Lazy<UTF8Marshaler> _instance = new Lazy<UTF8Marshaler>(() => new UTF8Marshaler());
public static ICustomMarshaler GetInstance(string pstrCookie)
{
return _instance.Value;
}
public static string? PtrToStringUTF8(IntPtr pNativeData)
{
return _instance.Value.MarshalNativeToManaged(pNativeData) as string;
}
public IntPtr MarshalManagedToNative(object managedObj)
{
if (managedObj is null)
return IntPtr.Zero;
if (!(managedObj is string))
throw new InvalidOperationException();
byte[] bytes = Encoding.UTF8.GetBytes((string)managedObj);
IntPtr pNativeData = Marshal.AllocHGlobal(bytes.Length + 1);
Marshal.Copy(bytes, 0, pNativeData, bytes.Length);
Marshal.WriteByte(pNativeData, bytes.Length, 0);
return pNativeData;
}
public object MarshalNativeToManaged(IntPtr pNativeData)
{
if (pNativeData == IntPtr.Zero)
return default!;
#if NETCOREAPP || NET5_0_OR_GREATER
return Marshal.PtrToStringUTF8(pNativeData)!;
#else
byte b;
int offset = 0;
do
{
b = Marshal.ReadByte(pNativeData, offset);
offset++;
}
while (b != 0);
byte[] bytes = new byte[offset - 1];
Marshal.Copy(pNativeData, bytes, 0, bytes.Length);
return Encoding.UTF8.GetString(bytes);
#endif
}
public void CleanUpManagedData(object managedObj)
{
}
public void CleanUpNativeData(IntPtr pNativeData)
{
if (pNativeData == IntPtr.Zero)
{
return;
}
/**
* NOTICE:
* 这里释放内存会导致外部 P/Invoke 调用 FreeSlice() 方法时抛出异常
* 因此请注释下面的代码
*/
// Marshal.FreeHGlobal(pNativeData);
}
public int GetNativeDataSize()
{
return -1;
}
}
}

894
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/Abstractions/ChatMessage.cs Normal file
View File

@ -0,0 +1,894 @@
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models.Abstractions
{
public abstract class ChatMessageBase
{
/// <summary>
/// 获取或设置扩展字段。
/// </summary>
[Newtonsoft.Json.JsonExtensionData]
[System.Text.Json.Serialization.JsonExtensionData]
public IDictionary<string, object>? ExtensionData { get; set; }
}
public class TextMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置文本内容。
/// </summary>
[Newtonsoft.Json.JsonProperty("content")]
[System.Text.Json.Serialization.JsonPropertyName("content")]
public string Content { get; set; } = default!;
}
public class ImageMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置图片 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置图片文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置图片文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("filesize")]
[System.Text.Json.Serialization.JsonPropertyName("filesize")]
public int FileSize { get; set; }
}
public class RevokeMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置原消息 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("pre_msgid")]
[System.Text.Json.Serialization.JsonPropertyName("pre_msgid")]
public string PreviousMessageId { get; set; } = default!;
}
public class AgreeMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("userid")]
[System.Text.Json.Serialization.JsonPropertyName("userid")]
public string UserId { get; set; } = default!;
/// <summary>
/// 获取或设置毫秒级时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("agree_time")]
[System.Text.Json.Serialization.JsonPropertyName("agree_time")]
public long AgreeTimeMilliseconds { get; set; }
}
public class VoiceMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置语音时长（单位：秒）。
/// </summary>
[Newtonsoft.Json.JsonProperty("play_length")]
[System.Text.Json.Serialization.JsonPropertyName("play_length")]
public int Duration { get; set; }
/// <summary>
/// 获取或设置语音 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置语音文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置语音文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("voice_size")]
[System.Text.Json.Serialization.JsonPropertyName("voice_size")]
public int FileSize { get; set; }
}
public class VideoMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置视频时长（单位：秒）。
/// </summary>
[Newtonsoft.Json.JsonProperty("play_length")]
[System.Text.Json.Serialization.JsonPropertyName("play_length")]
public int Duration { get; set; }
/// <summary>
/// 获取或设置视频 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置视频文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置视频文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("filesize")]
[System.Text.Json.Serialization.JsonPropertyName("filesize")]
public int FileSize { get; set; }
}
public class BusinessCardMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置企业名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("corpname")]
[System.Text.Json.Serialization.JsonPropertyName("corpname")]
public string CorpName { get; set; } = default!;
/// <summary>
/// 获取或设置 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("userid")]
[System.Text.Json.Serialization.JsonPropertyName("userid")]
public string UserId { get; set; } = default!;
}
public class LocationMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置纬度坐标。
/// </summary>
[Newtonsoft.Json.JsonProperty("latitude")]
[System.Text.Json.Serialization.JsonPropertyName("latitude")]
public double Latitude { get; set; }
/// <summary>
/// 获取或设置经度坐标。
/// </summary>
[Newtonsoft.Json.JsonProperty("longitude")]
[System.Text.Json.Serialization.JsonPropertyName("longitude")]
public double Longitude { get; set; }
/// <summary>
/// 获取或设置位置名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置详细地址。
/// </summary>
[Newtonsoft.Json.JsonProperty("address")]
[System.Text.Json.Serialization.JsonPropertyName("address")]
public string Address { get; set; } = default!;
/// <summary>
/// 获取或设置缩放比例。
/// </summary>
[Newtonsoft.Json.JsonProperty("zoom")]
[System.Text.Json.Serialization.JsonPropertyName("zoom")]
public int Zoom { get; set; }
}
public class EmotionMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置表情类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("type")]
[System.Text.Json.Serialization.JsonPropertyName("type")]
public int Type { get; set; }
/// <summary>
/// 获取或设置宽度（单位：像素）。
/// </summary>
[Newtonsoft.Json.JsonProperty("width")]
[System.Text.Json.Serialization.JsonPropertyName("width")]
public int Width { get; set; }
/// <summary>
/// 获取或设置高度（单位：像素）。
/// </summary>
[Newtonsoft.Json.JsonProperty("height")]
[System.Text.Json.Serialization.JsonPropertyName("height")]
public int Height { get; set; }
/// <summary>
/// 获取或设置表情 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置表情文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置表情文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("imagesize")]
[System.Text.Json.Serialization.JsonPropertyName("imagesize")]
public int FileSize { get; set; }
}
public class FileMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置文件名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("filename")]
[System.Text.Json.Serialization.JsonPropertyName("filename")]
public string FileName { get; set; } = default!;
/// <summary>
/// 获取或设置文件后缀。
/// </summary>
[Newtonsoft.Json.JsonProperty("fileext")]
[System.Text.Json.Serialization.JsonPropertyName("fileext")]
public string FileExtension { get; set; } = default!;
/// <summary>
/// 获取或设置文件 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("filesize")]
[System.Text.Json.Serialization.JsonPropertyName("filesize")]
public int FileSize { get; set; }
}
public class LinkMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置点击后跳转的链接。
/// </summary>
[Newtonsoft.Json.JsonProperty("link_url")]
[System.Text.Json.Serialization.JsonPropertyName("link_url")]
public string LinkUrl { get; set; } = default!;
/// <summary>
/// 获取或设置图文标题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置图文描述。
/// </summary>
[Newtonsoft.Json.JsonProperty("description")]
[System.Text.Json.Serialization.JsonPropertyName("description")]
public string Description { get; set; } = default!;
/// <summary>
/// 获取或设置图文封面的 URL。
/// </summary>
[Newtonsoft.Json.JsonProperty("image_url")]
[System.Text.Json.Serialization.JsonPropertyName("image_url")]
public string ImageUrl { get; set; } = default!;
}
public class MiniProgramMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置消息标题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置消息描述。
/// </summary>
[Newtonsoft.Json.JsonProperty("description")]
[System.Text.Json.Serialization.JsonPropertyName("description")]
public string Description { get; set; } = default!;
/// <summary>
/// 获取或设置小程序名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("displayname")]
[System.Text.Json.Serialization.JsonPropertyName("displayname")]
public string DisplayName { get; set; } = default!;
/// <summary>
/// 获取或设置用户名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("username")]
[System.Text.Json.Serialization.JsonPropertyName("username")]
public string UserName { get; set; } = default!;
}
public class ChatRecordMessage : ChatMessageBase
{
public static class Types
{
public class Record
{
/// <summary>
/// 获取或设置消息发送时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("msgtime")]
[System.Text.Json.Serialization.JsonPropertyName("msgtime")]
public long MessageTimestamp { get; set; }
/// <summary>
/// 获取或设置消息类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("type")]
[System.Text.Json.Serialization.JsonPropertyName("type")]
public string MessageType { get; set; } = default!;
/// <summary>
/// 获取或设置消息内容 JSON 字符串。
/// </summary>
[Newtonsoft.Json.JsonProperty("content")]
[System.Text.Json.Serialization.JsonPropertyName("content")]
public string MessageContentJson { get; set; } = default!;
/// <summary>
/// 获取或设置是否来自群聊。
/// </summary>
[Newtonsoft.Json.JsonProperty("from_chatroom")]
[System.Text.Json.Serialization.JsonPropertyName("from_chatroom")]
public bool IsFromChatroom { get; set; }
}
}
/// <summary>
/// 获取或设置聊天记录标题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置聊天记录列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("item")]
[System.Text.Json.Serialization.JsonPropertyName("item")]
public Types.Record[] RecordList { get; set; } = default!;
}
public class TodoMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置待办的来源文本。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置待办的具体内容。
/// </summary>
[Newtonsoft.Json.JsonProperty("content")]
[System.Text.Json.Serialization.JsonPropertyName("content")]
public string Content { get; set; } = default!;
}
public class VoteMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置投票 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("voteid")]
[System.Text.Json.Serialization.JsonPropertyName("voteid")]
public string VoteId { get; set; } = default!;
/// <summary>
/// 获取或设置投票类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("votetype")]
[System.Text.Json.Serialization.JsonPropertyName("votetype")]
public int Type { get; set; }
/// <summary>
/// 获取或设置投票主题。
/// </summary>
[Newtonsoft.Json.JsonProperty("votetitle")]
[System.Text.Json.Serialization.JsonPropertyName("votetitle")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置投票选项列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("voteitem")]
[System.Text.Json.Serialization.JsonPropertyName("voteitem")]
public string[] Options { get; set; } = default!;
}
public class CollectMessage : ChatMessageBase
{
public static class Types
{
public class Detail
{
/// <summary>
/// 获取或设置表项 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("id")]
[System.Text.Json.Serialization.JsonPropertyName("id")]
public long ID { get; set; }
/// <summary>
/// 获取或设置表项类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("type")]
[System.Text.Json.Serialization.JsonPropertyName("type")]
public string Type { get; set; } = default!;
/// <summary>
/// 获取或设置表项名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("ques")]
[System.Text.Json.Serialization.JsonPropertyName("ques")]
public string Question { get; set; } = default!;
}
}
/// <summary>
/// 获取或设置群聊名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("room_name")]
[System.Text.Json.Serialization.JsonPropertyName("room_name")]
public string RoomName { get; set; } = default!;
/// <summary>
/// 获取或设置创建者名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("creator")]
[System.Text.Json.Serialization.JsonPropertyName("creator")]
public string CreatorName { get; set; } = default!;
/// <summary>
/// 获取或设置创建时间字符串（格式：yyyy-MM-dd HH:mm:ss）。
/// </summary>
[Newtonsoft.Json.JsonProperty("create_time")]
[System.Text.Json.Serialization.JsonPropertyName("create_time")]
public string CreateTimeString { get; set; } = default!;
/// <summary>
/// 获取或设置表名。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置表项列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("details")]
[System.Text.Json.Serialization.JsonPropertyName("details")]
public Types.Detail[] DetailList { get; set; } = default!;
}
public class RedPacketMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置红包类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("type")]
[System.Text.Json.Serialization.JsonPropertyName("type")]
public int Type { get; set; }
/// <summary>
/// 获取或设置红包祝福语。
/// </summary>
[Newtonsoft.Json.JsonProperty("wish")]
[System.Text.Json.Serialization.JsonPropertyName("wish")]
public string Wishing { get; set; } = default!;
/// <summary>
/// 获取或设置总个数。
/// </summary>
[Newtonsoft.Json.JsonProperty("totalcnt")]
[System.Text.Json.Serialization.JsonPropertyName("totalcnt")]
public int TotalCount { get; set; }
/// <summary>
/// 获取或设置总金额（单位：分）。
/// </summary>
[Newtonsoft.Json.JsonProperty("totalamount")]
[System.Text.Json.Serialization.JsonPropertyName("totalamount")]
public int TotalAmount { get; set; }
}
public class MeetingMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置会议类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("meetingtype")]
[System.Text.Json.Serialization.JsonPropertyName("meetingtype")]
public int Type { get; set; }
/// <summary>
/// 获取或设置会议 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("meetingid")]
[System.Text.Json.Serialization.JsonPropertyName("meetingid")]
[System.Text.Json.Serialization.JsonNumberHandling(System.Text.Json.Serialization.JsonNumberHandling.AllowReadingFromString)]
public long MeetingId { get; set; }
/// <summary>
/// 获取或设置会议主题。
/// </summary>
[Newtonsoft.Json.JsonProperty("topic")]
[System.Text.Json.Serialization.JsonPropertyName("topic")]
public string Topic { get; set; } = default!;
/// <summary>
/// 获取或设置会议开始时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("starttime")]
[System.Text.Json.Serialization.JsonPropertyName("starttime")]
public long StartTimestamp { get; set; }
/// <summary>
/// 获取或设置会议结束时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("endtime")]
[System.Text.Json.Serialization.JsonPropertyName("endtime")]
public long EndTimestamp { get; set; }
/// <summary>
/// 获取或设置会议地址。
/// </summary>
[Newtonsoft.Json.JsonProperty("address")]
[System.Text.Json.Serialization.JsonPropertyName("address")]
public string Address { get; set; } = default!;
/// <summary>
/// 获取或设置备注信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("remarks")]
[System.Text.Json.Serialization.JsonPropertyName("remarks")]
public string Remark { get; set; } = default!;
/// <summary>
/// 获取或设置会议邀请处理状态。
/// </summary>
[Newtonsoft.Json.JsonProperty("status")]
[System.Text.Json.Serialization.JsonPropertyName("status")]
public int? Status { get; set; }
}
public class DocumentMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置文档标题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置文档链接。
/// </summary>
[Newtonsoft.Json.JsonProperty("link_url")]
[System.Text.Json.Serialization.JsonPropertyName("link_url")]
public string LinkUrl { get; set; } = default!;
/// <summary>
/// 获取或设置创建者 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("doc_creator")]
[System.Text.Json.Serialization.JsonPropertyName("doc_creator")]
public string CreatorUserId { get; set; } = default!;
}
public class InfoMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置 Markdown 内容。
/// </summary>
[Newtonsoft.Json.JsonProperty("content")]
[System.Text.Json.Serialization.JsonPropertyName("content")]
public string? MarkdownContent { get; set; }
/// <summary>
/// 获取或设置图文消息链接。
/// </summary>
[Newtonsoft.Json.JsonProperty("url")]
[System.Text.Json.Serialization.JsonPropertyName("url")]
public string? NewsUrl { get; set; }
/// <summary>
/// 获取或设置图文消息标题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string? NewsTitle { get; set; }
/// <summary>
/// 获取或设置图文消息描述。
/// </summary>
[Newtonsoft.Json.JsonProperty("description")]
[System.Text.Json.Serialization.JsonPropertyName("description")]
public string? NewsDescription { get; set; }
/// <summary>
/// 获取或设置 VoIP 通话时长（单位：秒）。
/// </summary>
[Newtonsoft.Json.JsonProperty("callduration")]
[System.Text.Json.Serialization.JsonPropertyName("callduration")]
public int? VoIPCallDuration { get; set; }
/// <summary>
/// 获取或设置 VoIP 通话类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("invitetype")]
[System.Text.Json.Serialization.JsonPropertyName("invitetype")]
public int? VoIPInviteType { get; set; }
/// <summary>
/// 获取或设置微盘文件名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("filename")]
[System.Text.Json.Serialization.JsonPropertyName("filename")]
public string? WedriveFileName { get; set; }
}
public class CalendarMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置日程主题。
/// </summary>
[Newtonsoft.Json.JsonProperty("title")]
[System.Text.Json.Serialization.JsonPropertyName("title")]
public string Title { get; set; } = default!;
/// <summary>
/// 获取或设置日程组织者名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("creatorname")]
[System.Text.Json.Serialization.JsonPropertyName("creatorname")]
public string CreatorName { get; set; } = default!;
/// <summary>
/// 获取或设置日程开始时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("starttime")]
[System.Text.Json.Serialization.JsonPropertyName("starttime")]
public long StartTimestamp { get; set; }
/// <summary>
/// 获取或设置日程结束时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("endtime")]
[System.Text.Json.Serialization.JsonPropertyName("endtime")]
public long EndTimestamp { get; set; }
/// <summary>
/// 获取或设置日程参与人名称列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("attendeename")]
[System.Text.Json.Serialization.JsonPropertyName("attendeename")]
public string[] AttendeeNameList { get; set; } = default!;
/// <summary>
/// 获取或设置日程地点。
/// </summary>
[Newtonsoft.Json.JsonProperty("place")]
[System.Text.Json.Serialization.JsonPropertyName("place")]
public string Place { get; set; } = default!;
/// <summary>
/// 获取或设置备注信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("remarks")]
[System.Text.Json.Serialization.JsonPropertyName("remarks")]
public string Remark { get; set; } = default!;
}
public class MixedMessage : ChatMessageBase
{
public static class Types
{
public class Message
{
/// <summary>
/// 获取或设置消息类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("type")]
[System.Text.Json.Serialization.JsonPropertyName("type")]
public string Type { get; set; } = default!;
/// <summary>
/// 获取或设置消息内容 JSON 字符串。
/// </summary>
[Newtonsoft.Json.JsonProperty("content")]
[System.Text.Json.Serialization.JsonPropertyName("content")]
public string ContentJson { get; set; } = default!;
}
}
/// <summary>
/// 获取或设置混合消息列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("item")]
[System.Text.Json.Serialization.JsonPropertyName("item")]
public Types.Message[] MessageList { get; set; } = default!;
}
public class MeetingVoiceCallMessage : ChatMessageBase
{
public static class Types
{
public class ShareFileData
{
/// <summary>
/// 获取或设置文件名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("filename")]
[System.Text.Json.Serialization.JsonPropertyName("filename")]
public string FileName { get; set; } = default!;
/// <summary>
/// 获取或设置操作者 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("demooperator")]
[System.Text.Json.Serialization.JsonPropertyName("demooperator")]
public string OperatorUserId { get; set; } = default!;
/// <summary>
/// 获取或设置开始时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("starttime")]
[System.Text.Json.Serialization.JsonPropertyName("starttime")]
public long StartTimestamp { get; set; }
/// <summary>
/// 获取或设置结束时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("endtime")]
[System.Text.Json.Serialization.JsonPropertyName("endtime")]
public long EndTimestamp { get; set; }
}
public class ShareScreenData
{
/// <summary>
/// 获取或设置分享者 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("share")]
[System.Text.Json.Serialization.JsonPropertyName("share")]
public string SharerUserId { get; set; } = default!;
/// <summary>
/// 获取或设置开始时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("starttime")]
[System.Text.Json.Serialization.JsonPropertyName("starttime")]
public long StartTimestamp { get; set; }
/// <summary>
/// 获取或设置结束时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("endtime")]
[System.Text.Json.Serialization.JsonPropertyName("endtime")]
public long EndTimestamp { get; set; }
}
}
/// <summary>
/// 获取或设置音频 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置音频结束时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("endtime")]
[System.Text.Json.Serialization.JsonPropertyName("endtime")]
public long EndTimestamp { get; set; }
/// <summary>
/// 获取或设置文档分享对象列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("demofiledata")]
[System.Text.Json.Serialization.JsonPropertyName("demofiledata")]
public Types.ShareFileData[]? ShareFileDataList { get; set; }
/// <summary>
/// 获取或设置屏幕共享对象列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("sharescreendata")]
[System.Text.Json.Serialization.JsonPropertyName("sharescreendata")]
public Types.ShareScreenData[]? ShareScreenDataList { get; set; }
}
public class VoIPDocumentShareMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置音频文件名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("filename")]
[System.Text.Json.Serialization.JsonPropertyName("filename")]
public string FileName { get; set; } = default!;
/// <summary>
/// 获取或设置音频 FileId。
/// </summary>
[Newtonsoft.Json.JsonProperty("sdkfileid")]
[System.Text.Json.Serialization.JsonPropertyName("sdkfileid")]
public string FileId { get; set; } = default!;
/// <summary>
/// 获取或设置音频文件 MD5 哈希值。
/// </summary>
[Newtonsoft.Json.JsonProperty("md5sum")]
[System.Text.Json.Serialization.JsonPropertyName("md5sum")]
public string FileMD5 { get; set; } = default!;
/// <summary>
/// 获取或设置音频文件大小（单位：字节）。
/// </summary>
[Newtonsoft.Json.JsonProperty("filesize")]
[System.Text.Json.Serialization.JsonPropertyName("filesize")]
public int FileSize { get; set; }
}
public class ChannelsFeedMessage : ChatMessageBase
{
/// <summary>
/// 获取或设置消息类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("feed_type")]
[System.Text.Json.Serialization.JsonPropertyName("feed_type")]
public int FeedType { get; set; }
/// <summary>
/// 获取或设置视频号账号名称。
/// </summary>
[Newtonsoft.Json.JsonProperty("sph_name")]
[System.Text.Json.Serialization.JsonPropertyName("sph_name")]
public string ChannelsNickName { get; set; } = default!;
/// <summary>
/// 获取或设置消息描述。
/// </summary>
[Newtonsoft.Json.JsonProperty("feed_desc")]
[System.Text.Json.Serialization.JsonPropertyName("feed_desc")]
public string Description { get; set; } = default!;
}
}

29
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/DecryptChatRecordRequest.cs Normal file
View File

@ -0,0 +1,29 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之解密会话记录数据接口的请求。</para>
/// </summary>
public class DecryptChatRecordRequest : WechatWorkFinanceRequest
{
/// <summary>
/// 获取或设置消息加解密公钥版本号。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public int PublicKeyVersion { get; set; }
/// <summary>
/// 获取或设置经过加密的随机密钥。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string EncryptedRandomKey { get; set; } = string.Empty;
/// <summary>
/// 获取或设置经过加密的聊天内容。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string EncryptedChatMessage { get; set; } = string.Empty;
}
}

358
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/DecryptChatRecordResponse.cs Normal file
View File

@ -0,0 +1,358 @@
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之解密会话记录数据接口的响应。</para>
/// </summary>
public class DecryptChatRecordResponse : WechatWorkFinanceResponse
{
public static class Types
{
public class TextMessage : Abstractions.TextMessage
{
}
public class ImageMessage : Abstractions.ImageMessage
{
}
public class RevokeMessage : Abstractions.RevokeMessage
{
}
public class AgreeMessage : Abstractions.AgreeMessage
{
}
public class VoiceMessage : Abstractions.VoiceMessage
{
}
public class VideoMessage : Abstractions.VideoMessage
{
}
public class BusinessCardMessage : Abstractions.BusinessCardMessage
{
}
public class LocationMessage : Abstractions.LocationMessage
{
}
public class EmotionMessage : Abstractions.EmotionMessage
{
}
public class FileMessage : Abstractions.FileMessage
{
}
public class LinkMessage : Abstractions.LinkMessage
{
}
public class MiniProgramMessage : Abstractions.MiniProgramMessage
{
}
public class ChatRecordMessage : Abstractions.ChatRecordMessage
{
}
public class TodoMessage : Abstractions.TodoMessage
{
}
public class VoteMessage : Abstractions.VoteMessage
{
}
public class CollectMessage : Abstractions.CollectMessage
{
}
public class RedPacketMessage : Abstractions.RedPacketMessage
{
}
public class MeetingMessage : Abstractions.MeetingMessage
{
}
public class DocumentMessage : Abstractions.DocumentMessage
{
}
public class InfoMessage : Abstractions.InfoMessage
{
}
public class CalendarMessage : Abstractions.CalendarMessage
{
}
public class MixedMessage : Abstractions.MixedMessage
{
}
public class MeetingVoiceCallMessage : Abstractions.MeetingVoiceCallMessage
{
}
public class VoIPDocumentShareMessage : Abstractions.VoIPDocumentShareMessage
{
}
public class ChannelsFeedMessage : Abstractions.ChannelsFeedMessage
{
}
}
/// <summary>
/// 获取或设置消息 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("msgid")]
[System.Text.Json.Serialization.JsonPropertyName("msgid")]
public string MessageId { get; set; } = default!;
/// <summary>
/// 获取或设置消息动作。
/// </summary>
[Newtonsoft.Json.JsonProperty("action")]
[System.Text.Json.Serialization.JsonPropertyName("action")]
public string Action { get; set; } = default!;
/// <summary>
/// 获取或设置消息发送方 UserId。
/// </summary>
[Newtonsoft.Json.JsonProperty("from")]
[System.Text.Json.Serialization.JsonPropertyName("from")]
public string? FromUserId { get; set; }
/// <summary>
/// 获取或设置消息接收方 UserId 列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("tolist")]
[System.Text.Json.Serialization.JsonPropertyName("tolist")]
public string[]? ToUserIdList { get; set; }
/// <summary>
/// 获取或设置群聊房间 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("roomid")]
[System.Text.Json.Serialization.JsonPropertyName("roomid")]
public string? RoomId { get; set; }
/// <summary>
/// 获取或设置消息发送毫秒级时间戳。
/// </summary>
[Newtonsoft.Json.JsonProperty("msgtime")]
[System.Text.Json.Serialization.JsonPropertyName("msgtime")]
public long MessageTimeMilliseconds { get; set; }
/// <summary>
/// 获取或设置消息类型。
/// </summary>
[Newtonsoft.Json.JsonProperty("msgtype")]
[System.Text.Json.Serialization.JsonPropertyName("msgtype")]
public string MessageType { get; set; } = default!;
/// <summary>
/// 获取或设置文本消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("text")]
[System.Text.Json.Serialization.JsonPropertyName("text")]
public Types.TextMessage? MessageContentForText { get; set; }
/// <summary>
/// 获取或设置图片消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("image")]
[System.Text.Json.Serialization.JsonPropertyName("image")]
public Types.ImageMessage? MessageContentForImage { get; set; }
/// <summary>
/// 获取或设置撤回消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("revoke")]
[System.Text.Json.Serialization.JsonPropertyName("revoke")]
public Types.RevokeMessage? MessageContentForRevoke { get; set; }
/// <summary>
/// 获取或设置同意/不同意消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("agree")]
[System.Text.Json.Serialization.JsonPropertyName("agree")]
public Types.AgreeMessage? MessageContentForAgree { get; set; }
/// <summary>
/// 获取或设置语音消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("voice")]
[System.Text.Json.Serialization.JsonPropertyName("voice")]
public Types.VoiceMessage? MessageContentForVoice { get; set; }
/// <summary>
/// 获取或设置视频消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("video")]
[System.Text.Json.Serialization.JsonPropertyName("video")]
public Types.VideoMessage? MessageContentForVideo { get; set; }
/// <summary>
/// 获取或设置名片消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("card")]
[System.Text.Json.Serialization.JsonPropertyName("card")]
public Types.BusinessCardMessage? MessageContentForBusinessCard { get; set; }
/// <summary>
/// 获取或设置位置消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("location")]
[System.Text.Json.Serialization.JsonPropertyName("location")]
public Types.LocationMessage? MessageContentForLocation { get; set; }
/// <summary>
/// 获取或设置表情消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("emotion")]
[System.Text.Json.Serialization.JsonPropertyName("emotion")]
public Types.EmotionMessage? MessageContentForEmotion { get; set; }
/// <summary>
/// 获取或设置文件消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("file")]
[System.Text.Json.Serialization.JsonPropertyName("file")]
public Types.FileMessage? MessageContentForFile { get; set; }
/// <summary>
/// 获取或设置图文链接消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("link")]
[System.Text.Json.Serialization.JsonPropertyName("link")]
public Types.LinkMessage? MessageContentForLink { get; set; }
/// <summary>
/// 获取或设置小程序消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("weapp")]
[System.Text.Json.Serialization.JsonPropertyName("weapp")]
public Types.MiniProgramMessage? MessageContentForMiniProgram { get; set; }
/// <summary>
/// 获取或设置会话记录消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("chatrecord")]
[System.Text.Json.Serialization.JsonPropertyName("chatrecord")]
public Types.ChatRecordMessage? MessageContentForChatRecord { get; set; }
/// <summary>
/// 获取或设置待办消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("todo")]
[System.Text.Json.Serialization.JsonPropertyName("todo")]
public Types.TodoMessage? MessageContentForTodo { get; set; }
/// <summary>
/// 获取或设置投票消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("vote")]
[System.Text.Json.Serialization.JsonPropertyName("vote")]
public Types.VoteMessage? MessageContentForVote { get; set; }
/// <summary>
/// 获取或设置填表消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("collect")]
[System.Text.Json.Serialization.JsonPropertyName("collect")]
public Types.CollectMessage? MessageContentForCollect { get; set; }
/// <summary>
/// 获取或设置红包消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("redpacket")]
[System.Text.Json.Serialization.JsonPropertyName("redpacket")]
public Types.RedPacketMessage? MessageContentForRedPacket { get; set; }
/// <summary>
/// 获取或设置会议消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("meeting")]
[System.Text.Json.Serialization.JsonPropertyName("meeting")]
public Types.MeetingMessage? MessageContentForMeeting { get; set; }
/// <summary>
/// 获取或设置在线文档消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("doc")]
[System.Text.Json.Serialization.JsonPropertyName("doc")]
public Types.DocumentMessage? MessageContentForDocument { get; set; }
/// <summary>
/// 获取或设置 Markdown、图文消息或音视频通话信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("info")]
[System.Text.Json.Serialization.JsonPropertyName("info")]
public Types.InfoMessage? MessageContentForInfo { get; set; }
/// <summary>
/// 获取或设置日程消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("calendar")]
[System.Text.Json.Serialization.JsonPropertyName("calendar")]
public Types.CalendarMessage? MessageContentForCalendar { get; set; }
/// <summary>
/// 获取或设置混合消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("mixed")]
[System.Text.Json.Serialization.JsonPropertyName("mixed")]
public Types.MixedMessage? MessageContentForMixed { get; set; }
/// <summary>
/// 获取或设置会议音频存档消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("meeting_voice_call")]
[System.Text.Json.Serialization.JsonPropertyName("meeting_voice_call")]
public Types.MeetingVoiceCallMessage? MessageContentForMeetingVoiceCall { get; set; }
/// <summary>
/// 获取或设置 VoIP 音频存档消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("voip_doc_share")]
[System.Text.Json.Serialization.JsonPropertyName("voip_doc_share")]
public Types.VoIPDocumentShareMessage? MessageContentForVoIPDocumentShare { get; set; }
/// <summary>
/// 获取或设置视频号消息信息。
/// </summary>
[Newtonsoft.Json.JsonProperty("sphfeed")]
[System.Text.Json.Serialization.JsonPropertyName("sphfeed")]
public Types.ChannelsFeedMessage? MessageContentForChannelsFeed { get; set; }
/// <summary>
/// 获取或设置音频 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("voiceid")]
[System.Text.Json.Serialization.JsonPropertyName("voiceid")]
public string? VoiceId { get; set; } = default!;
/// <summary>
/// 获取或设置 VoIP ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("voipid")]
[System.Text.Json.Serialization.JsonPropertyName("voipid")]
public string? VoIPId { get; set; } = default!;
/// <summary>
/// 获取或设置扩展字段。
/// </summary>
[Newtonsoft.Json.JsonExtensionData]
[System.Text.Json.Serialization.JsonExtensionData]
public IDictionary<string, object>? ExtensionData { get; set; }
}
}

23
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetChatRecordsRequest.cs Normal file
View File

@ -0,0 +1,23 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取会话记录数据接口的请求。</para>
/// </summary>
public class GetChatRecordsRequest : WechatWorkFinanceRequest
{
/// <summary>
/// 获取或设置起始序号。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public long LastSequence { get; set; }
/// <summary>
/// 获取或设置分页每页数量。
/// <para>默认值：1000</para>
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public int Limit { get; set; } = 1000;
}
}

75
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetChatRecordsResponse.cs Normal file
View File

@ -0,0 +1,75 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取会话记录数据接口的响应。</para>
/// </summary>
public class GetChatRecordsResponse : WechatWorkFinanceResponse
{
public static class Types
{
public class Record
{
/// <summary>
/// 获取或设置序号。
/// </summary>
[Newtonsoft.Json.JsonProperty("seq")]
[System.Text.Json.Serialization.JsonPropertyName("seq")]
public long Sequence { get; set; }
/// <summary>
/// 获取或设置消息 ID。
/// </summary>
[Newtonsoft.Json.JsonProperty("msgid")]
[System.Text.Json.Serialization.JsonPropertyName("msgid")]
public string MessageId { get; set; } = default!;
/// <summary>
/// 获取或设置消息加解密公钥版本号。
/// </summary>
[Newtonsoft.Json.JsonProperty("publickey_ver")]
[System.Text.Json.Serialization.JsonPropertyName("publickey_ver")]
public int PublicKeyVersion { get; set; }
/// <summary>
/// 获取或设置经过加密的随机密钥。
/// </summary>
[Newtonsoft.Json.JsonProperty("encrypt_random_key")]
[System.Text.Json.Serialization.JsonPropertyName("encrypt_random_key")]
public string EncryptedRandomKey { get; set; } = default!;
/// <summary>
/// 获取或设置经过加密的聊天内容。
/// </summary>
[Newtonsoft.Json.JsonProperty("encrypt_chat_msg")]
[System.Text.Json.Serialization.JsonPropertyName("encrypt_chat_msg")]
public string EncryptedChatMessage { get; set; } = default!;
}
}
/// <summary>
/// 获取或设置错误码。
/// </summary>
[Newtonsoft.Json.JsonProperty("errcode")]
[System.Text.Json.Serialization.JsonPropertyName("errcode")]
public int ErrorCode { get; set; }
/// <summary>
/// 获取或设置错误描述。
/// </summary>
[Newtonsoft.Json.JsonProperty("errmsg")]
[System.Text.Json.Serialization.JsonPropertyName("errmsg")]
public string? ErrorMessage { get; set; }
/// <summary>
/// 获取或设置聊天记录列表。
/// </summary>
[Newtonsoft.Json.JsonProperty("chatdata")]
[System.Text.Json.Serialization.JsonPropertyName("chatdata")]
public Types.Record[] RecordList { get; set; } = default!;
public override bool IsSuccessful()
{
return base.IsSuccessful() && ErrorCode == 0;
}
}
}

22
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetMediaFileBufferRequest.cs Normal file
View File

@ -0,0 +1,22 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取媒体文件分片接口的请求。</para>
/// </summary>
public class GetMediaFileBufferRequest : WechatWorkFinanceRequest
{
/// <summary>
/// 获取或设置起始分片索引。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string? BufferIndex { get; set; }
/// <summary>
/// 获取或设置文件 FileId。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string FileId { get; set; } = string.Empty;
}
}

38
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetMediaFileBufferResponse.cs Normal file
View File

@ -0,0 +1,38 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取媒体文件分片接口的响应。</para>
/// </summary>
public class GetMediaFileBufferResponse : WechatWorkFinanceResponse
{
/// <summary>
/// 获取或设置文件分片二进制数组。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public byte[] FileBufferBytes
{
get { return RawBytes; }
set { RawBytes = value; }
}
/// <summary>
/// 获取或设置下一次的分片索引。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string? NextBufferIndex { get; set; }
/// <summary>
/// 获取或设置是否完成。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public bool IsFinished { get; set; }
public override bool IsSuccessful()
{
return base.IsSuccessful() && FileBufferBytes?.Length > 0;
}
}
}

15
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetMediaFileRequest.cs Normal file
View File

@ -0,0 +1,15 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取媒体文件接口的请求。</para>
/// </summary>
public class GetMediaFileRequest : WechatWorkFinanceRequest
{
/// <summary>
/// 获取或设置文件 FileId。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public string FileId { get; set; } = string.Empty;
}
}

24
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Models/GetMediaFileResponse.cs Normal file
View File

@ -0,0 +1,24 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Models
{
/// <summary>
/// <para>表示会话内容存档之获取媒体文件接口的响应。</para>
/// </summary>
public class GetMediaFileResponse : WechatWorkFinanceResponse
{
/// <summary>
/// 获取或设置文件二进制数组。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public byte[] FileBytes
{
get { return RawBytes; }
set { RawBytes = value; }
}
public override bool IsSuccessful()
{
return base.IsSuccessful() && FileBytes?.Length > 0;
}
}
}

25
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Settings/Credentials.cs Normal file
View File

@ -0,0 +1,25 @@
using System;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Settings
{
public class Credentials
{
/// <summary>
/// 初始化客户端时 <see cref="WechatWorkFinanceClientOptions.CorpId"/> 的副本。
/// </summary>
public string CorpId { get; }
/// <summary>
/// 初始化客户端时 <see cref="WechatWorkFinanceClientOptions.SecretKey"/> 的副本。
/// </summary>
public string SecretKey { get; }
internal Credentials(WechatWorkFinanceClientOptions options)
{
if (options == null) throw new ArgumentNullException(nameof(options));
CorpId = options.CorpId;
SecretKey = options.SecretKey;
}
}
}

70
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Settings/EncryptionKeyEntry.cs Normal file
View File

@ -0,0 +1,70 @@
using System;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Settings
{
/// <summary>
/// 表示一个企业微信会话内容存档的消息加解密密钥实体。
/// </summary>
public struct EncryptionKeyEntry : IEquatable<EncryptionKeyEntry>
{
/// <summary>
/// 获取版本号。
/// </summary>
public int Version { get; }
/// <summary>
/// 获取私钥内容（PKCS#1 PEM 格式，即 -----BEGIN RSA PRIVATE KEY----- ... -----END RSA PRIVATE KEY-----）
/// </summary>
public string PrivateKey { get; }
[Newtonsoft.Json.JsonConstructor]
[System.Text.Json.Serialization.JsonConstructor]
public EncryptionKeyEntry(int version, string privateKey)
{
if (version <= 0)
throw new ArgumentException("The value of `version` can not be less than zero.", nameof(version));
if (string.IsNullOrEmpty(privateKey))
throw new ArgumentException("The value of `privateKey` can not be empty.", nameof(privateKey));
if (!privateKey.Trim().StartsWith("-----BEGIN RSA PRIVATE KEY-----") || !privateKey.Trim().EndsWith("-----END RSA PRIVATE KEY-----"))
throw new ArgumentException("The value of `privateKey` is an invalid private key file content.", nameof(privateKey));
Version = version;
PrivateKey = privateKey;
}
public bool Equals(EncryptionKeyEntry other)
{
return int.Equals(Version, other.Version) &&
string.Equals(PrivateKey, other.PrivateKey);
}
public override bool Equals(object? obj)
{
if (ReferenceEquals(null, obj))
return false;
if (GetType() != obj.GetType())
return false;
return Equals((EncryptionKeyEntry)obj);
}
public override int GetHashCode()
{
#if NETFRAMEWORK || NETSTANDARD2_0
return (Version.GetHashCode(), PrivateKey?.GetHashCode()).GetHashCode();
#else
return HashCode.Combine(Version.GetHashCode(), PrivateKey?.GetHashCode());
#endif
}
public static bool operator ==(EncryptionKeyEntry left, EncryptionKeyEntry right)
{
return left.Equals(right);
}
public static bool operator !=(EncryptionKeyEntry left, EncryptionKeyEntry right)
{
return !left.Equals(right);
}
}
}

77
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/Settings/EncryptionKeyManager.cs Normal file
View File

@ -0,0 +1,77 @@
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.Settings
{
/// <summary>
/// 企业微信会话内容存档的消息加解密密钥管理器接口。
/// </summary>
public abstract class EncryptionKeyManager
{
/// <summary>
/// 获取存储的全部消息加解密密钥实体。
/// </summary>
/// <returns></returns>
public abstract IEnumerable<EncryptionKeyEntry> AllEntries();
/// <summary>
/// 添加一个消息加解密密钥实体。
/// </summary>
/// <param name="entry"></param>
public abstract void AddEntry(EncryptionKeyEntry entry);
/// <summary>
/// 根据版本号获取消息加解密密钥实体。
/// </summary>
/// <param name="version"></param>
/// <returns></returns>
public abstract EncryptionKeyEntry? GetEntry(int version);
/// <summary>
/// 根据版本号移除消息加解密密钥实体。
/// </summary>
/// <param name="version"></param>
/// <returns></returns>
public abstract bool RemoveEntry(int version);
}
/// <summary>
/// 一个基于内存实现的 <see cref="EncryptionKeyManager"/>。
/// </summary>
public class InMemoryEncryptionKeyManager : EncryptionKeyManager
{
private readonly ConcurrentDictionary<int, EncryptionKeyEntry> _dict;
public InMemoryEncryptionKeyManager()
{
_dict = new ConcurrentDictionary<int, EncryptionKeyEntry>();
}
public override IEnumerable<EncryptionKeyEntry> AllEntries()
{
return _dict.Values.ToArray();
}
public override void AddEntry(EncryptionKeyEntry entry)
{
_dict.TryRemove(entry.Version, out _);
_dict.TryAdd(entry.Version, entry);
}
public override EncryptionKeyEntry? GetEntry(int version)
{
if (_dict.TryGetValue(version, out var entry))
{
return entry;
}
return null;
}
public override bool RemoveEntry(int version)
{
return _dict.TryRemove(version, out _);
}
}
}

452
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/WechatWorkFinanceClient.cs Normal file
View File

@ -0,0 +1,452 @@
using System;
using System.IO;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance
{
using SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance.InteropServices;
/// <summary>
/// 一个企业微信会话内容存档 API HTTP 客户端。
/// </summary>
public sealed class WechatWorkFinanceClient : CommonClientBase, ICommonClient, IWechatWorkFinanceClient, IDisposable
{
private static readonly object _lockObj = new object();
private readonly int _timeout;
private readonly string? _proxyAddress;
private readonly string? _proxyAuthentication;
private IntPtr _sdkPtr;
private bool _initialized;
private bool _disposed;
/// <summary>
/// 获取当前客户端使用的企业微信会话内容存档凭证。
/// </summary>
public Settings.Credentials Credentials { get; }
/// <summary>
/// 获取当前客户端使用的企业微信会话内容存档消息加解密密钥管理器。
/// </summary>
public Settings.EncryptionKeyManager EncryptionKeyManager { get; }
/// <summary>
/// 用指定的配置项初始化 <see cref="WechatWorkFinanceClient"/> 类的新实例。
/// </summary>
/// <param name="options">配置项。</param>
public WechatWorkFinanceClient(WechatWorkFinanceClientOptions options)
: base()
{
if (options == null) throw new ArgumentNullException(nameof(options));
Credentials = new Settings.Credentials(options);
EncryptionKeyManager = options.EncryptionKeyManager;
_timeout = options.Timeout;
_proxyAddress = options.ProxyAddress;
_proxyAuthentication = options.ProxyAuthentication;
_sdkPtr = /* 申请用于构造 SDK 的内存空间 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.NewSdk() :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.NewSdk() :
throw new PlatformNotSupportedException();
}
~WechatWorkFinanceClient()
{
Dispose(disposing: false);
}
private static bool IsRunOnWindows()
{
#if NET471_OR_GREATER || NETSTANDARD
return RuntimeInformation.IsOSPlatform(OSPlatform.Windows);
#else
return Environment.OSVersion.Platform == PlatformID.Win32NT;
#endif
}
private static bool IsRunOnLinux()
{
#if NET471_OR_GREATER || NETSTANDARD
return RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ||
RuntimeInformation.IsOSPlatform(OSPlatform.OSX);
#elif NETFRAMEWORK
return Environment.OSVersion.Platform == PlatformID.Unix ||
Environment.OSVersion.Platform == PlatformID.MacOSX;
#else
return Environment.OSVersion.Platform == PlatformID.Unix;
#endif
}
/// <summary>
/// <inheritdoc/>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public Task<Models.GetChatRecordsResponse> ExecuteGetChatRecordsAsync(Models.GetChatRecordsRequest request, CancellationToken cancellationToken = default)
{
if (request == null) throw new ArgumentNullException(nameof(request));
EnsureInitialized();
return Task.Run(() =>
{
IntPtr dataPtr = IntPtr.Zero;
Action freeDataPtr = () =>
{
if (dataPtr != IntPtr.Zero)
{
if (IsRunOnWindows()) FinanceDllWindowsPInvoker.FreeSlice(dataPtr);
else if (IsRunOnLinux()) FinanceDllLinuxPInvoker.FreeSlice(dataPtr);
else Marshal.FreeHGlobal(dataPtr);
dataPtr = IntPtr.Zero;
}
};
cancellationToken.Register(freeDataPtr);
dataPtr = /* 申请用于存储聊天记录数据的内存空间 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.NewSlice() :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.NewSlice() :
throw new PlatformNotSupportedException();
Models.GetChatRecordsResponse response = new Models.GetChatRecordsResponse();
try
{
int ret = /* 获取聊天记录数据 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetChatData(_sdkPtr, request.LastSequence, request.Limit, _proxyAddress!, _proxyAuthentication!, (request.Timeout ?? _timeout) / 1000, dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetChatData(_sdkPtr, request.LastSequence, request.Limit, _proxyAddress!, _proxyAuthentication!, (request.Timeout ?? _timeout) / 1000, dataPtr) :
throw new PlatformNotSupportedException();
if (ret == 0)
{
//int dataSize = /* 获取聊天记录数据内容长度 */
// IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetSliceLen(dataPtr) :
// IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetSliceLen(dataPtr) :
// throw new PlatformNotSupportedException();
string dataContent = /* 获取聊天记录数据内容 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetContentFromSlice(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetContentFromSlice(dataPtr) :
throw new PlatformNotSupportedException();
response = JsonSerializer.Deserialize<Models.GetChatRecordsResponse>(dataContent);
response.RawBytes = Encoding.UTF8.GetBytes(dataContent);
}
response.ReturnCode = ret;
return response;
}
catch (Exception ex)
{
throw new WechatWorkFinanceException("Failed to fetch chat data. Please see the inner exception for more details.", ex);
}
finally
{
freeDataPtr();
}
}, cancellationToken);
}
/// <summary>
/// <inheritdoc/>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public Task<Models.DecryptChatRecordResponse> ExecuteDecryptChatRecordAsync(Models.DecryptChatRecordRequest request, CancellationToken cancellationToken = default)
{
if (request == null) throw new ArgumentNullException(nameof(request));
EnsureInitialized();
return Task.Run(() =>
{
string encryptKey;
try
{
Settings.EncryptionKeyEntry? encryptionKeyEntry = EncryptionKeyManager.GetEntry(request.PublicKeyVersion);
if (!encryptionKeyEntry.HasValue)
throw new WechatWorkFinanceException($"Failed to decrypt random key of the encrypted chat data, because there is no private key matched the verion: \"{request.PublicKeyVersion}\".");
encryptKey = Utilities.RSAUtility.DecryptWithECB(
privateKey: encryptionKeyEntry.Value.PrivateKey,
cipherText: request.EncryptedRandomKey
);
}
catch (WechatWorkFinanceException)
{
throw;
}
catch (Exception ex)
{
throw new WechatWorkFinanceException("Failed to decrypt random key of the encrypted chat data. Please see the inner exception for more details.", ex);
}
IntPtr dataPtr = IntPtr.Zero;
Action freeDataPtr = () =>
{
if (dataPtr != IntPtr.Zero)
{
if (IsRunOnWindows()) FinanceDllWindowsPInvoker.FreeSlice(dataPtr);
else if (IsRunOnLinux()) FinanceDllLinuxPInvoker.FreeSlice(dataPtr);
else Marshal.FreeHGlobal(dataPtr);
dataPtr = IntPtr.Zero;
}
};
cancellationToken.Register(freeDataPtr);
dataPtr = /* 申请用于存储聊天记录数据的内存空间 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.NewSlice() :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.NewSlice() :
throw new PlatformNotSupportedException();
Models.DecryptChatRecordResponse response = new Models.DecryptChatRecordResponse();
try
{
int ret = /* 解密聊天记录数据 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.DecryptData(_sdkPtr, encryptKey, request.EncryptedChatMessage, dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.DecryptData(_sdkPtr, encryptKey, request.EncryptedChatMessage, dataPtr) :
throw new PlatformNotSupportedException();
if (ret == 0)
{
//int dataSize = /* 获取聊天记录数据内容长度 */
// IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetSliceLen(dataPtr) :
// IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetSliceLen(dataPtr) :
// throw new PlatformNotSupportedException();
string dataContent = /* 获取聊天记录数据内容 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetContentFromSlice(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetContentFromSlice(dataPtr) :
throw new PlatformNotSupportedException();
response = JsonSerializer.Deserialize<Models.DecryptChatRecordResponse>(dataContent);
response.RawBytes = Encoding.UTF8.GetBytes(dataContent);
}
response.ReturnCode = ret;
return response;
}
catch (Exception ex)
{
throw new WechatWorkFinanceException("Failed to decrypt chat data. Please see the inner exception for more details.", ex);
}
finally
{
freeDataPtr();
}
}, cancellationToken);
}
/// <summary>
/// <inheritdoc/>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public Task<Models.GetMediaFileBufferResponse> ExecuteGetMediaFileBufferAsync(Models.GetMediaFileBufferRequest request, CancellationToken cancellationToken = default)
{
if (request == null) throw new ArgumentNullException(nameof(request));
EnsureInitialized();
return Task.Run(() =>
{
IntPtr dataPtr = IntPtr.Zero;
Action freeDataPtr = () =>
{
if (dataPtr != IntPtr.Zero)
{
if (IsRunOnWindows()) FinanceDllWindowsPInvoker.FreeMediaData(dataPtr);
else if (IsRunOnLinux()) FinanceDllLinuxPInvoker.FreeMediaData(dataPtr);
else Marshal.FreeHGlobal(dataPtr);
dataPtr = IntPtr.Zero;
}
};
cancellationToken.Register(freeDataPtr);
dataPtr = /* 申请用于存储媒体文件数据的内存空间 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.NewMediaData() :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.NewMediaData() :
throw new PlatformNotSupportedException();
Models.GetMediaFileBufferResponse response = new Models.GetMediaFileBufferResponse();
try
{
int ret = /* 获取媒体文件数据 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetMediaData(_sdkPtr, request.BufferIndex ?? string.Empty, request.FileId, _proxyAddress!, _proxyAuthentication!, (request.Timeout ?? _timeout) / 1000, dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetMediaData(_sdkPtr, request.BufferIndex ?? string.Empty, request.FileId, _proxyAddress!, _proxyAuthentication!, (request.Timeout ?? _timeout) / 1000, dataPtr) :
throw new PlatformNotSupportedException();
if (ret == 0)
{
int dataSize = /* 获取媒体文件数据内容长度 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetDataLen(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetDataLen(dataPtr) :
throw new PlatformNotSupportedException();
IntPtr dataContentPtr = /* 获取媒体文件数据内容 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetData(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetData(dataPtr) :
throw new PlatformNotSupportedException();
string dataNextBufferIndex = /* 获取媒体文件数据内容缓冲标识 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.GetOutIndexBuf(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.GetOutIndexBuf(dataPtr) :
throw new PlatformNotSupportedException();
int dataIsFinishFlag = /* 获取媒体文件数据内容完结标识 */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.IsMediaDataFinish(dataPtr) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.IsMediaDataFinish(dataPtr) :
throw new PlatformNotSupportedException();
byte[] bytes = new byte[dataSize];
Marshal.Copy(dataContentPtr, bytes, 0, bytes.Length);
Marshal.FreeHGlobal(dataContentPtr);
response.FileBufferBytes = bytes;
response.NextBufferIndex = dataNextBufferIndex;
response.IsFinished = dataIsFinishFlag != 0;
}
response.ReturnCode = ret;
return response;
}
catch (Exception ex)
{
throw new WechatWorkFinanceException("Failed to get media data. Please see the inner exception for more details.", ex);
}
finally
{
freeDataPtr();
}
}, cancellationToken);
}
/// <summary>
/// <inheritdoc/>
/// </summary>
/// <param name="request"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public async Task<Models.GetMediaFileResponse> ExecuteGetMediaFileAsync(Models.GetMediaFileRequest request, CancellationToken cancellationToken = default)
{
if (request == null) throw new ArgumentNullException(nameof(request));
EnsureInitialized();
const int ATTAMPT_MAX = 3; // 错误最大重试次数
const int ATTAMPT_INTERVAL = 500; // 错误等待间隔（单位：毫秒）
int retryCount = 0; // 当前已重试次数，获取每个分片前都重置为 0
string fileId = request.FileId;
string? nextBufferIndex = null;
Models.GetMediaFileResponse response = new Models.GetMediaFileResponse();
using (MemoryStream stream = new MemoryStream())
{
while (true)
{
if (retryCount >= ATTAMPT_MAX)
break;
cancellationToken.ThrowIfCancellationRequested();
var reqBuffer = new Models.GetMediaFileBufferRequest()
{
FileId = fileId,
BufferIndex = nextBufferIndex,
Timeout = request.Timeout
};
var resBuffer = await ExecuteGetMediaFileBufferAsync(reqBuffer, cancellationToken);
response.ReturnCode = resBuffer.ReturnCode;
if (resBuffer.IsSuccessful())
{
retryCount = 0;
nextBufferIndex = resBuffer.NextBufferIndex;
await stream.WriteAsync(resBuffer.FileBufferBytes, 0, resBuffer.FileBufferBytes.Length, cancellationToken);
if (resBuffer.IsFinished)
break;
}
else
{
if (10001 == resBuffer.ReturnCode ||
10002 == resBuffer.ReturnCode ||
10003 == resBuffer.ReturnCode)
{
// 根据官方建议，这三种错误代码需要重试
await Task.Delay(ATTAMPT_INTERVAL);
retryCount++;
continue;
}
break;
}
}
response.RawBytes = stream.ToArray();
return response;
}
}
private void EnsureInitialized()
{
if (_disposed)
throw new ObjectDisposedException(nameof(WechatWorkFinanceClient));
if (!_initialized)
{
lock (_lockObj)
{
if (!_initialized)
{
int ret = /* 初始化 SDK */
IsRunOnWindows() ? FinanceDllWindowsPInvoker.Init(_sdkPtr, Credentials.CorpId, Credentials.SecretKey) :
IsRunOnLinux() ? FinanceDllLinuxPInvoker.Init(_sdkPtr, Credentials.CorpId, Credentials.SecretKey) :
throw new PlatformNotSupportedException();
if (ret != 0)
throw new WechatWorkFinanceException($"Failed to initialize Wechat Work Finance SDK (ret: {ret}).");
_initialized = true;
}
}
}
}
private void Dispose(bool disposing)
{
if (!_disposed)
{
if (disposing)
{
// 释放托管资源
}
// 释放非托管资源
IntPtr tmpptr = _sdkPtr;
if (tmpptr != IntPtr.Zero)
{
if (IsRunOnWindows()) FinanceDllWindowsPInvoker.DestroySdk(tmpptr);
else if (IsRunOnLinux()) FinanceDllLinuxPInvoker.DestroySdk(tmpptr);
else Marshal.FreeHGlobal(tmpptr);
_sdkPtr = IntPtr.Zero;
}
_disposed = true;
}
}
public override void Dispose()
{
base.Dispose();
Dispose(disposing: true);
GC.SuppressFinalize(this);
}
}
}

40
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/WechatWorkFinanceClientOptions.cs Normal file
View File

@ -0,0 +1,40 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance
{
/// <summary>
/// 一个用于构造 <see cref="WechatWorkFinanceClient"/> 时使用的配置项。
/// </summary>
public class WechatWorkFinanceClientOptions
{
/// <summary>
/// 获取或设置请求超时时间（单位：毫秒），建议设置为 1000 的整数倍。
/// <para>默认值：30000</para>
/// </summary>
public int Timeout { get; set; } = 30 * 1000;
/// <summary>
/// 获取或设置代理地址。
/// </summary>
public string? ProxyAddress { get; set; }
/// <summary>
/// 获取或设置代理认证信息（如账号、密码）。
/// </summary>
public string? ProxyAuthentication { get; set; }
/// <summary>
/// 获取或设置企业微信 CorpId。
/// </summary>
public string CorpId { get; set; } = default!;
/// <summary>
/// 获取或设置企业微信会话内容存档 SecretKey。
/// </summary>
public string SecretKey { get; set; } = default!;
/// <summary>
/// 获取或设置企业微信会话内容存档消息加解密密钥管理器。
/// <para>默认值：<see cref="Settings.InMemoryEncryptionKeyManager"/></para>
/// </summary>
public Settings.EncryptionKeyManager EncryptionKeyManager { get; set; } = new Settings.InMemoryEncryptionKeyManager();
}
}

27
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/WechatWorkFinanceException.cs Normal file
View File

@ -0,0 +1,27 @@
using System;
namespace SKIT.FlurlHttpClient.Wechat.Work
{
/// <summary>
/// 当调用企业微信会话内容存档 API 出错时引发的异常。
/// </summary>
public class WechatWorkFinanceException : WechatWorkException
{
/// <inheritdoc/>
public WechatWorkFinanceException()
{
}
/// <inheritdoc/>
public WechatWorkFinanceException(string message)
: base(message)
{
}
/// <inheritdoc/>
public WechatWorkFinanceException(string message, Exception innerException)
: base(message, innerException)
{
}
}
}

15
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/WechatWorkFinanceRequest.cs Normal file
View File

@ -0,0 +1,15 @@
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance
{
/// <summary>
/// 表示企业微信会话内容存档 API 请求的基类。
/// </summary>
public abstract class WechatWorkFinanceRequest : ICommonRequest
{
/// <summary>
/// 获取或设置请求超时时间（单位：毫秒）。如果不指定将使用构造 <see cref="WechatWorkFinanceClient"/> 时的 <see cref="WechatWorkFinanceClientOptions.Timeout"/> 参数。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public virtual int? Timeout { get; set; }
}
}

61
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/WechatWorkFinanceResponse.cs Normal file
View File

@ -0,0 +1,61 @@
using System;
using System.Collections.Generic;
namespace SKIT.FlurlHttpClient.Wechat.Work.SDK.Finance
{
/// <summary>
/// 表示企业微信会话内容存档 API 响应的基类。
/// </summary>
public abstract class WechatWorkFinanceResponse : ICommonResponse
{
/// <summary>
///
/// </summary>
int ICommonResponse.RawStatus
{
get { throw new NotSupportedException(); }
set { throw new NotSupportedException(); }
}
/// <summary>
///
/// </summary>
IDictionary<string, string> ICommonResponse.RawHeaders
{
get { throw new NotSupportedException(); }
set { throw new NotSupportedException(); }
}
/// <summary>
///
/// </summary>
byte[] ICommonResponse.RawBytes { get; set; } = Array.Empty<byte>();
/// <summary>
/// 获取原始的响应数据。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public byte[] RawBytes
{
get { return ((ICommonResponse)this).RawBytes; }
internal set { ((ICommonResponse)this).RawBytes = value; }
}
/// <summary>
/// 获取企业微信会话内容存档 API 返回的返回值。
/// </summary>
[Newtonsoft.Json.JsonIgnore]
[System.Text.Json.Serialization.JsonIgnore]
public int ReturnCode { get; internal set; }
/// <summary>
/// 获取一个值，该值指示调用企业微信会话内容存档 API 是否成功（即 "ret" 值为 0）。
/// </summary>
/// <returns></returns>
public virtual bool IsSuccessful()
{
return ReturnCode == 0;
}
}
}

BIN
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/_Libs/WeWorkFinanceSdk.dll Normal file
View File

Binary file not shown.

BIN
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/_Libs/libWeWorkFinanceSdk_C.so Normal file
View File

Binary file not shown.

BIN
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/_Libs/libcrypto-1_1-x64.dll Normal file
View File

Binary file not shown.

BIN
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/_Libs/libcurl-x64.dll Normal file
View File

Binary file not shown.

BIN
src/SKIT.FlurlHttpClient.Wechat.Work/SDK/Finance/_Libs/libssl-1_1-x64.dll Normal file
View File

Binary file not shown.

18
src/SKIT.FlurlHttpClient.Wechat.Work/SKIT.FlurlHttpClient.Wechat.Work.csproj
View File

@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFrameworks>net461; netstandard2.0; net6.0</TargetFrameworks>
<TargetFrameworks>net461; net471; netstandard2.0; net6.0</TargetFrameworks>
<LangVersion>8.0</LangVersion>
<Nullable>enable</Nullable>
<NullableReferenceTypes>true</NullableReferenceTypes>
@ -33,13 +33,21 @@
<ItemGroup>
<None Include="../../LOGO.png" Pack="true" PackagePath="/" />
<None Include="README.md" Pack="true" PackagePath="/" />
</ItemGroup>
<ItemGroup>
<Reference Include="System.Web" Condition="'$(TargetFramework)' == 'net461'" />
</ItemGroup>
<ItemGroup>
<ContentWithTargetPath Include="SDK\Finance\_Libs\*.*">
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
<TargetPath>%(Filename)%(Extension)</TargetPath>
</ContentWithTargetPath>
</ItemGroup>
<ItemGroup>
<Reference Include="System.Web" Condition="'$(TargetFramework)' == 'net461' Or '$(TargetFramework)' == 'net471'" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="BouncyCastle.Cryptography" Version="2.1.1" />
<PackageReference Include="SKIT.FlurlHttpClient.Common" Version="2.6.0" />
</ItemGroup>

98
src/SKIT.FlurlHttpClient.Wechat.Work/Utilities/RSAUtility.cs Normal file
View File

@ -0,0 +1,98 @@
using System;
using System.IO;
using System.Text;
using System.Text.RegularExpressions;
using Org.BouncyCastle.Crypto;
using Org.BouncyCastle.Crypto.Parameters;
using Org.BouncyCastle.Math;
using Org.BouncyCastle.OpenSsl;
using Org.BouncyCastle.Pkcs;
using Org.BouncyCastle.Security;
using Org.BouncyCastle.Crypto;
using Org.BouncyCastle.Crypto.Parameters;
using Org.BouncyCastle.Security;
using Org.BouncyCastle.Utilities.IO;
using Org.BouncyCastle.Utilities;
using System.Security.Cryptography.X509Certificates;
using System.Xml.Linq;
namespace SKIT.FlurlHttpClient.Wechat.Work.Utilities
{
/// <summary>
/// RSA 算法工具类。
/// </summary>
public static class RSAUtility
{
private const string RSA_CIPHER_ALGORITHM_NONE = "RSA/ECB";
private const string RSA_CIPHER_PADDING_PKCS1 = "PKCS1PADDING";
private static byte[] ConvertPrivateKeyPkcs1PemToByteArray(string privateKey)
{
using (TextReader textReader = new StringReader(privateKey))
using (PemReader pemReader = new PemReader(textReader))
{
AsymmetricCipherKeyPair cipherKeyPair = (AsymmetricCipherKeyPair)pemReader.ReadObject();
using (TextWriter textWriter = new StringWriter())
using (PemWriter pemWriter = new PemWriter(textWriter))
{
Pkcs8Generator pkcs8 = new Pkcs8Generator(cipherKeyPair.Private);
pemWriter.WriteObject(pkcs8);
pemWriter.Writer.Close();
privateKey = textWriter.ToString();
privateKey = privateKey
.Replace("-----BEGIN PRIVATE KEY-----", string.Empty)
.Replace("-----END PRIVATE KEY-----", string.Empty);
privateKey = Regex.Replace(privateKey, "\\s+", string.Empty);
return Convert.FromBase64String(privateKey);
}
}
}
private static RsaKeyParameters ParsePrivateKeyPemToPrivateKeyParameters(byte[] privateKeyBytes)
{
return (RsaKeyParameters)PrivateKeyFactory.CreateKey(privateKeyBytes);
}
private static byte[] DecryptWithECB(RsaKeyParameters rsaPrivateKeyParams, byte[] cipherBytes, string paddingMode)
{
IBufferedCipher cipher = CipherUtilities.GetCipher($"{RSA_CIPHER_ALGORITHM_NONE}/{paddingMode}");
cipher.Init(false, rsaPrivateKeyParams);
return cipher.DoFinal(cipherBytes);
}
/// <summary>
/// 使用私钥基于 ECB 模式解密数据。
/// </summary>
/// <param name="privateKeyBytes">PKCS#1 私钥字节数据。</param>
/// <param name="cipherBytes">待解密的数据字节数据。</param>
/// <param name="paddingMode">填充模式。（默认值：<see cref="RSA_CIPHER_PADDING_PKCS1"/>）</param>
/// <returns>解密后的数据字节数组。</returns>
public static byte[] DecryptWithECB(byte[] privateKeyBytes, byte[] cipherBytes, string paddingMode = RSA_CIPHER_PADDING_PKCS1)
{
if (privateKeyBytes == null) throw new ArgumentNullException(nameof(privateKeyBytes));
if (cipherBytes == null) throw new ArgumentNullException(nameof(cipherBytes));
RsaKeyParameters rsaPrivateKeyParams = ParsePrivateKeyPemToPrivateKeyParameters(privateKeyBytes);
return DecryptWithECB(rsaPrivateKeyParams, cipherBytes, paddingMode);
}
/// <summary>
/// 使用私钥基于 ECB 模式解密数据。
/// </summary>
/// <param name="privateKey">PKCS#1 私钥（PEM 格式）。</param>
/// <param name="cipherText">经 Base64 编码的待解密数据。</param>
/// <param name="paddingMode">填充模式。（默认值：<see cref="RSA_CIPHER_PADDING_PKCS1"/>）</param>
/// <returns>解密后的文本数据。</returns>
public static string DecryptWithECB(string privateKey, string cipherText, string paddingMode = RSA_CIPHER_PADDING_PKCS1)
{
if (privateKey == null) throw new ArgumentNullException(nameof(privateKey));
if (cipherText == null) throw new ArgumentNullException(nameof(cipherText));
byte[] privateKeyBytes = ConvertPrivateKeyPkcs1PemToByteArray(privateKey);
byte[] cipherBytes = Convert.FromBase64String(cipherText);
byte[] plainBytes = DecryptWithECB(privateKeyBytes, cipherBytes, paddingMode);
return Encoding.UTF8.GetString(plainBytes);
}
}
}

2
src/SKIT.FlurlHttpClient.Wechat.Work/WechatWorkEndpoints.cs
View File

@ -1,4 +1,4 @@
namespace SKIT.FlurlHttpClient.Wechat.Work
namespace SKIT.FlurlHttpClient.Wechat.Work
{
/// <summary>
/// <para>企业微信 API 接口域名。</para>

3
src/SKIT.FlurlHttpClient.Wechat.Work/WechatWorkException.cs
View File

@ -1,4 +1,5 @@
using System;
using System;
using Newtonsoft.Json;
namespace SKIT.FlurlHttpClient.Wechat.Work
{

1125
test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/TestCase_FinanceSdkTests.cs Normal file
View File

File diff suppressed because it is too large Load Diff

21
test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/TestCase_ToolsRSAUtilityTests.cs Normal file
View File

@ -0,0 +1,21 @@
using Xunit;
namespace SKIT.FlurlHttpClient.Wechat.Work.UnitTests
{
public class TestCase_ToolsRSAUtilityTests
{
// 此处测试的 RSA 公钥/私钥是自签名生成的，仅供执行 RSA 相关的单元测试，不能用于调用企业微信 API
private const string RSA_PEM_PUBLIC_KEY = "-----BEGIN RSA PUBLIC KEY-----MIIBCgKCAQEAuwQaAJGSMda9ESGhyY2PPuVds8OjoqyRi29IEQgXJ03Bu/o6KjZVbPQT4n3WncrT0c92zA6lazJDbaXQkHlvdDpOo3FqBvczDDT0jveCfg7azeOmRxHE8P/iWOkQm+Dhk5hnmfxqtX7pzu2quzuGt9JH4FxPhNEOkn4/uRn+1qo/KrrU2Db09gm3aPjOWTT5XEVD9tPNTsZr/vaKYGCQKTqeRWhDGL3JAgyyLgGyGTAOTt0gl0MPG/O6omwELTVQdzXqyRrKgx0tEhIKoeYBVPKbWOTJyXsRO9dcfXKu56jry9QyqjFHcVtfCuphOaFIhGUEDYuAIJsqBKJqrSZoVQIDAQAB-----END RSA PUBLIC KEY-----";
private const string RSA_PEM_PRIVATE_KEY = "-----BEGIN RSA PRIVATE KEY-----MIIEogIBAAKCAQEAuwQaAJGSMda9ESGhyY2PPuVds8OjoqyRi29IEQgXJ03Bu/o6KjZVbPQT4n3WncrT0c92zA6lazJDbaXQkHlvdDpOo3FqBvczDDT0jveCfg7azeOmRxHE8P/iWOkQm+Dhk5hnmfxqtX7pzu2quzuGt9JH4FxPhNEOkn4/uRn+1qo/KrrU2Db09gm3aPjOWTT5XEVD9tPNTsZr/vaKYGCQKTqeRWhDGL3JAgyyLgGyGTAOTt0gl0MPG/O6omwELTVQdzXqyRrKgx0tEhIKoeYBVPKbWOTJyXsRO9dcfXKu56jry9QyqjFHcVtfCuphOaFIhGUEDYuAIJsqBKJqrSZoVQIDAQABAoIBAFEqL4rNovBkbTvxJ8FM4b1/WFJ7dxpT4Prt+g4CP+I7+ff2WqYVXK/jonmq+akT7Shi7QEU3jAO6Xq9+y2otnlwEM8YmtaZFJuYpAckXosNMWMoCPNRP/MEax0BUccFK4GeJGCNT1aj1R+MwItwA0DmT3GNPqm6/aMQjeFs6dAJ500SUVlWfMGnO3c40XGq3bHHNfTdZsdRa5NzlCViRKtc6vgoPf4iOHGE30da771XJ06iZb/2iLYcZyWlhQMU5vBUYyVd4oykVldNuGcrLQIffJsVR7Gq/aHEujQ6WSAmd2VZwGYRLxBCXVm/LGsaiw1AffAgLEazxLMBmFfWg2ECgYEA4TC6wE1GVacft6D3UsLUcKxTLIrqAE23RI6ky5wT+3MDlMIwWRLBdJO9zTQ2MG3EgruVKXgE6GEEM4cLPmhaxg1YrpRoLBr+t78lR7WwU+i9dM8GrJwoIqnCXjF1sjKa05/iEtZHbTMaXuSirHHMjEoW40I3N6ygLd4Bewzct70CgYEA1JpR4/9TiVY9k4ml5/dvatzr+4mVplTqJ3U5Ie8lhwaAtj+ouXsERaLwpLp72gP+m1rjDHoU8zuYnfVqxm35GNf7Wv1YOlpXHcebMWLkvBc6112KmcnxmSiRAHv94AAT2YxSRPu57ITlB0biUIWiCxUlevbavLsn1vHtpx1S0HkCgYBDF8esX9miz2ZNybGmgNHWuCEX1lOdv4no7S8AUwJJGp1ohursvv/Qgew85V930lyILudkMZQUwEMGLygUcfcJpxRS/3iCG5DkohizYtikR2WbFcuBRg1XNojok4fjjdw/TRWIUzt4t48V0rz87/LnoXNsRmA5QD+BKvH5/X0NaQKBgD8oXP17Y0igSwiiUpv3oKzBVoVSGRfhj/IK298d2SsknmYFwUzgo6NARXbaQ2K/3wot1NdnCQQ9BxidyIuMLfzYZL5iFqy3G7woCQ2B0GukBwHlsv/+wvv51iGrs/6wZzUwf1wo39HIpPUldKPxHvNl482EufRpMOuk0THc/zYZAoGAROAO+sObNRQilQ4iKIO/8VQBoHnde6WF1Z7FNsQlxZxJrzZrO82OIWOPucaPNNOn0I/V4ttaFo7GSWvRX16ADvA0dNMXuB+5syGt5dgDPCOtTXzPZq0Twzwgc5uyknkS1cn9Gt+a0oZ9/+zGzjKK2tcX+HwM7r6bTaxVNzjd6Hg=-----END RSA PRIVATE KEY-----";
[Fact(DisplayName = "测试用例：使用 RSA 私钥解密")]
public void TestRSADecrypt()
{
string cipherText = "ewwZ8LmXVJpkJpj/JWcz16L4bePAGcf3Fi2EKyC6AS3JsF5u4aku7iOYqtcAczjoYwE1fqSadRd6YTrWr3tLP3uWFYmhqthQoaAcjmQS0vHYRFeS1V7q5hbziVLRp7C42S4YrvqXAmSmUyjPUXG5tXFVchARVkTr1F53HGoPP+iBg+i8y0uJK4FgiuKraFgdtKofv/k5/30xKzRHxdLFCFt1rF7wL+Hk/7Bl0tFZM/rfhmuvwbf46zWhxKKviAge+61tEot4QCSBLnAFpPuSQsTOOSOrlCl92DwW54dWdlWwhqkTVHdm6pXEdUE66y1yoZkXfpqjnONjta0njqN/Jw==";
string actualPlain = Utilities.RSAUtility.DecryptWithECB(RSA_PEM_PRIVATE_KEY, cipherText);
string expectedPlain = "RsaDecryptTest";
Assert.Equal(expectedPlain, actualPlain);
}
}
}

2
test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/TestCase_WxMsgCryptorTests.cs → test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/TestCase_ToolsWxMsgCryptorTests.cs
View File

@ -2,7 +2,7 @@ using Xunit;
namespace SKIT.FlurlHttpClient.Wechat.Work.UnitTests
{
public class TestCase_WxMsgCryptorTests
public class TestCase_ToolsWxMsgCryptorTests
{
[Fact(DisplayName = "测试用例：回调信息解析")]
public void TestWxBizMsgCryptorParsing()

4
test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/TestConfigs.cs
View File

@ -22,6 +22,8 @@ namespace SKIT.FlurlHttpClient.Wechat.Work.UnitTests
WechatAgentId = int.Parse(config.GetProperty("AgentId").GetString()!);
WechatAgentSecret = config.GetProperty("AgentSecret").GetString()!;
WechatAccessToken = config.GetProperty("AccessToken").GetString()!;
WechatFinanceSecretKey = config.GetProperty("FinanceSecretKey").GetString()!;
WechatFinanceEncryptionPrivateKey = config.GetProperty("FinanceEncryptionPrivateKey").GetString()!;
WorkDirectoryForSdk = jdoc.RootElement.GetProperty("WorkDirectoryForSdk").GetString()!;
WorkDirectoryForTest = jdoc.RootElement.GetProperty("WorkDirectoryForTest").GetString()!;
@ -36,6 +38,8 @@ namespace SKIT.FlurlHttpClient.Wechat.Work.UnitTests
public static readonly int WechatAgentId;
public static readonly string WechatAgentSecret;
public static readonly string WechatAccessToken;
public static readonly string WechatFinanceSecretKey;
public static readonly string WechatFinanceEncryptionPrivateKey;
public static readonly string WorkDirectoryForSdk;
public static readonly string WorkDirectoryForTest;

6
test/SKIT.FlurlHttpClient.Wechat.Work.UnitTests/appsettings.json
View File

@ -1,9 +1,11 @@
{
{
"TestConfig": {
"CorpId": "请在此填写用于测试的企业微信 CorpId",
"AgentId": "请在此填写用于测试的企业微信 AgentId",
"AgentSecret": "请在此填写用于测试的企业微信 AgentSecret",
"AccessToken": "请在此填写用于测试的微信 AccessToken"
"AccessToken": "请在此填写用于测试的企业微信 AccessToken",
"FinanceSecretKey": "请在此填写用于测试的企业微信会话内容存档 SecretKey",
"FinanceEncryptionPrivateKey": "请在此填写用于测试的企业微信会话内容存档消息加解密私钥"
},
"WorkDirectoryForSdk": "请输入当前 SDK 项目所在的目录完整路径，如 C:\\Project\\src\\SKIT.FlurlHttpClient.Wechat.Work\\",
"WorkDirectoryForTest": "请输入当前测试项目所在的目录完整路径，如 C:\\Project\\test\\SKIT.FlurlHttpClient.Wechat.Work.UnitTests\\"