feat: 添加缓存crud

Yi.Abp.Net8/framework/Yi.Framework.Ddd.Application/YiCacheCrudAppService.cs

@@ -0,0 +1,126 @@
+using Volo.Abp.Application.Dtos;
+using Volo.Abp.Caching;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.MultiTenancy;
+
+namespace Yi.Framework.Ddd.Application
+{
+    public abstract class YiCacheCrudAppService<TEntity, TEntityDto, TKey> : YiCrudAppService<TEntity, TEntityDto, TKey, PagedAndSortedResultRequestDto>
+          where TEntity : class, IEntity<TKey>
+          where TEntityDto : IEntityDto<TKey>
+    {
+        protected YiCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
+        {
+        }
+    }
+
+    public abstract class YiCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput>
+        : YiCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TEntityDto>
+        where TEntity : class, IEntity<TKey>
+        where TEntityDto : IEntityDto<TKey>
+    {
+        protected YiCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
+        {
+        }
+    }
+
+
+    public abstract class YiCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput>
+        : YiCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TCreateInput>
+        where TEntity : class, IEntity<TKey>
+        where TEntityDto : IEntityDto<TKey>
+    {
+        protected YiCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
+        {
+        }
+    }
+
+    public abstract class YiCacheCrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
+        : YiCrudAppService<TEntity, TEntityDto, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
+        where TEntity : class, IEntity<TKey>
+        where TEntityDto : IEntityDto<TKey>
+    {
+        protected YiCacheCrudAppService(IRepository<TEntity, TKey> repository) : base(repository)
+        {
+        }
+    }
+
+
+    public abstract class YiCacheCrudAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
+        : YiCrudAppService<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 YiCacheCrudAppService(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<TGetOutputDto> CreateAsync(TCreateInput input)
+        {
+            var output = await base.CreateAsync(input);
+            await Cache.RemoveAsync(GetCacheKey(output.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));
+            }
+
+        }
+    }
+}

Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Application/Services/DictionaryTypeService.cs

@@ -1,5 +1,7 @@
+using Microsoft.Extensions.DependencyInjection;
 using SqlSugar;
 using Volo.Abp.Application.Dtos;
+using Volo.Abp.Caching;
 using Yi.Framework.Ddd.Application;
 using Yi.Framework.Rbac.Application.Contracts.Dtos.DictionaryType;
 using Yi.Framework.Rbac.Application.Contracts.IServices;
@@ -36,6 +38,5 @@ namespace Yi.Framework.Rbac.Application.Services
                 Items = await MapToGetListOutputDtosAsync(entities)
             };
         }
-
     }
 }