修改

2024-10-22 13:55:09 +08:00
parent 3dcf94f637
commit ab4e1f8649
6 changed files with 18181 additions and 9 deletions
@@ -108,19 +108,97 @@ public class CRCSubmitedAndQCToAuditEventConsumer(


 /// <summary>
-/// CRC 回复质控质疑 通知QC
+/// CRC 回复质控质疑 通知QC  Code012，013
 /// </summary>
-public class CRCRepliedQCChallengeEventConsumer : IConsumer<CRCRepliedQCChallengeEvent>
+public class CRCRepliedQCChallengeEventConsumer(
+      IRepository<User> _userRepository,
+        IRepository<TrialUser> _trialUseRepository,
+       IRepository<SubjectVisit> _subjectVisitRepository,
+      IRepository<Trial> _trialRepository,
+      IRepository<ReadingQuestionCriterionTrial> _readingQuestionCriterionTrialRepository,
+      IRepository<VisitTask> _visitTaskRepository,
+         IRepository<Dictionary> _dictionaryRepository,
+      IRepository<EmailNoticeConfig> _emailNoticeConfigrepository,
+      IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig) : IConsumer<CRCRepliedQCChallengeEvent>
 {
-    public Task Consume(ConsumeContext<CRCRepliedQCChallengeEvent> context)
+
+    private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
+    public async Task Consume(ConsumeContext<CRCRepliedQCChallengeEvent> context)
    {
-        throw new NotImplementedException();
-    }
+        //Console.WriteLine("发送(Code012，013) 【加急项目所有IQC待领取质控任务】邮件！！！");
+        //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).FirstOrDefaultAsync();
+
+        //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.IQC).ToList();
+
+
+        //var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == subjectVisit.TrialId);
+
+        //var auditStateCode = "AuditStatePE";
+
+        //if (trialInfo.QCProcessEnum == TrialQCProcess.DoubleAudit)
+        //{
+        //    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()
+        //    {
+
+        //        DictionaryRepository = _dictionaryRepository,
+        //        IsEn_US = isEn_US,
+        //        DictionaryList = new List<DictionaryDto>()
+        //    {
+        //     new DictionaryDto (){DictionaryCode= auditStateCode,EnumValue=subjectVisit.AuditState.GetEnumInt(), }, //审核状态
+
+        //    }
+        //    });
+
+        //    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),
+        //           userinfo.FullName,              // 用户名  {0}
+        //           trialInfo.ExperimentName,        // 项目   {1}
+        //           subjectCode, // 受试者 {2}
+        //           subjectVisit.VisitName,             // 访视  {3}
+        //           dictionValue[0],    // 审核状态 {4}
+        //           _systemEmailConfig.SiteUrl             // 链接                  {5}
+        //            );
+
+        //        return (topicStr, htmlBodyStr);
+        //    };
+
+        //    await CommonEmailHelper.GetEmailSubejctAndHtmlInfoAndBuildAsync(_emailNoticeConfigrepository,
+
+        //     context.Message.IsPd ? EmailBusinessScenario.PDVerification_PendingImageQCClaim : EmailBusinessScenario.EligibilityVerification_PendingClaim,
+
+        //        messageToSend, emailConfigFunc);
+
+        //    await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
+        //}
 }


 /// <summary>
-/// QC回复 质控质疑，通知CRC
+/// QC回复 质控质疑，通知CRC 
 /// </summary>
 public class QCRepliedQCChallengeEventConsumer : IConsumer<QCRepliedQCChallengeEvent>
 {