520 lines
22 KiB
C#
520 lines
22 KiB
C#
using IRaCIS.Core.Application.Helper;
|
||
using IRaCIS.Core.Application.MassTransit.Command;
|
||
using IRaCIS.Core.Application.MassTransit.Consumer.Dto;
|
||
using IRaCIS.Core.Application.Service.Reading.Dto;
|
||
using IRaCIS.Core.Domain;
|
||
using IRaCIS.Core.Domain._DomainEvent;
|
||
using IRaCIS.Core.Domain.BaseModel;
|
||
using IRaCIS.Core.Domain.Models;
|
||
using IRaCIS.Core.Domain.Share;
|
||
using IRaCIS.Core.Infra.EFCore.Common;
|
||
using MassTransit;
|
||
using MassTransit.Mediator;
|
||
using MassTransit.Scheduling;
|
||
using Medallion.Threading;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.AspNetCore.StaticFiles;
|
||
using Microsoft.Extensions.Options;
|
||
using MimeKit;
|
||
using Newtonsoft.Json;
|
||
using Panda.DynamicWebApi.Attributes;
|
||
using RestSharp;
|
||
using SkiaSharp;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Globalization;
|
||
using System.IO;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace IRaCIS.Core.Application.MassTransit.Consumer;
|
||
|
||
/// <summary>
|
||
/// 影像重传和阅片人筛选相关邮件发送
|
||
/// </summary>
|
||
public class ImageConsumer(
|
||
IRepository<UserRole> _userRoleRepository,
|
||
IRepository<TrialUserRole> _trialUseRoleRepository,
|
||
IRepository<SubjectVisit> _subjectVisitRepository,
|
||
IRepository<Trial> _trialRepository,
|
||
IRepository<Enroll> _enrollRepository,
|
||
IRepository<VisitTask> _visitTaskRepository,
|
||
IRepository<ReadModule> _readModuleRepository,
|
||
IRepository<EmailNoticeUserType> _emailNoticeUserTypeRepository,
|
||
IRepository<TrialSite> _trialSiteRepository,
|
||
IRepository<Dictionary> _dictionaryRepository,
|
||
IRepository<EmailNoticeConfig> _emailNoticeConfigrepository,
|
||
IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig) :
|
||
IConsumer<DirectApplyReupdloadEvent>,
|
||
IConsumer<CheckReuploadEvent>,
|
||
IConsumer<QCChanllengeReuploadEvent>,
|
||
IConsumer<HaveReadVisitTaskReReading>,
|
||
IConsumer<ReviewerPMApplyEvent>,
|
||
IConsumer<ReviewerSPMApprovedEvent>
|
||
{
|
||
private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
|
||
|
||
/// <summary>
|
||
/// 处理直接申请流程的重传事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<DirectApplyReupdloadEvent> context)
|
||
{
|
||
Console.WriteLine("发送【影像重传-直接申请流程】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
var subjectVisitId = context.Message.SubjectVisitId;
|
||
var subjectVisit = await _subjectVisitRepository.Where(x => x.Id == subjectVisitId).Include(x => x.Subject).FirstNotNullAsync();
|
||
var trialId = subjectVisit.TrialId;
|
||
List<UserTypeEnum> userTypes = null;
|
||
// 根据申请角色和状态确定邮件场景
|
||
EmailBusinessScenario scenario;
|
||
if (context.Message.ImageBackState == ImageBackStateEnum.None)
|
||
{
|
||
switch (context.Message.ApplyUserRole)
|
||
{
|
||
case ImageBackApplyEnum.IQCRequestBack:
|
||
scenario = EmailBusinessScenario.ImageQC_IQCApplyRe_Uploading; // 64
|
||
break;
|
||
case ImageBackApplyEnum.CRCRequestBack:
|
||
scenario = EmailBusinessScenario.ImageUploadCRCApplyRe_Uploading; // 65
|
||
break;
|
||
default:
|
||
scenario = EmailBusinessScenario.ImageQC_IQCApplyRe_Uploading; // 64
|
||
break;
|
||
|
||
}
|
||
}
|
||
else
|
||
{
|
||
scenario = EmailBusinessScenario.ImageReUpload_PMApprovalRe_Uploading; // 66
|
||
if (context.Message.ApplyUserRole == ImageBackApplyEnum.IQCRequestBack)
|
||
{
|
||
userTypes = new List<UserTypeEnum>() { UserTypeEnum.IQC, UserTypeEnum.ClinicalResearchCoordinator };
|
||
}
|
||
else if (context.Message.ApplyUserRole == ImageBackApplyEnum.CRCRequestBack)
|
||
{
|
||
userTypes = new List<UserTypeEnum>() { UserTypeEnum.ClinicalResearchCoordinator };
|
||
}
|
||
}
|
||
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
var inDto = new SendImageReuploadEmailInDto
|
||
{
|
||
EmailNoticeConfig = emailConfig,
|
||
Scenario = scenario,
|
||
SubjectVisit = subjectVisit,
|
||
TrialId = trialId,
|
||
UserTypes = userTypes,
|
||
ImageBackStateEnum = context.Message.ImageBackState
|
||
};
|
||
await SendImageReuploadEmail(inDto);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理一致性核查申请重传事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<CheckReuploadEvent> context)
|
||
{
|
||
Console.WriteLine("发送【一致性核查-影像重传】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
var subjectVisitId = context.Message.SubjectVisitId;
|
||
var subjectVisit = await _subjectVisitRepository.Where(x => x.Id == subjectVisitId).Include(x => x.Subject).FirstNotNullAsync();
|
||
var trialId = subjectVisit.TrialId;
|
||
|
||
// 根据状态确定邮件场景
|
||
EmailBusinessScenario scenario;
|
||
switch (context.Message.RequestBackState)
|
||
{
|
||
case RequestBackStateEnum.CRC_RequestBack:
|
||
scenario = EmailBusinessScenario.DataReconciliation_CRCApplyRe_Uploading; // 62
|
||
break;
|
||
case RequestBackStateEnum.PM_AgressBack:
|
||
case RequestBackStateEnum.PM_NotAgree:
|
||
scenario = EmailBusinessScenario.DataReconciliation_PMApprovalRe_Uploading; // 63
|
||
break;
|
||
default:
|
||
return; // 其他状态不发送邮件
|
||
}
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
var inDto = new SendImageReuploadEmailInDto
|
||
{
|
||
EmailNoticeConfig = emailConfig,
|
||
Scenario = scenario,
|
||
SubjectVisit = subjectVisit,
|
||
TrialId = trialId,
|
||
RequestBackStateEnum = context.Message.RequestBackState,
|
||
};
|
||
await SendImageReuploadEmail(inDto);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理质疑CRC申请重传事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<QCChanllengeReuploadEvent> context)
|
||
{
|
||
Console.WriteLine("发送【影像质疑-影像重传】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
var subjectVisitId = context.Message.SubjectVisitId;
|
||
var subjectVisit = await _subjectVisitRepository.Where(x => x.Id == subjectVisitId).Include(x => x.Subject).FirstNotNullAsync();
|
||
var trialId = subjectVisit.TrialId;
|
||
|
||
// 根据状态确定邮件场景
|
||
EmailBusinessScenario scenario;
|
||
switch (context.Message.ReuploadEnum)
|
||
{
|
||
case QCChanllengeReuploadEnum.CRCRequestReupload:
|
||
scenario = EmailBusinessScenario.ImageQueryCRCApplyRe_Uploading; // 60
|
||
break;
|
||
case QCChanllengeReuploadEnum.QCAgreeUpload:
|
||
scenario = EmailBusinessScenario.ImageQuery_IQCApprovalRe_Uploading; // 61
|
||
break;
|
||
default:
|
||
return; // 其他状态不发送邮件
|
||
}
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
var inDto = new SendImageReuploadEmailInDto
|
||
{
|
||
EmailNoticeConfig = emailConfig,
|
||
Scenario = scenario,
|
||
SubjectVisit = subjectVisit,
|
||
TrialId = trialId
|
||
};
|
||
await SendImageReuploadEmail(inDto);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理已阅任务重阅申请事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<HaveReadVisitTaskReReading> context)
|
||
{
|
||
Console.WriteLine("发送【重阅-影像重传】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
var visitTaskId = context.Message.VisitTaskId;
|
||
// 获取VisitTask关联的SubjectVisit
|
||
var visitTask = await _visitTaskRepository.Where(x => x.Id == visitTaskId).Include(x => x.Subject).Include(x => x.SourceSubjectVisit).FirstNotNullAsync();
|
||
var subjectVisit = new SubjectVisit() { };
|
||
if (visitTask.SourceSubjectVisitId != null)
|
||
{
|
||
subjectVisit = visitTask.SourceSubjectVisit;
|
||
}
|
||
else if (visitTask.SouceReadModuleId != null)
|
||
{
|
||
var readModule = await _readModuleRepository.Where(x => x.Id == visitTask.SouceReadModuleId).Include(x => x.SubjectVisit).FirstOrDefaultAsync();
|
||
subjectVisit = readModule.SubjectVisit;
|
||
}
|
||
|
||
var trialId = subjectVisit.TrialId;
|
||
|
||
// 根据状态确定邮件场景
|
||
EmailBusinessScenario scenario;
|
||
switch (context.Message.ReReadingApplyState)
|
||
{
|
||
case ReReadingApplyState.TrialGroupHaveApplyed:
|
||
scenario = EmailBusinessScenario.ReadTracking_PMApplyRe_Reading; // 67
|
||
break;
|
||
case ReReadingApplyState.Agree:
|
||
case ReReadingApplyState.Reject:
|
||
scenario = EmailBusinessScenario.Re_ReadApproval_SPMCPMApprovalRe_Reading; // 68
|
||
break;
|
||
default:
|
||
return; // 其他状态不发送邮件
|
||
}
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
var inDto = new SendImageReuploadEmailInDto
|
||
{
|
||
EmailNoticeConfig = emailConfig,
|
||
Scenario = scenario,
|
||
SubjectVisit = subjectVisit,
|
||
TrialId = trialId
|
||
};
|
||
await SendImageReuploadEmail(inDto);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送影像重传相关邮件的通用方法
|
||
/// </summary>
|
||
private async Task SendImageReuploadEmail(SendImageReuploadEmailInDto inDto)
|
||
{
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
inDto.SubjectVisit = await _subjectVisitRepository.Where(x => x.Id == inDto.SubjectVisit.Id).Include(x => x.Subject).FirstNotNullAsync();
|
||
// 获取项目信息
|
||
var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == inDto.TrialId);
|
||
|
||
// 根据不同场景获取不同角色的用户
|
||
var trialUser = await _trialUseRoleRepository.Where(x => x.TrialId == inDto.TrialId && !x.TrialUser.IsDeleted).Include(x => x.UserRole).Select(x => x.UserRole).ToListAsync();
|
||
|
||
// 根据场景确定收件人
|
||
List<UserRole> toUserList = new List<UserRole>();
|
||
List<UserRole> ccUserList = new List<UserRole>();
|
||
|
||
var emailNoticeUserList = await _emailNoticeUserTypeRepository.Where(x => x.EmailNoticeConfigId == inDto.EmailNoticeConfig.Id).ToListAsync();
|
||
var userTypeEnum = emailNoticeUserList.Select(x => x.UserType).ToList();
|
||
if (inDto.UserTypes != null)
|
||
{
|
||
userTypeEnum = inDto.UserTypes;
|
||
}
|
||
var crcUserList = new List<UserRole>() { };
|
||
if (userTypeEnum.Contains(UserTypeEnum.ClinicalResearchCoordinator))
|
||
{
|
||
crcUserList = await _trialSiteRepository.Where(x => x.Id == inDto.SubjectVisit.TrialSiteId).SelectMany(x => x.CRCUserList.Select(y => y.UserRole)).ToListAsync();
|
||
}
|
||
|
||
if (inDto.UserTypes == null)
|
||
{
|
||
var toList = emailNoticeUserList.Where(x => x.EmailUserType == EmailUserType.To && x.UserType != UserTypeEnum.ClinicalResearchCoordinator).Select(x => x.UserType).ToList();
|
||
|
||
toUserList = trialUser.Where(x => toList.Contains(x.UserTypeEnum)).ToList();
|
||
|
||
if (emailNoticeUserList.Any(x => x.EmailUserType == EmailUserType.To && x.UserType == UserTypeEnum.ClinicalResearchCoordinator))
|
||
{
|
||
toUserList.AddRange(crcUserList);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
var toList = inDto.UserTypes.Where(x => x != UserTypeEnum.ClinicalResearchCoordinator).ToList();
|
||
|
||
toUserList = trialUser.Where(x => toList.Contains(x.UserTypeEnum)).ToList();
|
||
|
||
if (inDto.UserTypes.Any(x => x == UserTypeEnum.ClinicalResearchCoordinator))
|
||
{
|
||
toUserList.AddRange(crcUserList);
|
||
}
|
||
}
|
||
|
||
|
||
var ccList = emailNoticeUserList.Where(x => x.EmailUserType == EmailUserType.Copy && x.UserType != UserTypeEnum.ClinicalResearchCoordinator).Select(x => x.UserType).ToList();
|
||
|
||
ccUserList = trialUser.Where(x => ccList.Contains(x.UserTypeEnum)).ToList();
|
||
|
||
if (emailNoticeUserList.Any(x => x.EmailUserType == EmailUserType.Copy && x.UserType == UserTypeEnum.ClinicalResearchCoordinator))
|
||
{
|
||
ccUserList.AddRange(crcUserList);
|
||
}
|
||
|
||
// 如果没有收件人，则不发送邮件
|
||
if (toUserList.Count == 0)
|
||
{
|
||
return;
|
||
}
|
||
|
||
|
||
List<DictionaryDto> dictionaryDtos = new List<DictionaryDto>() {
|
||
new DictionaryDto (){DictionaryCode= "YesOrNo",EnumValue=inDto.SubjectVisit.IsUrgent.ToString().ToLower(), }, //是否加急
|
||
};
|
||
if (inDto.Scenario == EmailBusinessScenario.DataReconciliation_PMApprovalRe_Uploading)
|
||
{
|
||
dictionaryDtos.Add(new DictionaryDto() { DictionaryCode = "RequestBackState", EnumValue = inDto.RequestBackStateEnum.GetEnumInt(), });
|
||
}
|
||
else
|
||
{
|
||
dictionaryDtos.Add(new DictionaryDto() { DictionaryCode = "ImageBackStateEnum", EnumValue = inDto.ImageBackStateEnum.GetEnumInt(), });//审批结果
|
||
}
|
||
|
||
|
||
var dictionValue = await CommonEmailHelper.TranslationDictionary(new TranslationDictionaryDto()
|
||
{
|
||
|
||
DictionaryRepository = _dictionaryRepository,
|
||
IsEn_US = isEn_US,
|
||
DictionaryList = dictionaryDtos
|
||
});
|
||
|
||
foreach (var userinfo in toUserList)
|
||
{
|
||
var messageToSend = new MimeMessage();
|
||
// 发件地址
|
||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||
|
||
// 添加抄送
|
||
foreach (var ccUser in ccUserList)
|
||
{
|
||
messageToSend.Cc.Add(new MailboxAddress(String.Empty, ccUser.EMail));
|
||
}
|
||
// 格式化邮件内容
|
||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||
{
|
||
var subjectCode = inDto.SubjectVisit.Subject.Code;
|
||
var topicStr = string.Format(input.topicStr, trialInfo.ResearchProgramNo, subjectCode, inDto.SubjectVisit.VisitName);
|
||
var htmlBodyStr = string.Format(
|
||
CommonEmailHelper.ReplaceCompanyName(_systemEmailConfig, input.htmlBodyStr),
|
||
userinfo.FullName, // 用户名 {0}
|
||
trialInfo.ExperimentName, // 项目 {1}
|
||
subjectCode, // 受试者 {2}
|
||
inDto.SubjectVisit.VisitName, // 访视 {3}
|
||
dictionValue[0], // 是否加急 {4}
|
||
dictionValue[1], // 审批结果 {5}
|
||
_systemEmailConfig.SiteUrl // 链接 {6}
|
||
);
|
||
|
||
return (topicStr, htmlBodyStr);
|
||
};
|
||
|
||
await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(inDto.EmailNoticeConfig, messageToSend, emailConfigFunc);
|
||
|
||
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理PM申请阅片人筛选事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<ReviewerPMApplyEvent> context)
|
||
{
|
||
Console.WriteLine("发送【阅片人筛选-PM申请审批】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
// 获取项目信息
|
||
var enrollIdList = context.Message.EnrollIdList;
|
||
if (enrollIdList == null || !enrollIdList.Any())
|
||
{
|
||
return;
|
||
}
|
||
|
||
// 获取第一个Enroll的TrialId
|
||
var enrollId = enrollIdList.First();
|
||
var enroll = await _enrollRepository.Where(x => x.Id == enrollId).FirstNotNullAsync();
|
||
var trialId = enroll.TrialId;
|
||
|
||
// 设置邮件场景
|
||
var scenario = EmailBusinessScenario.ReviewerSelection_PMApplyApproving; // 69
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
await SendReviewerSelectionEmail(emailConfig, trialId, enrollIdList);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理SPM审批阅片人筛选事件
|
||
/// </summary>
|
||
public async Task Consume(ConsumeContext<ReviewerSPMApprovedEvent> context)
|
||
{
|
||
Console.WriteLine("发送【阅片人筛选-SPM审批】邮件！！！");
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
// 获取项目信息
|
||
var enrollIdList = context.Message.EnrollIdList;
|
||
if (enrollIdList == null || !enrollIdList.Any())
|
||
{
|
||
return;
|
||
}
|
||
|
||
// 获取第一个Enroll的TrialId
|
||
var enrollId = enrollIdList.First();
|
||
var enroll = await _enrollRepository.Where(x => x.Id == enrollId).FirstNotNullAsync();
|
||
var trialId = enroll.TrialId;
|
||
|
||
// 设置邮件场景
|
||
var scenario = EmailBusinessScenario.ReviewerSelection_SPMCPMApproval; // 70
|
||
|
||
var emailConfig = _emailNoticeConfigrepository.Where(t => t.BusinessScenarioEnum == scenario && t.IsEnable && t.IsAutoSend).FirstOrDefault();
|
||
|
||
if (emailConfig != null)
|
||
{
|
||
await SendReviewerSelectionEmail(emailConfig, trialId, enrollIdList);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送阅片人筛选相关邮件的通用方法
|
||
/// </summary>
|
||
private async Task SendReviewerSelectionEmail(EmailNoticeConfig emailNoticeConfig, Guid trialId, List<Guid> enrollIdList)
|
||
{
|
||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||
|
||
// 获取项目信息
|
||
var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == trialId);
|
||
|
||
// 根据不同场景获取不同角色的用户
|
||
var trialUser = await _trialUseRoleRepository.Where(x => x.TrialId == trialId && !x.TrialUser.IsDeleted).Include(x => x.UserRole).Select(x => x.UserRole).ToListAsync();
|
||
|
||
// 根据场景确定收件人
|
||
List<UserRole> toUserList = new List<UserRole>();
|
||
List<UserRole> ccUserList = new List<UserRole>();
|
||
|
||
var emailNoticeUserList = await _emailNoticeUserTypeRepository.Where(x => x.EmailNoticeConfigId == emailNoticeConfig.Id).ToListAsync();
|
||
|
||
var toList = emailNoticeUserList.Where(x => x.EmailUserType == EmailUserType.To).Select(x => x.UserType).ToList();
|
||
|
||
toUserList = trialUser.Where(x => toList.Contains(x.UserTypeEnum)).ToList();
|
||
|
||
var ccList = emailNoticeUserList.Where(x => x.EmailUserType == EmailUserType.Copy && x.UserType != UserTypeEnum.ClinicalResearchCoordinator).Select(x => x.UserType).ToList();
|
||
|
||
ccUserList = trialUser.Where(x => ccList.Contains(x.UserTypeEnum)).ToList();
|
||
|
||
|
||
// 如果没有收件人，则不发送邮件
|
||
if (toUserList.Count == 0)
|
||
{
|
||
return;
|
||
}
|
||
|
||
foreach (var userinfo in toUserList)
|
||
{
|
||
var messageToSend = new MimeMessage();
|
||
// 发件地址
|
||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||
|
||
// 添加抄送
|
||
foreach (var ccUser in ccUserList)
|
||
{
|
||
messageToSend.Cc.Add(new MailboxAddress(String.Empty, ccUser.EMail));
|
||
}
|
||
|
||
// 格式化邮件内容
|
||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||
{
|
||
var topicStr = string.Format(input.topicStr, trialInfo.ResearchProgramNo);
|
||
var htmlBodyStr = string.Format(
|
||
CommonEmailHelper.ReplaceCompanyName(_systemEmailConfig, input.htmlBodyStr),
|
||
userinfo.FullName, // 用户名 {0}
|
||
trialInfo.ExperimentName, // 项目 {1}
|
||
"", // 受试者 {2} - 阅片人筛选不涉及受试者
|
||
"", // 访视 {3} - 阅片人筛选不涉及访视
|
||
"", // 是否加急 {4}
|
||
"", // 预留 {5}
|
||
_systemEmailConfig.SiteUrl // 链接 {6}
|
||
);
|
||
|
||
return (topicStr, htmlBodyStr);
|
||
};
|
||
|
||
await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(emailNoticeConfig, messageToSend, emailConfigFunc);
|
||
|
||
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
|
||
}
|
||
}
|
||
}
|
||
|
||
|