feat: 添加缓存crud

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

@@ -0,0 +1,120 @@
+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));
+        }
+    }
+}