WCSDB.cs 3.8 KB

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