HRDataContext.cs 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  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. //------------------------Logs------------------------
  44. public DbSet<UserLog> UserLogs { get; set; }
  45. public DbSet<AuthLog> AuthLogs { get; set; }
  46. public DbSet<FileLog> FileLogs { get; set; }
  47. public DbSet<RoleLog> RoleLogs { get; set; }
  48. public DbSet<SettingLog> SettingLogs { get; set; }
  49. public DbSet<UserTaskLog> UserTaskLogs { get; set; }
  50. public DbSet<TeamLog> TeamLogs { get; set; }
  51. public DbSet<MeetingLog> MeetingLogs { get; set; }
  52. public DbSet<AttendanceLog> AttendanceLogs { get; set; }
  53. //----------------------------------------
  54. protected override void OnModelCreating(ModelBuilder builder)
  55. {
  56. base.OnModelCreating(builder);
  57. SetGlobalFilters(builder);
  58. builder.ApplyConfigurationsFromAssembly(typeof(HRDataContext).Assembly);
  59. }
  60. private void SetGlobalFilters(ModelBuilder builder)
  61. {
  62. builder.SetQueryFilterOnAllEntities<ISoftDelete>(p => !p.IsDeleted);
  63. }
  64. #region SaveChanges
  65. public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
  66. {
  67. BeforeSaveProccess();
  68. return base.SaveChangesAsync(cancellationToken);
  69. }
  70. public override int SaveChanges()
  71. {
  72. BeforeSaveProccess();
  73. return base.SaveChanges();
  74. }
  75. public override int SaveChanges(bool acceptAllChangesOnSuccess)
  76. {
  77. BeforeSaveProccess();
  78. return base.SaveChanges(acceptAllChangesOnSuccess);
  79. }
  80. private void BeforeSaveProccess()
  81. {
  82. var changes = from e in this.ChangeTracker.Entries()
  83. where e.State != EntityState.Unchanged
  84. select e;
  85. foreach (var change in changes)
  86. {
  87. if (change.State == EntityState.Added)
  88. {
  89. if (change.Entity is IAudit)
  90. {
  91. ((IAudit)change.Entity).CreateUser = _globalInfo.UserId;
  92. ((IAudit)change.Entity).CreateDate = DateTime.Now;
  93. }
  94. }
  95. else if (change.State == EntityState.Modified)
  96. {
  97. if (change.Entity is IAudit
  98. && ((change.Entity is IFullAudit && !((IFullAudit)change.Entity).IsDeleted) || change.Entity is not IFullAudit))
  99. {
  100. ((IAudit)change.Entity).UpdateUser = _globalInfo.UserId;
  101. ((IAudit)change.Entity).UpdateDate = DateTime.Now;
  102. }
  103. if (change.Entity is IFullAudit && ((IFullAudit)change.Entity).IsDeleted)
  104. {
  105. ((IFullAudit)change.Entity).DeleteUserId = _globalInfo.UserId;
  106. }
  107. }
  108. else if (change.State == EntityState.Deleted)
  109. {
  110. }
  111. }
  112. }
  113. #endregion
  114. }
  115. }