当前位置：首页 > news >正文

65.【.NET8 实战--孢子记账--从单体到微服务--转向微服务】--新增功能--账本合并

news 2026/6/16 5:22:50

有时我们需要把几个账本合并到一个账本中，这样就可以在一个账本中查看所有的交易记录。那么，在本片文章中我们就来一起实现这个功能。

一、需求分析

用户需要能够将多个账本中的交易记录合并到一个目标账本中，以便在统一的视图下管理和查看所有交易数据。用户首先选择一个目标账本作为合并的目的地，然后选择一个或多个源账本，系统将源账本中的所有交易记录复制到目标账本中。

在这里我们暂时不考虑合并后可能出现的重复交易记录问题，因为这个功能属于一个较为复杂的功能，因此我们会把这个功能放在进阶的阶段去讲解具体怎么实现。

二、功能设计

我们现在已经了解了需求，接下来我们来设计一下这个功能。这个功能很简单，只需要一个接口，一个方法就可以实现。

我们在AccountBookController中添加一个新的接口MergeAccountBooks，该方法接受一个目标账本 ID 和一个源账本 ID 列表，代码如下：

///<summary>///账本合并///</summary>///<param name="request">账本合并请求</param>[HttpPost("merge")]publicActionResult<bool>MergeAccountBooks([FromBody]AccountBookMergeRequestrequest){_accountBookServer.Merge(request);returnOk();}

接下来我们需要定义AccountBookMergeRequest类来封装请求参数：

namespaceSP.FinanceService.Models.Request{/// <summary>/// 账本合并请求模型/// </summary>publicclassAccountBookMergeRequest{/// <summary>/// 目标账本ID/// </summary>publiclongTargetAccountBookId{get;set;}/// <summary>/// 源账本ID列表/// </summary>publicList<long>SourceAccountBookIds{get;set;}=new();}}

接下来我们在IAccountBookServer中新增Merge方法，并在AccountBookServerImpl类中实现该方法：

// IAccountBookServer.cs/// <summary>/// 合并账本/// </summary>/// <param name="request"></param>voidMerge(AccountBookMergeRequestrequest);// AccountBookServerImpl.cs/// <summary>/// 合并账本/// </summary>/// <param name="request"></param>/// <exception cref="NotImplementedException"></exception>publicvoidMerge(AccountBookMergeRequestrequest){// 目标账本是否存在booltargetExist=Exist(request.TargetAccountBookId);if(targetExist){thrownewNotFoundException($"账本不存在，ID:{request.TargetAccountBookId}");}// 来源账本是否存在List<long>sourceIds=request.SourceAccountBookIds;List<long>notExistIds=BatchQuery(sourceIds);if(notExistIds.Any()){thrownewNotFoundException($"以下账本不存在，ID:{string.Join(", ",notExistIds)}");}// 迁移账本下的记录// 规则：源账本的记录迁移到目标账本下，修改账本ID为目标账本IDvaraccountingServer=_serviceProvider.GetRequiredService<IAccountingServer>();accountingServer.MigrateAccountBook(request.TargetAccountBookId,sourceIds);}

在上面的代码中，我们首先检查目标账本是否存在，如果不存在则抛出异常。接着检查源账本是否存在，如果有不存在的账本也抛出异常。最后，我们调用IAccountingServer的MigrateAccountBook方法来迁移源账本下的记录到目标账本下。

在合并前，系统需要通过Exist方法确认目标账本存在，若不存在则立即抛出NotFoundException异常，中断合并流程。随后使用BatchQuery方法对所有源账本进行批量查询，返回不存在的账本ID列表。这种方式比逐个验证更高效，特别是在源账本数量较多时。

核心的记录迁移操作通过MigrateAccountBook方法实现，将源账本中的所有交易记录转移到目标账本，其本质是更新这些记录的AccountBookId字段为目标账本ID，从而实现记录的归集。在实现此方法时，应当使用数据库事务确保整个迁移过程的原子性，避免数据不一致。对于大量交易记录的迁移场景，应使用批量更新操作而非逐条更新，以提高性能并减少数据库压力。