Merge branch 'Test_IRC_Net8' of http://192.168.3.68:2000/XCKJ/irc-netcore-api into Test_IRC_Net8
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/push Build is passing
Details
commit
3ee175f091
|
@ -13030,22 +13030,33 @@
|
|||
</member>
|
||||
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.QCRepliedQCChallengeEventConsumer">
|
||||
<summary>
|
||||
QC回复 质控质疑,通知CRC
|
||||
QC回复 质控质疑,通知CRC (014,015)
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:IRaCIS.Core.Application.MassTransit.Consumer.QCRepliedQCChallengeEventConsumer.#ctor(IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.User},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.TrialUser},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.SubjectVisit},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Trial},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallenge},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallengeDialog},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Dictionary},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.EmailNoticeConfig},Microsoft.Extensions.Options.IOptionsMonitor{IRaCIS.Core.Domain.Share.SystemEmailSendConfig})">
|
||||
<summary>
|
||||
QC回复 质控质疑,通知CRC (014,015)
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.CRCRepliedCheckChallengeEventConsumer">
|
||||
<summary>
|
||||
CRC 回复一致性核查质疑 通知PM
|
||||
CRC 回复一致性核查质疑 通知PM (019,020)
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.PMRepliedCheckChallengeEventConsumer">
|
||||
<member name="M:IRaCIS.Core.Application.MassTransit.Consumer.CRCRepliedCheckChallengeEventConsumer.#ctor(IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.User},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.TrialUser},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.SubjectVisit},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Trial},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallenge},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallengeDialog},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Dictionary},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.EmailNoticeConfig},Microsoft.Extensions.Options.IOptionsMonitor{IRaCIS.Core.Domain.Share.SystemEmailSendConfig})">
|
||||
<summary>
|
||||
PM 一致性核查 通知CRC
|
||||
CRC 回复一致性核查质疑 通知PM (019,020)
|
||||
</summary>
|
||||
</member>
|
||||
<!-- Badly formed XML comment ignored for member "T:IRaCIS.Core.Application.MassTransit.Consumer.PMRepliedCheckChallengeEventConsumer" -->
|
||||
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.CheckStateChangedToAuditEventConsumer">
|
||||
<summary>
|
||||
通知PM 进行一致性核查
|
||||
通知PM 进行一致性核查 (018,030)
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:IRaCIS.Core.Application.MassTransit.Consumer.CheckStateChangedToAuditEventConsumer.#ctor(IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.User},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.TrialUser},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.SubjectVisit},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Trial},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallenge},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.QCChallengeDialog},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Dictionary},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.EmailNoticeConfig},Microsoft.Extensions.Options.IOptionsMonitor{IRaCIS.Core.Domain.Share.SystemEmailSendConfig})">
|
||||
<summary>
|
||||
通知PM 进行一致性核查 (018,030)
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.QCClaimTaskEventConsumer">
|
||||
|
|
|
@ -3,6 +3,7 @@ using IRaCIS.Core.Application.MassTransit.Command;
|
|||
using IRaCIS.Core.Application.Service.Reading.Dto;
|
||||
using IRaCIS.Core.Domain;
|
||||
using IRaCIS.Core.Domain.BaseModel;
|
||||
using IRaCIS.Core.Domain.Models;
|
||||
using IRaCIS.Core.Infra.EFCore.Common;
|
||||
using MassTransit;
|
||||
using Microsoft.Extensions.Options;
|
||||
|
@ -55,15 +56,6 @@ public class CRCSubmitedAndQCToAuditEventConsumer(
|
|||
auditStateCode = "AuditStateRC";
|
||||
}
|
||||
|
||||
foreach (var userinfo in userinfoList)
|
||||
{
|
||||
var messageToSend = new MimeMessage();
|
||||
//发件地址
|
||||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||||
|
||||
|
||||
var companyName = isEn_US ? _systemEmailConfig.CompanyShortName : _systemEmailConfig.CompanyShortNameCN;
|
||||
|
||||
|
||||
var dictionValue = await CommonEmailHelper.TranslationDictionary(new TranslationDictionaryDto()
|
||||
|
@ -78,6 +70,18 @@ public class CRCSubmitedAndQCToAuditEventConsumer(
|
|||
}
|
||||
});
|
||||
|
||||
foreach (var userinfo in userinfoList)
|
||||
{
|
||||
var messageToSend = new MimeMessage();
|
||||
//发件地址
|
||||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||||
|
||||
|
||||
var companyName = isEn_US ? _systemEmailConfig.CompanyShortName : _systemEmailConfig.CompanyShortNameCN;
|
||||
|
||||
|
||||
|
||||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||||
{
|
||||
var subjectCode = subjectVisit.Subject.Code;
|
||||
|
@ -197,32 +201,193 @@ public class CRCRepliedQCChallengeEventConsumer(
|
|||
|
||||
|
||||
/// <summary>
|
||||
/// QC回复 质控质疑,通知CRC
|
||||
/// QC回复 质控质疑,通知CRC (014,015)
|
||||
/// </summary>
|
||||
public class QCRepliedQCChallengeEventConsumer : IConsumer<QCRepliedQCChallengeEvent>
|
||||
public class QCRepliedQCChallengeEventConsumer(
|
||||
IRepository<User> _userRepository,
|
||||
IRepository<TrialUser> _trialUseRepository,
|
||||
IRepository<SubjectVisit> _subjectVisitRepository,
|
||||
IRepository<Trial> _trialRepository,
|
||||
IRepository<QCChallenge> _qCChallengeRepository,
|
||||
IRepository<QCChallengeDialog> _qCChallengeDialogRepository,
|
||||
IRepository<Dictionary> _dictionaryRepository,
|
||||
IRepository<EmailNoticeConfig> _emailNoticeConfigrepository,
|
||||
IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig) : IConsumer<QCRepliedQCChallengeEvent>
|
||||
{
|
||||
public Task Consume(ConsumeContext<QCRepliedQCChallengeEvent> context)
|
||||
private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
|
||||
public async Task Consume(ConsumeContext<QCRepliedQCChallengeEvent> context)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
Console.WriteLine("发送(014,015) 【 QC回复 质控质疑,通知CRC】邮件!!!");
|
||||
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
|
||||
var qCChallengeDialog = await _qCChallengeDialogRepository.Where(x => x.Id == context.Message.QCChallengeDialogId).Include(x => x.QCChallenge).FirstNotNullAsync();
|
||||
var subjectVisitId = context.Message.SubjectVisitId;
|
||||
|
||||
var subjectVisit = await _subjectVisitRepository.Where(x => x.Id == subjectVisitId).Include(x => x.Subject).FirstNotNullAsync();
|
||||
|
||||
var trialUser = await _trialUseRepository.Where(x => x.TrialId == subjectVisit.TrialId).Include(x => x.User).Select(x => x.User).ToListAsync();
|
||||
|
||||
var userinfoList = trialUser.Where(x => x.UserTypeEnum == UserTypeEnum.ClinicalResearchCoordinator).ToList();
|
||||
|
||||
var craInfo = trialUser.Where(x => x.UserTypeEnum == UserTypeEnum.CRA).FirstOrDefault();
|
||||
|
||||
var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == subjectVisit.TrialId);
|
||||
|
||||
|
||||
|
||||
|
||||
var dictionValue = await CommonEmailHelper.TranslationDictionary(new TranslationDictionaryDto()
|
||||
{
|
||||
|
||||
DictionaryRepository = _dictionaryRepository,
|
||||
IsEn_US = isEn_US,
|
||||
DictionaryList = new List<DictionaryDto>()
|
||||
{
|
||||
new DictionaryDto (){DictionaryCode= "YesOrNo",EnumValue=qCChallengeDialog.QCChallenge.IsClosed.ToString(), }, //是否关闭
|
||||
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
foreach (var userinfo in userinfoList)
|
||||
{
|
||||
var messageToSend = new MimeMessage();
|
||||
//发件地址
|
||||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||||
if (craInfo != null)
|
||||
{
|
||||
messageToSend.Cc.Add(new MailboxAddress(String.Empty, craInfo.EMail));
|
||||
}
|
||||
|
||||
var companyName = isEn_US ? _systemEmailConfig.CompanyShortName : _systemEmailConfig.CompanyShortNameCN;
|
||||
|
||||
|
||||
|
||||
|
||||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||||
{
|
||||
var subjectCode = subjectVisit.Subject.Code;
|
||||
var topicStr = string.Format(input.topicStr, trialInfo.ResearchProgramNo, subjectCode, subjectVisit.VisitName);
|
||||
var htmlBodyStr = string.Format(
|
||||
CommonEmailHelper.ReplaceCompanyName(_systemEmailConfig, input.htmlBodyStr),
|
||||
trialInfo.ExperimentName, // 项目 {1}
|
||||
userinfo.FullName, // 用户名 {1}
|
||||
subjectCode, // 受试者 {2}
|
||||
subjectVisit.VisitName, // 访视 {3}
|
||||
dictionValue[0], // 质疑是否关闭 {4}
|
||||
qCChallengeDialog.TalkContent, // 质疑内容 {5}
|
||||
_systemEmailConfig.SiteUrl // 链接 {65}
|
||||
);
|
||||
|
||||
return (topicStr, htmlBodyStr);
|
||||
};
|
||||
|
||||
await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(_emailNoticeConfigrepository,
|
||||
|
||||
context.Message.IsPd ? EmailBusinessScenario.PDVerification_ImageQuery : EmailBusinessScenario.EligibilityVerification_ImageQuery,
|
||||
|
||||
messageToSend, emailConfigFunc);
|
||||
|
||||
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// CRC 回复一致性核查质疑 通知PM
|
||||
/// CRC 回复一致性核查质疑 通知PM (019,020)
|
||||
/// </summary>
|
||||
public class CRCRepliedCheckChallengeEventConsumer : IConsumer<CRCRepliedCheckChallengeEvent>
|
||||
public class CRCRepliedCheckChallengeEventConsumer(
|
||||
IRepository<User> _userRepository,
|
||||
IRepository<TrialUser> _trialUseRepository,
|
||||
IRepository<SubjectVisit> _subjectVisitRepository,
|
||||
IRepository<Trial> _trialRepository,
|
||||
IRepository<QCChallenge> _qCChallengeRepository,
|
||||
IRepository<QCChallengeDialog> _qCChallengeDialogRepository,
|
||||
IRepository<Dictionary> _dictionaryRepository,
|
||||
IRepository<EmailNoticeConfig> _emailNoticeConfigrepository,
|
||||
IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig) : IConsumer<CRCRepliedCheckChallengeEvent>
|
||||
{
|
||||
public Task Consume(ConsumeContext<CRCRepliedCheckChallengeEvent> context)
|
||||
|
||||
private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
|
||||
public async Task Consume(ConsumeContext<CRCRepliedCheckChallengeEvent> context)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
Console.WriteLine("发送(019,020) 【 CRC 回复一致性核查质疑 通知PM】邮件!!!");
|
||||
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 trialUser = await _trialUseRepository.Where(x => x.TrialId == subjectVisit.TrialId).Include(x => x.User).Select(x => x.User).ToListAsync();
|
||||
|
||||
var userinfoList = trialUser.Where(x => x.UserTypeEnum == UserTypeEnum.APM || x.UserTypeEnum == UserTypeEnum.ProjectManager).ToList();
|
||||
|
||||
|
||||
var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == subjectVisit.TrialId);
|
||||
|
||||
|
||||
|
||||
|
||||
var dictionValue = await CommonEmailHelper.TranslationDictionary(new TranslationDictionaryDto()
|
||||
{
|
||||
|
||||
DictionaryRepository = _dictionaryRepository,
|
||||
IsEn_US = isEn_US,
|
||||
DictionaryList = new List<DictionaryDto>()
|
||||
{
|
||||
new DictionaryDto (){DictionaryCode= "CheckState",EnumValue=subjectVisit.CheckState.GetEnumInt(), }, //审核状态
|
||||
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
foreach (var userinfo in userinfoList)
|
||||
{
|
||||
var messageToSend = new MimeMessage();
|
||||
//发件地址
|
||||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||||
|
||||
|
||||
var companyName = isEn_US ? _systemEmailConfig.CompanyShortName : _systemEmailConfig.CompanyShortNameCN;
|
||||
|
||||
|
||||
|
||||
|
||||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||||
{
|
||||
var subjectCode = subjectVisit.Subject.Code;
|
||||
var topicStr = string.Format(input.topicStr, trialInfo.ResearchProgramNo, subjectCode, subjectVisit.VisitName);
|
||||
var htmlBodyStr = string.Format(
|
||||
CommonEmailHelper.ReplaceCompanyName(_systemEmailConfig, input.htmlBodyStr),
|
||||
trialInfo.ExperimentName, // 项目 {1}
|
||||
userinfo.FullName, // 用户名 {1}
|
||||
subjectCode, // 受试者 {2}
|
||||
subjectVisit.VisitName, // 访视 {3}
|
||||
dictionValue[0], // 核查状态 {4}
|
||||
_systemEmailConfig.SiteUrl // 链接 {5}
|
||||
);
|
||||
|
||||
return (topicStr, htmlBodyStr);
|
||||
};
|
||||
|
||||
await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(_emailNoticeConfigrepository,
|
||||
|
||||
context.Message.IsPd ? EmailBusinessScenario.PDVerification_UnderDRForPMOrAPM : EmailBusinessScenario.EligibilityVerification_UnderDRForPMOrAPM,
|
||||
|
||||
messageToSend, emailConfigFunc);
|
||||
|
||||
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// PM 一致性核查 通知CRC
|
||||
/// PM 一致性核查 通知CRC (016,017)
|
||||
|
||||
/// </summary>
|
||||
public class PMRepliedCheckChallengeEventConsumer : IConsumer<PMRepliedCheckChallengeEvent>
|
||||
{
|
||||
|
@ -234,13 +399,90 @@ public class PMRepliedCheckChallengeEventConsumer : IConsumer<PMRepliedCheckChal
|
|||
|
||||
|
||||
/// <summary>
|
||||
/// 通知PM 进行一致性核查
|
||||
/// 通知PM 进行一致性核查 (018,030)
|
||||
/// </summary>
|
||||
public class CheckStateChangedToAuditEventConsumer : IConsumer<CheckStateChangedToAuditEvent>
|
||||
public class CheckStateChangedToAuditEventConsumer(
|
||||
IRepository<User> _userRepository,
|
||||
IRepository<TrialUser> _trialUseRepository,
|
||||
IRepository<SubjectVisit> _subjectVisitRepository,
|
||||
IRepository<Trial> _trialRepository,
|
||||
IRepository<QCChallenge> _qCChallengeRepository,
|
||||
IRepository<QCChallengeDialog> _qCChallengeDialogRepository,
|
||||
IRepository<Dictionary> _dictionaryRepository,
|
||||
IRepository<EmailNoticeConfig> _emailNoticeConfigrepository,
|
||||
IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig) : IConsumer<CheckStateChangedToAuditEvent>
|
||||
{
|
||||
public Task Consume(ConsumeContext<CheckStateChangedToAuditEvent> context)
|
||||
private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
|
||||
public async Task Consume(ConsumeContext<CheckStateChangedToAuditEvent> context)
|
||||
{
|
||||
throw new NotImplementedException();
|
||||
Console.WriteLine("发送(018,030) 【通知PM 进行一致性核查】邮件!!!");
|
||||
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 trialUser = await _trialUseRepository.Where(x => x.TrialId == subjectVisit.TrialId).Include(x => x.User).Select(x => x.User).ToListAsync();
|
||||
|
||||
var userinfoList = trialUser.Where(x => x.UserTypeEnum == UserTypeEnum.APM || x.UserTypeEnum == UserTypeEnum.ProjectManager).ToList();
|
||||
|
||||
|
||||
var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == subjectVisit.TrialId);
|
||||
|
||||
|
||||
|
||||
|
||||
var dictionValue = await CommonEmailHelper.TranslationDictionary(new TranslationDictionaryDto()
|
||||
{
|
||||
|
||||
DictionaryRepository = _dictionaryRepository,
|
||||
IsEn_US = isEn_US,
|
||||
DictionaryList = new List<DictionaryDto>()
|
||||
{
|
||||
new DictionaryDto (){DictionaryCode= "CheckState",EnumValue=subjectVisit.CheckState.GetEnumInt(), }, //审核状态
|
||||
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
foreach (var userinfo in userinfoList)
|
||||
{
|
||||
var messageToSend = new MimeMessage();
|
||||
//发件地址
|
||||
messageToSend.From.Add(new MailboxAddress(_systemEmailConfig.FromName, _systemEmailConfig.FromEmail));
|
||||
messageToSend.To.Add(new MailboxAddress(String.Empty, userinfo.EMail));
|
||||
|
||||
|
||||
var companyName = isEn_US ? _systemEmailConfig.CompanyShortName : _systemEmailConfig.CompanyShortNameCN;
|
||||
|
||||
|
||||
|
||||
|
||||
Func<(string topicStr, string htmlBodyStr), (string topicStr, string htmlBodyStr)> emailConfigFunc = input =>
|
||||
{
|
||||
var subjectCode = subjectVisit.Subject.Code;
|
||||
var topicStr = string.Format(input.topicStr, trialInfo.ResearchProgramNo, subjectCode, subjectVisit.VisitName);
|
||||
var htmlBodyStr = string.Format(
|
||||
CommonEmailHelper.ReplaceCompanyName(_systemEmailConfig, input.htmlBodyStr),
|
||||
trialInfo.ExperimentName, // 项目 {1}
|
||||
userinfo.FullName, // 用户名 {1}
|
||||
subjectCode, // 受试者 {2}
|
||||
subjectVisit.VisitName, // 访视 {3}
|
||||
dictionValue[0], // 核查状态 {4}
|
||||
_systemEmailConfig.SiteUrl // 链接 {5}
|
||||
);
|
||||
|
||||
return (topicStr, htmlBodyStr);
|
||||
};
|
||||
|
||||
await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(_emailNoticeConfigrepository,
|
||||
|
||||
context.Message.IsPd ? EmailBusinessScenario.PDVerification_DR : EmailBusinessScenario.EligibilityVerification_DR,
|
||||
|
||||
messageToSend, emailConfigFunc);
|
||||
|
||||
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -813,7 +813,7 @@ namespace IRaCIS.Application.Contracts
|
|||
/// </summary>
|
||||
public string Remark { get; set; }
|
||||
|
||||
|
||||
public bool IsIRUpload { get; set; } = false;
|
||||
|
||||
/// <summary>
|
||||
/// 文件类型
|
||||
|
@ -870,12 +870,15 @@ namespace IRaCIS.Application.Contracts
|
|||
/// </summary>
|
||||
public DateTime CreateTime { get; set; }
|
||||
|
||||
public bool IsIRUpload { get; set; }
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
public class GetDoctorCriterionFileInDto
|
||||
{
|
||||
|
||||
public Guid DoctorId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
|
|
|
@ -322,6 +322,13 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
|
||||
public Guid? ClassifyTableQuestionId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
|
||||
|
||||
public string ClassifyAlgorithms { get; set; } = string.Empty;
|
||||
|
||||
|
||||
|
@ -465,6 +472,9 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
public string ExportResultStr { get; set; } = "[]";
|
||||
|
||||
public List<ExportResult> ExportResult { get; set; }
|
||||
|
||||
[Comment("图片数量")]
|
||||
public int? ImageCount { get; set; }
|
||||
}
|
||||
|
||||
///<summary> ReadingTableQuestionSystemAddOrEdit 列表查询参数模型</summary>
|
||||
|
@ -481,6 +491,11 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
|
||||
public Guid? ClassifyTableQuestionId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
public string ClassifyAlgorithms { get; set; } = string.Empty;
|
||||
|
||||
/// <summary>
|
||||
|
@ -581,7 +596,8 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
|
||||
public List<ExportResult> ExportResult { get; set; }
|
||||
|
||||
|
||||
[Comment("图片数量")]
|
||||
public int? ImageCount { get; set; }
|
||||
public List<string> ParentTriggerValueList { get; set; } = new List<string>();
|
||||
public List<string> RelevanceValueList { get; set; } = new List<string>();
|
||||
|
||||
|
@ -1146,6 +1162,11 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
/// </summary>
|
||||
public string GroupEnName { get; set; } = string.Empty;
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
public List<string> ParentTriggerValueList { get; set; } = new List<string>();
|
||||
public List<string> RelevanceValueList { get; set; } = new List<string>();
|
||||
public List<CalculateInfo> CalculateQuestionList { get; set; }
|
||||
|
@ -1161,6 +1182,11 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
[Comment("导出标识")]
|
||||
public ExportIdentification? ExportIdentification { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 分类算法
|
||||
/// </summary>
|
||||
|
@ -1606,6 +1632,8 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
|
||||
public string Type { get; set; }
|
||||
|
||||
public List<string> TypeList { get; set; } = new List<string>();
|
||||
|
||||
}
|
||||
|
||||
public class GetTrialGroupNameOutDto
|
||||
|
@ -1744,7 +1772,10 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
public class AddOrUpdateReadingQuestionSystemInDto
|
||||
{
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 导出标识
|
||||
|
@ -1987,6 +2018,11 @@ namespace IRaCIS.Core.Application.Service.Reading.Dto
|
|||
/// </summary>
|
||||
public Guid? Id { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 分类问题类型
|
||||
/// </summary>
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 导出标识
|
||||
/// </summary>
|
||||
|
|
|
@ -94,6 +94,7 @@ namespace IRaCIS.Core.Application.Service
|
|||
|
||||
.Where(x => x.ReadingQuestionCriterionTrialId == inDto.TrialCriterionId)
|
||||
.WhereIf(!inDto.Type.IsNullOrEmpty(), x => x.Type == inDto.Type)
|
||||
.WhereIf(inDto.TypeList.Count()>0, x => inDto.TypeList.Contains(x.Type))
|
||||
.OrderBy(x => x.ShowOrder)
|
||||
.Select(x => new GetCalculateQuestionsOutDto
|
||||
()
|
||||
|
@ -380,7 +381,7 @@ namespace IRaCIS.Core.Application.Service
|
|||
{
|
||||
var types = new List<string>()
|
||||
{
|
||||
"select","radio"
|
||||
"select","radio","class",
|
||||
};
|
||||
var questionList = await _readingTableQuestionSystemRepository.Where(x => x.ReadingQuestionId == inDto.ReadingQuestionId)
|
||||
.Where(x => types.Contains(x.Type))
|
||||
|
@ -610,7 +611,7 @@ namespace IRaCIS.Core.Application.Service
|
|||
{
|
||||
var types = new List<string>()
|
||||
{
|
||||
"select","radio"
|
||||
"select","radio","class",
|
||||
};
|
||||
var questionList = await _readingQuestionTrialRepository.Where(x => x.ReadingQuestionCriterionTrialId == inDto.ReadingQuestionCriterionTrialId)
|
||||
.Where(x => types.Contains(x.Type))
|
||||
|
|
|
@ -8,13 +8,14 @@ namespace IRaCIS.Core.Domain.Share
|
|||
//不可用
|
||||
None = 0,
|
||||
|
||||
//待核查
|
||||
ToCheck = 9,
|
||||
|
||||
|
||||
//核查中
|
||||
CVIng = 10,
|
||||
|
||||
// 通过CV,等待转发
|
||||
// 通过CV,等待转发 核查通过
|
||||
CVPassed = 11,
|
||||
}
|
||||
}
|
||||
|
|
|
@ -357,6 +357,24 @@ namespace IRaCIS.Core.Domain.Share
|
|||
Automatic = 1
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 分类算法的类型
|
||||
/// </summary>
|
||||
public enum ClassifyType
|
||||
{
|
||||
/// <summary>
|
||||
/// 数值
|
||||
/// </summary>
|
||||
NumericalValue = 0,
|
||||
|
||||
/// <summary>
|
||||
/// 下拉框
|
||||
/// </summary>
|
||||
Dropdown = 1,
|
||||
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 问题分类
|
||||
/// </summary>
|
||||
|
|
|
@ -34,4 +34,7 @@ public class DoctorCriterionFile : BaseAddAuditEntity
|
|||
|
||||
public Guid? TrialReadingCriterionId { get; set; }
|
||||
|
||||
[Comment("是否是IR上传")]
|
||||
public bool IsIRUpload { get; set; } = false;
|
||||
|
||||
}
|
||||
|
|
|
@ -185,6 +185,9 @@ public class ReadingQuestionSystem : BaseAddAuditEntity
|
|||
[Comment("分组分类")]
|
||||
public GroupClassify? GroupClassify { get; set; }
|
||||
|
||||
[Comment("分类类型")]
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
[Comment("问题分类")]
|
||||
public QuestionClassify? QuestionClassify { get; set; }
|
||||
|
||||
|
|
|
@ -232,6 +232,8 @@ public class ReadingQuestionTrial : BaseAddAuditEntity
|
|||
[Comment("数据来源")]
|
||||
public DataSources DataSource { get; set; } = DataSources.ManualEntry;
|
||||
|
||||
|
||||
|
||||
[Comment("问题英文名称")]
|
||||
public string QuestionEnName { get; set; } = string.Empty;
|
||||
|
||||
|
@ -241,6 +243,9 @@ public class ReadingQuestionTrial : BaseAddAuditEntity
|
|||
[Comment("分类算法")]
|
||||
public string ClassifyAlgorithms { get; set; } = string.Empty;
|
||||
|
||||
[Comment("分类类型")]
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
[Comment("分类问题Id")]
|
||||
public Guid? ClassifyQuestionId { get; set; }
|
||||
|
||||
|
|
|
@ -87,6 +87,9 @@ public class ReadingTableQuestionSystem : BaseAddAuditEntity
|
|||
[Comment("最大问题数")]
|
||||
public int? MaxRowCount { get; set; }
|
||||
|
||||
[Comment("图片数量")]
|
||||
public int? ImageCount { get; set; }
|
||||
|
||||
[Comment("数据表名称")]
|
||||
public string DataTableName { get; set; } = string.Empty;
|
||||
|
||||
|
@ -139,6 +142,9 @@ public class ReadingTableQuestionSystem : BaseAddAuditEntity
|
|||
[Comment("分类问题表格Id")]
|
||||
public Guid? ClassifyTableQuestionId { get; set; }
|
||||
|
||||
[Comment("分类类型")]
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
[Comment("分类算法")]
|
||||
public string ClassifyAlgorithms { get; set; } = string.Empty;
|
||||
|
||||
|
|
|
@ -93,6 +93,9 @@ public class ReadingTableQuestionTrial : BaseAddAuditEntity
|
|||
public int ShowQuestion { get; set; }
|
||||
public int? MaxRowCount { get; set; }
|
||||
|
||||
[Comment("图片数量")]
|
||||
public int? ImageCount { get; set; }
|
||||
|
||||
public string DataTableName { get; set; } = string.Empty;
|
||||
|
||||
public string DataTableColumn { get; set; } = string.Empty;
|
||||
|
@ -155,6 +158,9 @@ public class ReadingTableQuestionTrial : BaseAddAuditEntity
|
|||
[Comment("分类问题表格Id")]
|
||||
public Guid? ClassifyTableQuestionId { get; set; }
|
||||
|
||||
[Comment("分类类型")]
|
||||
public ClassifyType? ClassifyType { get; set; }
|
||||
|
||||
[Comment("导出标识")]
|
||||
public ExportIdentification? ExportIdentification { get; set; }
|
||||
|
||||
|
|
|
@ -57,6 +57,9 @@ public class QCRepliedQCChallengeEvent : DomainEvent
|
|||
/// </summary>
|
||||
public class CRCRepliedCheckChallengeEvent : DomainEvent
|
||||
{
|
||||
|
||||
public bool IsPd { get; set; }
|
||||
|
||||
public Guid CheckChallengeDialogId { get; set; }
|
||||
|
||||
public Guid TrialId { get; set; }
|
||||
|
@ -81,6 +84,9 @@ public class PMRepliedCheckChallengeEvent : DomainEvent
|
|||
/// </summary>
|
||||
public class CheckStateChangedToAuditEvent : DomainEvent
|
||||
{
|
||||
|
||||
public bool IsPd { get; set; }
|
||||
|
||||
public Guid SubjectVisitId { get; set; }
|
||||
|
||||
}
|
||||
|
|
|
@ -89,7 +89,7 @@ public static class DBContext_Ext
|
|||
if (originCheckState == CheckStateEnum.None && subjectVisit.CheckState == CheckStateEnum.ToCheck
|
||||
)
|
||||
{
|
||||
subjectVisit.AddDomainEvent(new CheckStateChangedToAuditEvent() { SubjectVisitId = subjectVisit.Id });
|
||||
subjectVisit.AddDomainEvent(new CheckStateChangedToAuditEvent() { IsPd = subjectVisit.PDState == PDStateEnum.PDProgress, SubjectVisitId = subjectVisit.Id });
|
||||
}
|
||||
|
||||
if (originCurrentActionUserId == null && subjectVisit.CurrentActionUserId != null)
|
||||
|
@ -149,7 +149,7 @@ public static class DBContext_Ext
|
|||
//CRC 针对质控质疑进行回复
|
||||
if (entry.State == EntityState.Added && checkChallengeDialog.UserTypeEnum == UserTypeEnum.ClinicalResearchCoordinator)
|
||||
{
|
||||
checkChallengeDialog.AddDomainEvent(new CRCRepliedCheckChallengeEvent() { CheckChallengeDialogId = checkChallengeDialog.Id, SubjectVisitId = findSubjectVisit.Id, TrialId = findSubjectVisit.TrialId });
|
||||
checkChallengeDialog.AddDomainEvent(new CRCRepliedCheckChallengeEvent() { IsPd = findSubjectVisit.PDState == PDStateEnum.PDProgress, CheckChallengeDialogId = checkChallengeDialog.Id, SubjectVisitId = findSubjectVisit.Id, TrialId = findSubjectVisit.TrialId });
|
||||
}
|
||||
else if (entry.State == EntityState.Added && checkChallengeDialog.UserTypeEnum == UserTypeEnum.ProjectManager)
|
||||
{
|
||||
|
|
17954
IRaCIS.Core.Infra.EFCore/Migrations/20241023034834_iamgeandQuestion.Designer.cs
generated
Normal file
17954
IRaCIS.Core.Infra.EFCore/Migrations/20241023034834_iamgeandQuestion.Designer.cs
generated
Normal file
File diff suppressed because it is too large
Load Diff
|
@ -0,0 +1,40 @@
|
|||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace IRaCIS.Core.Infra.EFCore.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class iamgeandQuestion : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AddColumn<int>(
|
||||
name: "ImageCount",
|
||||
table: "ReadingTableQuestionTrial",
|
||||
type: "int",
|
||||
nullable: true,
|
||||
comment: "图片数量");
|
||||
|
||||
migrationBuilder.AddColumn<int>(
|
||||
name: "ImageCount",
|
||||
table: "ReadingTableQuestionSystem",
|
||||
type: "int",
|
||||
nullable: true,
|
||||
comment: "图片数量");
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.DropColumn(
|
||||
name: "ImageCount",
|
||||
table: "ReadingTableQuestionTrial");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "ImageCount",
|
||||
table: "ReadingTableQuestionSystem");
|
||||
}
|
||||
}
|
||||
}
|
17958
IRaCIS.Core.Infra.EFCore/Migrations/20241023061641_doctorfile.Designer.cs
generated
Normal file
17958
IRaCIS.Core.Infra.EFCore/Migrations/20241023061641_doctorfile.Designer.cs
generated
Normal file
File diff suppressed because it is too large
Load Diff
|
@ -0,0 +1,30 @@
|
|||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace IRaCIS.Core.Infra.EFCore.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class doctorfile : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AddColumn<bool>(
|
||||
name: "IsIRUpload",
|
||||
table: "DoctorCriterionFile",
|
||||
type: "bit",
|
||||
nullable: false,
|
||||
defaultValue: false,
|
||||
comment: "是否是IR上传");
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.DropColumn(
|
||||
name: "IsIRUpload",
|
||||
table: "DoctorCriterionFile");
|
||||
}
|
||||
}
|
||||
}
|
|
@ -1651,6 +1651,10 @@ namespace IRaCIS.Core.Infra.EFCore.Migrations
|
|||
b.Property<bool>("IsEnable")
|
||||
.HasColumnType("bit");
|
||||
|
||||
b.Property<bool>("IsIRUpload")
|
||||
.HasColumnType("bit")
|
||||
.HasComment("是否是IR上传");
|
||||
|
||||
b.Property<string>("Remark")
|
||||
.IsRequired()
|
||||
.HasMaxLength(400)
|
||||
|
@ -6361,6 +6365,10 @@ namespace IRaCIS.Core.Infra.EFCore.Migrations
|
|||
.HasColumnType("nvarchar(400)")
|
||||
.HasComment("文件类型");
|
||||
|
||||
b.Property<int?>("ImageCount")
|
||||
.HasColumnType("int")
|
||||
.HasComment("图片数量");
|
||||
|
||||
b.Property<bool>("IsCopy")
|
||||
.HasColumnType("bit")
|
||||
.HasComment("复制病灶的时候 是否复制这个问题");
|
||||
|
@ -6559,6 +6567,10 @@ namespace IRaCIS.Core.Infra.EFCore.Migrations
|
|||
.HasColumnType("nvarchar(400)")
|
||||
.HasComment("文件类型");
|
||||
|
||||
b.Property<int?>("ImageCount")
|
||||
.HasColumnType("int")
|
||||
.HasComment("图片数量");
|
||||
|
||||
b.Property<bool>("IsCopy")
|
||||
.HasColumnType("bit")
|
||||
.HasComment("复制病灶的时候 是否复制这个问题");
|
||||
|
|
Loading…
Reference in New Issue