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

修改阅片人筛选事件触发
continuous-integration/drone/push Build is passing Details

Test_IRC_Net8
hang 2025-05-06 10:26:39 +08:00
parent b7a803678c
commit 932772f8c8
3 changed files with 39 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
IRaCIS.Core.Domain/_DomainEvent/ReUploadEvent.cs
View File

@ -44,16 +44,8 @@ namespace IRaCIS.Core.Domain._DomainEvent
}
/// <summary>
///针对于未阅的任务 PM直接退回，通知CRC
/// </summary>
public class UnReadVisitTaskReReadingApproval : DomainEvent
{
public Guid SubjectVisitId { get; set; }
}
/// <summary>
///针对于已阅的任务 PM 申请， SPM/CPM审批，通知PM/阅片人
/// </summary>
@ -63,4 +55,14 @@ namespace IRaCIS.Core.Domain._DomainEvent
public ReReadingApplyState ReReadingApplyState { get; set; }
}
/// <summary>
///针对于未阅的任务 PM直接退回，通知CRC --这里废弃 ，没有审批流程，不做
/// </summary>
public class UnReadVisitTaskReReadingApproval : DomainEvent
{
public Guid SubjectVisitId { get; set; }
}
}

10
IRaCIS.Core.Domain/_DomainEvent/ReviewerEvent.cs
View File

@ -10,7 +10,7 @@ namespace IRaCIS.Core.Domain._DomainEvent
{
/// <summary>
/// SPM审批通过，通知PM； (在消费者中判断项目是否配置了SPM 并且有SPM,有的话才发邮件,因为没有SPM的时候，状态会跳的 ) Enroll表
/// SPM审批通过，通知PM； Enroll表
/// </summary>
public class ReviewerSPMApprovedEvent : DomainEvent
{
@ -21,4 +21,12 @@ namespace IRaCIS.Core.Domain._DomainEvent
/// </summary>
//public EnrollStatus EnrollStatus { get; set; }
}
/// <summary>
/// PM 申请审批 Enroll表
/// </summary>
public class ReviewerPMApplyEvent : DomainEvent
{
public List<Guid> EnrollIdList { get; set; }
}
}

24
IRaCIS.Core.Infra.EFCore/Interceptor/AddDomainExt.cs
View File

@ -425,7 +425,8 @@ public static class DBContext_Ext
#region 阅片人筛选
var enrollIdList = new List<Guid>();
var spmApproveEnrollIdList = new List<Guid>();
var pmApplyEnrollIdList = new List<Guid>();
Enroll lastEnroll = null;
foreach (var entry in changeTracker.Entries<Enroll>())
{
@ -435,15 +436,30 @@ public static class DBContext_Ext
if (originEnrollStatus == EnrollStatus.HasCommittedToCRO && enroll.EnrollStatus == EnrollStatus.InviteIntoGroup)
{
enrollIdList.Add(enroll.Id);
spmApproveEnrollIdList.Add(enroll.Id);
lastEnroll = enroll;
}
if (originEnrollStatus == EnrollStatus.HasApplyDownloadResume && enroll.EnrollStatus == EnrollStatus.HasCommittedToCRO)
{
pmApplyEnrollIdList.Add(enroll.Id);
lastEnroll = enroll;
}
}
if (enrollIdList.Count > 0)
if (spmApproveEnrollIdList.Count > 0)
{
lastEnroll.AddDomainEvent(new ReviewerSPMApprovedEvent() { EnrollIdList = enrollIdList });
lastEnroll.AddDomainEvent(new ReviewerSPMApprovedEvent() { EnrollIdList = spmApproveEnrollIdList });
eventStoreList.AddRange(GetStoreEvents(lastEnroll.DomainEvents));
}
if (pmApplyEnrollIdList.Count > 0)
{
lastEnroll.AddDomainEvent(new ReviewerPMApplyEvent() { EnrollIdList = spmApproveEnrollIdList });
eventStoreList.AddRange(GetStoreEvents(lastEnroll.DomainEvents));
}