RepositoryBase.cs 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. 
  2. using System;
  3. using System.Threading.Tasks;
  4. using System.Linq.Expressions;
  5. using FreeSql;
  6. using Admin.Core.Common.Auth;
  7. namespace Admin.Core.Repository
  8. {
  9. public abstract class RepositoryBase<TEntity, TKey> : BaseRepository<TEntity, TKey>, IRepositoryBase<TEntity, TKey> where TEntity : class,new()
  10. {
  11. private readonly IUser _user;
  12. protected RepositoryBase(IFreeSql freeSql, IUser user) : base(freeSql, null, null)
  13. {
  14. _user = user;
  15. }
  16. public virtual Task<TDto> GetAsync<TDto>(TKey id)
  17. {
  18. return Select.WhereDynamic(id).ToOneAsync<TDto>();
  19. }
  20. public virtual Task<TEntity> GetAsync(Expression<Func<TEntity, bool>> exp)
  21. {
  22. return Select.Where(exp).ToOneAsync();
  23. }
  24. public virtual Task<TDto> GetAsync<TDto>(Expression<Func<TEntity, bool>> exp)
  25. {
  26. return Select.Where(exp).ToOneAsync<TDto>();
  27. }
  28. public async Task<bool> SoftDeleteAsync(TKey id)
  29. {
  30. await UpdateDiy
  31. .SetDto(new {
  32. IsDeleted = true,
  33. ModifiedUserId = _user.Id,
  34. ModifiedUserName = _user.Name
  35. })
  36. .WhereDynamic(id)
  37. .ExecuteAffrowsAsync();
  38. return true;
  39. }
  40. public async Task<bool> SoftDeleteAsync(TKey[] ids)
  41. {
  42. await UpdateDiy
  43. .SetDto(new {
  44. IsDeleted = true,
  45. ModifiedUserId = _user.Id,
  46. ModifiedUserName = _user.Name
  47. })
  48. .WhereDynamic(ids)
  49. .ExecuteAffrowsAsync();
  50. return true;
  51. }
  52. }
  53. public abstract class RepositoryBase<TEntity> : RepositoryBase<TEntity, long> where TEntity : class, new()
  54. {
  55. protected RepositoryBase(MyUnitOfWorkManager muowm, IUser user) : base(muowm.Orm, user)
  56. {
  57. muowm.Binding(this);
  58. }
  59. }
  60. }