diff --git a/IRaCIS.Core.Application/MassTransit/Consumer/SiteSurverEmailConsumer.cs b/IRaCIS.Core.Application/MassTransit/Consumer/SiteSurverEmailConsumer.cs index e11306d4d..327cf090b 100644 --- a/IRaCIS.Core.Application/MassTransit/Consumer/SiteSurverEmailConsumer.cs +++ b/IRaCIS.Core.Application/MassTransit/Consumer/SiteSurverEmailConsumer.cs @@ -56,6 +56,7 @@ public class UserSiteSurveySubmitedEventConsumer( if (emailConfig != null) { + var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == trialId); var trialUserList = await _trialUserRoleRepository.Where(t => t.TrialId == siteSurveyInfo.TrialId && t.TrialUser.IsDeleted == false) .Where(t => t.UserRole.UserTypeEnum == UserTypeEnum.SPM || t.UserRole.UserTypeEnum == UserTypeEnum.CPM || t.UserRole.UserTypeEnum == UserTypeEnum.ProjectManager || t.UserRole.UserTypeEnum == UserTypeEnum.APM) @@ -68,8 +69,8 @@ public class UserSiteSurveySubmitedEventConsumer( var toUserName = string.Empty; - //有SPM - if (sPMOrCPMList.Count > 0) + //有SPM 并且参与 + if (trialInfo.IsSPMJoinSiteSurvey && sPMOrCPMList.Count > 0) { foreach (var user in sPMOrCPMList) { @@ -97,7 +98,6 @@ public class UserSiteSurveySubmitedEventConsumer( //发件地址 messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail)); - var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == trialId); var siteInfo = await _trialSiteRepository.FirstOrDefaultAsync(t => t.TrialId == trialId && t.Id == siteSurveyInfo.TrialSiteId, true);