XCKJ/irc-netcore-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加

Browse Source
This commit is contained in:
he
2023-02-08 18:11:04 +08:00
parent c930df4153
commit f45cb3db86
2 changed files with 58 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
IRaCIS.Core.Application/Triggers/AddSubjectTrigger.cs
+34 -2
View File
@@ -11,14 +11,20 @@ namespace IRaCIS.Core.Application.Triggers
public class AddSubjectTrigger : IBeforeSaveTrigger<Subject>
{
private readonly IRepository<SubjectVisit> _subjectVisitRepository;
private readonly IRepository<ClinicalDataTrialSet> _clinicalDataTrialSetRepository;
private readonly IRepository<ReadingClinicalData> _readingClinicalDataRepository;
private readonly IRepository<VisitStage> _visitStageRepository;
private readonly IRepository<Trial> _trialRepository;
private readonly IMapper _mapper;
public AddSubjectTrigger(IRepository<SubjectVisit> subjectVisitRepository, IMapper mapper, IRepository<VisitStage> visitStageRepository, IRepository<Trial> trialRepository)
public AddSubjectTrigger(IRepository<SubjectVisit> subjectVisitRepository,
IRepository<ClinicalDataTrialSet> clinicalDataTrialSetRepository,
IRepository<ReadingClinicalData> readingClinicalDataRepository,
IMapper mapper, IRepository<VisitStage> visitStageRepository, IRepository<Trial> trialRepository)
{
_subjectVisitRepository = subjectVisitRepository;
this._clinicalDataTrialSetRepository = clinicalDataTrialSetRepository;
this._readingClinicalDataRepository = readingClinicalDataRepository;
_trialRepository = trialRepository;
_visitStageRepository = visitStageRepository;
@@ -41,6 +47,16 @@ namespace IRaCIS.Core.Application.Triggers
var IsEnrollementQualificationConfirm = await _trialRepository.Where(t => t.Id == subject.TrialId).Select(u => u.IsEnrollementQualificationConfirm).FirstOrDefaultAsync();
var cRCClinicalDatas = await _clinicalDataTrialSetRepository.Where(x => x.TrialId == subject.TrialId && x.UploadRole == UploadRole.CRC && x.IsConfirm)
.Select(x =>new {
x.Id,
x.ClinicalDataLevel,
} ).ToListAsync();
List<ReadingClinicalData> readingClinicals = new List<ReadingClinicalData>();
svList.ForEach(t =>
{
t.Subject = subject;
@@ -48,8 +64,24 @@ namespace IRaCIS.Core.Application.Triggers
t.TrialId = subject.TrialId;
t.SiteId = subject.SiteId;
t.IsEnrollmentConfirm = t.IsBaseLine ? IsEnrollementQualificationConfirm : false;
readingClinicals.AddRange(
cRCClinicalDatas.WhereIf(!t.IsBaseLine, x => x.ClinicalDataLevel == ClinicalLevel.SubjectVisit).Select(x => new ReadingClinicalData()
{
ClinicalDataTrialSetId = x.Id,
IsVisit = true,
SubjectId = subject.Id,
ReadingId = t.Id,
TrialId = subject.TrialId
}).ToList()
);
});
await _readingClinicalDataRepository.AddRangeAsync(readingClinicals);
await _subjectVisitRepository.AddRangeAsync(svList);