WCSDB.cs 4.0 KB

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