NPinFramework/framework/NPin.Framework.Ddd.Application/NPinCacheCrudAppService.cs

using Volo.Abp.Application.Dtos;
using Volo.Abp.Caching;
using Volo.Abp.Domain.Entities;
using Volo.Abp.Domain.Repositories;

namespace NPin.Framework.Ddd.Application;

public abstract class NPinCacheCrudAppService<TEntity, TEntityDto, TKey> : NPinCrudAppService<TEntity, TEntityDto,
    TKey,
    PagedAndSortedResultRequestDto>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
{
    protected NPinCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
    {
    }
}

public abstract class NPinCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput>
    : NPinCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TEntityDto>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
{
    protected NPinCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
    {
    }
}

public abstract class NPinCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput>
    : NPinCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TCreateInput>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
{
    protected NPinCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
    {
    }
}

public abstract class NPinCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    : NPinCrudAppService<TEntity, TEntityDto, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
{
    protected NPinCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
    {
    }
}

public abstract class NPinCacheCrudAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput,
    TCreateInput, TUpdateInput>
    : NPinCrudAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    where TEntity : class, IEntity<TKey>
    where TGetOutputDto : IEntityDto<TKey>
    where TGetListOutputDto : IEntityDto<TKey>
{
    protected IDistributedCache<TEntity> Cache =>
        LazyServiceProvider.LazyGetRequiredService<IDistributedCache<TEntity>>();

    protected string GetCacheKey(TKey id) =>
        typeof(TEntity).Name + ":" + (CurrentTenant.Id ?? Guid.Empty) + ":" + id.ToString();

    protected NPinCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
    {
    }

    public override async Task<TGetOutputDto> UpdateAsync(TKey id, TUpdateInput input)
    {
        var output = await base.UpdateAsync(id, input);
        await Cache.RemoveAsync(GetCacheKey(id));
        return output;
    }

    public override async Task<PagedResultDto<TGetListOutputDto>> GetListAsync(TGetListInput input)
    {
        //两种方式：
        //1：全表缓存，使用缓存直接查询
        //2：非全部缓存，查询到的数据直接添加到缓存

        //判断是否该实体为全表缓存
        throw new NotImplementedException();

        //IDistributedCache 有局限性，条件查询无法进行缓存了
        //if (true)
        //{
        //    return await GetListByCacheAsync(input);
        //}
        //else
        //{
        //    return await GetListByDbAsync(input);
        //}
    }

    protected virtual async Task<PagedResultDto<TGetListOutputDto>> GetListByDbAsync(TGetListInput input)
    {
        //如果不是全表缓存，可以走这个啦
        throw new NotImplementedException();
    }

    protected virtual async Task<PagedResultDto<TGetListOutputDto>> GetListByCacheAsync(TGetListInput input)
    {
        //如果是全表缓存，可以走这个啦
        throw new NotImplementedException();
    }


    protected override async Task<TEntity> GetEntityByIdAsync(TKey id)
    {
        var output = await Cache.GetOrAddAsync(GetCacheKey(id), async () => await base.GetEntityByIdAsync(id));
        return output!;
    }

    public override async Task DeleteAsync(IEnumerable<TKey> id)
    {
        await base.DeleteAsync(id);
        foreach (var itemId in id)
        {
            await Cache.RemoveAsync(GetCacheKey(itemId));
        }
    }
}