IRaCIS.Core.Domain/_DomainEvent/SubjectVisitStateChangedEvent.cs

@@ -43,9 +43,7 @@ public class QCRepliedQCChallengeEvent : DomainEvent
 
     public bool IsPd { get; set; }
 
-    public Guid? QCChallengeDialogId { get; set; }
+    public Guid QCChallengeDialogId { get; set; }
-
-    public Guid? QCChallengeId { get; set; }
 
     public Guid TrialId { get; set; }
 
@@ -54,8 +52,6 @@ public class QCRepliedQCChallengeEvent : DomainEvent
 }
 
 
-
-
 /// <summary>
 /// CRC 回复一致性核查质疑 通知PM
 /// </summary>

IRaCIS.Core.Infra.EFCore/Interceptor/AddDomainExt.cs

@@ -82,7 +82,7 @@ public static class DBContext_Ext
                     originAuditState == AuditStateEnum.None && subjectVisit.AuditState == AuditStateEnum.ToAudit
                     )
                 {
-                    subjectVisit.AddDomainEvent(new CRCSubmitedAndQCToAuditEvent() { SubjectVisitId = subjectVisit.Id, IsPd = subjectVisit.PDState == PDStateEnum.PDProgress });
+                    subjectVisit.AddDomainEvent(new CRCSubmitedAndQCToAuditEvent() { SubjectVisitId = subjectVisit.Id,IsPd= subjectVisit.PDState == PDStateEnum.PDProgress });
                 }
 
                 //一致性核查通知PM发送邮件
@@ -99,7 +99,7 @@ public static class DBContext_Ext
                   var delaySeconds =  dbContext.TrialEmailNoticeConfig.Where(t => t.BusinessScenarioEnum == businessEnum)
                        .Select(t => t.EmailDelaySeconds).FirstOrDefault();
 
-                    subjectVisit.AddDomainEvent(new QCClaimTaskEvent() { IsPd = subjectVisit.PDState == PDStateEnum.PDProgress, SubjectVisitId = subjectVisit.Id, DelaySeconds = delaySeconds, CurrentActionUserId = (Guid)subjectVisit.CurrentActionUserId });
+                    subjectVisit.AddDomainEvent(new QCClaimTaskEvent() { IsPd = subjectVisit.PDState == PDStateEnum.PDProgress, SubjectVisitId = subjectVisit.Id,  DelaySeconds= delaySeconds, CurrentActionUserId = (Guid)subjectVisit.CurrentActionUserId });
 
                 }
 
@@ -110,30 +110,6 @@ public static class DBContext_Ext
 
         }
 
-        foreach (var entry in changeTracker.Entries<QCChallenge>())
-        {
-            var qCChallenge = entry.Entity;
-
-            var findSubjectVisit = dbContext.SubjectVisit.Where(t => t.Id == qCChallenge.SubjectVisitId)
-                        .Select(t => new { IsEnrollmentConfirm = t.IsEnrollmentConfirm, PDState = t.PDState, t.Id, t.TrialId }).FirstOrDefault().IfNullThrowException();
-
-            //入组或者PD 才执行下面的逻辑
-            if ((findSubjectVisit.IsEnrollmentConfirm || findSubjectVisit.PDState == PDStateEnum.PDProgress))
-            {
-
-                if (entry.State == EntityState.Added)
-                {
-                    qCChallenge.AddDomainEvent(new QCRepliedQCChallengeEvent() { IsPd = findSubjectVisit.PDState == PDStateEnum.PDProgress,
-                        QCChallengeId = qCChallenge.Id, SubjectVisitId = findSubjectVisit.Id, TrialId = findSubjectVisit.TrialId });
-
-                }
-
-                //添加进记录
-                eventStoreList.AddRange(GetStoreEvents(qCChallenge.DomainEvents));
-            }
-        }
-
-
         foreach (var entry in changeTracker.Entries<QCChallengeDialog>())
         {
             var qCChallengeDialog = entry.Entity;