From 849db7d2b2852bb2df300045d62830ae356a2046 Mon Sep 17 00:00:00 2001
From: OpenClaw Agent <agent@openclaw.ai>
Date: Fri, 13 Mar 2026 16:53:02 +0000
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BA=A4=E6=98=93=E5=90=8E=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E8=A7=A6=E5=8F=91=E5=87=80=E5=80=BC=E5=8E=86=E5=8F=B2?=
 =?UTF-8?q?=E9=87=8D=E7=AE=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- CreateTransaction完成后删除该交易日期之后的净值记录
- 下次请求收益曲线时自动重新计算
- 修改CreateTransaction为async方法
- 注入IPortfolioNavService到PortfolioService

流程：
1. 用户买入/卖出 → 创建交易记录
2. 删除交易日期之后的净值历史
3. 下次请求收益曲线 → 自动回填缺失数据
---
 .../Controllers/PortfolioController.cs        |  4 ++--
 AssetManager.Services/IPortfolioService.cs    |  2 +-
 AssetManager.Services/PortfolioService.cs     | 20 ++++++++++++++++++-
 3 files changed, 22 insertions(+), 4 deletions(-)

diff --git a/AssetManager.API/Controllers/PortfolioController.cs b/AssetManager.API/Controllers/PortfolioController.cs
index 5d81a94..d4f4caa 100755
--- a/AssetManager.API/Controllers/PortfolioController.cs
+++ b/AssetManager.API/Controllers/PortfolioController.cs
@@ -263,7 +263,7 @@ public class PortfolioController : ControllerBase
     /// <param name="request">交易请求参数（类型、标的、数量、价格等）</param>
     /// <returns>创建的交易记录</returns>
     [HttpPost("transactions")]
-    public ActionResult<ApiResponse<CreateTransactionResponse>> CreateTransaction([FromBody] CreateTransactionRequest request)
+    public async Task<ActionResult<ApiResponse<CreateTransactionResponse>>> CreateTransaction([FromBody] CreateTransactionRequest request)
     {
         var userId = GetCurrentUserId();
         if (string.IsNullOrEmpty(userId))
@@ -325,7 +325,7 @@ public class PortfolioController : ControllerBase
             }
         }
         
-        var response = _portfolioService.CreateTransaction(request, userId);
+        var response = await _portfolioService.CreateTransaction(request, userId);
 
         _logger.LogInformation("Transaction created successfully");
         
diff --git a/AssetManager.Services/IPortfolioService.cs b/AssetManager.Services/IPortfolioService.cs
index ba70ca3..ce6446e 100755
--- a/AssetManager.Services/IPortfolioService.cs
+++ b/AssetManager.Services/IPortfolioService.cs
@@ -10,5 +10,5 @@ public interface IPortfolioService
     PortfolioDetailResponse GetPortfolioById(string id, string userId);
     Task<PortfolioDetailResponse> GetPortfolioByIdAsync(string id, string userId);
     GetTransactionsResponse GetTransactions(string portfolioId, string userId, int limit, int offset);
-    CreateTransactionResponse CreateTransaction(CreateTransactionRequest request, string userId);
+    Task<CreateTransactionResponse> CreateTransaction(CreateTransactionRequest request, string userId);
 }
\ No newline at end of file
diff --git a/AssetManager.Services/PortfolioService.cs b/AssetManager.Services/PortfolioService.cs
index f67ad66..12fc6b1 100755
--- a/AssetManager.Services/PortfolioService.cs
+++ b/AssetManager.Services/PortfolioService.cs
@@ -11,17 +11,20 @@ public class PortfolioService : IPortfolioService
     private readonly ISqlSugarClient _db;
     private readonly IMarketDataService _marketDataService;
     private readonly IExchangeRateService _exchangeRateService;
+    private readonly IPortfolioNavService _navService;
     private readonly ILogger<PortfolioService> _logger;
 
     public PortfolioService(
         ISqlSugarClient db, 
         IMarketDataService marketDataService, 
         IExchangeRateService exchangeRateService,
+        IPortfolioNavService navService,
         ILogger<PortfolioService> logger)
     {
         _db = db;
         _marketDataService = marketDataService;
         _exchangeRateService = exchangeRateService;
+        _navService = navService;
         _logger = logger;
     }
 
@@ -444,7 +447,7 @@ public class PortfolioService : IPortfolioService
         };
     }
 
-    public CreateTransactionResponse CreateTransaction(CreateTransactionRequest request, string userId)
+    public async Task<CreateTransactionResponse> CreateTransaction(CreateTransactionRequest request, string userId)
     {
         // 验证投资组合是否属于该用户
         var portfolio = _db.Queryable<Portfolio>()
@@ -602,6 +605,21 @@ public class PortfolioService : IPortfolioService
         portfolio.UpdatedAt = DateTime.Now;
         _db.Updateable(portfolio).ExecuteCommand();
 
+        // 删除该交易日期之后的净值历史记录，下次请求收益曲线时会自动重新计算
+        try
+        {
+            var deletedCount = await _navService.DeleteNavHistoryAfterDateAsync(request.portfolioId, transactionTime.Date);
+            if (deletedCount > 0)
+            {
+                _logger.LogInformation("交易创建后删除净值历史: PortfolioId={PortfolioId}, Date={Date}, Count={Count}",
+                    request.portfolioId, transactionTime.Date, deletedCount);
+            }
+        }
+        catch (Exception ex)
+        {
+            _logger.LogWarning(ex, "删除净值历史失败，将在下次请求时重新计算");
+        }
+
         return new CreateTransactionResponse
         {
             id = transaction.Id,