完善 AI Sample，使用兼容性更好的方案

JeffreySu · May 24, 2024 · d721b11 · d721b11
1 parent 636339a
commit d721b11
Show file tree

Hide file tree

Showing 5 changed files with 96 additions and 40 deletions.
diff --git a/Samples/All/Senparc.Weixin.Sample.CommonService/AI/MessageHandlers/ChatStore.cs b/Samples/All/Senparc.Weixin.Sample.CommonService/AI/MessageHandlers/ChatStore.cs
@@ -20,14 +20,18 @@ public class ChatStore
     {
         public ChatStatus Status { get; set; }
 
-        public IWantToRun IWantToRun { get; set; }
+        public string History { get; set; }
     }
 
     /// <summary>
     /// 聊天状态
     /// </summary>
     public enum ChatStatus
     {
+        /// <summary>
+        /// 默认状态（可能是转换失败）
+        /// </summary>
+        None,
         /// <summary>
         /// 聊天中
         /// </summary>

diff --git a/...les/All/Senparc.Weixin.Sample.CommonService/AI/MessageHandlers/CustomMessageHandler_AI.cs b/...les/All/Senparc.Weixin.Sample.CommonService/AI/MessageHandlers/CustomMessageHandler_AI.cs
@@ -13,6 +13,8 @@
 using System.Threading.Tasks;
 using Senparc.AI.Entities;
 using Senparc.AI.Kernel;
+using Senparc.CO2NET.Extensions;
+using Senparc.CO2NET.Helpers;
 using Senparc.CO2NET.Trace;
 using Senparc.NeuChar.Entities;
 using Senparc.Weixin.MP.Entities;
@@ -42,40 +44,15 @@ private async Task<IResponseMessageBase> StartAIChatAsync()
         {
             var currentMessageContext = await base.GetCurrentMessageContext();
 
-            /* 模型配置
-             * 注意： 需要在 appsettings.json 中的 <SenparcAiSetting> 节点配置 AI 模型参数，否则无法使用 AI 能力
-             */
-            var setting = (SenparcAiSetting)Senparc.AI.Config.SenparcAiSetting;//也可以留空，将自动获取
-
-            //模型请求参数
-            var parameter = new PromptConfigParameter()
-            {
-                MaxTokens = 2000,
-                Temperature = 0.7,
-                TopP = 0.5,
-            };
-
-            //最大保存 AI 对话记录数
-            var maxHistoryCount = 10;
-
-            //默认 SystemMessage（可根据自己需要修改）
-            var systemMessage = Senparc.AI.DefaultSetting.DEFAULT_SYSTEM_MESSAGE;
-
-            var semanticAiHandler = new SemanticAiHandler(setting);
-            var iWantToRun = semanticAiHandler.ChatConfig(parameter,
-                                userId: "Jeffrey",
-                                maxHistoryStore: maxHistoryCount,
-                                chatSystemMessage: systemMessage,
-                                senparcAiSetting: setting).iWantToRun;
 
             //新建个人对话缓存（由于使用了 CurrentMessageContext，多用户之前完全隔离，对话不会串）
             var storage = new ChatStore()
             {
                 Status = ChatStatus.Chat,
-                IWantToRun = iWantToRun
+                History = ""
             };
 
-            currentMessageContext.StorageData = storage;
+            currentMessageContext.StorageData = storage.ToJson();//为了提升兼容性，采用字符格式
 
             await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
 
@@ -94,7 +71,22 @@ private async Task<IResponseMessageBase> AIChatAsync(RequestMessageBase requestM
         {
             var currentMessageContext = await base.GetCurrentMessageContext();
 
-            if (!(currentMessageContext.StorageData is ChatStore chatStore))
+            if (!(currentMessageContext.StorageData is string chatJson))
+            {
+                return null;
+            }
+
+            ChatStore chatStore;
+
+            try
+            {
+                chatStore = chatJson.GetObject<ChatStore>();
+                if (chatStore == null || chatStore.Status == ChatStatus.None || chatStore.History == null)
+                {
+                    return null;
+                }
+            }
+            catch
             {
                 return null;
             }
@@ -110,26 +102,25 @@ private async Task<IResponseMessageBase> AIChatAsync(RequestMessageBase requestM
                         prompt = $"我即将结束对话，请发送一段文字和我告别，并提醒我：输入“AI”可以再次启动对话。";
 
                         //消除状态记录
-                        currentMessageContext.StorageData = null;
-                        await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
+                        await UpdateMessageContext(currentMessageContext, null);
                     }
                     else if (requestMessageText.Content.Equals("P", StringComparison.OrdinalIgnoreCase))
                     {
                         prompt = $"我即将临时暂停对话，请发送一段文字和我告别，并提醒我：输入“AI”可以再次启动对话。请记住，下次启动会话时，发送再次欢迎我回来的信息。";
 
                         // 修改状态记录
                         chatStore.Status = ChatStatus.Paused;
-                        await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
+                        await UpdateMessageContext(currentMessageContext, chatStore);
                     }
                     else if (chatStore.Status == ChatStatus.Paused)
                     {
                         if (requestMessageText.Content.Equals("AI", StringComparison.OrdinalIgnoreCase))
                         {
-                            prompt = @"我将重新开始对话，请发送一段欢迎信息，并且在最后提示我（注意保留换行）："+ WELCOME_MESSAGE;
+                            prompt = @"我将重新开始对话，请发送一段欢迎信息，并且在最后提示我（注意保留换行）：" + WELCOME_MESSAGE;
 
                             // 修改状态记录
                             chatStore.Status = ChatStatus.Chat;
-                            await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
+                            await UpdateMessageContext(currentMessageContext, chatStore);
                         }
                         else
                         {
@@ -141,12 +132,48 @@ private async Task<IResponseMessageBase> AIChatAsync(RequestMessageBase requestM
                         prompt = requestMessageText.Content;
                     }
 
-                    var aiHandler = chatStore.IWantToRun.SemanticAiHandler;
+                    #region 请求 AI 模型进入 Chat 的经典模式
+
+                    /* 模型配置
+                     * 注意：需要在 appsettings.json 中的 <SenparcAiSetting> 节点配置 AI 模型参数，否则无法使用 AI 能力
+                     */
+                    var setting = (SenparcAiSetting)Senparc.AI.Config.SenparcAiSetting;//也可以留空，将自动获取
+
+                    //模型请求参数
+                    var parameter = new PromptConfigParameter()
+                    {
+                        MaxTokens = 2000,
+                        Temperature = 0.7,
+                        TopP = 0.5,
+                    };
+
+                    //最大保存 AI 对话记录数
+                    var maxHistoryCount = 10;
+
+                    //默认 SystemMessage（可根据自己需要修改）
+                    var systemMessage = Senparc.AI.DefaultSetting.DEFAULT_SYSTEM_MESSAGE;
+
+                    var aiHandler = new SemanticAiHandler(setting);
+                    var iWantToRun = aiHandler.ChatConfig(parameter,
+                                        userId: "Jeffrey",
+                                        maxHistoryStore: maxHistoryCount,
+                                        chatSystemMessage: systemMessage,
+                                        senparcAiSetting: setting).iWantToRun;
+
+                    //注入历史记录（也可以把 iWantToRun 对象缓存起来，其中会自动包含 history，不需要每次读取或者保存）
+                    iWantToRun.StoredAiArguments.Context["history"] = chatStore.History;
 
                     //获取请求（注意：因为微信需要一次返回所有文本，所以此处不使用 AI 流行的 Stream（流式）输出
-                    var result = await aiHandler.ChatAsync(chatStore.IWantToRun, prompt);
+                    var result = await aiHandler.ChatAsync(iWantToRun, prompt);
+
+                    #endregion
 
 
+                    //保存历史记录
+                    chatStore.History = iWantToRun.StoredAiArguments.Context["history"]?.ToString();
+                    await UpdateMessageContext(currentMessageContext, chatStore);
+
+                    //组织返回消息
                     var responseMessage = base.CreateResponseMessage<ResponseMessageText>();
                     responseMessage.Content = result.OutputString;
                     return responseMessage;
@@ -168,5 +195,11 @@ private async Task<IResponseMessageBase> AIChatAsync(RequestMessageBase requestM
             }
 
         }
+
+        private async Task UpdateMessageContext(CustomMessageContext currentMessageContext, ChatStore chatStore)
+        {
+            currentMessageContext.StorageData = chatStore==null?null : chatStore.ToJson();
+            await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
+        }
     }
 }
diff --git a/...ple.CommonService/MessageHandlers/CustomMessageHandler/Async/CustomMessageHandlerAsync.cs b/...ple.CommonService/MessageHandlers/CustomMessageHandler/Async/CustomMessageHandlerAsync.cs
@@ -28,7 +28,9 @@ public override async Task OnExecutingAsync(CancellationToken cancellationToken)
         {
             //演示：MessageContext.StorageData
 
-            var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
+            //var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
+            var currentMessageContext = await base.GetCurrentMessageContext();
+
             if (currentMessageContext.StorageData == null)
             {
                 currentMessageContext.StorageData = 0;
@@ -41,7 +43,8 @@ public override async Task OnExecutedAsync(CancellationToken cancellationToken)
         {
             //演示：MessageContext.StorageData
 
-            var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
+            //var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
+            var currentMessageContext = await base.GetCurrentMessageContext();
 
             if (currentMessageContext.StorageData is int data)
             {

diff --git a/....Weixin.Sample.CommonService/MessageHandlers/CustomMessageHandler/CustomMessageHandler.cs b/....Weixin.Sample.CommonService/MessageHandlers/CustomMessageHandler/CustomMessageHandler.cs
@@ -467,8 +467,7 @@ public override async Task<IResponseMessageBase> OnTextRequestAsync(RequestMessa
                     var currentMessageContext = await base.GetCurrentMessageContext();
                     if (currentMessageContext.RequestMessages.Count > 1)
                     {
-                        result.AppendFormat("您此前还发送了如下消息（{0}/{1}）：\r\n", currentMessageContext.RequestMessages.Count,
-                            currentMessageContext.StorageData);
+                        result.AppendFormat("您此前还发送了如下消息（{0}）：\r\n", currentMessageContext.RequestMessages.Count);
                         for (int i = currentMessageContext.RequestMessages.Count - 2; i >= 0; i--)
                         {
                             var historyMessage = currentMessageContext.RequestMessages[i];

diff --git a/Samples/All/net8-mvc/Senparc.Weixin.Sample.Net8/Senparc.Weixin.Sample.net8.csproj b/Samples/All/net8-mvc/Senparc.Weixin.Sample.Net8/Senparc.Weixin.Sample.net8.csproj
@@ -62,6 +62,23 @@
 		<None Update="App_Data\QrCode\readme.txt">
 			<CopyToOutputDirectory>Always</CopyToOutputDirectory>
 		</None>
+		<None Update="Web.config">
+			<CopyToPublishDirectory>Never</CopyToPublishDirectory>
+		</None>
+		<None Update="appsettings.json">
+			<CopyToPublishDirectory>Never</CopyToPublishDirectory>
+		</None>
+		<None Update="appsettings.Development.json">
+			<CopyToPublishDirectory>Never</CopyToPublishDirectory>
+		</None>
+		<None Update="App_Data\**\*">
+			<CopyToPublishDirectory>Never</CopyToPublishDirectory>
+		</None>
+	</ItemGroup>
+
+	<ItemGroup Condition="'$(Configuration)' == 'Release'">
+		<!-- 忽略 Web.config 文件，仅在发布时 -->
+
 	</ItemGroup>
 
 	<ItemGroup>