mirror of
https://github.com/nsnail/NetAdmin.git
synced 2025-04-22 22:22:51 +08:00
style: 💄 code format (#202)
[skip ci] Co-authored-by: tk <fiyne1a@dingtalk.com>
This commit is contained in:
parent
2f300285aa
commit
587b22014d
@ -51,10 +51,10 @@ public abstract class RepositoryService<TEntity, TPrimary, TLogger>(BasicReposit
|
|||||||
where TQuery : DataAbstraction, new()
|
where TQuery : DataAbstraction, new()
|
||||||
{
|
{
|
||||||
var select = selector(query)
|
var select = selector(query)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.Take(Numbers.MAX_LIMIT_EXPORT);
|
.Take(Numbers.MAX_LIMIT_EXPORT);
|
||||||
|
|
||||||
object list = listExp == null ? await select.ToListAsync().ConfigureAwait(false) : await select.ToListAsync(listExp).ConfigureAwait(false);
|
object list = listExp == null ? await select.ToListAsync().ConfigureAwait(false) : await select.ToListAsync(listExp).ConfigureAwait(false);
|
||||||
|
|
||||||
|
@ -21,10 +21,10 @@ public sealed class ApiService(
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -46,10 +46,10 @@ public sealed class ApiService(
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class ConfigService(BasicRepository<Sys_Config, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -64,10 +64,10 @@ public sealed class ConfigService(BasicRepository<Sys_Config, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class DeptService(BasicRepository<Sys_Dept, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -80,10 +80,10 @@ public sealed class DeptService(BasicRepository<Sys_Dept, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class DicCatalogService(BasicRepository<Sys_DicCatalog, long> rpo)
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -77,10 +77,10 @@ public sealed class DicCatalogService(BasicRepository<Sys_DicCatalog, long> rpo)
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class DicContentService(BasicRepository<Sys_DicContent, long> rpo)
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -86,10 +86,10 @@ public sealed class DicContentService(BasicRepository<Sys_DicContent, long> rpo)
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class JobRecordService(BasicRepository<Sys_JobRecord, long> rpo) /
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class JobRecordService(BasicRepository<Sys_JobRecord, long> rpo) /
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -29,10 +29,10 @@ public sealed class JobService(BasicRepository<Sys_Job, long> rpo, IJobRecordSer
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -128,10 +128,10 @@ public sealed class JobService(BasicRepository<Sys_Job, long> rpo, IJobRecordSer
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class LoginLogService(BasicRepository<Sys_LoginLog, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class LoginLogService(BasicRepository<Sys_LoginLog, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class MenuService(BasicRepository<Sys_Menu, long> rpo, IUserServic
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -64,10 +64,10 @@ public sealed class MenuService(BasicRepository<Sys_Menu, long> rpo, IUserServic
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class RequestLogDetailService(BasicRepository<Sys_RequestLogDetail
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class RequestLogDetailService(BasicRepository<Sys_RequestLogDetail
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -27,10 +27,10 @@ public sealed class RequestLogService(BasicRepository<Sys_RequestLog, long> rpo,
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -59,10 +59,10 @@ public sealed class RequestLogService(BasicRepository<Sys_RequestLog, long> rpo,
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class RoleService(BasicRepository<Sys_Role, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -79,10 +79,10 @@ public sealed class RoleService(BasicRepository<Sys_Role, long> rpo) //
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class SiteMsgDeptService(BasicRepository<Sys_SiteMsgDept, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class SiteMsgDeptService(BasicRepository<Sys_SiteMsgDept, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class SiteMsgFlagService(BasicRepository<Sys_SiteMsgFlag, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class SiteMsgFlagService(BasicRepository<Sys_SiteMsgFlag, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class SiteMsgRoleService(BasicRepository<Sys_SiteMsgRole, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class SiteMsgRoleService(BasicRepository<Sys_SiteMsgRole, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -28,10 +28,10 @@ public sealed class SiteMsgService(BasicRepository<Sys_SiteMsg, long> rpo, Conte
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -93,10 +93,10 @@ public sealed class SiteMsgService(BasicRepository<Sys_SiteMsg, long> rpo, Conte
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -25,10 +25,10 @@ public sealed class SiteMsgUserService(BasicRepository<Sys_SiteMsgUser, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -51,10 +51,10 @@ public sealed class SiteMsgUserService(BasicRepository<Sys_SiteMsgUser, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -45,10 +45,10 @@ public sealed class UserProfileService(BasicRepository<Sys_UserProfile, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -79,10 +79,10 @@ public sealed class UserProfileService(BasicRepository<Sys_UserProfile, long> rp
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
@ -68,10 +68,10 @@ public sealed class UserService(
|
|||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
#pragma warning disable VSTHRD103
|
#pragma warning disable VSTHRD103
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
#pragma warning restore VSTHRD103
|
#pragma warning restore VSTHRD103
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -28,10 +28,10 @@ public sealed class VerifyCodeService(BasicRepository<Sys_VerifyCode, long> rpo,
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.CountAsync();
|
.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -60,10 +60,10 @@ public sealed class VerifyCodeService(BasicRepository<Sys_VerifyCode, long> rpo,
|
|||||||
{
|
{
|
||||||
req.ThrowIfInvalid();
|
req.ThrowIfInvalid();
|
||||||
return QueryInternal(req)
|
return QueryInternal(req)
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.AnyAsync();
|
.AnyAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
@ -178,10 +178,10 @@ public sealed class VerifyCodeService(BasicRepository<Sys_VerifyCode, long> rpo,
|
|||||||
, Value = destDevice
|
, Value = destDevice
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
#if DBTYPE_SQLSERVER
|
#if DBTYPE_SQLSERVER
|
||||||
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
.WithLock(SqlServerLock.NoLock | SqlServerLock.NoWait)
|
||||||
#endif
|
#endif
|
||||||
.ToOneAsync();
|
.ToOneAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
private ISelect<Sys_VerifyCode> QueryInternal(QueryReq<QueryVerifyCodeReq> req)
|
private ISelect<Sys_VerifyCode> QueryInternal(QueryReq<QueryVerifyCodeReq> req)
|
||||||
|
@ -15,7 +15,7 @@ public sealed record RequestLogEvent : DataAbstraction, IEventSourceGeneric<Crea
|
|||||||
, CancellationToken cancellationToken = default)
|
, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
Data = data;
|
Data = data;
|
||||||
IsConsumeOnce = isConsumeOnce;
|
IsConsumeOnce = isConsumeOnce;
|
||||||
Payload = payload;
|
Payload = payload;
|
||||||
CreatedTime = createdTime;
|
CreatedTime = createdTime;
|
||||||
CancellationToken = cancellationToken;
|
CancellationToken = cancellationToken;
|
||||||
|
@ -17,7 +17,7 @@ public sealed record UserCreatedEvent : DataAbstraction, IEventSourceGeneric<Use
|
|||||||
Data = data;
|
Data = data;
|
||||||
CancellationToken = cancellationToken;
|
CancellationToken = cancellationToken;
|
||||||
CreatedTime = createdTime;
|
CreatedTime = createdTime;
|
||||||
IsConsumeOnce = isConsumeOnce;
|
IsConsumeOnce = isConsumeOnce;
|
||||||
Payload = payload;
|
Payload = payload;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -17,7 +17,7 @@ public sealed record UserUpdatedEvent : DataAbstraction, IEventSourceGeneric<Use
|
|||||||
Data = data;
|
Data = data;
|
||||||
CancellationToken = cancellationToken;
|
CancellationToken = cancellationToken;
|
||||||
CreatedTime = createdTime;
|
CreatedTime = createdTime;
|
||||||
IsConsumeOnce = isConsumeOnce;
|
IsConsumeOnce = isConsumeOnce;
|
||||||
Payload = payload;
|
Payload = payload;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -17,7 +17,7 @@ public sealed record VerifyCodeCreatedEvent : DataAbstraction, IEventSourceGener
|
|||||||
Data = data;
|
Data = data;
|
||||||
CancellationToken = cancellationToken;
|
CancellationToken = cancellationToken;
|
||||||
CreatedTime = createdTime;
|
CreatedTime = createdTime;
|
||||||
IsConsumeOnce = isConsumeOnce;
|
IsConsumeOnce = isConsumeOnce;
|
||||||
Payload = payload;
|
Payload = payload;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user