HRDataContext.cs 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
  2. using Microsoft.EntityFrameworkCore;
  3. using MTWorkHR.Core.Entities;
  4. using MTWorkHR.Core.Entities.Base;
  5. using MTWorkHR.Core.Global;
  6. using MTWorkHR.Infrastructure.Entities;
  7. using MTWorkHR.Infrastructure.Data;
  8. using System.Reflection.Emit;
  9. namespace MTWorkHR.Infrastructure.DBContext
  10. {
  11. public class HRDataContext : IdentityDbContext<ApplicationUser, ApplicationRole, string>
  12. {
  13. private readonly GlobalInfo _globalInfo;
  14. public HRDataContext(DbContextOptions<HRDataContext> options, GlobalInfo globalInfo) : base(options) {
  15. this._globalInfo = globalInfo;
  16. }
  17. public DbSet<AttachmentType> AttachmentTypes { get; set; }
  18. public DbSet<UserAttachment> UserAttachments { get; set; }
  19. public DbSet<Permission> Permissions { get; set; }
  20. public DbSet<RolePermission> RolePermissions { get; set; }
  21. //-------------------------------------
  22. public DbSet<Company> Companies { get; set; }
  23. public DbSet<Project> Projects { get; set; }
  24. // public DbSet<AttachmentType> AttachmentTypes { get; set; }
  25. public DbSet<UserTaskStatus> UserTaskStatuses { get; set; }
  26. public DbSet<UserTask> UserTasks { get; set; }
  27. public DbSet<UserTaskAttachment> UserTaskAttachments { get; set; }
  28. public DbSet<UserTaskHistory> UserTaskHistories { get; set; }
  29. public DbSet<Team> Teams { get; set; }
  30. public DbSet<Meeting> Meetings { get; set; }
  31. public DbSet<Attendance> Attendances { get; set; }
  32. //------------------------Logs------------------------
  33. public DbSet<UserLog> UserLogs { get; set; }
  34. public DbSet<AuthLog> AuthLogs { get; set; }
  35. public DbSet<FileLog> FileLogs { get; set; }
  36. public DbSet<RoleLog> RoleLogs { get; set; }
  37. public DbSet<SettingLog> SettingLogs { get; set; }
  38. public DbSet<UserTaskLog> UserTaskLogs { get; set; }
  39. public DbSet<TeamLog> TeamLogs { get; set; }
  40. public DbSet<MeetingLog> MeetingLogs { get; set; }
  41. public DbSet<AttendanceLog> AttendanceLogs { get; set; }
  42. //----------------------------------------
  43. protected override void OnModelCreating(ModelBuilder builder)
  44. {
  45. base.OnModelCreating(builder);
  46. SetGlobalFilters(builder);
  47. builder.ApplyConfigurationsFromAssembly(typeof(HRDataContext).Assembly);
  48. }
  49. private void SetGlobalFilters(ModelBuilder builder)
  50. {
  51. builder.SetQueryFilterOnAllEntities<ISoftDelete>(p => !p.IsDeleted);
  52. }
  53. #region SaveChanges
  54. public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
  55. {
  56. BeforeSaveProccess();
  57. return base.SaveChangesAsync(cancellationToken);
  58. }
  59. public override int SaveChanges()
  60. {
  61. BeforeSaveProccess();
  62. return base.SaveChanges();
  63. }
  64. public override int SaveChanges(bool acceptAllChangesOnSuccess)
  65. {
  66. BeforeSaveProccess();
  67. return base.SaveChanges(acceptAllChangesOnSuccess);
  68. }
  69. private void BeforeSaveProccess()
  70. {
  71. var changes = from e in this.ChangeTracker.Entries()
  72. where e.State != EntityState.Unchanged
  73. select e;
  74. foreach (var change in changes)
  75. {
  76. if (change.State == EntityState.Added)
  77. {
  78. if (change.Entity is IAudit)
  79. {
  80. ((IAudit)change.Entity).CreateUser = _globalInfo.UserId;
  81. ((IAudit)change.Entity).CreateDate = DateTime.Now;
  82. }
  83. }
  84. else if (change.State == EntityState.Modified)
  85. {
  86. if (change.Entity is IAudit
  87. && ((change.Entity is IFullAudit && !((IFullAudit)change.Entity).IsDeleted) || change.Entity is not IFullAudit))
  88. {
  89. ((IAudit)change.Entity).UpdateUser = _globalInfo.UserId;
  90. ((IAudit)change.Entity).UpdateDate = DateTime.Now;
  91. }
  92. if (change.Entity is IFullAudit && ((IFullAudit)change.Entity).IsDeleted)
  93. {
  94. ((IFullAudit)change.Entity).DeleteUserId = _globalInfo.UserId;
  95. }
  96. }
  97. else if (change.State == EntityState.Deleted)
  98. {
  99. }
  100. }
  101. }
  102. #endregion
  103. }
  104. }