IlyaSobolev/DocSpace-buildtools
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CompileAsyncQuery: linkdao

Browse Source
This commit is contained in:
Anton Suhorukov 2023-05-22 14:43:39 +03:00
parent 387762a2e8
commit d1e2bf0dfa
1 changed files with 32 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
products/ASC.Files/Core/Core/Dao/TeamlabDao/LinkDao.cs
View File

@ -78,10 +78,7 @@ internal class LinkDao : AbstractDao, ILinkDao
linkedId = (await MappingIDAsync(linkedId)).ToString();
var sourceId = await filesDbContext.FilesLink
.Where(r => r.TenantId == TenantID && r.LinkedId == linkedId && r.LinkedFor == _authContext.CurrentAccount.ID)
.Select(r => r.SourceId)
.SingleOrDefaultAsync();
var sourceId = await LinkDaoQueries.GetSourceIdAsync(filesDbContext, TenantID, linkedId, _authContext.CurrentAccount.ID);
return (await MappingIDAsync(sourceId))?.ToString();
}
@ -92,10 +89,7 @@ internal class LinkDao : AbstractDao, ILinkDao
sourceId = (await MappingIDAsync(sourceId)).ToString();
var linkedId = await filesDbContext.FilesLink
.Where(r => r.TenantId == TenantID && r.SourceId == sourceId && r.LinkedFor == _authContext.CurrentAccount.ID)
.Select(r => r.LinkedId)
.SingleOrDefaultAsync();
var linkedId = await LinkDaoQueries.GetLinkedIdAsync(filesDbContext, TenantID, sourceId, _authContext.CurrentAccount.ID);
return (await MappingIDAsync(linkedId))?.ToString();
}
@ -106,9 +100,7 @@ internal class LinkDao : AbstractDao, ILinkDao
sourceId = (await MappingIDAsync(sourceId)).ToString();
var link = await filesDbContext.FilesLink
.Where(r => r.TenantId == TenantID && r.SourceId == sourceId && r.LinkedFor == _authContext.CurrentAccount.ID)
.SingleOrDefaultAsync();
var link = await LinkDaoQueries.GetFileLinkAsync(filesDbContext, TenantID, sourceId, _authContext.CurrentAccount.ID);
filesDbContext.FilesLink.Remove(link);
@ -122,5 +114,34 @@ internal class LinkDao : AbstractDao, ILinkDao
fileId = (await MappingIDAsync(fileId)).ToString();
await filesDbContext.FilesLink.Where(r => r.TenantId == TenantID && (r.SourceId == fileId || r.LinkedId == fileId)).ExecuteDeleteAsync();
await LinkDaoQueries.DeleteFileLinks(filesDbContext, TenantID, fileId);
}
}
file static class LinkDaoQueries
{
public static readonly Func<FilesDbContext, int, string, Guid, Task<string>> GetSourceIdAsync = Microsoft.EntityFrameworkCore.EF.CompileAsyncQuery(
(FilesDbContext ctx, int tenantId, string linkedId, Guid id) =>
ctx.FilesLink
.Where(r => r.TenantId == tenantId && r.LinkedId == linkedId && r.LinkedFor == id)
.Select(r => r.SourceId)
.SingleOrDefault());
public static readonly Func<FilesDbContext, int, string, Guid, Task<string>> GetLinkedIdAsync = Microsoft.EntityFrameworkCore.EF.CompileAsyncQuery(
(FilesDbContext ctx, int tenantId, string sourceId, Guid id) =>
ctx.FilesLink
.Where(r => r.TenantId == tenantId && r.SourceId == sourceId && r.LinkedFor == id)
.Select(r => r.LinkedId)
.SingleOrDefault());
public static readonly Func<FilesDbContext, int, string, Guid, Task<DbFilesLink>> GetFileLinkAsync = Microsoft.EntityFrameworkCore.EF.CompileAsyncQuery(
(FilesDbContext ctx, int tenantId, string sourceId, Guid id) =>
ctx.FilesLink
.Where(r => r.TenantId == tenantId && r.SourceId == sourceId && r.LinkedFor == id)
.SingleOrDefault());
public static readonly Func<FilesDbContext, int, string, Task<int>> DeleteFileLinks = Microsoft.EntityFrameworkCore.EF.CompileAsyncQuery(
(FilesDbContext ctx, int tenantId, string fileId) =>
ctx.FilesLink
.Where(r => r.TenantId == tenantId && (r.SourceId == fileId || r.LinkedId == fileId)).ExecuteDelete());
}