feat(openai): 移除第三方接入方式的相关接口模型，并重命名原平台接入方式的相关接口模型

2026-02-12 02:36:21 +08:00 · 2022-11-21 11:30:38 +08:00
parent 922e70f8db
commit 16aaeb3c31
358 changed files with 373 additions and 8040 deletions
--- a/src/SKIT.FlurlHttpClient.Wechat.OpenAI/Extensions/WechatOpenAIClientEventExtensions.cs
+++ b/src/SKIT.FlurlHttpClient.Wechat.OpenAI/Extensions/WechatOpenAIClientEventExtensions.cs
@@ -0,0 +1,102 @@
+using System;
+
+namespace SKIT.FlurlHttpClient.Wechat.OpenAI
+{
+    /// <summary>
+    /// 为 <see cref="WechatOpenAIClient"/> 提供回调通知事件的扩展方法。
+    /// </summary>
+    public static class WechatOpenAIClientEventExtensions
+    {
+        private static TEvent InnerDeserializeEventFromXml<TEvent>(this WechatOpenAIClient client, string callbackXml)
+            where TEvent : WechatOpenAIEvent
+        {
+            if (client == null) throw new ArgumentNullException(nameof(client));
+            if (string.IsNullOrEmpty(callbackXml)) throw new ArgumentNullException(callbackXml);
+
+            try
+            {
+                if (!Utilities.WxMsgCryptor.TryParseXml(callbackXml, out string? encryptedXml))
+                    throw new Exceptions.WechatOpenAIEventSerializationException("Encrypt event failed, because of empty encrypted data.");
+
+                callbackXml = Utilities.WxMsgCryptor.AESDecrypt(cipherText: encryptedXml!, encodingAESKey: client.Credentials.EncodingAESKey!, out _);
+                return Utilities.XmlUtility.Deserialize<TEvent>(callbackXml);
+            }
+            catch (WechatOpenAIException)
+            {
+                throw;
+            }
+            catch (Exception ex)
+            {
+                throw new Exceptions.WechatOpenAIEventSerializationException("Deserialize event failed. Please see the `InnerException` for more details.", ex);
+            }
+        }
+
+        /// <summary>
+        /// <para>从 XML 反序列化得到 <see cref="WechatOpenAIEvent"/> 对象。</para>
+        /// </summary>
+        /// <typeparam name="TEvent"></typeparam>
+        /// <param name="client"></param>
+        /// <param name="callbackXml"></param>
+        /// <returns></returns>
+        public static TEvent DeserializeEventFromXml<TEvent>(this WechatOpenAIClient client, string callbackXml)
+            where TEvent : WechatOpenAIEvent, WechatOpenAIEvent.Serialization.IXmlSerializable, new()
+        {
+            return InnerDeserializeEventFromXml<TEvent>(client, callbackXml);
+        }
+
+        /// <summary>
+        /// <para>从 XML 反序列化得到 <see cref="WechatOpenAIEvent"/> 对象。</para>
+        /// </summary>
+        /// <param name="client"></param>
+        /// <param name="callbackXml"></param>
+        /// <returns></returns>
+        public static WechatOpenAIEvent DeserializeEventFromXml(this WechatOpenAIClient client, string callbackXml)
+        {
+            return InnerDeserializeEventFromXml<WechatOpenAIEvent>(client, callbackXml);
+        }
+
+        /// <summary>
+        /// 将 <see cref="WechatOpenAIEvent"/> 对象序列化成 XML。
+        /// </summary>
+        /// <typeparam name="TEvent"></typeparam>
+        /// <param name="client"></param>
+        /// <param name="callbackModel"></param>
+        /// <returns></returns>
+        public static string SerializeEventToXml<TEvent>(this WechatOpenAIClient client, TEvent callbackModel)
+            where TEvent : WechatOpenAIEvent, WechatOpenAIEvent.Serialization.IXmlSerializable, new()
+        {
+            string xml;
+
+            try
+            {
+                xml = Utilities.XmlUtility.Serialize(callbackModel);
+            }
+            catch (Exception ex)
+            {
+                throw new Exceptions.WechatOpenAIEventSerializationException("Serialize event failed. Please see the `InnerException` for more details.", ex);
+            }
+
+            if (string.IsNullOrEmpty(client.Credentials.EncodingAESKey))
+                throw new Exceptions.WechatOpenAIEventSerializationException("Encrypt event failed, because there is no encoding AES key.");
+            if (string.IsNullOrEmpty(client.Credentials.Token))
+                throw new Exceptions.WechatOpenAIEventSerializationException("Encrypt event failed, because there is no token.");
+
+            try
+            {
+                string cipher = Utilities.WxMsgCryptor.AESEncrypt(
+                    plainText: xml,
+                    encodingAESKey: client.Credentials.EncodingAESKey!,
+                    appId: client.Credentials.AppId!
+                );
+
+                xml = Utilities.WxMsgCryptor.WrapXml(sToken: client.Credentials.Token!, sMsgEncrypt: cipher);
+            }
+            catch (Exception ex)
+            {
+                throw new Exceptions.WechatOpenAIEventSerializationException("Encrypt event failed. Please see the `InnerException` for more details.", ex);
+            }
+
+            return xml;
+        }
+    }
+}