diff --git a/Infrastructure/Cache/EnyimMemcachedContext.cs b/Infrastructure/Cache/EnyimMemcachedContext.cs
index e12fb2e2..772b20d6 100644
--- a/Infrastructure/Cache/EnyimMemcachedContext.cs
+++ b/Infrastructure/Cache/EnyimMemcachedContext.cs
@@ -27,6 +27,12 @@ namespace Infrastructure.Cache
_memcachedClient = client;
}
+ ///
+ ///
+ ///
+ ///
+ ///
+ ///
public override T Get(string key)
{
return _memcachedClient.Get(key);
diff --git a/Infrastructure/Cache/RedisCacheContext.cs b/Infrastructure/Cache/RedisCacheContext.cs
index d80ac073..9f9aacc0 100644
--- a/Infrastructure/Cache/RedisCacheContext.cs
+++ b/Infrastructure/Cache/RedisCacheContext.cs
@@ -14,7 +14,6 @@ namespace Infrastructure.Cache
private ConnectionMultiplexer _conn { get; set; }
private IDatabase iDatabase { get; set; }
- private AppSetting _appSettings;
public RedisCacheContext(IOptions options)
{
_conn = ConnectionMultiplexer.Connect(options.Value.RedisConf);
diff --git a/Infrastructure/Extensions/AutofacManager/AutofacContainerModule.cs b/Infrastructure/Extensions/AutofacManager/AutofacContainerModule.cs
index b29053f6..8585aaad 100644
--- a/Infrastructure/Extensions/AutofacManager/AutofacContainerModule.cs
+++ b/Infrastructure/Extensions/AutofacManager/AutofacContainerModule.cs
@@ -4,7 +4,7 @@ namespace Infrastructure.Extensions.AutofacManager
{
///
/// 提供全局静态获取服务的能力。
- /// 例:AutofacContainerModule.GetService()
+ /// 例:AutofacContainerModule.GetService<IPathProvider>()
///
public class AutofacContainerModule
{
diff --git a/Infrastructure/Extensions/ConvertJsonExtension.cs b/Infrastructure/Extensions/ConvertJsonExtension.cs
index ad7cff2e..fb7cbf09 100644
--- a/Infrastructure/Extensions/ConvertJsonExtension.cs
+++ b/Infrastructure/Extensions/ConvertJsonExtension.cs
@@ -91,7 +91,7 @@ namespace Infrastructure.Extensions
///
/// list转换为json
///
- ///
+ ///
///
///
///
diff --git a/Infrastructure/Extensions/EntityProperties.cs b/Infrastructure/Extensions/EntityProperties.cs
index e359a417..b300850e 100644
--- a/Infrastructure/Extensions/EntityProperties.cs
+++ b/Infrastructure/Extensions/EntityProperties.cs
@@ -26,7 +26,7 @@ namespace Infrastructure.Extensions
/// 获取对象里指定成员名称
///
///
- /// 格式 Expression> exp = x => new { x.字段1, x.字段2 };或x=>x.Name
+ /// > exp = x => new { x.字段1, x.字段2 };或x=>x.Name]]>
///
public static string[] GetExpressionProperty(this Expression> properties)
{
@@ -132,7 +132,7 @@ namespace Infrastructure.Extensions
colType += "(" + (asType ? ((DisplayFormatAttribute) objAtrr).DataFormatString : "18,5") + ")";
}
- ///如果是string,根据 varchar或nvarchar判断最大长度
+ //如果是string,根据 varchar或nvarchar判断最大长度
if (property.PropertyType.ToString() == "System.String")
{
colType = colType.Split("(")[0];
@@ -198,7 +198,6 @@ namespace Infrastructure.Extensions
///
///
/// 指定生成的数组值的类型
- ///
///
public static string GetArraySql(this object[] array, FieldType fieldType, string sql)
{
@@ -220,7 +219,6 @@ namespace Infrastructure.Extensions
///
/// 根据实体获取key的类型,用于update或del操作
///
- ///
///
public static FieldType GetFieldType(this Type typeEntity)
{
@@ -607,13 +605,9 @@ namespace Infrastructure.Extensions
///
- /// 判断是否包含某个属性:
- /// 如 [Editable(true)]
- // public string MO { get; set; }包含Editable
+ /// 判断是否包含某个属性
+ /// public string MO {get; set; }包含Editable
///
- ///
- ///
- ///
public static bool ContainsCustomAttributes(this PropertyInfo propertyInfo, Type type)
{
propertyInfo.GetTypeCustomAttributes(type, out bool contains);
@@ -795,7 +789,7 @@ namespace Infrastructure.Extensions
/// 如果是小数float或Decimal必须对propertyInfo字段加DisplayFormatAttribute属性
///
///
- /// IEnumerable<(bool, string, object)> bool成否校验成功,string校验失败信息,object,当前校验的值
+ /// IEnumerable<(bool, string, object)> bool成否校验成功,string校验失败信息,object,当前校验的值
public static IEnumerable<(bool, string, object)> ValidationValueForDbType(this PropertyInfo propertyInfo,
params object[] values)
{
@@ -1036,7 +1030,7 @@ namespace Infrastructure.Extensions
///
/// 当前类
/// 指定的类
- /// 指定属性的值 格式 Expression> exp = x => new { x.字段1, x.字段2 };
+ /// 指定属性的值 格式 Expression<Func<entityt, object>> exp = x => new { x.字段1, x.字段2 };
/// 返回的是字段+value
public static Dictionary GetTypeCustomValues(this MemberInfo member,
Expression> expression)
@@ -1066,7 +1060,7 @@ namespace Infrastructure.Extensions
///
/// 当前类
/// 指定的类
- /// 指定属性的值 格式 Expression> exp = x => new { x.字段1, x.字段2 };
+ /// 指定属性的值 格式 Expression<Func<entityt, object>> exp = x => new { x.字段1, x.字段2 };
///
public static string GetTypeCustomValue(this MemberInfo member,
Expression> expression)
@@ -1259,7 +1253,7 @@ namespace Infrastructure.Extensions
}
///
- /// 将数据源映射到新的数据中,目前只支持List映射到List或TSource映射到TResult
+ /// 将数据源映射到新的数据中,目前只支持List<TSource>映射到List<TResult>或TSource映射到TResult
/// 目前只支持Dictionary或实体类型
///
///
diff --git a/Infrastructure/Helpers/XmlHelper.cs b/Infrastructure/Helpers/XmlHelper.cs
index b16c22c1..85832875 100644
--- a/Infrastructure/Helpers/XmlHelper.cs
+++ b/Infrastructure/Helpers/XmlHelper.cs
@@ -1,7 +1,5 @@
using System.Xml;
-/// 这个是用VS2010写的,如果用VS2005,请去掉System.Linq和System.Xml.Linq的引用
-/// 可以将此文件直接编译成dll,今后程序只需要引用该dll后开头添加using XmlLibrary;即可。
namespace Infrastructure.Helpers
{
///
@@ -371,7 +369,7 @@ namespace Infrastructure.Helpers
else
{
XmlNode xn = GetNode(xns, nodeName);
- if (xn != null) return xn; /// V1.0.0.3添加节点判断
+ if (xn != null) return xn;
}
}
return null;
diff --git a/Infrastructure/Infrastructure.csproj b/Infrastructure/Infrastructure.csproj
index 8e5ffc46..4b68fee7 100644
--- a/Infrastructure/Infrastructure.csproj
+++ b/Infrastructure/Infrastructure.csproj
@@ -6,15 +6,16 @@
bin\Debug\net5.0\Infrastructure.xml
+ 1701;1702;1591;1573;1572;1570
-
+
-
-
+
+
diff --git a/Infrastructure/Snowflake/Core/SnowWorkerM1.cs b/Infrastructure/Snowflake/Core/SnowWorkerM1.cs
index f2085047..91348ec5 100644
--- a/Infrastructure/Snowflake/Core/SnowWorkerM1.cs
+++ b/Infrastructure/Snowflake/Core/SnowWorkerM1.cs
@@ -126,18 +126,18 @@ namespace Yitter.IdGenerator
{
return;
- if (GenAction == null)
- {
- return;
- }
-
- DoGenIdAction(new OverCostActionArg(
- WorkerId,
- useTimeTick,
- 1,
- _OverCostCountInOneTerm,
- _GenCountInOneTerm,
- _TermIndex));
+ // if (GenAction == null)
+ // {
+ // return;
+ // }
+ //
+ // DoGenIdAction(new OverCostActionArg(
+ // WorkerId,
+ // useTimeTick,
+ // 1,
+ // _OverCostCountInOneTerm,
+ // _GenCountInOneTerm,
+ // _TermIndex));
}
private void EndOverCostAction(in long useTimeTick)
@@ -148,54 +148,54 @@ namespace Yitter.IdGenerator
}
return;
- if (GenAction == null)
- {
- return;
- }
-
- DoGenIdAction(new OverCostActionArg(
- WorkerId,
- useTimeTick,
- 2,
- _OverCostCountInOneTerm,
- _GenCountInOneTerm,
- _TermIndex));
+ // if (GenAction == null)
+ // {
+ // return;
+ // }
+ //
+ // DoGenIdAction(new OverCostActionArg(
+ // WorkerId,
+ // useTimeTick,
+ // 2,
+ // _OverCostCountInOneTerm,
+ // _GenCountInOneTerm,
+ // _TermIndex));
}
private void BeginTurnBackAction(in long useTimeTick)
{
return;
- if (GenAction == null)
- {
- return;
- }
-
- DoGenIdAction(new OverCostActionArg(
- WorkerId,
- useTimeTick,
- 8,
- 0,
- 0,
- _TurnBackIndex));
+ // if (GenAction == null)
+ // {
+ // return;
+ // }
+ //
+ // DoGenIdAction(new OverCostActionArg(
+ // WorkerId,
+ // useTimeTick,
+ // 8,
+ // 0,
+ // 0,
+ // _TurnBackIndex));
}
private void EndTurnBackAction(in long useTimeTick)
{
return;
- if (GenAction == null)
- {
- return;
- }
-
- DoGenIdAction(new OverCostActionArg(
- WorkerId,
- useTimeTick,
- 9,
- 0,
- 0,
- _TurnBackIndex));
+ // if (GenAction == null)
+ // {
+ // return;
+ // }
+ //
+ // DoGenIdAction(new OverCostActionArg(
+ // WorkerId,
+ // useTimeTick,
+ // 9,
+ // 0,
+ // 0,
+ // _TurnBackIndex));
}
private long NextOverCostId()
diff --git a/Infrastructure/Utilities/UriUtil.cs b/Infrastructure/Utilities/UriUtil.cs
index d9573960..b931c9d4 100644
--- a/Infrastructure/Utilities/UriUtil.cs
+++ b/Infrastructure/Utilities/UriUtil.cs
@@ -58,17 +58,5 @@ namespace Infrastructure.Utilities
String result = url.ToLower().Replace("&" + fragmentToRemove, string.Empty).Replace("?" + fragmentToRemove, string.Empty);
return result;
}
-
- ///
- /// 根据URL的相对地址获取决定路径
- /// eg: /Home/About ==>http://192.168.0.1/Home/About
- ///
- /// System.String.
- //public static string GetAbsolutePathForRelativePath(string relativePath)
- //{
- // HttpRequest Request = HttpContext.Current.Request;
- // string returnUrl = string.Format("{0}{1}",Request.Url.AbsoluteUri.Replace(Request.Url.PathAndQuery, string.Empty) , VirtualPathUtility.ToAbsolute(relativePath));
- // return returnUrl;
- //}
}
}
\ No newline at end of file
diff --git a/OpenAuth.App/AppManager/AppManager.cs b/OpenAuth.App/AppManager/AppManager.cs
index 55024252..af6213d6 100644
--- a/OpenAuth.App/AppManager/AppManager.cs
+++ b/OpenAuth.App/AppManager/AppManager.cs
@@ -2,6 +2,7 @@
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.Repository;
@@ -39,7 +40,7 @@ namespace OpenAuth.App
{
var applications = UnitWork.Find(null);
- return applications.ToList();
+ return await applications.ToListAsync();
}
diff --git a/OpenAuth.App/AuthStrategies/AuthStrategyContext.cs b/OpenAuth.App/AuthStrategies/AuthStrategyContext.cs
index ad79ce67..0a29d81f 100644
--- a/OpenAuth.App/AuthStrategies/AuthStrategyContext.cs
+++ b/OpenAuth.App/AuthStrategies/AuthStrategyContext.cs
@@ -63,17 +63,7 @@ namespace OpenAuth.App
{
get { return _strategy.Orgs; }
}
- ///
- /// 获取角色可以访问的字段信息,只是单纯的获取数据库
- ///
- ///
- ///
- [Obsolete("请使用GetTableColumns代替")]
- public List GetProperties(string moduleCode)
- {
- return _strategy.GetProperties(moduleCode);
- }
-
+
///
/// 获取角色可以访问的字段信息
///
diff --git a/OpenAuth.App/AuthStrategies/NormalAuthStrategy.cs b/OpenAuth.App/AuthStrategies/NormalAuthStrategy.cs
index 106a9a9d..b50272ad 100644
--- a/OpenAuth.App/AuthStrategies/NormalAuthStrategy.cs
+++ b/OpenAuth.App/AuthStrategies/NormalAuthStrategy.cs
@@ -117,29 +117,7 @@ namespace OpenAuth.App
_userRoleIds = UnitWork.Find(u => u.FirstId == _user.Id && u.Key == Define.USERROLE).Select(u => u.SecondId).ToList();
}
}
-
- ///
- /// 获取用户可访问的字段列表
- ///
- /// 模块的code
- ///
- public List GetProperties(string moduleCode)
- {
- var allprops = _dbExtension.GetProperties(moduleCode);
-
- //如果是系统模块,直接返回所有字段。防止开发者把模块配置成系统模块,还在外层调用loginContext.GetProperties("xxxx");
- bool? isSysModule = UnitWork.FirstOrDefault(u => u.Code == moduleCode)?.IsSys;
- if (isSysModule!= null && isSysModule.Value)
- {
- return allprops;
- }
-
- var props =UnitWork.Find(u =>
- u.Key == Define.ROLEDATAPROPERTY && _userRoleIds.Contains(u.FirstId) && u.SecondId == moduleCode)
- .Select(u => u.ThirdId);
-
- return allprops.Where(u => props.Contains(u.Key)).ToList();
- }
+
public List GetTableColumns(string moduleCode)
{
diff --git a/OpenAuth.App/AuthStrategies/SystemAuthStrategy.cs b/OpenAuth.App/AuthStrategies/SystemAuthStrategy.cs
index 05f637ef..e9bab0c5 100644
--- a/OpenAuth.App/AuthStrategies/SystemAuthStrategy.cs
+++ b/OpenAuth.App/AuthStrategies/SystemAuthStrategy.cs
@@ -91,11 +91,7 @@ namespace OpenAuth.App
throw new Exception("超级管理员,禁止设置用户");
}
}
-
- public List GetProperties(string moduleCode)
- {
- return _dbExtension.GetProperties(moduleCode);
- }
+
public List GetTableColumns(string moduleCode)
{
diff --git a/OpenAuth.App/Base/BaseApp.cs b/OpenAuth.App/Base/BaseApp.cs
index 41705215..b7ec26d3 100644
--- a/OpenAuth.App/Base/BaseApp.cs
+++ b/OpenAuth.App/Base/BaseApp.cs
@@ -34,7 +34,7 @@ namespace OpenAuth.App
///
/// 获取当前登录用户的数据访问权限
///
- /// linq表达式参数的名称,如u=>u.name中的"u"
+ /// linq表达式参数的名称,如u=>u.name中的"u"
///
protected IQueryable GetDataPrivilege(string parametername)
{
diff --git a/OpenAuth.App/Base/BaseIntAutoGenApp.cs b/OpenAuth.App/Base/BaseIntAutoGenApp.cs
index 758d03f8..a03391d5 100644
--- a/OpenAuth.App/Base/BaseIntAutoGenApp.cs
+++ b/OpenAuth.App/Base/BaseIntAutoGenApp.cs
@@ -15,6 +15,7 @@ namespace OpenAuth.App
/// 业务层基类,UnitWork用于事务操作,Repository用于普通的数据库操作
///
///
+ ///
public class BaseIntAutoGenApp :BaseApp where T : IntAutoGenEntity where TDbContext: DbContext
{
public BaseIntAutoGenApp(IUnitWork unitWork, IRepository repository, IAuth auth) : base(unitWork, repository, auth)
diff --git a/OpenAuth.App/Base/BaseLongApp.cs b/OpenAuth.App/Base/BaseLongApp.cs
index 9317e60c..c5964cca 100644
--- a/OpenAuth.App/Base/BaseLongApp.cs
+++ b/OpenAuth.App/Base/BaseLongApp.cs
@@ -14,6 +14,7 @@ namespace OpenAuth.App
/// 业务层基类,UnitWork用于事务操作,Repository用于普通的数据库操作
///
///
+ ///
public class BaseLongApp :BaseApp where T : LongEntity where TDbContext: DbContext
{
diff --git a/OpenAuth.App/Base/BaseStringApp.cs b/OpenAuth.App/Base/BaseStringApp.cs
index 69b0e186..de50a01a 100644
--- a/OpenAuth.App/Base/BaseStringApp.cs
+++ b/OpenAuth.App/Base/BaseStringApp.cs
@@ -11,9 +11,10 @@ namespace OpenAuth.App
{
///
/// 业务层基类,UnitWork用于事务操作,Repository用于普通的数据库操作
- /// 如用户管理:Class UserManagerApp:BaseApp
+ /// 如用户管理:Class UserManagerApp:BaseApp<User>
///
///
+ ///
public class BaseStringApp :BaseApp where T : StringEntity where TDbContext: DbContext
{
diff --git a/OpenAuth.App/Base/BaseTreeApp.cs b/OpenAuth.App/Base/BaseTreeApp.cs
index 7d75aa61..b52d527c 100644
--- a/OpenAuth.App/Base/BaseTreeApp.cs
+++ b/OpenAuth.App/Base/BaseTreeApp.cs
@@ -10,6 +10,7 @@ namespace OpenAuth.App
/// 树状结构处理
///
///
+ /// ///
public class BaseTreeApp :BaseStringApp where T : TreeEntity where TDbContext :DbContext
{
diff --git a/OpenAuth.App/BuilderTable/BuilderTableApp.cs b/OpenAuth.App/BuilderTable/BuilderTableApp.cs
index 4b6b8bf7..f7cb794c 100644
--- a/OpenAuth.App/BuilderTable/BuilderTableApp.cs
+++ b/OpenAuth.App/BuilderTable/BuilderTableApp.cs
@@ -11,6 +11,7 @@ using Infrastructure;
using Infrastructure.Extensions;
using Infrastructure.Helpers;
using Infrastructure.Utilities;
+using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyModel;
using Microsoft.Extensions.Options;
using OpenAuth.App.Interface;
@@ -29,8 +30,7 @@ namespace OpenAuth.App
private BuilderTableColumnApp _builderTableColumnApp;
private CategoryApp _categoryApp;
private DbExtension _dbExtension;
- private string _webProject = null;
- private string _apiNameSpace = null;
+ private string _webProject = string.Empty;
private string _startName = "";
private IOptions _appConfiguration;
@@ -61,12 +61,12 @@ namespace OpenAuth.App
{
get
{
- if (_webProject != null)
+ if (string.IsNullOrEmpty(_webProject))
return _webProject;
_webProject = ProjectPath.GetLastIndexOfDirectoryName(".WebApi") ??
ProjectPath.GetLastIndexOfDirectoryName("Api") ??
ProjectPath.GetLastIndexOfDirectoryName(".Mvc");
- if (_webProject == null)
+ if (string.IsNullOrEmpty(_webProject))
{
throw new Exception("未获取到以.WebApi结尾的项目名称,无法创建页面");
}
@@ -93,10 +93,10 @@ namespace OpenAuth.App
objs = objs.Where(u => u.Id.Contains(request.key));
}
- result.data = objs.OrderBy(u => u.Id)
+ result.data =await objs.OrderBy(u => u.Id)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit).ToList();
- result.count = objs.Count();
+ .Take(request.limit).ToListAsync();
+ result.count =await objs.CountAsync();
return result;
}
@@ -764,8 +764,8 @@ namespace OpenAuth.App
Name = u.TableName
});
- result.data = objs.OrderBy(u => u.Id).ToList();
- result.count = objs.Count();
+ result.data =await objs.OrderBy(u => u.Id).ToListAsync();
+ result.count =await objs.CountAsync();
return result;
}
}
diff --git a/OpenAuth.App/BuilderTable/BuilderTableColumnApp.cs b/OpenAuth.App/BuilderTable/BuilderTableColumnApp.cs
index 4b4839ed..b176b2a3 100644
--- a/OpenAuth.App/BuilderTable/BuilderTableColumnApp.cs
+++ b/OpenAuth.App/BuilderTable/BuilderTableColumnApp.cs
@@ -3,6 +3,7 @@ using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Infrastructure;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
@@ -36,10 +37,10 @@ namespace OpenAuth.App
objs = objs.Where(u => u.ColumnName.Contains(request.key));
}
- result.data = objs.OrderBy(u => u.ColumnName)
+ result.data =await objs.OrderBy(u => u.ColumnName)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit).ToList();
- result.count = objs.Count();
+ .Take(request.limit).ToListAsync();
+ result.count =await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/Category/CategoryApp.cs b/OpenAuth.App/Category/CategoryApp.cs
index 0a44d3e9..ba216bd0 100644
--- a/OpenAuth.App/Category/CategoryApp.cs
+++ b/OpenAuth.App/Category/CategoryApp.cs
@@ -3,6 +3,7 @@ using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Infrastructure;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
@@ -25,12 +26,11 @@ namespace OpenAuth.App
{
throw new CommonException("登录已过期", Define.INVALID_TOKEN);
}
-
- var properties = loginContext.GetProperties("Category");
-
- if (properties == null || properties.Count == 0)
+
+ var columnFields = loginContext.GetTableColumns("Category");
+ if (columnFields == null || columnFields.Count == 0)
{
- throw new Exception("当前登录用户没有访问该模块字段的权限,请联系管理员配置");
+ throw new Exception("请在代码生成界面配置Category表的字段属性");
}
var result = new TableData();
@@ -45,12 +45,12 @@ namespace OpenAuth.App
objs = objs.Where(u => u.Id.Contains(request.key) || u.Name.Contains(request.key));
}
- var propertyStr = string.Join(',', properties.Select(u =>u.Key));
- result.columnHeaders = properties;
+ var propertyStr = string.Join(',', columnFields.Select(u =>u.ColumnName));
+ result.columnFields = columnFields;
result.data = objs.OrderBy(u => u.DtCode)
.Skip((request.page - 1) * request.limit)
.Take(request.limit).Select($"new ({propertyStr})");
- result.count = objs.Count();
+ result.count = await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/Category/CategoryTypeApp.cs b/OpenAuth.App/Category/CategoryTypeApp.cs
index 851bc443..3b072c3e 100644
--- a/OpenAuth.App/Category/CategoryTypeApp.cs
+++ b/OpenAuth.App/Category/CategoryTypeApp.cs
@@ -3,6 +3,7 @@ using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Infrastructure;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
@@ -29,10 +30,10 @@ namespace OpenAuth.App
objs = objs.Where(u => u.Id.Contains(request.key) || u.Name.Contains(request.key));
}
- result.data = objs.OrderBy(u => u.Name)
+ result.data =await objs.OrderBy(u => u.Name)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit);
- result.count = objs.Count();
+ .Take(request.limit).ToListAsync();
+ result.count =await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/DataPrivilege/DataPrivilegeRuleApp.cs b/OpenAuth.App/DataPrivilege/DataPrivilegeRuleApp.cs
index 76d0d4c4..e23e9aa5 100644
--- a/OpenAuth.App/DataPrivilege/DataPrivilegeRuleApp.cs
+++ b/OpenAuth.App/DataPrivilege/DataPrivilegeRuleApp.cs
@@ -2,6 +2,7 @@ using System;
using System.Linq;
using System.Threading.Tasks;
using Infrastructure;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
@@ -25,15 +26,13 @@ namespace OpenAuth.App
{
throw new CommonException("登录已过期", Define.INVALID_TOKEN);
}
-
- var properties = loginContext.GetProperties("DataPrivilegeRule");
-
- if (properties == null || properties.Count == 0)
+
+ var columnFields = loginContext.GetTableColumns("DataPrivilegeRule");
+ if (columnFields == null || columnFields.Count == 0)
{
- throw new Exception("当前登录用户没有访问该模块字段的权限,请联系管理员配置");
+ throw new Exception("请在代码生成界面配置DataPrivilegeRule表的字段属性");
}
-
var result = new TableData();
var objs = UnitWork.Find(null);
if (!string.IsNullOrEmpty(request.key))
@@ -41,13 +40,12 @@ namespace OpenAuth.App
objs = objs.Where(u => u.Id.Contains(request.key) || u.SourceCode.Contains(request.key) || u.Description.Contains(request.key));
}
-
- var propertyStr = string.Join(',', properties.Select(u => u.Key));
- result.columnHeaders = properties;
+ var propertyStr = string.Join(',', columnFields.Select(u => u.ColumnName));
+ result.columnFields = columnFields;
result.data = objs.OrderBy(u => u.Id)
.Skip((request.page - 1) * request.limit)
.Take(request.limit).Select($"new ({propertyStr})");
- result.count = objs.Count();
+ result.count = await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/DbExtension.cs b/OpenAuth.App/DbExtension.cs
index a53331cd..94b12245 100644
--- a/OpenAuth.App/DbExtension.cs
+++ b/OpenAuth.App/DbExtension.cs
@@ -173,7 +173,7 @@ select utc.column_name as COLUMNNAME,
foreach (var context in _contexts)
{
- var columns = context.Query().FromSqlRaw(sql);
+ var columns = context.Set().FromSqlRaw(sql);
var columnList = columns?.ToList();
if (columnList != null && columnList.Any())
{
@@ -238,7 +238,7 @@ select utc.column_name as COLUMNNAME,
foreach (var context in _contexts)
{
- var columns = context.Query().FromSqlRaw(sql);
+ var columns = context.Set().FromSqlRaw(sql);
var columnList = columns?.ToList();
if (columnList != null && columnList.Any())
{
@@ -344,7 +344,7 @@ select utc.column_name as COLUMNNAME,
foreach (var context in _contexts)
{
- var columns = context.Query().FromSqlRaw(sql);
+ var columns = context.Set().FromSqlRaw(sql);
var columnList = columns?.ToList();
if (columnList != null && columnList.Any())
{
diff --git a/OpenAuth.App/Files/FileApp.cs b/OpenAuth.App/Files/FileApp.cs
index cbe8db2b..92e9a0c0 100644
--- a/OpenAuth.App/Files/FileApp.cs
+++ b/OpenAuth.App/Files/FileApp.cs
@@ -7,6 +7,7 @@ using Infrastructure;
using Infrastructure.Extensions;
using Infrastructure.Helpers;
using Microsoft.AspNetCore.Http;
+using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using OpenAuth.App.Interface;
@@ -52,10 +53,10 @@ namespace OpenAuth.App
objs = objs.Where(u => u.FileName.Contains(request.key) || u.FilePath.Contains(request.key));
}
- result.data = objs.OrderByDescending(u => u.CreateTime)
+ result.data =await objs.OrderByDescending(u => u.CreateTime)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit);
- result.count = objs.Count();
+ .Take(request.limit).ToListAsync();
+ result.count =await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/FlowInstance/FlowInstanceApp.cs b/OpenAuth.App/FlowInstance/FlowInstanceApp.cs
index f604a08c..538fc07b 100644
--- a/OpenAuth.App/FlowInstance/FlowInstanceApp.cs
+++ b/OpenAuth.App/FlowInstance/FlowInstanceApp.cs
@@ -27,6 +27,7 @@ using System.Net.Http;
using System.Threading.Tasks;
using Infrastructure.Const;
using Infrastructure.Helpers;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.Repository;
namespace OpenAuth.App
@@ -632,9 +633,9 @@ namespace OpenAuth.App
waitExp = waitExp.And(t => t.CustomName.Contains(request.key));
}
- result.count = UnitWork.Find(waitExp).Count();
+ result.count = await UnitWork.Find(waitExp).CountAsync();
- result.data = UnitWork.Find(request.page, request.limit, "CreateDate descending", waitExp).ToList();
+ result.data =await UnitWork.Find(request.page, request.limit, "CreateDate descending", waitExp).ToListAsync();
}
else if (request.type == "disposed") //已办事项(即我参与过的流程)
{
@@ -650,10 +651,10 @@ namespace OpenAuth.App
query = query.Where(t => t.CustomName.Contains(request.key));
}
- result.data = query.OrderByDescending(u => u.CreateDate)
+ result.data = await query.OrderByDescending(u => u.CreateDate)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit).ToList();
- result.count = instances.Count();
+ .Take(request.limit).ToListAsync();
+ result.count =await instances.CountAsync();
}
else //我的流程
{
@@ -665,9 +666,9 @@ namespace OpenAuth.App
myFlowExp = myFlowExp.And(t => t.CustomName.Contains(request.key));
}
- result.count = UnitWork.Find(myFlowExp).Count();
- result.data = UnitWork.Find(request.page, request.limit,
- "CreateDate descending", myFlowExp).ToList();
+ result.count =await UnitWork.Find(myFlowExp).CountAsync();
+ result.data = await UnitWork.Find(request.page, request.limit,
+ "CreateDate descending", myFlowExp).ToListAsync();
}
return result;
diff --git a/OpenAuth.App/FlowScheme/FlowSchemeApp.cs b/OpenAuth.App/FlowScheme/FlowSchemeApp.cs
index b2c873d6..7299a102 100644
--- a/OpenAuth.App/FlowScheme/FlowSchemeApp.cs
+++ b/OpenAuth.App/FlowScheme/FlowSchemeApp.cs
@@ -1,6 +1,7 @@
using System;
using System.Linq;
using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
@@ -59,10 +60,10 @@ namespace OpenAuth.App
objs = objs.Where(u => u.SchemeName.Contains(request.key) || u.Id.Contains(request.key));
}
- result.data = objs.OrderByDescending(u => u.CreateDate)
+ result.data = await objs.OrderByDescending(u => u.CreateDate)
.Skip((request.page - 1) * request.limit)
- .Take(request.limit).ToList();
- result.count = objs.Count();
+ .Take(request.limit).ToListAsync();
+ result.count = await objs.CountAsync();
return result;
}
diff --git a/OpenAuth.App/Form/FormApp.cs b/OpenAuth.App/Form/FormApp.cs
index 6679dafa..fc5c1065 100644
--- a/OpenAuth.App/Form/FormApp.cs
+++ b/OpenAuth.App/Form/FormApp.cs
@@ -4,6 +4,7 @@ using System.Threading.Tasks;
using Infrastructure;
using Infrastructure.Utilities;
using Microsoft.AspNetCore.Http;
+using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Options;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
@@ -17,7 +18,6 @@ namespace OpenAuth.App
{
public class FormApp : BaseStringApp