博主最近失业在家，找工作之余，自己动手写了个洋葱架构（整洁架构）解决方案，以总结和整理以前的项目经验，起名叫OnionArch，其目的是为了更好的实现采用DDD（领域驱动分析）和命令查询职责分离（CQRS）的洋葱架构。
什么是OnionArch
OnionArch解决方案清晰的展示了程序各分层的职责，帮助程序员写出逻辑更清晰的代码，提高程序的高内聚、低耦合性。提高程序逻辑的可重用性，可扩展性和可测试性。
OnionArch可降低单个微服务，特别是SAAS微服务开发的复杂度，在保证软件质量的基础上提高软件开发效率。
OnionArch基于最新的开源.Net 7.0 RC1, 数据库采用PostgreSQL, 目前实现了包括多租户在内的12个特性。详细内容请看：https://www.cnblogs.com/xiaozhuang/p/16772485.html
OnionArch如何实现更新指定字段的通用Handler
本篇主要讲述OnionArch如何实现更新指定字段的通用Handler，这里的Handler是指MediatR中继承IRequestHandler接口的处理逻辑。
Let me show you the code：
public async override Task<UpdateProductReply> UpdateProduct(UpdateProductRequest request, ServerCallContext context)
{
UpdateCommand<UpdateProductRequest> updateProductCommand = new UpdateCommand<UpdateProductRequest>(Guid.Parse(request.ProductId),request,p => p.Description);
await _mediator.Send(updateProductCommand);
return new UpdateProductReply()
{
Message = "Update Product sucess"
};
}
这是一个实现UpdateProduct业务用例的GRPC方法，新建一个UpdateCommand更新命令，并传入ProductId和要更新的数据request（表单提交的ViewModel），以及要更新的属性字段。然后调用Mediator.Send发送该命令即可。
UpdateCommand命令定义如下，继承自CQRS的ICommand接口，并采用了C#的record类型，确保必填字段不为空。
public record UpdateCommand<TModel>(Guid Id, TModel Model, params Expression<Func<TModel, object>>[] UpdateProperties) : ICommand
{ }
第三个参数可以传入多个要更新的字段的Lambda 表达式，不采用字符串List的方式以防止程序员写错。
Mediator的更新命令处理对象UpdateCommandHandler 接收到该命令进行处理：
public class UpdateCommandHandler<TModel, TEntity> : IRequestHandler<UpdateCommand<TModel>> where TEntity : BaseEntity
{
private readonly CURDDomainService<TEntity> _curdDomainService;
public UpdateCommandHandler(CURDDomainService<TEntity> curdDomainService)
{
_curdDomainService = curdDomainService;
}
public async Task<Unit> Handle(UpdateCommand<TModel> request, CancellationToken cancellationToken)
{
TEntity updateEntity = await _curdDomainService.Retrieve(request.Id);
updateEntity = request.Model.Adapt(updateEntity);
List<string> updateProperties = new List<string>();
foreach (var expression in request.UpdateProperties)
{
var member = expression.Body as MemberExpression;
if (member != null)
updateProperties.Add(member.Member.Name);
}
await _curdDomainService.Update(updateEntity, updateProperties);
return Unit.Value;
}
}
首先根据传入的ProductId获取到Product实体，然和将传入的request Model数据，通过Mapster的Adapt方法赋值给该实体，该实体字段就有了最新的值。
然后将传入的要更新的属性字段Lambda 表达式转换为属性字符串List，再调用领域层方法保存该实体到数据库。
领域层更新实体的仓储方法如下：
public async Task<TEntity> Update(TEntity entity, IEnumerable<string> updateProperties)
{
var entry = _dbContext.ChangeTracker.Entries<TEntity>().FirstOrDefault(p => p.Entity == entity);
if (entry == null)
{
entry = _dbContext.Set<TEntity>().Attach(entity);
}
entry.State = EntityState.Unchanged;
foreach (var updateProperty in updateProperties)
{
entry.Property(updateProperty).IsModified = true;
}
return entry.Entity;
}
可以看到，该方法只将要更新的字段设置为IsModified = true，即可达到更新特定字段的目的。
输出的SQL语句如下：
Executed DbCommand (11ms) [Parameters=[@p3='?' (DbType = Guid), @p0='?', @p1='?' (DbType = DateTime), @p2='?'], CommandType='Text', CommandTimeout='30']
UPDATE "T_Product" SET "Description" = @p0, "LastModified" = @p1, "LastModifiedBy" = @p2
WHERE "Id" = @p3;
可以看到，SQL只更新了Description字段，LastModified和LastModifiedBy字段是OnionArch的实体数据审计特性自动加上的。打完收工。
找工作时间
接下来又到了找工作广告时间：
博主有15年以上的软件技术实施经验（Technical Leader），专注于微服务和云原生（K8s）软件架构设计、专注于 .Net Core\Java开发和Devops构建发布。 博主10年以上的软件交付管理经验（Project Manager & Product Ower），致力于敏捷（Scrum）项目管理、软件产品业务需求分析和原型设计。 博主熟练配置和使用 Microsoft Azure云。 博主为人诚恳，积极乐观，工作认真负责。
我家在广州，也可以去深圳工作。做架构和项目管理都可以，希望能从事稳定行业的业务数字化转型。有工作机会推荐的朋友可以加我微信 15920128707，微信名字叫Jerry。
标签：
留言评论