using IRaCIS.Core.Domain.Models;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using System;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore.ChangeTracking;
using System.Reflection;
using EntityFramework.Exceptions.SqlServer;
using IRaCIS.Core.Domain.Share;
using MassTransit;
using Microsoft.EntityFrameworkCore.Infrastructure;
using Microsoft.EntityFrameworkCore.Metadata;
using Microsoft.EntityFrameworkCore.ValueGeneration;
using UserTypeGroup = IRaCIS.Core.Domain.Models.UserTypeGroup;
using IRaCIS.Core.Infra.EFCore.Common;
using IRaCIS.Core.Infra.EFCore.Common.Dto;
using Microsoft.Identity.Client;
using EntityFramework.Exceptions.Common;
using System.Data;
using IRaCIS.Core.Infrastructure;
using System.Reflection.Metadata;
using System.Collections.Generic;
using System.ComponentModel;
using Microsoft.VisualBasic;
namespace IRaCIS.Core.Infra.EFCore
{
#region 连接池废弃
///
/// 报错,添加subject 报错,重复添加访视
///
//public class IRaCISDBScopedFactory : IDbContextFactory
//{
// private readonly IDbContextFactory _pooledFactory;
// private readonly IUserInfo _userInfo;
// public IRaCISDBScopedFactory(IDbContextFactory pooledFactory,IUserInfo userInfo)
// {
// _pooledFactory = pooledFactory;
// _userInfo = userInfo;
// }
// public IRaCISDBContext CreateDbContext()
// {
// var context = _pooledFactory.CreateDbContext();
// context._userInfo = _userInfo;
// return context;
// }
//}
#endregion
public class IRaCISDBContext : DbContext
{
public IRaCISDBContext(DbContextOptions options) : base(options)
{
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
#region pgsql codefirst 配置 暂时屏蔽
//if (base.Database.IsNpgsql())
//{
// modelBuilder.HasPostgresExtension("uuid-ossp");
// //保证pgsql 生成的时间默认为timestamp 而不是 timestamp with time zone
// foreach (var entityType in modelBuilder.Model.GetEntityTypes())
// {
// foreach (var property in entityType.GetProperties())
// {
// if (property.ClrType == typeof(DateTime) || property.ClrType == typeof(DateTime?))
// {
// property.SetColumnType("timestamp without time zone");
// }
// }
// }
//}
#endregion
//遍历实体模型手动配置
var typesToRegister = Assembly.GetExecutingAssembly().GetTypes().Where(q => q.GetInterface(typeof(IEntityTypeConfiguration<>).FullName) != null);
foreach (var type in typesToRegister)
{
dynamic configurationInstance = Activator.CreateInstance(type);
modelBuilder.ApplyConfiguration(configurationInstance);
}
base.OnModelCreating(modelBuilder);
foreach (var entityType in modelBuilder.Model.GetEntityTypes())
{
// 软删除配置
if (typeof(ISoftDelete).IsAssignableFrom(entityType.ClrType))
{
entityType.AddSoftDeleteQueryFilter();
}
if (typeof(Entity).IsAssignableFrom(entityType.ClrType))
{
modelBuilder.Entity(entityType.ClrType).Property(nameof(Entity.Id)).HasValueGenerator();
}
if (typeof(IEntitySeqId).IsAssignableFrom(entityType.ClrType))
{
modelBuilder.Entity(entityType.ClrType).Property(nameof(IEntitySeqId.SeqId)).HasValueGenerator();
}
}
}
#region 获取表名 和字段名 优化
///
/// 直接获取代码定义的模型,以及表上定义的Description 获取表信息 以及备注
///
///
public List GetContextTablesList()
{
var tableList = new List();
foreach (var entityType in this.Model.GetEntityTypes())
{
var clrType = entityType.ClrType;
var tableName = entityType.GetTableName();
var tableDescription = clrType.GetCustomAttribute()?.Description ?? string.Empty;
tableList.Add(new TableList
{
Name = tableName,
Remake = tableDescription,
});
}
return tableList;
}
///
/// 直接获取代码定义的某个表的属性,以及属性上定义的Description 获取备注
///
///
public List GetContextTableColumnList(string tableName)
{
var tableColumList = new List();
var entityType = this.Model.GetEntityTypes().FirstOrDefault(t => t.GetTableName().ToLower() == tableName.ToLower());
if (entityType == null)
{
throw new ArgumentException($"Table '{tableName}' not found.");
}
var clrType = entityType.ClrType;
foreach (var property in entityType.GetProperties())
{
var columnName = property.GetColumnName();
var columnDescription = clrType.GetProperty(property.Name)?.GetCustomAttribute()?.Description ?? string.Empty;
tableColumList.Add(new TableList
{
Name = columnName,
Remake = columnDescription,
});
}
return tableColumList.OrderBy(t => t.Name).ToList();
}
#endregion
#region Doctor
public virtual DbSet Dictionary { get; set; }
public virtual DbSet Doctor { get; set; }
public virtual DbSet DoctorCriterionFile { get; set; }
public virtual DbSet DoctorDictionary { get; set; }
public virtual DbSet Postgraduate { get; set; }
public virtual DbSet Education { get; set; }
public virtual DbSet ResearchPublications { get; set; }
public virtual DbSet TrialExperience { get; set; }
public virtual DbSet UserDoctor { get; set; }
public virtual DbSet Vacation { get; set; }
public virtual DbSet Attachment { get; set; }
public virtual DbSet TrialExperienceCriteria { get; set; }
#endregion
#region Enroll
public virtual DbSet DoctorWorkload { get; set; }
public virtual DbSet Enroll { get; set; }
public virtual DbSet EnrollReadingCategory { get; set; }
public virtual DbSet EnrollDetails { get; set; }
#endregion
#region Reading
public virtual DbSet TrialCriterionDictionaryCode { get; set; }
public virtual DbSet ReadingCustomTag { get; set; }
public virtual DbSet SystemCriterionDictionaryCode { get; set; }
public virtual DbSet ReadingTaskRelation { get; set; }
public virtual DbSet OrganInfo { get; set; }
public virtual DbSet ReadingSystemCriterionDictionary { get; set; }
public virtual DbSet ReadingTableAnswerRowInfo { get; set; }
public virtual DbSet OrganTrialInfo { get; set; }
public virtual DbSet ReadingTableQuestionSystem { get; set; }
public virtual DbSet ReadingPeriodSet { get; set; }
public virtual DbSet ReadingTaskQuestionAnswer { get; set; }
public virtual DbSet ReadingPeriodPlan { get; set; }
public virtual DbSet ReadingClinicalData { get; set; }
public virtual DbSet ReadingOncologyTaskInfo { get; set; }
public virtual DbSet ReadingGlobalTaskInfo { get; set; }
public virtual DbSet ReadingQuestionCriterionSystem { get; set; }
public virtual DbSet ReadingQuestionCriterionTrial { get; set; }
public virtual DbSet ReadingQuestionSystem { get; set; }
public virtual DbSet ReadingQuestionTrial { get; set; }
public virtual DbSet ReadingClinicalDataPDF { get; set; }
public virtual DbSet ReadingConsistentClinicalData { get; set; }
public virtual DbSet ReadingConsistentClinicalDataPDF { get; set; }
public virtual DbSet ReadingJudgeInfo { get; set; }
public virtual DbSet ReadModule { get; set; }
public virtual DbSet ReadModuleView { get; set; }
public virtual DbSet ClinicalDataTrialSet { get; set; }
public virtual DbSet ClinicalDataSystemSet { get; set; }
public virtual DbSet ReadingMedicineSystemQuestion { get; set; }
public virtual DbSet ReadingMedicineTrialQuestion { get; set; }
public virtual DbSet ReadingMedicineQuestionAnswer { get; set; }
public virtual DbSet ReadingMedicalReviewDialog { get; set; }
public virtual DbSet CriterionNidusSystem { get; set; }
public virtual DbSet CriterionNidusTrial { get; set; }
public virtual DbSet ReadingTrialCriterionDictionary { get; set; }
public virtual DbSet ReadingTableQuestionTrial { get; set; }
public virtual DbSet TumorAssessment_RECIST1Point1BM { get; set; }
public virtual DbSet TumorAssessment_RECIST1Point1 { get; set; }
public virtual DbSet TumorAssessment_IRECIST1Point1 { get; set; }
public virtual DbSet TrialClinicalDataSetCriterion { get; set; }
public virtual DbSet TrialCriterionAdditionalAssessmentType { get; set; }
public virtual DbSet SubjectCriteriaEvaluation { get; set; }
public virtual DbSet SubjectAdditionalEvaluationResult { get; set; }
public virtual DbSet SubjectCriteriaEvaluationVisitFilter { get; set; }
public virtual DbSet SubjectCriteriaEvaluationVisitStudyFilter { get; set; }
public virtual DbSet ReadingTaskQuestionMark { get; set; }
//public virtual DbSet TrialClinicalDataCriterion { get; set; }
//public virtual DbSet SystemClinicalDataCriterion { get; set; }
#endregion
#region Subject and Visit and study
public virtual DbSet StudyMonitor { get; set; }
public virtual DbSet Subject { get; set; }
public virtual DbSet VisitPlans { get; set; }
public virtual DbSet VisitPlanInfluenceStudy { get; set; }
public virtual DbSet VisitPlanInfluenceStat { get; set; }
public virtual DbSet NoneDicomStudyFile { get; set; }
public virtual DbSet NoneDicomStudy { get; set; }
public virtual DbSet PreviousPDF { get; set; }
public virtual DbSet PreviousSurgery { get; set; }
public virtual DbSet PreviousOther { get; set; }
public virtual DbSet PreviousHistory { get; set; }
public virtual DbSet DicomStudys { get; set; }
public virtual DbSet DicomSeries { get; set; }
public virtual DbSet DicomInstances { get; set; }
public virtual DbSet ImageShare { get; set; }
#endregion
#region Management
public virtual DbSet VerificationCodes { get; set; }
public virtual DbSet