HRDataContext.cs 5.3 KB

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