Healnet.Core 1.0.2

Healnet.Core

Healnet.Core 是 Healnet 框架的核心业务层类库，提供领域层的基础接口和通用服务。

功能特性

• 仓储接口 (IRepository<TEntity, TKey>) - 定义完整的数据访问操作接口
• 工作单元 (IUnitOfWork) - 提供事务管理支持
• 服务接口 (IService) - 定义业务服务基类接口
• 缓存服务 (ICacheService) - 定义缓存操作接口
• 消息发布/订阅 (IMessagePublisher/IMessageSubscriber) - 定义消息队列接口
• 异常类型 - 提供统一的业务异常处理

安装

Install-Package Healnet.Core

使用示例

IRepository

public class UserService
{
    private readonly IRepository<User, long> _userRepository;
    
    public UserService(IRepository<User, long> userRepository)
    {
        _userRepository = userRepository;
    }
    
    public async Task<User> CreateUserAsync(UserCreateDto dto)
    {
        var user = new User
        {
            Name = dto.Name,
            Email = dto.Email,
            Password = HashPassword(dto.Password)
        };
        
        return await _userRepository.AddAsync(user);
    }
    
    public async Task<User> UpdateUserAsync(long id, UserUpdateDto dto)
    {
        var user = await _userRepository.GetByIdAsync(id);
        if (user == null) throw new NotFoundException("User not found");
        
        user.Name = dto.Name;
        user.Email = dto.Email;
        
        return await _userRepository.UpdateAsync(user);
    }
}

IUnitOfWork

public async Task ProcessOrderAsync(Order order)
{
    using var unitOfWork = _unitOfWorkFactory.Create();
    
    try
    {
        await _orderRepository.AddAsync(order);
        await _inventoryRepository.UpdateStockAsync(order.Items);
        
        await unitOfWork.CommitAsync();
    }
    catch
    {
        await unitOfWork.RollbackAsync();
        throw;
    }
}

异常处理

try
{
    var user = await _userRepository.GetByIdAsync(userId);
    if (user == null)
    {
        throw new NotFoundException("User not found");
    }
    
    if (!user.IsActive)
    {
        throw new BusinessException("User is inactive");
    }
}
catch (NotFoundException ex)
{
    // 处理资源未找到异常
}
catch (BusinessException ex)
{
    // 处理业务逻辑异常
}

命名空间

using Healnet.Core.Interfaces;
using Healnet.Core.Services;
using Healnet.Core.Exceptions;
using Healnet.Core.Entities;
using Healnet.Core.Responses;

许可证

MIT License