on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

доработка методов репозитория

Browse Source
This commit is contained in:
eugeniy_ivanov 2023-02-13 23:11:39 +05:00
parent 95790af1f6
commit 6bf992f1f6
2 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
AsbCloudDb/Model/IAsbCloudDbContext.cs
View File

@ -71,7 +71,6 @@ namespace AsbCloudDb.Model
int SaveChanges(bool acceptAllChangesOnSuccess); int SaveChanges(bool acceptAllChangesOnSuccess);
Task<int> SaveChangesAsync(CancellationToken cancellationToken); Task<int> SaveChangesAsync(CancellationToken cancellationToken);
DbSet<TEntity> Set<TEntity>(string name) where TEntity : class; DbSet<TEntity> Set<TEntity>(string name) where TEntity : class;
DbSet<TEntity> Set<TEntity>() where TEntity : class; DbSet<TEntity> Set<TEntity>() where TEntity : class;
EntityEntry<TEntity> Entry<TEntity>([NotNull] TEntity entity) where TEntity : class;
} }
} }

27
AsbCloudInfrastructure/Repository/UserRepository.cs
View File

@ -121,8 +121,7 @@ namespace AsbCloudInfrastructure.Repository
entity.Patronymic = user.Patronymic; entity.Patronymic = user.Patronymic;
entity.Position = user.Position; entity.Position = user.Position;
entity.IdCompany = user.IdCompany; entity.IdCompany = user.IdCompany;
entity.IdState = user.IdState; entity.IdState = user.IdState;
entity.RelationUsersUserRoles = user.RelationUsersUserRoles;
await dbContext.SaveChangesAsync(token); await dbContext.SaveChangesAsync(token);
} }
DropCacheUsers(); DropCacheUsers();
@ -199,25 +198,19 @@ namespace AsbCloudInfrastructure.Repository
var entities = query.ToArray(); var entities = query.ToArray();
return entities; return entities;
}); });
return cache; return cache!;
} }
private void DropCacheRelationUserUserRoleCacheTag() private void DropCacheRelationUserUserRoleCacheTag()
{ {
memoryCache.Remove(relationUserUserRoleCacheTag); memoryCache.Remove(relationUserUserRoleCacheTag);
} }
private async Task UpdateRolesCacheForUserAsync(int idUser, IEnumerable<UserRoleDto> newRoles, CancellationToken token) private async Task UpdateRolesCacheForUserAsync(int idUser, IEnumerable<UserRoleDto> roleDtos, CancellationToken token)
{ {
var relations = dbContext.RelationUserUserRoles.Where(r => r.IdUser == idUser); var relations = dbContext.RelationUserUserRoles.Where(r => r.IdUser == idUser);
dbContext.RelationUserUserRoles.RemoveRange(relations); dbContext.RelationUserUserRoles.RemoveRange(relations);
var entityRoles = roleDtos.Select(role => Convert(role));
if (newRoles?.Any() is true) dbContext.RelationUserUserRoles.AddRange(entityRoles);
await dbContext.RelationUserUserRoles.AddRangeAsync(newRoles.Select(role => new RelationUserUserRole
{
IdUser = idUser,
IdUserRole = role.Id
}), token).ConfigureAwait(false);
await dbContext.SaveChangesAsync(token); await dbContext.SaveChangesAsync(token);
DropCacheRelationUserUserRoleCacheTag(); DropCacheRelationUserUserRoleCacheTag();
} }
@ -237,7 +230,7 @@ namespace AsbCloudInfrastructure.Repository
var entities = query.ToArray(); var entities = query.ToArray();
return entities; return entities;
}); });
return cache; return cache!;
} }
private Task<IEnumerable<User>> GetCacheUserAsync(CancellationToken token) private Task<IEnumerable<User>> GetCacheUserAsync(CancellationToken token)
@ -252,7 +245,7 @@ namespace AsbCloudInfrastructure.Repository
var entities = await query.ToArrayAsync(token); var entities = await query.ToArrayAsync(token);
return entities.AsEnumerable(); return entities.AsEnumerable();
}); });
return cache; return cache!;
} }
protected User Convert(UserExtendedDto dto) protected User Convert(UserExtendedDto dto)
@ -263,7 +256,11 @@ namespace AsbCloudInfrastructure.Repository
return entity; return entity;
} }
protected RelationUserUserRole Convert(UserRoleDto dto)
{
var entity = dto.Adapt<RelationUserUserRole>();
return entity;
}
protected virtual UserExtendedDto Convert(User entity) protected virtual UserExtendedDto Convert(User entity)
{ {