feat(飞书Bot): Enhance message handling with rich message support and improve token refresh logic

Author: 239573049

src/KoalaWiki/Services/Feishu/Feishu/FeiShuClient.cs

@@ -19,10 +19,10 @@ public async ValueTask SendMessages(SendMessageInput input, string receiveIdType
         var result =
             await client.PostAsJsonAsync(
                 "https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=" + receiveIdType,
-                input);
+                input,JsonSerializerOptions.Web);
 
         var response = await result.Content.ReadFromJsonAsync<FeiShuResult>();
-
+        
         if (response.code == 0)
         {
             return;

src/KoalaWiki/Services/Feishu/Feishu/FeishuStore.cs

@@ -94,6 +94,11 @@ public async Task StartAsync(CancellationToken cancellationToken)
     {
         _logger.LogInformation("飞书token定时刷新服务启动");
 
+        if (string.IsNullOrEmpty(FeishuOptions.AppId))
+        {
+            return;
+        }
+
         // 立即刷新一次token
         await RefreshTokenInternalAsync();
 

src/KoalaWiki/Services/Feishu/Feishu/SendMessageInput.cs

@@ -1,15 +1,12 @@
 using System.Text.Json.Serialization;
 
-namespace ImageAgent.Feishu;
+namespace KoalaWiki.Services.Feishu.Feishu;
 
 public class SendMessageInput(string content, string msgType, string receiveId)
 {
-    [JsonPropertyName("content")]
-    public string content { get; set; } = content;
+    [JsonPropertyName("content")] public string content { get; set; } = content;
 
-    [JsonPropertyName("msg_type")]
-    public string msg_type { get; set; } = msgType;
+    [JsonPropertyName("msg_type")] public string msg_type { get; set; } = msgType;
 
-    [JsonPropertyName("receive_id")]
-    public string receive_id { get; set; } = receiveId;
+    [JsonPropertyName("receive_id")] public string receive_id { get; set; } = receiveId;
 }

src/KoalaWiki/Services/Feishu/FeishuBotService.cs

@@ -201,7 +201,7 @@ await context.Response.WriteAsJsonAsync(new
 
                     logger.LogInformation("启动异步任务处理群聊消息");
                     await Task.Factory.StartNew(async () =>
-                        await Handler(input.Event.message.content, input.Event.message.message_id, chatId, warehouse,
+                        await Handler(input.Event.message.message_id, input.Event.message.content, chatId, warehouse,
                             document, "chat_id"));
                     return;
                 }
@@ -229,7 +229,7 @@ private async Task Handler(string messageId, string content, string sessionId,
             logger.LogInformation("消息解析成功，IsText: {IsText}", userInput?.IsText);
 
             var history = new ChatHistory();
-            
+
             // 解析仓库的目录结构
             var path = document.GitPath;
 
@@ -376,7 +376,11 @@ private async Task Handler(string messageId, string content, string sessionId,
             sb = new StringBuilder(Regex.Replace(sb.ToString(), @"<thinking>.*?<\/thinking>", "",
                 RegexOptions.IgnoreCase | RegexOptions.Singleline));
 
-            await SendMessages(sessionId, sb.ToString(), type);
+            // 解析sb的#标题
+            var titleMatch = Regex.Match(sb.ToString(), @"#\s*(.+)");
+            var title = titleMatch.Success ? titleMatch.Groups[1].Value.Trim() : "OpenDeepWiki 回复";
+
+            await SendRichMessage(sessionId, title, sb.ToString(), type);
             logger.LogInformation("已发送回复消息给用户: {SessionId}", sessionId);
         }
         catch (Exception exception)
@@ -397,6 +401,31 @@ await feiShuClient.SendMessages(
                 sessionId), receiveIdType);
     }
 
+    public async Task SendRichMessage(string sessionId, string title, string text,
+        string receiveIdType = "open_id")
+    {
+        await feiShuClient.SendMessages(
+            new SendMessageInput(JsonSerializer.Serialize(new
+                {
+                    zh_cn = new
+                    {
+                        title,
+                        content = new object[]
+                        {
+                            new object[]
+                            {
+                                new
+                                {
+                                    tag = "text",
+                                    text,
+                                }
+                            }
+                        }
+                    }
+                }, JsonSerializerOptions.Web), "post",
+                sessionId), receiveIdType);
+    }
+
     public async Task SendImageMessages(string sessionId, byte[] bytes, string receiveIdType = "open_id")
     {
         await feiShuClient.SendImageAsync(bytes, sessionId, receiveIdType);