WCSDB.cs 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. using DBHelper;
  2. using Microsoft.EntityFrameworkCore;
  3. using Microsoft.Extensions.Configuration;
  4. using System.Collections.Generic;
  5. using System.ComponentModel.DataAnnotations;
  6. using System.Linq;
  7. using WCS.Entity;
  8. using WCS.Entity.Protocol;
  9. using WCS.Entity.Protocol.BCR;
  10. using WCS.Entity.Protocol.Station;
  11. namespace WCS.Service
  12. {
  13. public class WCSDB : DbContext
  14. {
  15. protected override void OnModelCreating(ModelBuilder modelBuilder)
  16. {
  17. var fks = modelBuilder.Model.GetEntityTypes().SelectMany(v => v.GetForeignKeys()).Where(v => v.DeleteBehavior == DeleteBehavior.Cascade).ToArray();
  18. foreach (var fk in fks)
  19. {
  20. fk.DeleteBehavior = DeleteBehavior.Restrict;
  21. }
  22. base.OnModelCreating(modelBuilder);
  23. }
  24. protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
  25. {
  26. //var loggerFactory = new LoggerFactory();
  27. //loggerFactory.AddProvider(new EFLoggerProvider());
  28. optionsBuilder.UseSqlServer(AppSettings.Config.GetConnectionString("WCSDB"))/*.UseLoggerFactory(loggerFactory)*/.EnableSensitiveDataLogging();
  29. //optionsBuilder.UseLoggerFactory(LoggerFactory.Create(builder =>
  30. //{
  31. // builder.AddFilter((category, level) => category == DbLoggerCategory.Database.Command.Name && level == LogLevel.Information).AddConsole();
  32. //}));
  33. }
  34. public override int SaveChanges()
  35. {
  36. var entities = from e in ChangeTracker.Entries()
  37. where e.State is EntityState.Added or EntityState.Modified
  38. select e.Entity;
  39. var list = new List<ValidationResult>();
  40. foreach (var entity in entities)
  41. {
  42. var validationContext = new ValidationContext(entity);
  43. try
  44. {
  45. Validator.ValidateObject(entity, validationContext);
  46. }
  47. catch (ValidationException ex)
  48. {
  49. list.Add(ex.ValidationResult);
  50. }
  51. }
  52. if (list.Count > 0)
  53. throw new EntityValidationException { EntityValidationErrors = list };
  54. return base.SaveChanges();
  55. }
  56. public DbSet<WCS_PLC> WCS_PLC { get; set; }
  57. public DbSet<WCS_DATABLOCK> WCS_DATABLOCK { get; set; }
  58. public DbSet<WCS_DEVICE> WCS_DEVICE { get; set; }
  59. public DbSet<WCS_DEVICEPROTOCOL> WCS_DEVICEPROTOCOL { get; set; }
  60. public DbSet<WCS_EXCEPTION> WCS_EXCEPTION { get; set; }
  61. public DbSet<WCS_Station520> WCS_STATION520 { get; set; }
  62. public DbSet<WCS_Station521> WCS_STATION521 { get; set; }
  63. public DbSet<WCS_Station523> WCS_STATION523 { get; set; }
  64. public DbSet<WCS_SystemConfig> WCS_SystemConfig { get; set; }
  65. public DbSet<WCS_StatusLog> WCS_StatusLog { get; set; }
  66. public DbSet<WCS_RGV520> WCS_RGV520 { get; set; }
  67. public DbSet<WCS_RGV521> WCS_RGV521 { get; set; }
  68. public DbSet<WCS_RGV523> WCS_RGV523 { get; set; }
  69. public DbSet<WCS_GROUPMEMBER> WCS_GROUPMEMBER { get; set; }
  70. public DbSet<WCS_SRM520> WCS_SRM520 { get; set; }
  71. public DbSet<WCS_SRM521> WCS_SRM521 { get; set; }
  72. public DbSet<WCS_SRM537> WCS_SRM537 { get; set; }
  73. public DbSet<WCS_BCR80> WCS_BCR80 { get; set; }
  74. public DbSet<WCS_CMD> WCS_CMD { get; set; }
  75. public DbSet<WCS_TASK> WCS_TASK { get; set; }
  76. public DbSet<WCS_ROUTE> WCS_ROUTE { get; set; }
  77. public DbSet<WCS_PATH> WCS_PATH { get; set; }
  78. public DbSet<WCS_AGVTask> WCS_AGVTask { get; set; }
  79. public DbSet<WCS_PATHPOINT> WCS_PATHPOINT { get; set; }
  80. public DbSet<WCS_Users> WCS_Users { get; set; }
  81. public DbSet<WCS_MAPPINGENTRY> WCS_MAPPINGENTRY { get; set; }
  82. public DbSet<WCS_TASK_OLD> WCS_TASK_OLD { get; set; }
  83. }
  84. }