修改

Net6Demo_Api.Business/BaseBusiness.cs

@@ -26,10 +26,14 @@ namespace Net6Demo_Api.Business
         /// 构造函数
         /// </summary>
         /// <param name="db">注入数据库</param>
-        public BaseBusiness(IDbAccessor db, IDistributedCache cache)
+        public BaseBusiness(IDbAccessor db, IDistributedCache cache, bool iscache = false)
         {
             _db = db;
             _cache = cache;
+            if (iscache)
+            {
+                try { cache.Refresh(CacheName); IsCache = true; } catch { IsCache = false; }
+            }
         }
 
         #endregion
@@ -42,7 +46,7 @@ namespace Net6Demo_Api.Business
         /// <summary>
         /// 缓存名称
         /// </summary>
-        protected string CacheName { get; set; } = "";
+        protected string CacheName { get; set; } = typeof(T).Name;
         /// <summary>
         /// 主键字段
         /// </summary>
@@ -360,11 +364,7 @@ namespace Net6Demo_Api.Business
             #region 启用缓存
             if (IsCache)
             {
-                var listCache = GetRedis().Result;
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(p => KeyFiled.GetValue(p).ToString() == keyValue[0].ToString()).FirstOrDefault();
-                }
+                return GetIQueryable().Where(p => KeyFiled.GetValue(p).ToString() == keyValue[0].ToString()).FirstOrDefault();
             }
             #endregion
             return _db.GetEntity<T>(keyValue);
@@ -380,11 +380,7 @@ namespace Net6Demo_Api.Business
             #region 启用缓存
             if (IsCache)
             {
-                var listCache = await GetRedis();
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(p => KeyFiled.GetValue(p).ToString() == keyValue[0].ToString()).FirstOrDefault();
-                }
+                return GetIQueryable().Where(p => KeyFiled.GetValue(p).ToString() == keyValue[0].ToString()).FirstOrDefault();
             }
             #endregion
 
@@ -397,18 +393,7 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public int GetCount(Expression<Func<T, bool>> condition)
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = GetRedis().Result;
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(condition).Count();
-                }
-            }
-            #endregion
-
-            return _db.GetIQueryable<T>().AsNoTracking().Where(condition).Count();
+            return GetIQueryable().Where(condition).Count();
         }
 
         /// <summary>
@@ -417,18 +402,10 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public async Task<int> GetCountAsync(Expression<Func<T, bool>> condition)
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = await GetRedis();
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(condition).Count();
-                }
-            }
-            #endregion
+            var query = GetIQueryable().Where(condition);
 
-            return await _db.GetIQueryable<T>().AsNoTracking().Where(condition).CountAsync();
+            if (IsCache) return query.Count();
+            return await query.CountAsync();
         }
 
         /// <summary>
@@ -437,17 +414,7 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public List<T> GetList()
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = GetRedis().Result;
-                if (listCache != null)
-                {
-                    return listCache;
-                }
-            }
-            #endregion
-            return _db.GetIQueryable<T>().AsNoTracking().ToList();
+            return GetIQueryable().ToList();
         }
 
         /// <summary>
@@ -457,18 +424,8 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public List<T> GetList(Expression<Func<T, bool>> condition)
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = GetRedis().Result;
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(condition).ToList();
-                }
-            }
-            #endregion
-
-            return _db.GetIQueryable<T>().AsNoTracking().Where(condition).ToList();
+            var query = GetIQueryable().Where(condition);
+            return query.ToList();
         }
 
         /// <summary>
@@ -477,17 +434,9 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public async Task<List<T>> GetListAsync()
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = await GetRedis();
-                if (listCache != null)
-                {
-                    return listCache;
-                }
-            }
-            #endregion
-            return await _db.GetIQueryable<T>().AsNoTracking().ToListAsync();
+            var query = GetIQueryable();
+            if (IsCache) return query.ToList();
+            return await query.ToListAsync();
         }
 
         /// <summary>
@@ -497,18 +446,9 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public async Task<List<T>> GetListAsync(Expression<Func<T, bool>> condition)
         {
-            #region 启用缓存
-            if (IsCache)
-            {
-                var listCache = await GetRedis();
-                if (listCache != null)
-                {
-                    return listCache.AsQueryable().Where(condition).ToList();
-                }
-            }
-            #endregion
-
-            return await _db.GetIQueryable<T>().AsNoTracking().Where(condition).ToListAsync();
+            var query = GetIQueryable().Where(condition);
+            if (IsCache) return query.ToList();
+            return await query.ToListAsync();
         }
 
         /// <summary>
@@ -520,9 +460,13 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public async Task<ValueTuple<List<T>, int>> GetListPageAsync(PageInput page, Expression<Func<T, bool>> condition, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy)
         {
-            var iq = _db.GetIQueryable<T>().AsNoTracking().Where(condition);
-
-            var list = await orderBy(iq).Skip((page.PageIndex - 1) * page.PageRows).Take(page.PageRows).ToListAsync();
+            var iq = GetIQueryable().Where(condition);
+            var query = orderBy(iq).Skip((page.PageIndex - 1) * page.PageRows).Take(page.PageRows);
+            if (IsCache)
+            {
+                return (query.ToList(), iq.Count());
+            }
+            var list = await query.ToListAsync();
             int total = await iq.CountAsync();
 
             return (list, total);
@@ -534,7 +478,15 @@ namespace Net6Demo_Api.Business
         /// <returns></returns>
         public virtual IQueryable<T> GetIQueryable()
         {
-            return _db.GetIQueryable<T>();
+            if (IsCache)
+            {
+                var listCache = GetRedis().Result;
+                if (listCache != null)
+                {
+                    return listCache.AsQueryable();
+                }
+            }
+            return _db.GetIQueryable<T>().AsNoTracking();
         }
 
         #endregion

Net6Demo_Api.Business/System/CustomFiledBusiness.cs

@@ -8,10 +8,8 @@ namespace Net6Demo_Api.Business
 {
     public class CustomFiledBusiness : BaseBusiness<T_Sys_CustomFiled>, ICustomFiledBusiness, ITransientDependency
     {
-        public CustomFiledBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public CustomFiledBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_CustomFiled";
         }
     }
 }

Net6Demo_Api.Business/System/DepartmentBusiness.cs

@@ -14,10 +14,8 @@ namespace Net6Demo_Api.Business
 {
     public class DepartmentBusiness : BaseBusiness<T_Sys_Department>, IDepartmentBusiness, ITransientDependency
     {
-        public DepartmentBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public DepartmentBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_Department";
         }
     }
 }

Net6Demo_Api.Business/System/MenuBusiness.cs

@@ -8,10 +8,8 @@ namespace Net6Demo_Api.Business
 {
     public class MenuBusiness : BaseBusiness<T_Sys_Menu>, IMenuBusiness, ITransientDependency
     {
-        public MenuBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public MenuBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_Menu";
         }
     }
 }

Net6Demo_Api.Business/System/RoleBusiness.cs

@@ -8,10 +8,8 @@ namespace Net6Demo_Api.Business
 {
     public class RoleBusiness : BaseBusiness<T_Sys_Role>, IRoleBusiness, ITransientDependency
     {
-        public RoleBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public RoleBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_Role";
         }
     }
 }

Net6Demo_Api.Business/System/RoleMenuBusiness.cs

@@ -8,10 +8,8 @@ namespace Net6Demo_Api.Business
 {
     public class RoleMenuBusiness : BaseBusiness<T_Sys_RoleMenu>, IRoleMenuBusiness, ITransientDependency
     {
-        public RoleMenuBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public RoleMenuBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_RoleMenu";
         }
 
         /// <summary>

Net6Demo_Api.Business/System/SystemConfigBusiness.cs

@@ -8,10 +8,8 @@ namespace Net6Demo_Api.Business
 {
     public class SystemConfigBusiness : BaseBusiness<T_Sys_SystemConfig>, ISystemConfigBusiness, ITransientDependency
     {
-        public SystemConfigBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache)
+        public SystemConfigBusiness(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_SystemConfig";
         }
     }
 }

Net6Demo_Api.Business/System/UserAccountBusiness.cs

@@ -18,10 +18,8 @@ namespace Net6Demo_Api.Business
     public class UserAccountBusiness : BaseBusiness<T_Sys_UserAccount>, IUserAccountBusiness, ITransientDependency
     {
         private readonly IMapper _mapper;
-        public UserAccountBusiness(IDbAccessor db, IDistributedCache cache, IMapper mapper) : base(db, cache)
+        public UserAccountBusiness(IDbAccessor db, IDistributedCache cache, IMapper mapper) : base(db, cache, true)
         {
-            IsCache = true;
-            CacheName = "T_Sys_UserAccount";
             _mapper = mapper;
         }