From 6a9c879dee57baea2d16518f45fd0268ef778148 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=AD=99=E8=AF=9A?= <sunchengsuncheng@gmail.com>
Date: Sat, 10 Jan 2026 17:47:09 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E9=87=8D=E6=9E=84=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=9C=8D=E5=8A=A1=EF=BC=8C=E6=9B=BF=E6=8D=A2=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E8=AE=B0=E5=BD=95=E6=9C=8D=E5=8A=A1=E4=B8=BA=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=9C=8D=E5=8A=A1=EF=BC=8C=E6=9B=B4=E6=96=B0=E7=9B=B8=E5=85=B3?=
 =?UTF-8?q?=E4=BE=9D=E8=B5=96=E5=92=8C=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Service/BudgetService.cs                            |  5 +++--
 Service/EmailServices/EmailHandleService.cs         | 13 +++++--------
 .../{MessageRecordService.cs => MessageService.cs}  | 11 ++++++++---
 WebApi/Controllers/MessageRecordController.cs       |  2 +-
 4 files changed, 17 insertions(+), 14 deletions(-)
 rename Service/{MessageRecordService.cs => MessageService.cs} (86%)

diff --git a/Service/BudgetService.cs b/Service/BudgetService.cs
index 03f2435..8b14592 100644
--- a/Service/BudgetService.cs
+++ b/Service/BudgetService.cs
@@ -20,7 +20,7 @@ public class BudgetService(
     ITransactionRecordRepository transactionRecordRepository,
     IOpenAiService openAiService,
     IConfigService configService,
-    IMessageRecordService messageService,
+    IMessageService messageService,
     ILogger<BudgetService> logger
 ) : IBudgetService
 {
@@ -398,7 +398,8 @@ public class BudgetService(
                 await messageService.AddAsync(
                     title: $"{year}年{month}月 - 预算归档报告",
                     content: htmlReport,
-                    type: MessageType.Html);
+                    type: MessageType.Html,
+                    url: "/balance?tab=message");
             }
         }
         catch (Exception ex)
diff --git a/Service/EmailServices/EmailHandleService.cs b/Service/EmailServices/EmailHandleService.cs
index 9a2f7cd..b4e86c9 100644
--- a/Service/EmailServices/EmailHandleService.cs
+++ b/Service/EmailServices/EmailHandleService.cs
@@ -21,7 +21,7 @@ public class EmailHandleService(
     IEmailMessageRepository emailRepo,
     ITransactionRecordRepository trxRepo,
     IEnumerable<IEmailParseServices> emailParsers,
-    IMessageRecordService messageRecordService,
+    IMessageService messageService,
     ISmartHandleService smartHandleService
 ) : IEmailHandleService
 {
@@ -62,18 +62,15 @@ public class EmailHandleService(
             );
         if (parsed == null || parsed.Length == 0)
         {
-            await messageRecordService.AddAsync(
+            await messageService.AddAsync(
                 "邮件解析失败",
-                $"来自 {from} 发送给 {to} 的邮件（主题：{subject}）未能成功解析内容，可能格式已变更或不受支持。"
+                $"来自 {from} 发送给 {to} 的邮件（主题：{subject}）未能成功解析内容，可能格式已变更或不受支持。",
+                url: $"/balance?tab=email"
             );
             logger.LogWarning("未能成功解析邮件内容，跳过账单处理");
             return true;
         }
 
-        await messageRecordService.AddAsync(
-            "邮件解析成功",
-            $"来自 {from} 发送给 {to} 的邮件（主题：{subject}）已成功解析出 {parsed.Length} 条交易记录。"
-        );
         logger.LogInformation("成功解析邮件，共 {Count} 条交易记录", parsed.Length);
 
         bool allSuccess = true;
@@ -191,7 +188,7 @@ public class EmailHandleService(
         await trxRepo.UpdateRangeAsync(records);
 
         // 消息
-        await messageRecordService.AddAsync(
+        await messageService.AddAsync(
             "交易记录待确认分类",
             $"共有 {records.Length} 条交易记录待确认分类，请点击前往确认。",
             MessageType.Url,
diff --git a/Service/MessageRecordService.cs b/Service/MessageService.cs
similarity index 86%
rename from Service/MessageRecordService.cs
rename to Service/MessageService.cs
index 82e3700..e7c4114 100644
--- a/Service/MessageRecordService.cs
+++ b/Service/MessageService.cs
@@ -1,6 +1,6 @@
 namespace Service;
 
-public interface IMessageRecordService
+public interface IMessageService
 {
     Task<(IEnumerable<MessageRecord> List, long Total)> GetPagedListAsync(int pageIndex, int pageSize);
     Task<MessageRecord?> GetByIdAsync(long id);
@@ -12,7 +12,7 @@ public interface IMessageRecordService
     Task<long> GetUnreadCountAsync();
 }
 
-public class MessageRecordService(IMessageRecordRepository messageRepo, INotificationService notificationService) : IMessageRecordService
+public class MessageService(IMessageRecordRepository messageRepo, INotificationService notificationService) : IMessageService
 {
     public async Task<(IEnumerable<MessageRecord> List, long Total)> GetPagedListAsync(int pageIndex, int pageSize)
     {
@@ -29,7 +29,12 @@ public class MessageRecordService(IMessageRecordRepository messageRepo, INotific
         return await messageRepo.AddAsync(message);
     }
 
-    public async Task<bool> AddAsync(string title, string content, MessageType type = MessageType.Text, string? url = null)
+    public async Task<bool> AddAsync(
+        string title, 
+        string content, 
+        MessageType type = MessageType.Text, 
+        string? url = null
+    )
     {
         var message = new MessageRecord
         {
diff --git a/WebApi/Controllers/MessageRecordController.cs b/WebApi/Controllers/MessageRecordController.cs
index 07142ad..02b1da5 100644
--- a/WebApi/Controllers/MessageRecordController.cs
+++ b/WebApi/Controllers/MessageRecordController.cs
@@ -5,7 +5,7 @@ namespace WebApi.Controllers;
 [Authorize]
 [ApiController]
 [Route("api/[controller]/[action]")]
-public class MessageRecordController(IMessageRecordService messageService, ILogger<MessageRecordController> logger) : ControllerBase
+public class MessageRecordController(IMessageService messageService, ILogger<MessageRecordController> logger) : ControllerBase
 {
     /// <summary>
     /// 获取消息列表