整理trigger 到不同的文件夹

2024-09-27 13:58:33 +08:00
parent 654fb7116b
commit b6459d2f9f
22 changed files with 170 additions and 72 deletions
@@ -0,0 +1,46 @@
+
+
+using AutoMapper;
+using IRaCIS.Core.Domain;
+using MassTransit;
+
+namespace IRaCIS.Core.Application.MassTransit.Consumer;
+
+/// <summary>
+/// 添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致 暂时废弃
+/// </summary>
+/// <param name="_subjectVisitRepository"></param>
+/// <param name="_visitStageRepository"></param>
+/// <param name="_trialRepository"></param>
+/// <param name="_mapper"></param>
+public class AddSubjectTriggerConsumer(IRepository<SubjectVisit> _subjectVisitRepository,
+
+         IRepository<VisitStage> _visitStageRepository,
+         IRepository<Trial> _trialRepository,
+         IMapper _mapper) : IConsumer<AddSubjectTriggerCommand>
+{
+    public async Task Consume(ConsumeContext<AddSubjectTriggerCommand> context)
+    {
+        var addSubjectEvent= context.Message;
+
+        //添加受试者的时候，获取访视计划列表，添加到受试者访视表。
+        var visitPlanList = await _visitStageRepository.Where(t => t.TrialId == addSubjectEvent.TrialId && t.IsConfirmed).ToListAsync();
+
+        var svList = _mapper.Map<List<SubjectVisit>>(visitPlanList);
+
+        var IsEnrollementQualificationConfirm = await _trialRepository.Where(t => t.Id == addSubjectEvent.TrialId).Select(u => u.IsEnrollementQualificationConfirm).FirstOrDefaultAsync();
+
+        svList.ForEach(t =>
+        {
+            t.SubjectId = addSubjectEvent.SubjectId;
+            t.TrialId = addSubjectEvent.TrialId;
+            t.TrialSiteId = addSubjectEvent.TrialSiteId;
+            t.IsEnrollmentConfirm = t.IsBaseLine ? IsEnrollementQualificationConfirm : false;
+            t.Id = NewId.NextGuid();
+
+        });
+
+        await _subjectVisitRepository.AddRangeAsync(svList);
+        await _subjectVisitRepository.SaveChangesAsync();
+    }
+}